- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 221 for initiatives (0.26 sec)
-
internal/config/policy/plugin/config.go
AuthToken: getCfg(AuthToken), Transport: transport, CloseRespFn: closeRespFn, } if err = args.Validate(); err != nil { return args, err } return args, nil } // New - initializes Authorization Management Plugin. func New(args Args) *AuthZPlugin { if args.URL == nil || args.URL.Scheme == "" && args.AuthToken == "" { return nil } return &AuthZPlugin{ args: args,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
/** * A helper which does some thread-safe operations for aggregate futures, which must be implemented * differently in GWT. Namely: * * <ul> * <li>Lazily initializes a set of seen exceptions * <li>Decrements a counter atomically * </ul> */ @GwtCompatible(emulated = true) @ReflectionSupport(value = ReflectionSupport.Level.FULL) @ElementTypesAreNonnullByDefault
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
cmd/event-notification.go
} // Targets returns all the registered targets func (evnot *EventNotifier) Targets() []event.Target { return evnot.targetList.Targets() } // InitBucketTargets - initializes event notification system from notification.xml of all buckets. func (evnot *EventNotifier) InitBucketTargets(ctx context.Context, objAPI ObjectLayer) error { if objAPI == nil { return errServerNotInitialized }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AggregateFutureState.java
/** * A helper which does some thread-safe operations for aggregate futures, which must be implemented * differently in GWT. Namely: * * <ul> * <li>Lazily initializes a set of seen exceptions * <li>Decrements a counter atomically * </ul> */ @GwtCompatible(emulated = true) @ReflectionSupport(value = ReflectionSupport.Level.FULL) @ElementTypesAreNonnullByDefault
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
src/image/jpeg/huffman.go
d.bits.m >>= t s := int32(1) << t x := int32(d.bits.a>>uint8(d.bits.n)) & (s - 1) if x < s>>1 { x += ((-1) << t) + 1 } return x, nil } // processDHT processes a Define Huffman Table marker, and initializes a huffman // struct from its contents. Specified in section B.2.4.2. func (d *decoder) processDHT(n int) error { for n > 0 { if n < 17 { return FormatError("DHT has wrong length") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 11 17:08:05 UTC 2024 - 6.3K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/internal/component/external/model/DefaultMutableIvyModuleResolveMetadataTest.groovy
@Override AbstractMutableModuleComponentResolveMetadata createMetadata(ModuleComponentIdentifier id) { ivyMetadataFactory.create(id, []) as AbstractMutableModuleComponentResolveMetadata } def "initialises values from descriptor state and defaults"() { def id = DefaultModuleComponentIdentifier.newId(DefaultModuleIdentifier.newId("group", "module"), "version") configuration("runtime", [])
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 00:21:07 UTC 2024 - 9.5K bytes - Viewed (0) -
internal/config/identity/ldap/config.go
Key: LookupBindPassword, Value: "", }, } ) // Enabled returns if LDAP config is enabled. func Enabled(kvs config.KVS) bool { return kvs.Get(ServerAddr) != "" } // Lookup - initializes LDAP config, overrides config, if any ENV values are set. func Lookup(s config.Config, rootCAs *x509.CertPool) (l Config, err error) { l = Config{} // Purge all removed keys first
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/kubelet/server/server.go
a.registeredHandlePaths = append(a.registeredHandlePaths, path) } func (a *filteringContainer) RegisteredHandlePaths() []string { return a.registeredHandlePaths } // ListenAndServeKubeletServer initializes a server to respond to HTTP network requests on the Kubelet. func ListenAndServeKubeletServer( host HostInterface, resourceAnalyzer stats.ResourceAnalyzer, kubeCfg *kubeletconfiginternal.KubeletConfiguration,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 40.1K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/internal/component/external/model/DefaultMutableMavenModuleResolveMetadataTest.groovy
immutable.configurationNames == ["compile", "runtime", "test", "provided", "system", "optional", "master", "default", "javadoc", "sources"] as Set immutable.variants.empty } def "initialises values from descriptor state and defaults"() { def id = DefaultModuleComponentIdentifier.newId(DefaultModuleIdentifier.newId("group", "module"), "version") def vid = Mock(ModuleVersionIdentifier)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 00:21:07 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeports/node_ports.go
existingPorts := nodeInfo.UsedPorts for _, cp := range wantPorts { if existingPorts.CheckConflict(cp.HostIP, string(cp.Protocol), cp.HostPort) { return false } } return true } // New initializes a new plugin and returns it. func New(_ context.Context, _ runtime.Object, _ framework.Handle) (framework.Plugin, error) { return &NodePorts{}, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 10:53:29 UTC 2024 - 7.5K bytes - Viewed (0)