chainsync

Documentation

Index

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

Constants

const (
	PROTOCOL_ID_NTN uint16 = 2
	PROTOCOL_ID_NTC uint16 = 5

	STATE_IDLE = iota
	STATE_CAN_AWAIT
	STATE_MUST_REPLY
	STATE_INTERSECT
	STATE_DONE
)

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
)

Types

type ChainSync

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

TODO: add locking around outbound calls

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) RequestNext

func (c *ChainSync) RequestNext() error

type ChainSyncAwaitReplyFunc

type ChainSyncAwaitReplyFunc func() error

TODO: flesh out func args 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() error

type ChainSyncRollBackwardFunc

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

type ChainSyncRollForwardFunc

type ChainSyncRollForwardFunc func(uint, interface{}) error