- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 1,385 for _func (0.07 sec)
-
istioctl/pkg/writer/envoy/configdump/route.go
Verbose bool } // Verify returns true if the passed route matches the filter fields func (r *RouteFilter) Verify(route *route.RouteConfiguration) bool { if r.Name != "" && r.Name != route.Name { return false } return true } // PrintRouteSummary prints a summary of the relevant routes in the config dump to the ConfigWriter stdout func (c *ConfigWriter) PrintRouteSummary(filter RouteFilter) error {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Aug 08 20:44:50 UTC 2024 - 7.2K 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 (4) -
internal/logger/logger.go
var ( quietFlag, jsonFlag, anonFlag bool // Custom function to format error errorFmtFunc func(string, error, bool) string ) // EnableQuiet - turns quiet option on. func EnableQuiet() { color.TurnOff() // no colored outputs necessary in quiet mode. quietFlag = true } // EnableJSON - outputs logs in json format. func EnableJSON() { color.TurnOff() // no colored outputs necessary in JSON mode. jsonFlag = true
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 22 09:43:48 UTC 2024 - 12.4K bytes - Viewed (0) -
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) -
internal/s3select/jstream/scratch.go
fill int } // reset scratch buffer func (s *scratch) reset() { s.fill = 0 } // bytes returns the written contents of scratch buffer func (s *scratch) bytes() []byte { return s.data[0:s.fill] } // grow scratch buffer func (s *scratch) grow() { ndata := make([]byte, cap(s.data)*2) copy(ndata, s.data) s.data = ndata } // append single byte to scratch buffer func (s *scratch) add(c byte) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 758 bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle.go
ActionCount ) // DeleteRestored - Returns true if action demands delete on restored objects func (a Action) DeleteRestored() bool { return a == DeleteRestoredAction || a == DeleteRestoredVersionAction } // DeleteVersioned - Returns true if action demands delete on a versioned object func (a Action) DeleteVersioned() bool { return a == DeleteVersionAction || a == DeleteRestoredVersionAction }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 23 01:12:48 UTC 2024 - 17.9K bytes - Viewed (0) -
istioctl/pkg/injector/injector-list.go
needsRestart int } func Cmd(cliContext cli.Context) *cobra.Command { cmd := &cobra.Command{ Use: "injector", Short: "List sidecar injector and sidecar versions", Long: `List sidecar injector and sidecar versions`, Example: ` istioctl experimental injector list`, Args: func(cmd *cobra.Command, args []string) error { if len(args) != 0 {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Oct 18 11:39:52 UTC 2024 - 10.6K bytes - Viewed (0) -
internal/event/targetidset.go
// IsEmpty returns true if the set is empty. func (set TargetIDSet) IsEmpty() bool { return len(set) != 0 } // Clone - returns copy of this set. func (set TargetIDSet) Clone() TargetIDSet { setCopy := NewTargetIDSet() for k, v := range set { setCopy[k] = v } return setCopy } // add - adds TargetID to the set. func (set TargetIDSet) add(targetID TargetID) { set[targetID] = struct{}{} }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 1.9K bytes - Viewed (0) -
chainable_api.go
// } // // func OrderStatus(status []string) func (db *gorm.DB) *gorm.DB { // return func (db *gorm.DB) *gorm.DB { // return db.Scopes(AmountGreaterThan1000).Where("status in (?)", status) // } // } // // db.Scopes(AmountGreaterThan1000, OrderStatus([]string{"paid", "shipped"})).Find(&orders) func (db *DB) Scopes(funcs ...func(*DB) *DB) (tx *DB) { tx = db.getInstance()
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Mon Jun 24 09:42:59 UTC 2024 - 14.8K bytes - Viewed (0) -
cmd/iam-object-store.go
usersSysType UsersSysType objAPI ObjectLayer } func newIAMObjectStore(objAPI ObjectLayer, usersSysType UsersSysType) *IAMObjectStore { return &IAMObjectStore{ iamCache: newIamCache(), objAPI: objAPI, usersSysType: usersSysType, } } func (iamOS *IAMObjectStore) rlock() *iamCache { iamOS.RLock() return iamOS.iamCache } func (iamOS *IAMObjectStore) runlock() { iamOS.RUnlock() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 23:40:37 UTC 2024 - 26.6K bytes - Viewed (0)