Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for ES (0.13 sec)

  1. 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)
  2. 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)
  3. 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)
  4. logger/sql_test.go

    		pwd                = password("pass")
    		jsVal              = []byte(`{"Name":"test","Val":"test"}`)
    		js                 = JSON(jsVal)
    		esVal              = []byte(`{"Name":"test","Val":"test"}`)
    		es                 = ExampleStruct{Name: "test", Val: "test"}
    		intVal   intType   = 1
    		floatVal floatType = 1.23
    	)
    
    	results := []struct {
    		SQL           string
    		NumericRegexp *regexp.Regexp
    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)
  5. 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)
  6. cmd/endpoint-ellipses_test.go

    			}
    			if err == nil && !testCase.success {
    				t.Errorf("Expected failure but passed instead")
    			}
    			if !reflect.DeepEqual(testCase.es, gotEs) {
    				t.Errorf("Expected %v, got %v", testCase.es, gotEs)
    			}
    		})
    	}
    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)
  7. 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)
Back to top