leader

Documentation

Index

• type ConstElectionFactory
  • func (factory *ConstElectionFactory) NewElection(ctx context.Context, sequence int64) (Election, error)
• type Election
• type ElectionFactory
• type ElectionFactoryFunc
  • func (fun ElectionFactoryFunc) NewElection(ctx context.Context, sequence int64) (Election, error)
• type Elector
• type KeepLive
• type Leaders
  • func NewLeaders(partitions ...*Partition) *Leaders
  • func (pl *Leaders) AllPartitions() []PartitionID
  • func (pl *Leaders) SyncLeader(ctx context.Context, executor PartitionExecutor)
• type Member
  • func NewMember(elector Elector, electFactory ElectionFactory, option Option) *Member
  • func (mb *Member) CloseWithContext(ctx context.Context) error
  • func (mb *Member) DoAsLeader(ctx context.Context, do func(ctx context.Context)) bool
  • func (mb *Member) GetInfo() MemberInfo
  • func (mb *Member) Start() bool
  • func (mb *Member) SyncLeader(ctx context.Context, do func(ctx context.Context))
• type MemberInfo
• type MemoDecider
  • func NewMemoDecider() *MemoDecider
  • func (decider *MemoDecider) CreateElector() *MemoElector
• type MemoElector
  • func (elector *MemoElector) KeepLive(ctx context.Context, keepLive KeepLive) error
  • func (elector *MemoElector) PostElection(ctx context.Context, election Election) error
  • func (elector *MemoElector) WaitElectionNotify(ctx context.Context) (Election, error)
• type Middle
  • func NewRecorderMiddle(factory record.Factory) Middle
• type Option
• type Partition
  • func NewPartition(id PartitionID, member *Member, vars map[string]string) *Partition
  • func (part *Partition) GetValue(key string) string
  • func (part *Partition) ID() PartitionID
• type PartitionExecutor
• type PartitionID

Types

type ConstElectionFactory

type ConstElectionFactory struct {
	ConstID string
}

func (*ConstElectionFactory) NewElection

func (factory *ConstElectionFactory) NewElection(ctx context.Context, sequence int64) (Election, error)

type Election

type Election struct {
	Sequence int64
	ElectID  string
}

type ElectionFactory

type ElectionFactory interface {
	NewElection(ctx context.Context, sequence int64) (Election, error)
}

type ElectionFactoryFunc

type ElectionFactoryFunc func(ctx context.Context, sequence int64) (Election, error)

func (ElectionFactoryFunc) NewElection

func (fun ElectionFactoryFunc) NewElection(ctx context.Context, sequence int64) (Election, error)

type Elector

type Elector interface {
	PostElection(ctx context.Context, election Election) error
	KeepLive(ctx context.Context, keepLive KeepLive) error
	WaitElectionNotify(ctx context.Context) (Election, error)
}

type KeepLive

type KeepLive struct {
	Sequence int64
	ElectID  string
}

type Leaders

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

func NewLeaders

func NewLeaders(partitions ...*Partition) *Leaders

func (*Leaders) AllPartitions

func (pl *Leaders) AllPartitions() []PartitionID

func (*Leaders) SyncLeader

func (pl *Leaders) SyncLeader(ctx context.Context, executor PartitionExecutor)

type Member

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

func NewMember

func NewMember(elector Elector, electFactory ElectionFactory, option Option) *Member

func (*Member) CloseWithContext

func (mb *Member) CloseWithContext(ctx context.Context) error

func (*Member) DoAsLeader

func (mb *Member) DoAsLeader(ctx context.Context, do func(ctx context.Context)) bool

func (*Member) GetInfo

func (mb *Member) GetInfo() MemberInfo

func (*Member) Start

func (mb *Member) Start() bool

func (*Member) SyncLeader

func (mb *Member) SyncLeader(ctx context.Context, do func(ctx context.Context))

block and run do until leader, return if not leader

type MemberInfo

type MemberInfo struct {
	LeaderID   string
	IsLeader   bool
	ElectionID string
	Sequence   int64
}

type MemoDecider

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

func NewMemoDecider

func NewMemoDecider() *MemoDecider

func (*MemoDecider) CreateElector

func (decider *MemoDecider) CreateElector() *MemoElector

type MemoElector

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

func (*MemoElector) KeepLive

func (elector *MemoElector) KeepLive(ctx context.Context, keepLive KeepLive) error

func (*MemoElector) PostElection

func (elector *MemoElector) PostElection(ctx context.Context, election Election) error

func (*MemoElector) WaitElectionNotify

func (elector *MemoElector) WaitElectionNotify(ctx context.Context) (Election, error)

type Middle

type Middle interface {
	WrapElector(elector Elector) Elector
}

func NewRecorderMiddle

func NewRecorderMiddle(factory record.Factory) Middle

type Option

type Option struct {
	MaxElectDuration    time.Duration
	MinElectDuration    time.Duration
	MaxKeepLiveDuration time.Duration
	MinKeepLiveDuration time.Duration

	MaxExecDuration time.Duration
	MinExecDuration time.Duration
}

type Partition

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

func NewPartition

func NewPartition(id PartitionID, member *Member, vars map[string]string) *Partition

func (*Partition) GetValue

func (part *Partition) GetValue(key string) string

func (*Partition) ID

func (part *Partition) ID() PartitionID

type PartitionExecutor

type PartitionExecutor func(ctx context.Context, partition *Partition)

type PartitionID

type PartitionID int64