leaderelection

Documentation

Index

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

Constants

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"
)

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 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

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.