Documentation
¶
Index ¶
- func IsLeader() bool
- func Start(ctx context.Context, cfg *Config, nodeID string, client *kubernetes.Clientset) error
- func StartWithCallbacks(ctx context.Context, cfg *Config, nodeID string, client *kubernetes.Clientset, ...) error
- func TurnOffKlog()
- type Config
- type EmptyLogger
- func (e *EmptyLogger) Enabled() bool
- func (e *EmptyLogger) Error(err error, msg string, keysAndValues ...interface{})
- func (e *EmptyLogger) Info(msg string, keysAndValues ...interface{})
- func (e *EmptyLogger) V(level int) logr.Logger
- func (e *EmptyLogger) WithName(name string) logr.Logger
- func (e *EmptyLogger) WithValues(keysAndValues ...interface{}) logr.Logger
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsLeader ¶
func IsLeader() bool
IsLeader returns if leading currently is reporting being the leader
func Start ¶
Start with default callback implementation which is a basic atomic store/load int32
Use when only set/unset leader is needed Caller is responsible for calling cancel on context to release lease
func StartWithCallbacks ¶
func StartWithCallbacks(ctx context.Context, cfg *Config, nodeID string, client *kubernetes.Clientset, startFn *func(context.Context), stopFn *func(), newFn *func(string)) error
StartWithCallbacks with user defined callbacks for set/unset Caller is responsible for calling cancel on context to release lease
Types ¶
type Config ¶
type Config struct { LeaseDuration int `json:"lease_duration"` RenewDeadline int `json:"renew_deadline"` RetryPeriod int `json:"retry_period"` Lock string `json:"lock"` Namespace string `json:"namespace"` }
Config type with input to elector
type EmptyLogger ¶
type EmptyLogger struct{}
EmptyLogger implements logr.Logging
func (*EmptyLogger) Error ¶
func (e *EmptyLogger) Error(err error, msg string, keysAndValues ...interface{})
Error does nothing
func (*EmptyLogger) Info ¶
func (e *EmptyLogger) Info(msg string, keysAndValues ...interface{})
Info does nothing
func (*EmptyLogger) WithName ¶
func (e *EmptyLogger) WithName(name string) logr.Logger
WithName returns itself
func (*EmptyLogger) WithValues ¶
func (e *EmptyLogger) WithValues(keysAndValues ...interface{}) logr.Logger
WithValues returns itself
Click to show internal directories.
Click to hide internal directories.