- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for trigger (0.15 sec)
-
cmd/erasure-decode.go
p.orgReaders[bufIdx] = nil p.readers[i] = nil // Since ReadAt returned error, trigger another read. readTriggerCh <- true return } newBufLK.Lock() newBuf[bufIdx] = p.buf[bufIdx][:n] newBufLK.Unlock() // Since ReadAt returned success, there is no need to trigger another read. readTriggerCh <- false }(readerIndex) readerIndex++ } wg.Wait()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/bucket-replication.go
} if !ok { // existing object replication is enabled and object version is unreplicated so far. if resetID != "" && oi.ModTime.Before(resetBeforeDate) { // trigger replication if `mc replicate reset` requested rd.Replicate = true return } // For existing object reset - this condition is needed rd.Replicate = tgtStatus == "" return }
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) -
internal/bucket/lifecycle/action_string.go
// Code generated by "stringer -type Action lifecycle.go"; DO NOT EDIT. package lifecycle import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[NoneAction-0] _ = x[DeleteAction-1] _ = x[DeleteVersionAction-2] _ = x[TransitionAction-3] _ = x[TransitionVersionAction-4]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 1.1K bytes - Viewed (0) -
cmd/consolelogger.go
return nil } // Endpoint - dummy function for interface compatibility func (sys *HTTPConsoleLoggerSys) Endpoint() string { return sys.console.Endpoint() } // String - stringer function for interface compatibility func (sys *HTTPConsoleLoggerSys) String() string { return logger.ConsoleLoggerTgt } // Stats returns the target statistics.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
internal/grid/handlers.go
"encoding/hex" "errors" "fmt" "strings" "sync" "github.com/minio/minio/internal/hash/sha256" xioutil "github.com/minio/minio/internal/ioutil" "github.com/tinylib/msgp/msgp" ) //go:generate stringer -type=HandlerID -output=handlers_string.go -trimprefix=Handler msg.go $GOFILE // HandlerID is a handler identifier. // It is used to determine request routing on the server. // Handlers can be registered with a static subroute.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
// wait for an update event mt.Assert(EventTotals.Name(), map[string]string{"type": "update"}, monitortest.AtLeast(2)) // wait for the pod to be annotated // after Pod annotated, another update event will be triggered. assertPodAnnotated(t, client, pod) // Assert expected calls actually made fs.AssertExpectations(t) // unlabelling the namespace should cause only one RemovePodFromMesh to happen
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
internal/grid/handlers_string.go
// Code generated by "stringer -type=HandlerID -output=handlers_string.go -trimprefix=Handler msg.go handlers.go"; DO NOT EDIT. package grid import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[handlerInvalid-0] _ = x[HandlerLockLock-1] _ = x[HandlerLockRLock-2] _ = x[HandlerLockUnlock-3]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 4.2K bytes - Viewed (0) -
cmd/storage-rest-client.go
respBody, err := client.restClient.Call(ctx, method, values, body, length) if err != nil { return nil, toStorageErr(err) } return respBody, nil } // Stringer provides a canonicalized representation of network device. func (client *storageRESTClient) String() string { return client.endpoint.String() } // IsOnline - returns whether RPC client failed to connect or not.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
internal/grid/grid_test.go
} return } } // Inserted manually. func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[StateUnconnected-0] _ = x[StateConnecting-1] _ = x[StateConnected-2] _ = x[StateConnectionError-3] _ = x[StateShutdown-4] }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
} wk.Wait() return nil } //msgp:ignore decomMetrics type decomMetrics struct{} var globalDecommissionMetrics decomMetrics //msgp:ignore decomMetric //go:generate stringer -type=decomMetric -trimprefix=decomMetric $GOFILE type decomMetric uint8 const ( decomMetricDecommissionBucket decomMetric = iota decomMetricDecommissionObject decomMetricDecommissionRemoveObject )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1)