ResourceLock - Code Search

pkg/controller/endpointslicemirroring/endpointslicemirroring_controller_test.go

	"k8s.io/client-go/informers"
	"k8s.io/client-go/kubernetes/fake"
	v1core "k8s.io/client-go/kubernetes/typed/core/v1"
	"k8s.io/client-go/tools/cache"
	"k8s.io/client-go/tools/leaderelection/resourcelock"

	"k8s.io/klog/v2"
	"k8s.io/klog/v2/ktesting"
	"k8s.io/kubernetes/pkg/controller"
)

// Most of the tests related to EndpointSlice allocation can be found in reconciler_test.go

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Wed Jul 12 12:57:29 UTC 2023

- 13.9K bytes

- Viewed (0)

github.com/istio/istio

pilot/pkg/leaderelection/k8sleaderelection/k8sresourcelock/interface.go

	AcquireTime          metav1.Time `json:"acquireTime"`
	RenewTime            metav1.Time `json:"renewTime"`
	LeaderTransitions    int         `json:"leaderTransitions"`
}

// EventRecorder records a change in the ResourceLock.
type EventRecorder interface {
	Eventf(obj runtime.Object, eventType, reason, message string, args ...any)
}

// ResourceLockConfig common data that exists across different
// resource locks

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Mon Jul 25 19:30:47 UTC 2022

- 6K bytes

- Viewed (0)

github.com/gradle/gradle

subprojects/core/src/main/java/org/gradle/execution/plan/Node.java

import org.gradle.api.tasks.VerificationException;
import org.gradle.execution.plan.edges.DependencyNodesSet;
import org.gradle.execution.plan.edges.DependentNodesSet;
import org.gradle.internal.resources.ResourceLock;

import javax.annotation.Nullable;
import javax.annotation.OverridingMethodsMustInvokeSuper;
import java.util.Collections;
import java.util.List;
import java.util.Set;
import java.util.SortedSet;

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Thu Aug 24 13:30:48 UTC 2023

- 22.7K bytes

- Viewed (0)

github.com/gradle/gradle

subprojects/composite-builds/src/test/groovy/org/gradle/composite/internal/DefaultIncludedBuildTaskGraphParallelTest.groovy

import org.gradle.internal.operations.TestBuildOperationRunner
import org.gradle.internal.properties.bean.PropertyWalker
import org.gradle.internal.resources.DefaultResourceLockCoordinationService
import org.gradle.internal.resources.ResourceLock
import org.gradle.internal.service.DefaultServiceRegistry
import org.gradle.internal.snapshot.CaseSensitivity
import org.gradle.internal.work.DefaultWorkerLeaseService
import org.gradle.internal.work.WorkerLeaseService

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Fri Apr 05 16:29:26 UTC 2024

- 20.6K bytes

- Viewed (0)

github.com/gradle/gradle

subprojects/core/src/main/java/org/gradle/api/internal/AbstractTask.java

import org.gradle.internal.logging.slf4j.DefaultContextAwareTaskLogger;
import org.gradle.internal.metaobject.DynamicObject;
import org.gradle.internal.properties.bean.PropertyWalker;
import org.gradle.internal.resources.ResourceLock;
import org.gradle.internal.scripts.ScriptOriginUtil;
import org.gradle.internal.service.ServiceRegistry;
import org.gradle.internal.snapshot.impl.ImplementationSnapshot;
import org.gradle.util.Path;

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Thu Apr 11 12:20:43 UTC 2024

- 34.7K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

staging/publishing/import-restrictions.yaml

- baseImportPath: "./staging/src/k8s.io/client-go/tools"
  excludeTests: true
  ignoredSubTrees:
  - "./staging/src/k8s.io/client-go/tools/cache/testing"
  - "./staging/src/k8s.io/client-go/tools/leaderelection/resourcelock"
  - "./staging/src/k8s.io/client-go/tools/portforward"
  - "./staging/src/k8s.io/client-go/tools/record"
  - "./staging/src/k8s.io/client-go/tools/events"
  - "./staging/src/k8s.io/client-go/tools/reference"

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Thu May 30 13:13:22 UTC 2024

- 7.7K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/controller/endpoint/endpoints_controller.go

	"k8s.io/client-go/kubernetes/scheme"
	v1core "k8s.io/client-go/kubernetes/typed/core/v1"
	corelisters "k8s.io/client-go/listers/core/v1"
	"k8s.io/client-go/tools/cache"
	"k8s.io/client-go/tools/leaderelection/resourcelock"
	"k8s.io/client-go/tools/record"
	"k8s.io/client-go/util/workqueue"
	endpointsliceutil "k8s.io/endpointslice/util"
	"k8s.io/klog/v2"
	"k8s.io/kubernetes/pkg/api/v1/endpoints"

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Sat May 04 18:33:12 UTC 2024

- 26.3K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

cmd/kube-controller-manager/app/options/options_test.go

					QPS:         50.0,
					Burst:       100,
				},
				ControllerStartInterval: metav1.Duration{Duration: 2 * time.Minute},
				LeaderElection: componentbaseconfig.LeaderElectionConfiguration{
					ResourceLock:      "configmap",
					LeaderElect:       false,
					LeaseDuration:     metav1.Duration{Duration: 30 * time.Second},
					RenewDeadline:     metav1.Duration{Duration: 15 * time.Second},

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Mon May 27 02:59:09 UTC 2024

- 55.1K bytes

- Viewed (0)

github.com/istio/istio

pilot/pkg/leaderelection/k8sleaderelection/leaderelection_test.go

		return true, nil, fmt.Errorf("unreachable action")
	})

	lock, err := rl.New(objectType, "foo", "bar", c.CoreV1(), c.CoordinationV1(), resourceLockConfig)
	if err != nil {
		t.Fatal("resourcelock.New() = ", err)
	}

	lec := LeaderElectionConfig{
		Lock:          lock,
		LeaseDuration: 40 * time.Millisecond,
		RenewDeadline: 20 * time.Millisecond,
		RetryPeriod:   10 * time.Millisecond,

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Mon Jan 23 16:39:43 UTC 2023

- 42.5K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/generated/openapi/zz_generated.openapi.go

							Default:     "",
							Type:        []string{"string"},
							Format:      "",
						},
					},
					"resourceLock": {
						SchemaProps: spec.SchemaProps{
							Description: "ResourceLock indicates the resource object type that will be used to lock Should be \"leases\" or \"endpoints\"",
							Default:     "",
							Type:        []string{"string"},

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Wed Jun 05 18:37:07 UTC 2024

- 3M bytes

- Viewed (0)

Search Options