- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for commit1 (0.15 sec)
-
cmd/metrics.go
prometheus.GaugeOpts{ Namespace: "minio", Name: "version_info", Help: "Version of current MinIO server instance", }, []string{ // current version "version", // commit-id of the current version "commit", }, ) ) const ( healMetricsNamespace = "self_heal" cacheNamespace = "cache" s3Namespace = "s3" bucketNamespace = "bucket" minioNamespace = "minio"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
cmd/update.go
} // DO NOT CHANGE USER AGENT STYLE. // The style should be // // MinIO (<OS>; <ARCH>[; <MODE>][; dcos][; kubernetes][; docker][; source]) MinIO/<VERSION> MinIO/<RELEASE-TAG> MinIO/<COMMIT-ID> [MinIO/universe-<PACKAGE-NAME>] [MinIO/helm-<HELM-VERSION>] // // Any change here should be discussed by opening an issue at // https://github.com/minio/minio/issues. func getUserAgent(mode string) string {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
internal/event/target/kafka.go
} return err } msg, err := target.toProducerMessage(eventData) if err != nil { return err } if err = target.batch.Add(key.Name, msg); err != nil { return err } } // commit the batch if the key is the last one present in the store. if key.IsLast || target.batch.IsFull() { return target.commitBatch() } return nil } func (target *KafkaTarget) commitBatch() error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
Makefile
verifiers: lint check-gen check-gen: ## check for updated autogenerated files @go generate ./... >/dev/null @(! git diff --name-only | grep '_gen.go$$') || (echo "Non-committed changes in auto-generated code is detected, please commit them to proceed." && false) lint: getdeps ## runs golangci-lint suite of linters @echo "Running $@ check" @$(GOLANGCI) run --build-tags kqueue --timeout=10m --config ./.golangci.yml
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:55:41 GMT 2024 - 10.3K bytes - Viewed (1) -
docs/metrics/prometheus/list.md
## Software Metrics | Name | Description | |:------------------------------|:---------------------------------------| | `minio_software_commit_info` | Git commit hash for the MinIO release. | | `minio_software_version_info` | MinIO Release tag for the server. | ## Drive Metrics
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 43.4K bytes - Viewed (2) -
cmd/erasure-healing-common_test.go
expectedRQuorum = len(partsMetadata) } reducedErr := reduceReadQuorumErrs(ctx, errs, objectOpIgnoredErrs, expectedRQuorum) if reducedErr != nil { return FileInfo{}, reducedErr } // List all the file commit ids from parts metadata. modTimes := listObjectModtimes(partsMetadata, errs) // Count all latest updated FileInfo values var count int var latestFileInfo FileInfo
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 23K bytes - Viewed (1) -
cmd/peer-rest-client.go
respBody, err := client.callWithContext(ctx, peerRESTMethodVerifyBinary, values, reader, -1) if err != nil { return err } defer xhttp.DrainBody(respBody) return nil } // CommitBinary - sends commit binary message to remote peers. func (client *peerRESTClient) CommitBinary(ctx context.Context) error { respBody, err := client.callWithContext(ctx, peerRESTMethodCommitBinary, nil, nil, -1) if err != nil { return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
cmd/erasure-multipart.go
// Save current erasure metadata for validation. currentFI := fi // Allocate parts similar to incoming slice. fi.Parts = make([]ObjectPartInfo, len(parts)) // Validate each part and then commit to disk. for i, part := range parts { partIdx := objectPartIndex(currentFI.Parts, part.PartNumber) // All parts should have same part number. if partIdx == -1 { invp := InvalidPart{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
docs/bucket/versioning/README.md
Spark/Hadoop workloads which use Hadoop MR Committer v1/v2 algorithm upload objects to a temporary prefix in a bucket. These objects are 'renamed' to a different prefix on Job commit. Object storage admins are forced to configure separate ILM policies to expire these objects and their versions to reclaim space. ### Solution
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 04 21:43:52 GMT 2023 - 11.9K bytes - Viewed (1) -
cmd/erasure-healing-common.go
func listOnlineDisks(disks []StorageAPI, partsMetadata []FileInfo, errs []error, quorum int) (onlineDisks []StorageAPI, modTime time.Time, etag string) { onlineDisks = make([]StorageAPI, len(disks)) // List all the file commit ids from parts metadata. modTimes := listObjectModtimes(partsMetadata, errs) // Reduce list of UUIDs to a single common value. modTime = commonTime(modTimes, quorum)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.8K bytes - Viewed (0)