leaderelection

Documentation

Index

• type Callbacks
• type Config
• type KubernetesDriver
  • func NewKubernetesDriver(conf Config, clientset *kubernetes.Clientset) *KubernetesDriver
  • func (d *KubernetesDriver) Register(ctx context.Context, key string, callbacks Callbacks)
• type RedisDriver
  • func NewRedisDriver(conf Config, rdb redis.UniversalClient) *RedisDriver
  • func (d *RedisDriver) Register(ctx context.Context, key string, callbacks Callbacks)
• type Service
  • func New(connPool *supervisor.ConnPool) Service

Types

type Callbacks

type Callbacks struct {
	OnStartedLeading func(ctx context.Context)
	OnStoppedLeading func()
}

type Config

type Config struct {
	Identity      string
	LeaseDuration time.Duration
	RenewRate     time.Duration
	RetryRate     time.Duration
}

type KubernetesDriver

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

func NewKubernetesDriver

func NewKubernetesDriver(conf Config, clientset *kubernetes.Clientset) *KubernetesDriver

func (*KubernetesDriver) Register

func (d *KubernetesDriver) Register(ctx context.Context, key string, callbacks Callbacks)

type RedisDriver

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

func NewRedisDriver

func NewRedisDriver(conf Config, rdb redis.UniversalClient) *RedisDriver

func (*RedisDriver) Register

func (d *RedisDriver) Register(ctx context.Context, key string, callbacks Callbacks)

type Service

type Service interface {
	Register(ctx context.Context, key string, callbacks Callbacks)
}

func New

func New(connPool *supervisor.ConnPool) Service