- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for ES (0.13 sec)
-
internal/event/target/elasticsearch.go
// ESSUnsupported -> we won't work with this ES server ESSUnsupported ESSupportStatus = "ESSUnsupported" // ESSSupported -> all good! ESSSupported ESSupportStatus = "ESSSupported" ) func getESVersionSupportStatus(version string) (res ESSupportStatus, err error) { parts := strings.Split(version, ".") if len(parts) < 1 { err = fmt.Errorf("bad ES version string: %s", version) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
applyExpiryOnTransitionedObject(es.ctx, es.objAPI, v.objInfo, v.event, v.src) } else { applyExpiryOnNonTransitionedObjects(es.ctx, es.objAPI, v.objInfo, v.event, v.src) } case newerNoncurrentTask: deleteObjectVersions(es.ctx, es.objAPI, v.bucket, v.versions, v.event) case jentry: transitionLogIf(es.ctx, deleteObjectFromRemoteTier(es.ctx, v.ObjName, v.VersionID, v.TierName))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/data-scanner_test.go
globalBucketMetadataSys = NewBucketMetadataSys() globalBucketObjectLockSys = &BucketObjectLockSys{} globalBucketVersioningSys = &BucketVersioningSys{} es := newExpiryState(context.Background(), objAPI, 0) workers := []chan expiryOp{make(chan expiryOp)} es.workers.Store(&workers) globalExpiryState = es var wg sync.WaitGroup wg.Add(1) expired := make([]ObjectToDelete, 0, 5) go func() { defer wg.Done()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
logger/sql_test.go
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Thu Mar 21 08:00:02 GMT 2024 - 8.4K bytes - Viewed (0) -
cmd/bucket-replication.go
if replicationStatus == replication.Failed { eventName = event.ObjectReplicationFailed } newReplStatusInternal := rinfos.ReplicationStatusInternal() // Note that internal replication status(es) may match for previously replicated objects - in such cases // metadata should be updated with last resync timestamp. objInfo := ri.ToObjectInfo()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/endpoint-ellipses_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Dec 07 09:33:56 GMT 2023 - 15.2K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
istioctl experimental envoy-stats <pod-name[.namespace]> --output prom-merged # Retrieve Envoy cluster metrics istioctl experimental envoy-stats <pod-name[.namespace]> --type clusters `, Aliases: []string{"es"}, Args: func(cmd *cobra.Command, args []string) error { if len(args) != 1 && (labelSelector == "") { cmd.Println(cmd.UsageString()) return fmt.Errorf("stats requires pod name or label selector") }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 48K bytes - Viewed (0)