- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 30 for Implementation (0.26 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval.go
// copied over. // // The source of events for the interval is typically either // the watchCache circular buffer, if events being retrieved // need to be for resource versions > 0 or the underlying // implementation of Store, if resource version = 0. // // Furthermore, an interval can be either valid or invalid at // any given point of time. The notion of validity makes sense // only in cases where the window of events in the underlying
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 8.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/cbor/cbor.go
if u, ok := into.(runtime.Unstructured); ok { var content map[string]interface{} defer func() { switch u := u.(type) { case *unstructured.UnstructuredList: // UnstructuredList's implementation of SetUnstructuredContent // produces different objects than those produced by a decode using // UnstructuredJSONScheme: // // 1. SetUnstructuredContent retains the "items" key in the list's
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 14:57:12 UTC 2024 - 9.6K bytes - Viewed (0) -
cmd/kubelet/app/plugins.go
See the License for the specific language governing permissions and limitations under the License. */ package app // This file exists to force the desired plugin implementations to be linked. import ( "k8s.io/component-base/featuregate" "k8s.io/utils/exec" // Volume plugins "k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume/configmap"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 21:09:52 UTC 2024 - 3.1K bytes - Viewed (0) -
pkg/kubeapiserver/options/plugins.go
See the License for the specific language governing permissions and limitations under the License. */ package options // This file exists to force the desired plugin implementations to be linked. // This should probably be part of some configuration fed into the build for a // given binary target. import ( validatingadmissionpolicy "k8s.io/apiserver/pkg/admission/plugin/policy/validating"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 17:20:46 UTC 2024 - 8.2K 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) -
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) -
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) -
cmd/kube-controller-manager/app/plugins.go
See the License for the specific language governing permissions and limitations under the License. */ package app import ( // This file exists to force the desired plugin implementations to be linked. // This should probably be part of some configuration fed into the build for a // given binary target. "fmt" "k8s.io/klog/v2" // Volume plugins "k8s.io/kubernetes/pkg/volume"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:17:15 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/scheduler/internal/queue/events.go
BackoffComplete = "BackoffComplete" // ForceActivate is the event when a pod is moved from unschedulablePods/backoffQ // to activeQ. Usually it's triggered by plugin implementations. ForceActivate = "ForceActivate" // PodUpdate is the event when a pod is updated PodUpdate = "PodUpdate" ) var (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 6.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/library/format.go
MaxRegexSize: 30, }, "labelValue": { Name: "LabelValue", ValidateFunc: validation.IsValidLabelValue, MaxRegexSize: 40, }, // CRD formats // Implementations sourced from strfmt, which kube-openapi uses as its // format library. There are other CRD formats supported, but they are // covered by other portions of the CEL library (like IP/CIDR), or their
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 17:22:44 UTC 2024 - 8.2K bytes - Viewed (0)