leader

Documentation

Index

• type ElectionConfig
  • func NewDefaultElectionConfig(namespace, name string, cfg *rest.Config) *ElectionConfig
  • func NewElectionConfig(ttl time.Duration, namespace, name, lockType string, cfg *rest.Config) *ElectionConfig
  • func (ec *ElectionConfig) Run(ctx context.Context, id string, onLeader OnLeader, onSwitchLeader OnNewLeader) error
• type OnLeader
• type OnNewLeader

Types

type ElectionConfig

type ElectionConfig struct {
	TTL                               time.Duration
	Name, Namespace, ResourceLockType string
	// contains filtered or unexported fields
}

func NewDefaultElectionConfig

func NewDefaultElectionConfig(namespace, name string, cfg *rest.Config) *ElectionConfig

func NewElectionConfig

func NewElectionConfig(ttl time.Duration, namespace, name, lockType string, cfg *rest.Config) *ElectionConfig

func (*ElectionConfig) Run

func (ec *ElectionConfig) Run(ctx context.Context, id string, onLeader OnLeader, onSwitchLeader OnNewLeader) error

type OnLeader

type OnLeader func(context.Context) error

type OnNewLeader

type OnNewLeader func(string)