- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 185 for Implementation (0.81 sec)
-
pkg/controller/statefulset/stateful_set_status_updater.go
// For any use other than testing, clients should create an instance using NewRealStatefulSetStatusUpdater. type StatefulSetStatusUpdaterInterface interface { // UpdateStatefulSetStatus sets the set's Status to status. Implementations are required to retry on conflicts, // but fail on other errors. If the returned error is nil set's Status has been successfully set to status.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 13 20:32:13 UTC 2021 - 2.9K bytes - Viewed (0) -
pkg/volume/util/fsquota/common/quota_common_linux.go
// should be applied (perhaps by setting a quota too large to // be hit) SetQuotaOnDir(path string, id QuotaID, bytes int64) error // QuotaIDIsInUse determines whether the quota ID is in use. // Implementations should not check /etc/project or /etc/projid, // only whether their underlying mechanism already has the ID in // use. // Return value of false with no error means that the ID is not
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 28 06:09:31 UTC 2023 - 3.2K bytes - Viewed (0) -
pkg/proxy/ipvs/util/ipvs.go
limitations under the License. */ package ipvs import ( "net" "strconv" "strings" "time" ) // Interface is an injectable interface for running ipvs commands. Implementations must be goroutine-safe. type Interface interface { // Flush clears all virtual servers in system. return occurred error immediately. Flush() error // AddVirtualServer creates the specified virtual server.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 4.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/groupversion.go
// empty, defaults to GroupVersion. OptionsExternalVersion *schema.GroupVersion // MetaGroupVersion defaults to "meta.k8s.io/v1" and is the scheme group version used to decode // common API implementations like ListOptions. Future changes will allow this to vary by group // version (for when the inevitable meta/v2 group emerges). MetaGroupVersion *schema.GroupVersion
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 5.9K bytes - Viewed (0) -
staging/src/k8s.io/api/events/v1/types.go
// The default event reporter in "k8s.io/client-go/tools/events/event_broadcaster.go" shows // how this struct is updated on heartbeats and can guide customized reporter implementations. type EventSeries struct { // count is the number of occurrences in this series up to the last heartbeat time. Count int32 `json:"count" protobuf:"varint,1,opt,name=count"`
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/kubelet/util/manager/manager.go
// RegisterPod registers all objects referenced from a given pod. // // NOTE: All implementations of RegisterPod should be idempotent. RegisterPod(pod *v1.Pod) // UnregisterPod unregisters objects referenced from a given pod that are not // used by any other registered pod. // // NOTE: All implementations of UnregisterPod should be idempotent. UnregisterPod(pod *v1.Pod) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 10 02:22:52 UTC 2023 - 2.3K bytes - Viewed (0) -
pkg/credentialprovider/plugins.go
"k8s.io/klog/v2" ) // All registered credential providers. var providersMutex sync.Mutex var providers = make(map[string]DockerConfigProvider) // RegisterCredentialProvider is called by provider implementations on // initialization to register themselves, like so: // // func init() { // RegisterCredentialProvider("name", &myProvider{...}) // } func RegisterCredentialProvider(name string, provider DockerConfigProvider) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 22:01:25 UTC 2024 - 2K bytes - Viewed (0) -
pkg/proxy/types.go
*/ package proxy import ( "fmt" v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/kubernetes/pkg/proxy/config" ) // Provider is the interface provided by proxier implementations. type Provider interface { config.EndpointSliceHandler config.ServiceHandler config.NodeHandler config.ServiceCIDRHandler // Sync immediately synchronizes the Provider's current state to proxy rules.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 21 14:28:37 UTC 2024 - 1.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
// producer should stop sending events and close the result channel. The // consumer should keep watching for events until the result channel is // closed. // // Because some implementations may create channels when constructed, Stop // must always be called, even if the consumer has not yet called // ResultChan(). // // Only the consumer should call Stop(), not the producer. If the producer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
pkg/kubelet/kubelet_network.go
defer kl.updatePodCIDRMux.Unlock() podCIDR := kl.runtimeState.podCIDR() if podCIDR == cidr { return false, nil } // kubelet -> generic runtime -> runtime shim -> network plugin // docker/non-cri implementations have a passthrough UpdatePodCIDR if err := kl.getRuntime().UpdatePodCIDR(ctx, cidr); err != nil { // If updatePodCIDR would fail, theoretically pod CIDR could not change.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 05 13:02:13 UTC 2022 - 2.4K bytes - Viewed (0)