leader

Documentation

Index

• func RunOrDie(ctx context.Context, namespace, name string, client kubernetes.Interface, ...)
• type Callback
• type Manager
  • func NewManager(namespace, name string, k8s kubernetes.Interface) *Manager
  • func (m *Manager) OnLeader(f func(ctx context.Context) error)
  • func (m *Manager) Start(ctx context.Context)

Functions

func RunOrDie

func RunOrDie(ctx context.Context, namespace, name string, client kubernetes.Interface, cb Callback)

Types

type Callback

type Callback func(cb context.Context)

type Manager

type Manager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewManager

func NewManager(namespace, name string, k8s kubernetes.Interface) *Manager

func (*Manager) OnLeader

func (m *Manager) OnLeader(f func(ctx context.Context) error)

OnLeader this function will be called when leadership is acquired.

func (*Manager) Start

func (m *Manager) Start(ctx context.Context)