state

Documentation

Index

• func InitState(stateHolder **State, statePath string, incomingCh <-chan *Indices, ...)
• type Indices
• type State
  • func (s *State) DoProcessIncoming(cidx int64, midx int64) bool
  • func (s *State) LastCreateIndex() int64
  • func (s *State) LastLockIndex() int64
  • func (s *State) LastModifyIndex() int64

Functions

func InitState

func InitState(stateHolder **State, statePath string, incomingCh <-chan *Indices, errch chan<- error, doneCh chan<- struct{})

Types

type Indices

type Indices struct {
	CreateIndex int64
	ModifyIndex int64
	LockIndex   int64
}

type State

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

func (*State) DoProcessIncoming

func (s *State) DoProcessIncoming(cidx int64, midx int64) bool

func (*State) LastCreateIndex

func (s *State) LastCreateIndex() int64

func (*State) LastLockIndex

func (s *State) LastLockIndex() int64

func (*State) LastModifyIndex

func (s *State) LastModifyIndex() int64