elect

Documentation

Index

• type Elect
  • func NewElect(config *EtcdConfig, key string) (*Elect, error)
  • func (elect *Elect) Start(ctx context.Context)
  • func (elect *Elect) Stop()
  • func (elect *Elect) SubscribeWithAction(ctx context.Context, onWin, onLost func())
• type EtcdConfig
  • func NewEtcdConfigFromDBOptions(opts *options.DBOptions) (*EtcdConfig, error)

Types

type Elect

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

func NewElect

func NewElect(config *EtcdConfig, key string) (*Elect, error)

func (*Elect) Start

func (elect *Elect) Start(ctx context.Context)

func (*Elect) Stop

func (elect *Elect) Stop()

func (*Elect) SubscribeWithAction

func (elect *Elect) SubscribeWithAction(ctx context.Context, onWin, onLost func())

type EtcdConfig

type EtcdConfig struct {
	Endpoints []string
	Username  string
	Password  string
	TLS       *tls.Config

	LockTTL    int
	LockPrefix string
	// contains filtered or unexported fields
}

func NewEtcdConfigFromDBOptions

func NewEtcdConfigFromDBOptions(opts *options.DBOptions) (*EtcdConfig, error)