leaderelection

package

v0.9.1 Latest Latest Go to latest Published: Feb 4, 2021 License: Apache-2.0 Imports: 16 Imported by: 61

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kubernetes-csi/csi-lib-utils

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewLeaderElection(clientset kubernetes.Interface, lockName string, ...) *leaderElection
func NewLeaderElectionWithConfigMaps(clientset kubernetes.Interface, lockName string, ...) *leaderElection
func NewLeaderElectionWithEndpoints(clientset kubernetes.Interface, lockName string, ...) *leaderElection
func NewLeaderElectionWithLeases(clientset kubernetes.Interface, lockName string, ...) *leaderElection
type Server

Constants ¶

View Source

const (
	DefaultHealthCheckTimeout = 20 * time.Second

	// HealthCheckerAddress is the address at which the leader election health
	// checker reports status.
	// The caller sidecar should document this address in appropriate flag
	// descriptions.
	HealthCheckerAddress = "/healthz/leader-election"
)

Variables ¶

This section is empty.

Functions ¶

func NewLeaderElection ¶

func NewLeaderElection(clientset kubernetes.Interface, lockName string, runFunc func(ctx context.Context)) *leaderElection

NewLeaderElection returns the default & preferred leader election type

func NewLeaderElectionWithConfigMaps ¶

func NewLeaderElectionWithConfigMaps(clientset kubernetes.Interface, lockName string, runFunc func(ctx context.Context)) *leaderElection

NewLeaderElectionWithConfigMaps returns an implementation of leader election using ConfigMaps

func NewLeaderElectionWithEndpoints ¶

func NewLeaderElectionWithEndpoints(clientset kubernetes.Interface, lockName string, runFunc func(ctx context.Context)) *leaderElection

NewLeaderElectionWithEndpoints returns an implementation of leader election using Endpoints

func NewLeaderElectionWithLeases ¶

func NewLeaderElectionWithLeases(clientset kubernetes.Interface, lockName string, runFunc func(ctx context.Context)) *leaderElection

NewLeaderElectionWithLeases returns an implementation of leader election using Leases

Types ¶

type Server ¶ added in v0.9.0

type Server interface {
	Handle(pattern string, handler http.Handler)
}

Server represents any type that could serve HTTP requests for the leader election health check endpoint.

Source Files ¶

View all Source files

leader_election.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL