consensus

package

v0.0.1 Latest Latest Go to latest Published: Oct 31, 2018 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ConsEngine struct {
	M *MsgMapper
	// contains filtered or unexported fields
}

ConsEngine Consensus engine

func NewConsEngine() *ConsEngine

NewConsEngine New a consensus engine

func (c *ConsEngine) Add2Engine(msg *nats.Msg) error

Add2Engine Add a message to consensus engine

func (c *ConsEngine) SetSequence(s int64)

func (c *ConsEngine) StartEngine(from, to string) error

type Ferry struct {
}

Ferry Comsumer tx message and handle(consensus, broadcast...) it.

type MsgMapper struct {
	MsgMap map[int64]map[string]string
	// contains filtered or unexported fields
}

func (m *MsgMapper) AddMsgToMap(event types.Event, f *Ferry) (sequence int64, err error)