- Sort Score
- Result 10 results
- Languages All
Results 251 - 260 of 1,387 for funcs (0.03 sec)
-
cmd/notification.go
// returns the slice of errors from all function calls. func (g *NotificationGroup) Wait() []NotificationPeerErr { g.workers.Wait() return g.errs } // Go calls the given function in a new goroutine. // // The first call to return a non-nil error will be // collected in errs slice and returned by Wait(). func (g *NotificationGroup) Go(ctx context.Context, f func() error, index int, addr xnet.Host) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 46.2K bytes - Viewed (0) -
cmd/signals.go
"github.com/minio/minio/internal/logger" ) func shutdownHealMRFWithTimeout() { const shutdownTimeout = time.Minute finished := make(chan struct{}) go func() { globalMRFState.shutdown() close(finished) }() select { case <-time.After(shutdownTimeout): case <-finished: } } func handleSignals() { // Custom exit function exit := func(success bool) { if globalLoggerOutput != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 04 17:02:39 UTC 2024 - 3.2K bytes - Viewed (0) -
tests/sql_builder_test.go
} } type ageInt int8 func (ageInt) String() string { return "age" } type ageBool bool func (ageBool) String() string { return "age" } type ageUint64 uint64 func (ageUint64) String() string { return "age" } type ageFloat float64 func (ageFloat) String() string { return "age" } func TestExplainSQL(t *testing.T) {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Fri Jan 12 08:42:21 UTC 2024 - 16.7K bytes - Viewed (0) -
cmd/bucket-replication-utils_gen_test.go
} if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgBucketReplicationResyncStatus(b *testing.B) { v := BucketReplicationResyncStatus{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgBucketReplicationResyncStatus(b *testing.B) { v := BucketReplicationResyncStatus{}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Aug 22 23:53:06 UTC 2022 - 23K bytes - Viewed (0) -
internal/rest/rpc-stats.go
// Return a function which update the global stats related to tcp connections func setupReqStatsUpdate(req *http.Request) (*http.Request, func()) { var dialStart, dialEnd int64 start := time.Now() trace := &httptrace.ClientTrace{ GotFirstResponseByte: func() { atomic.AddUint64(&globalStats.tcpTimeForFirstByteTotalDur, uint64(time.Since(start))) }, ConnectStart: func(network, addr string) { atomic.StoreInt64(&dialStart, time.Now().UnixNano())
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 18:21:34 UTC 2024 - 2.6K bytes - Viewed (0) -
schema/constraint.go
Constraint string // length(phone) >= 10 *Field } func (chk *CheckConstraint) GetName() string { return chk.Name } func (chk *CheckConstraint) Build() (sql string, vars []interface{}) { return "CONSTRAINT ? CHECK (?)", []interface{}{clause.Column{Name: chk.Name}, clause.Expr{SQL: chk.Constraint}} } // ParseCheckConstraints parse schema check constraints func (schema *Schema) ParseCheckConstraints() map[string]CheckConstraint {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Mon Mar 18 07:33:54 UTC 2024 - 1.9K bytes - Viewed (0) -
internal/http/dial_others.go
// //nolint:unused func setTCPParametersFn(opts TCPOptions) func(network, address string, c syscall.RawConn) error { return func(network, address string, c syscall.RawConn) error { return nil } } // DialContext is a function to make custom Dial for internode communications type DialContext func(ctx context.Context, network, address string) (net.Conn, error)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Apr 24 04:08:47 UTC 2024 - 1.6K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
return w, fullStatus, nil } func xdsStatusPrintln(w io.Writer, status *xdsWriterStatus) error { _, err := fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\t%v\t%v\t%v\t%v\n", status.proxyID, status.clusterID, status.clusterStatus, status.listenerStatus, status.endpointStatus, status.routeStatus, status.extensionconfigStatus, status.istiodID, status.istiodVersion) return err }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Jun 21 22:47:20 UTC 2024 - 6.5K bytes - Viewed (0) -
cmd/metacache-entries.go
// isDir returns if the entry is representing a prefix directory. func (e metaCacheEntry) isDir() bool { return len(e.metadata) == 0 && strings.HasSuffix(e.name, slashSeparator) } // isObject returns if the entry is representing an object. func (e metaCacheEntry) isObject() bool { return len(e.metadata) > 0 } // isObjectDir returns if the entry is representing an object/ func (e metaCacheEntry) isObjectDir() bool {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 24.1K bytes - Viewed (0) -
api/go1.15.txt
pkg bufio, var ErrBadReadCount error pkg crypto, method (Hash) String() string pkg crypto/ecdsa, func SignASN1(io.Reader, *PrivateKey, []uint8) ([]uint8, error) pkg crypto/ecdsa, func VerifyASN1(*PublicKey, []uint8, []uint8) bool pkg crypto/ecdsa, method (*PrivateKey) Equal(crypto.PrivateKey) bool pkg crypto/ecdsa, method (*PublicKey) Equal(crypto.PublicKey) bool pkg crypto/ed25519, method (PrivateKey) Equal(crypto.PrivateKey) bool
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Jul 17 02:15:01 UTC 2020 - 7.6K bytes - Viewed (0)