- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 91 for caster (0.18 sec)
-
cmd/metrics-v3-cluster-notification.go
) // loadClusterNotificationMetrics - `MetricsLoaderFn` for cluster notification metrics. func loadClusterNotificationMetrics(_ context.Context, m MetricValues, _ *metricsCache) error { if globalEventNotifier == nil { return nil } nstats := globalEventNotifier.targetList.Stats()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:10:35 GMT 2024 - 2.2K bytes - Viewed (0) -
internal/s3select/message.go
// closes `doneCh` to indicate to caller to also exit. // // 2. If caller (Evaluate()) has an error, it sends an error // message and waits for this go-routine to quit in // FinishWithError() // // 3. If caller is done, it waits for this go-routine to exit // in Finish() quitFlag := false for !quitFlag { select { case data := <-writer.errCh: quitFlag = true
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
cmd/update.go
} // IsDocker - returns if the environment minio is running in docker or // not. The check is a simple file existence check. // // https://github.com/moby/moby/blob/master/daemon/initlayer/setup_unix.go // https://github.com/containers/podman/blob/master/libpod/runtime.go // // "/.dockerenv": "file", // "/run/.containerenv": "file", func IsDocker() bool { var err error for _, envfile := range []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) -
cmd/kms-handlers.go
writeCustomErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInternalError), err.Error(), r.URL) return } writeSuccessResponseJSON(w, v) } // KMSCreateKeyHandler - POST /minio/kms/v1/key/create?key-id=<master-key-id> func (a kmsAPIHandlers) KMSCreateKeyHandler(w http.ResponseWriter, r *http.Request) { // If env variable MINIO_KMS_SECRET_KEY is populated, prevent creation of new keys ctx := newContext(r, w, "KMSCreateKey")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 20.7K bytes - Viewed (0) -
cmd/metrics-v2.go
switch madmin.BatchJobType(mj.JobType) { case madmin.BatchJobReplicate: objects = float64(mj.Replicate.Objects) objectsFailed = float64(mj.Replicate.ObjectsFailed) bucket = mj.Replicate.Bucket case madmin.BatchJobKeyRotate: objects = float64(mj.KeyRotate.Objects) objectsFailed = float64(mj.KeyRotate.ObjectsFailed) bucket = mj.KeyRotate.Bucket case madmin.BatchJobExpire:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
internal/s3select/parquet/reader.go
// ensure it's UTF8 encoded. value = string(val) case [12]byte: // TODO: This is returned for the parquet INT96 type. We just // treat it same as []byte (but AWS S3 treats it as a large int) // - fix this later. value = string(val[:]) case int32: value = int64(val) if logicalType := se.GetLogicalType(); logicalType != nil { if logicalType.IsSetDATE() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 14 13:54:47 GMT 2022 - 4.5K bytes - Viewed (0) -
internal/config/identity/openid/provider/keycloak.go
} defer resp.Body.Close() switch resp.StatusCode { case http.StatusOK, http.StatusPartialContent: var u User if err = json.NewDecoder(resp.Body).Decode(&u); err != nil { return User{}, err } return u, nil case http.StatusNotFound: return User{ ID: userid, Enabled: false, }, nil case http.StatusUnauthorized: return User{}, ErrAccessTokenExpired }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 29 01:27:09 GMT 2022 - 4.6K bytes - Viewed (0) -
cmd/metrics.go
"Total capacity online in the cluster", nil, nil), prometheus.GaugeValue, float64(GetTotalCapacity(server.Disks)), ) // Report total capacity free ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(minioNamespace, "capacity_raw_free", "total"), "Total free capacity online in the cluster", nil, nil), prometheus.GaugeValue,
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) -
internal/event/target/nats.go
NATSClientCert = "client_cert" NATSClientKey = "client_key" // Streaming constants - deprecated NATSStreaming = "streaming" NATSStreamingClusterID = "streaming_cluster_id" NATSStreamingAsync = "streaming_async" NATSStreamingMaxPubAcksInFlight = "streaming_max_pub_acks_in_flight" // JetStream constants NATSJetStream = "jetstream"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0) -
cmd/erasure-object.go
ok = etag != "" && etag == fi.Metadata["etag"] } if ok { continue } } // in all other cases metadata is corrupt, do not read from it. onlineMeta[i] = FileInfo{} onlineDisks[i] = nil } select { case mrfCheck <- fi.ShallowCopy(): case <-ctx.Done(): return fi, onlineMeta, onlineDisks, toObjectErr(ctx.Err(), bucket, object) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2)