- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 364 for Implementation (0.25 sec)
-
pkg/controller/nodeipam/ipam/range_allocator_test.go
t.Errorf("%v: failed to create CIDRRangeAllocator with error %v", tc.description, err) return } rangeAllocator, ok := allocator.(*rangeAllocator) if !ok { t.Logf("%v: found non-default implementation of CIDRAllocator, skipping white-box test...", tc.description) return } rangeAllocator.nodesSynced = test.AlwaysReady rangeAllocator.recorder = testutil.NewFakeRecorder() go allocator.Run(tCtx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 25.2K bytes - Viewed (0) -
staging/src/k8s.io/api/node/v1/types.go
// +optional metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"` // handler specifies the underlying runtime and configuration that the CRI // implementation will use to handle pods of this class. The possible values // are specific to the node & CRI configuration. It is assumed that all // handlers are available on every node, and handlers of the same name are
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/plugin.go
func Register(plugins *admission.Plugins) { plugins.Register(PluginName, func(configFile io.Reader) (admission.Interface, error) { return NewPlugin(configFile), nil }) } // Plugin is an implementation of admission.Interface. type Policy = v1.ValidatingAdmissionPolicy type PolicyBinding = v1.ValidatingAdmissionPolicyBinding type PolicyEvaluator = Validator
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 7.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/grpc_service.go
kmsservice "k8s.io/kms/pkg/service" "k8s.io/kms/pkg/util" ) const ( // unixProtocol is the only supported protocol for remote KMS provider. unixProtocol = "unix" ) // The gRPC implementation for envelope.Service. type gRPCService struct { kmsClient kmsapi.KeyManagementServiceClient connection *grpc.ClientConn callTimeout time.Duration }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 23:18:16 UTC 2023 - 4.6K bytes - Viewed (0) -
pkg/kubelet/kubelet_server_journal.go
// Support for this is implementation specific and only available for service logs. TailLines *int // Boot show messages from a specific boot. Allowed values are less than 1. Passing an invalid boot offset will fail // retrieving logs and return an error. Support for this is implementation specific Boot *int
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 26 18:56:28 UTC 2023 - 13.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/versionconverter.go
"k8s.io/apimachinery/pkg/runtime/schema" "sigs.k8s.io/structured-merge-diff/v4/fieldpath" "sigs.k8s.io/structured-merge-diff/v4/merge" "sigs.k8s.io/structured-merge-diff/v4/typed" ) // versionConverter is an implementation of // sigs.k8s.io/structured-merge-diff/merge.Converter type versionConverter struct { typeConverter TypeConverter objectConvertor runtime.ObjectConvertor
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 3.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/webhook/webhook.go
// such as retry requests. type GenericWebhook struct { RestClient *rest.RESTClient RetryBackoff wait.Backoff ShouldRetry func(error) bool } // DefaultShouldRetry is a default implementation for the GenericWebhook ShouldRetry function property. // If the error reason is one of: networking (connection reset) or http (InternalServerError (500), GatewayTimeout (504), TooManyRequests (429)),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 20 19:02:55 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/scheduler/metrics/metric_recorder.go
// metric Inc(), Dec() and Clear() type MetricRecorder interface { Inc() Dec() Clear() } var _ MetricRecorder = &PendingPodsRecorder{} // PendingPodsRecorder is an implementation of MetricRecorder type PendingPodsRecorder struct { recorder metrics.GaugeMetric } // NewActivePodsRecorder returns ActivePods in a Prometheus metric fashion func NewActivePodsRecorder() *PendingPodsRecorder {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 16 07:27:08 UTC 2023 - 4.4K bytes - Viewed (0) -
pkg/volume/util/hostutil/fake_hostutil.go
limitations under the License. */ package hostutil import ( "errors" "os" "sync" "k8s.io/mount-utils" ) // FakeHostUtil is a fake HostUtils implementation for testing type FakeHostUtil struct { MountPoints []mount.MountPoint Filesystem map[string]FileType mutex sync.Mutex } // NewFakeHostUtil returns a struct that implements the HostUtils interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 13:32:38 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/credentialprovider/plugin/plugin.go
pluginBinDir: pluginBinDir, args: provider.Args, envVars: provider.Env, environ: os.Environ, }, }, nil } // pluginProvider is the plugin-based implementation of the DockerConfigProvider interface. type pluginProvider struct { clock clock.Clock sync.Mutex group singleflight.Group
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 05 05:07:28 UTC 2024 - 17.1K bytes - Viewed (0)