leaderelection

type Config struct {
	// Mode specifies the leader election mode. Valid modes are "standalone" or "kubernetes".
	Mode Mode `validate:"required"`
	// LeaseLockName is the name of the Kubernetes Lock Object.
	LeaseLockName string
	// LeaseLockNamespace is the namespace of the Kubernetes Lock Object.
	LeaseLockNamespace string
	// LeaseDuration is how long the lease is held for.
	// Non-leaders must wait this long before trying to acquire the lease.
	LeaseDuration time.Duration
	// RenewDeadline is the duration that the acting leader will retry refreshing leadership before giving up.
	RenewDeadline time.Duration
	// RetryPeriod is the duration the LeaderElector clients should wait between tries of actions.
	RetryPeriod time.Duration
	// PodName is the name of the pod.
	PodName string
	// Connection details to the leader
	LeaderConnection client.ApiConnectionDetails
}

type KubernetesLeaderController struct {
	// contains filtered or unexported fields
}

type LeaderClientConnectionProvider interface {
	GetCurrentLeaderClientConnection() (bool, *grpc.ClientConn, error)
}

type LeaderConnectionProvider struct {
	// contains filtered or unexported fields
}

type LeaderController interface {
	// GetToken returns a LeaderToken which allows you to determine if you are leader or not
	GetToken() LeaderToken
	// ValidateToken allows a caller to determine whether a previously obtained token is still valid.
	// Returns true if the token is a leader and false otherwise
	ValidateToken(tok LeaderToken) bool
	// Run starts the controller.  This is a blocking call which will return when the provided context is cancelled
	Run(ctx *armadacontext.Context) error
	// GetLeaderReport returns a report about the current leader
	GetLeaderReport() LeaderReport
}

type LeaderReport struct {
	IsCurrentProcessLeader bool
	LeaderName             string
}

type LeaderStatusMetricsCollector struct {
	// contains filtered or unexported fields
}

type LeaderToken struct {
	// contains filtered or unexported fields
}

type LeaseListener interface {
	// contains filtered or unexported methods
}

type MetricsOptions struct {
	// MetricsPrefix is the prefix for Prometheus metrics.
	MetricsPrefix string
	// MarkLeadingInStandaloneMode specifies whether to mark the instance as leading in standalone mode.
	MarkLeadingInStandaloneMode bool
}

type Mode string

type StandaloneLeaderController struct {
	// contains filtered or unexported fields
}