leader

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 StandaloneLeaderController struct {
	// contains filtered or unexported fields
}