Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 1,179 for funcs (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top