k8s

Documentation

Index

• type K8s
  • func New(config *config.Config) (k *K8s, err error)
  • func (k *K8s) RunLeaderElection(ctx context.Context, identity string, name string, ...) (err error)
• type K8sLeaderCallbacks
• type NewLeaderFunc
• type StartLeadingFunc
• type StopLeadingFunc

Types

type K8s

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

func New

func New(config *config.Config) (k *K8s, err error)

func (*K8s) RunLeaderElection

func (k *K8s) RunLeaderElection(ctx context.Context, identity string, name string, callbacks K8sLeaderCallbacks) (err error)

type K8sLeaderCallbacks

type K8sLeaderCallbacks struct {
	OnStartedLeading StartLeadingFunc
	OnStoppedLeading StopLeadingFunc
	OnNewLeader      NewLeaderFunc
}

type NewLeaderFunc

type NewLeaderFunc func(string)

type StartLeadingFunc

type StartLeadingFunc func(context.Context)

type StopLeadingFunc

type StopLeadingFunc func()