- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 1,179 for funcs (0.03 sec)
-
cmd/common-main.go
// This can be used for goroutines that live beyond the parent context. func bgContext(parent context.Context) context.Context { return bgCtx{parent: parent} } type bgCtx struct { parent context.Context } func (a bgCtx) Done() <-chan struct{} { return nil } func (a bgCtx) Err() error { return nil } func (a bgCtx) Deadline() (deadline time.Time, ok bool) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 21:50:11 UTC 2024 - 31.7K bytes - Viewed (0) -
tests/connpool_test.go
func (c *wrapperConnPool) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error) { c.got = append(c.got, query) return c.db.ExecContext(ctx, query, args...) } func (c *wrapperConnPool) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error) { c.got = append(c.got, query) return c.db.QueryContext(ctx, query, args...) }
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Tue Feb 06 02:54:40 UTC 2024 - 5.5K bytes - Viewed (0) -
internal/config/policy/opa/config.go
type Opa struct { args Args client *http.Client } // Enabled returns if opa is enabled. func Enabled(kvs config.KVS) bool { return kvs.Get(URL) != "" } // LookupConfig lookup Opa from config, override with any ENVs. func LookupConfig(kv config.KVS, transport *http.Transport, closeRespFn func(io.ReadCloser)) (Args, error) { args := Args{}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 10 20:16:44 UTC 2024 - 5.3K bytes - Viewed (0) -
callbacks/associations.go
package callbacks import ( "reflect" "strings" "gorm.io/gorm" "gorm.io/gorm/clause" "gorm.io/gorm/schema" "gorm.io/gorm/utils" ) func SaveBeforeAssociations(create bool) func(db *gorm.DB) { return func(db *gorm.DB) { if db.Error == nil && db.Statement.Schema != nil { selectColumns, restricted := db.Statement.SelectAndOmitColumns(create, !create) // Save Belongs To associations
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Tue Apr 11 03:06:13 UTC 2023 - 14.3K bytes - Viewed (0) -
cmd/namespace-lock.go
ctx context.Context cancel context.CancelFunc } // Context returns lock context func (l LockContext) Context() context.Context { return l.ctx } // Cancel function calls cancel() function func (l LockContext) Cancel() { if l.cancel != nil { l.cancel() } } // newNSLock - return a new name space lock map. func newNSLock(isDistErasure bool) *nsLockMap { nsMutex := nsLockMap{ isDistErasure: isDistErasure,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 9.2K bytes - Viewed (0) -
docs/iam/access-manager-plugin.go
json.NewEncoder(w).Encode(res) return } func main() { flag.Parse() serveFunc := func() error { return http.ListenAndServe(":8080", nil) } if certFile != "" || keyFile != "" { if certFile == "" || keyFile == "" { log.Fatal("Please provide both a key file and a cert file to enable TLS.") } serveFunc = func() error { return http.ListenAndServeTLS(":8080", certFile, keyFile, nil)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 08 17:15:20 UTC 2024 - 2.7K bytes - Viewed (0) -
cmd/server-main.go
bootstrapTrace("initBackgroundExpiry", func() { initBackgroundExpiry(GlobalContext, newObject) }) bootstrapTrace("globalTransitionState.Init", func() { globalTransitionState.Init(newObject) }) go func() { // Initialize transition tier configuration manager bootstrapTrace("globalTierConfigMgr.Init", func() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 21:50:11 UTC 2024 - 35.2K bytes - Viewed (1) -
gorm.go
Context context.Context Logger logger.Interface NowFunc func() time.Time CreateBatchSize int } // Open initialize db session based on dialector func Open(dialector Dialector, opts ...Option) (db *DB, err error) { config := &Config{} sort.Slice(opts, func(i, j int) bool { _, isConfig := opts[i].(*Config) _, isConfig2 := opts[j].(*Config)
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Oct 09 11:29:48 UTC 2024 - 12.1K bytes - Viewed (0) -
cmd/bucket-stats_gen.go
func (z *BucketStats) Msgsize() (s int) { s = 1 + 7 + msgp.Int64Size + 17 + z.ReplicationStats.Msgsize() + 11 + 1 + 6 + msgp.ArrayHeaderSize for za0001 := range z.QueueStats.Nodes { s += z.QueueStats.Nodes[za0001].Msgsize() } s += 7 + msgp.Int64Size + 11 + z.ProxyStats.Msgsize() return } // DecodeMsg implements msgp.Decodable
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 57.5K bytes - Viewed (0) -
migrator/table_type.go
} // Schema returns the schema of the table. func (ct TableType) Schema() string { return ct.SchemaValue } // Name returns the name of the table. func (ct TableType) Name() string { return ct.NameValue } // Type returns the type of the table. func (ct TableType) Type() string { return ct.TypeValue } // Comment returns the comment of current table. func (ct TableType) Comment() (comment string, ok bool) {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Fri May 05 07:58:27 UTC 2023 - 688 bytes - Viewed (0)