chainsync

Documentation

Index

• Constants
• Variables
• type ChainSync
  • func New(m *muxer.Muxer, errorChan chan error, nodeToNode bool, ...) *ChainSync
  • func (c *ChainSync) FindIntersect(points []interface{}) error
  • func (c *ChainSync) NewMsgFromCbor(msgType uint, data []byte) (protocol.Message, error)
  • func (c *ChainSync) RequestNext() error
• type ChainSyncAwaitReplyFunc
• type ChainSyncCallbackConfig
• type ChainSyncDoneFunc
• type ChainSyncIntersectFoundFunc
• type ChainSyncIntersectNotFoundFunc
• type ChainSyncRollBackwardFunc
• type ChainSyncRollForwardFunc

Constants

const (
	PROTOCOL_NAME          = "chain-sync"
	PROTOCOL_ID_NTN uint16 = 2
	PROTOCOL_ID_NTC uint16 = 5
)

const (
	MESSAGE_TYPE_REQUEST_NEXT        = 0
	MESSAGE_TYPE_AWAIT_REPLY         = 1
	MESSAGE_TYPE_ROLL_FORWARD        = 2
	MESSAGE_TYPE_ROLL_BACKWARD       = 3
	MESSAGE_TYPE_FIND_INTERSECT      = 4
	MESSAGE_TYPE_INTERSECT_FOUND     = 5
	MESSAGE_TYPE_INTERSECT_NOT_FOUND = 6
	MESSAGE_TYPE_DONE                = 7
)

Variables

var (
	STATE_IDLE       = protocol.NewState(1, "Idle")
	STATE_CAN_AWAIT  = protocol.NewState(2, "CanAwait")
	STATE_MUST_REPLY = protocol.NewState(3, "MustReply")
	STATE_INTERSECT  = protocol.NewState(4, "Intersect")
	STATE_DONE       = protocol.NewState(5, "Done")
)

Types

type ChainSync

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

func New

func New(m *muxer.Muxer, errorChan chan error, nodeToNode bool, callbackConfig *ChainSyncCallbackConfig) *ChainSync

func (*ChainSync) FindIntersect

func (c *ChainSync) FindIntersect(points []interface{}) error

func (*ChainSync) NewMsgFromCbor

func (c *ChainSync) NewMsgFromCbor(msgType uint, data []byte) (protocol.Message, error)

func (*ChainSync) RequestNext

func (c *ChainSync) RequestNext() error

type ChainSyncAwaitReplyFunc

type ChainSyncAwaitReplyFunc func() error

Callback function types

type ChainSyncCallbackConfig

type ChainSyncCallbackConfig struct {
	AwaitReplyFunc        ChainSyncAwaitReplyFunc
	RollBackwardFunc      ChainSyncRollBackwardFunc
	RollForwardFunc       ChainSyncRollForwardFunc
	IntersectFoundFunc    ChainSyncIntersectFoundFunc
	IntersectNotFoundFunc ChainSyncIntersectNotFoundFunc
	DoneFunc              ChainSyncDoneFunc
}

type ChainSyncDoneFunc

type ChainSyncDoneFunc func() error

type ChainSyncIntersectFoundFunc

type ChainSyncIntersectFoundFunc func(interface{}, interface{}) error

type ChainSyncIntersectNotFoundFunc

type ChainSyncIntersectNotFoundFunc func(interface{}) error

type ChainSyncRollBackwardFunc

type ChainSyncRollBackwardFunc func(interface{}, interface{}) error

type ChainSyncRollForwardFunc

type ChainSyncRollForwardFunc func(uint, interface{}) error