proposerstate

Documentation

Index

• type State
  • func (t *State) Marshal(wire io.Writer)
  • func (t *State) New() fastrpc.Serializable
  • func (t *State) Unmarshal(wire io.Reader) error
• type Stateiser
  • func StateiserNew(replica *genericsmr.Replica, proposer proposer.Proposer, freq time.Duration) Stateiser
  • func (state *Stateiser) BcastCurrentState()
  • func (state *Stateiser) BeginTimer()
  • func (state *Stateiser) GetCurrentInstance() int32
  • func (state *Stateiser) HandleState(stateMsg *State, proposer proposer.Proposer)
  • func (state *Stateiser) SetCurrentInstance(inst int32)

Types

type State

type State struct {
	ProposerID      int32
	CurrentInstance int32
}

func (*State) Marshal

func (t *State) Marshal(wire io.Writer)

func (*State) New

func (t *State) New() fastrpc.Serializable

func (*State) Unmarshal

func (t *State) Unmarshal(wire io.Reader) error

type Stateiser

type Stateiser struct {
	Recv chan fastrpc.Serializable

	*genericsmr.Replica

	proposer.Proposer
	T *time.Timer
	// contains filtered or unexported fields
}

func StateiserNew

func StateiserNew(replica *genericsmr.Replica, proposer proposer.Proposer, freq time.Duration) Stateiser

func (*Stateiser) BcastCurrentState

func (state *Stateiser) BcastCurrentState()

func (*Stateiser) BeginTimer

func (state *Stateiser) BeginTimer()

func (*Stateiser) GetCurrentInstance

func (state *Stateiser) GetCurrentInstance() int32

func (*Stateiser) HandleState

func (state *Stateiser) HandleState(stateMsg *State, proposer proposer.Proposer)

func (*Stateiser) SetCurrentInstance

func (state *Stateiser) SetCurrentInstance(inst int32)