- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 170 for coordinationv1 (0.15 sec)
-
pkg/controlplane/controller/apiserverleasegc/gc_controller_test.go
func Test_Controller(t *testing.T) { fakeClock := testingclock.NewFakeClock(time.Now()) tests := []struct { name string lease *coordinationv1.Lease expectDeleted bool }{ { name: "lease not expired", lease: &coordinationv1.Lease{ ObjectMeta: metav1.ObjectMeta{ Name: "kube-apiserver-12345", Namespace: metav1.NamespaceSystem, Labels: map[string]string{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 13 20:37:22 UTC 2023 - 4.7K bytes - Viewed (0) -
pkg/registry/coordination/rest/storage_coordination.go
*/ package rest import ( coordinationv1 "k8s.io/api/coordination/v1" "k8s.io/apiserver/pkg/registry/generic" "k8s.io/apiserver/pkg/registry/rest" genericapiserver "k8s.io/apiserver/pkg/server" serverstorage "k8s.io/apiserver/pkg/server/storage" "k8s.io/kubernetes/pkg/api/legacyscheme" "k8s.io/kubernetes/pkg/apis/coordination" leasestorage "k8s.io/kubernetes/pkg/registry/coordination/lease/storage" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 23 18:36:33 UTC 2022 - 2.4K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/k8sresourcelock/leaselock.go
limitations under the License. */ package k8sresourcelock import ( "context" "encoding/json" "errors" "fmt" coordinationv1 "k8s.io/api/coordination/v1" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" coordinationv1client "k8s.io/client-go/kubernetes/typed/coordination/v1" ) type LeaseLock struct { // LeaseMeta should contain a Name and a Namespace of a
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Jun 04 16:02:26 UTC 2022 - 4.3K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller_test.go
limitations under the License. */ package storageversiongc import ( "context" "reflect" "testing" "time" apiserverinternalv1alpha1 "k8s.io/api/apiserverinternal/v1alpha1" coordinationv1 "k8s.io/api/coordination/v1" apierrors "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/client-go/informers" "k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes/fake"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 12:19:43 UTC 2023 - 12.1K bytes - Viewed (0) -
pkg/kubelet/util/nodelease.go
// a node OwnerReference to the given lease object func SetNodeOwnerFunc(c clientset.Interface, nodeName string) func(lease *coordinationv1.Lease) error { return func(lease *coordinationv1.Lease) error { // Setting owner reference needs node's UID. Note that it is different from // kubelet.nodeRef.UID. When lease is initially created, it is possible that // the connection between master and node is not ready yet. So try to set
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Mar 07 15:47:46 UTC 2021 - 1.9K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller.go
func (c *Controller) onDeleteLease(logger klog.Logger, obj interface{}) { castObj, ok := obj.(*coordinationv1.Lease) if !ok { tombstone, ok := obj.(cache.DeletedFinalStateUnknown) if !ok { utilruntime.HandleError(fmt.Errorf("couldn't get object from tombstone %#v", obj)) return } castObj, ok = tombstone.Obj.(*coordinationv1.Lease) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0) -
pkg/apis/coordination/v1/register.go
See the License for the specific language governing permissions and limitations under the License. */ package v1 import ( coordinationv1 "k8s.io/api/coordination/v1" "k8s.io/apimachinery/pkg/runtime/schema" ) // GroupName is the group name use in this package const GroupName = "coordination.k8s.io" // SchemeGroupVersion is group version used to register these objects
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 25 10:06:08 UTC 2019 - 1.6K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/k8sresourcelock/interface.go
package k8sresourcelock import ( "context" "fmt" "time" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" clientset "k8s.io/client-go/kubernetes" coordinationv1 "k8s.io/client-go/kubernetes/typed/coordination/v1" corev1 "k8s.io/client-go/kubernetes/typed/core/v1" restclient "k8s.io/client-go/rest" ) const ( LeaderElectionRecordAnnotationKey = "control-plane.alpha.kubernetes.io/leader"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 25 19:30:47 UTC 2022 - 6K bytes - Viewed (0) -
pkg/controlplane/controller/apiserverleasegc/gc_controller.go
"fmt" "time" v1 "k8s.io/api/coordination/v1" "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/labels" utilruntime "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/apimachinery/pkg/util/wait" informers "k8s.io/client-go/informers/coordination/v1" "k8s.io/client-go/kubernetes" listers "k8s.io/client-go/listers/coordination/v1" "k8s.io/client-go/tools/cache"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 25 03:27:44 UTC 2021 - 4.6K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection_test.go
obj = &corev1.Endpoints{ObjectMeta: objectMeta} case "configmaps": obj = &corev1.ConfigMap{ObjectMeta: objectMeta} case "leases": var spec coordinationv1.LeaseSpec if record != nil { spec = rl.LeaderElectionRecordToLeaseSpec(record) } obj = &coordinationv1.Lease{ObjectMeta: objectMeta, Spec: spec} default: t.Fatal("unexpected objType:" + objectType) } return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 23 16:39:43 UTC 2023 - 42.5K bytes - Viewed (0)