- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 411 for afunc (0.04 sec)
-
cmd/peer-s3-client.go
} type localPeerS3Client struct { node Node pools []int } func (l *localPeerS3Client) GetHost() string { return l.node.Host } func (l *localPeerS3Client) SetPools(p []int) { l.pools = make([]int, len(p)) copy(l.pools, p) } func (l localPeerS3Client) GetPools() []int { return l.pools } func (l localPeerS3Client) ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.3K bytes - Viewed (0) -
cmd/erasure-sets.go
} } } func (s *erasureSets) GetLockers(setIndex int) func() ([]dsync.NetLocker, string) { return func() ([]dsync.NetLocker, string) { lockers := make([]dsync.NetLocker, len(s.erasureLockers[setIndex])) copy(lockers, s.erasureLockers[setIndex]) return lockers, s.erasureLockOwner } } func (s *erasureSets) GetEndpointStrings(setIndex int) func() []string { return func() []string {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 37.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
return nil } func (w *watchCache) SetOnReplace(onReplace func()) { w.Lock() defer w.Unlock() w.onReplace = onReplace } func (w *watchCache) Resync() error { // Nothing to do return nil } func (w *watchCache) getListResourceVersion() uint64 { w.RLock() defer w.RUnlock() return w.listResourceVersion } func (w *watchCache) currentCapacity() int {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0) -
src/cmd/go/internal/fsys/fsys.go
type fakeDir string func (f fakeDir) Name() string { return string(f) } func (f fakeDir) Size() int64 { return 0 } func (f fakeDir) Mode() fs.FileMode { return fs.ModeDir | 0500 } func (f fakeDir) ModTime() time.Time { return time.Unix(0, 0) } func (f fakeDir) IsDir() bool { return true } func (f fakeDir) Sys() any { return nil } func (f fakeDir) String() string {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 18:35:34 UTC 2024 - 22.7K bytes - Viewed (0) -
src/encoding/gob/encode.go
scratch [64]byte } var encBufferPool = sync.Pool{ New: func() any { e := new(encBuffer) e.data = e.scratch[0:0] return e }, } func (e *encBuffer) writeByte(c byte) { e.data = append(e.data, c) } func (e *encBuffer) Write(p []byte) (int, error) { e.data = append(e.data, p...) return len(p), nil } func (e *encBuffer) WriteString(s string) { e.data = append(e.data, s...) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 02:00:26 UTC 2024 - 19K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
} // Empty returns true if no targets with resync decision present func (r ResyncDecision) Empty() bool { return r.targets == nil } func (r ResyncDecision) mustResync() bool { for _, v := range r.targets { if v.Replicate { return true } } return false } func (r ResyncDecision) mustResyncTarget(tgtArn string) bool { if r.targets == nil { return false }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 26.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
// HasSynced returns true when all registries have synced func (c *Controller) HasSynced() bool { for _, r := range c.GetRegistries() { if !r.HasSynced() { log.Debugf("registry %s is syncing", r.Cluster()) return false } } return true } func (c *Controller) AppendServiceHandler(f model.ServiceHandler) { c.handlers.AppendServiceHandler(f) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
tests/integration/ambient/waypoint_test.go
kubetest "istio.io/istio/pkg/test/kube" "istio.io/istio/pkg/test/scopes" "istio.io/istio/pkg/test/util/retry" ) func TestWaypointStatus(t *testing.T) { framework. NewTest(t). Run(func(t framework.TestContext) { client := t.Clusters().Default().GatewayAPI().GatewayV1beta1().GatewayClasses() check := func() error { gwc, _ := client.Get(context.Background(), constants.WaypointGatewayClassName, metav1.GetOptions{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 11.4K bytes - Viewed (0) -
src/go/types/typeparam.go
// returns the result of f(nil). func (t *TypeParam) is(f func(*term) bool) bool { return t.iface().typeSet().is(f) } // underIs calls f with the underlying types of the specific type terms // of t's constraint and reports whether all calls to f returned true. // If there are no specific terms, underIs returns the result of f(nil). func (t *TypeParam) underIs(f func(Type) bool) bool { return t.iface().typeSet().underIs(f)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 20:03:31 UTC 2024 - 5.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/plugin.go
compositionEnvTemplateWithStrictCost, err := cel.NewCompositionEnv(cel.VariablesTypeName, environment.MustBaseEnvSet(environment.DefaultCompatibilityVersion(), true)) if err != nil { panic(err) } return compositionEnvTemplateWithStrictCost }() compositionEnvTemplateWithoutStrictCost *cel.CompositionEnv = func() *cel.CompositionEnv {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 7.5K bytes - Viewed (0)