chainsync

Documentation

Index

• type ChainsyncClientState
• type State
  • func NewState(eventBus *event.EventBus, ledgerState *state.LedgerState) *State
  • func (s *State) AddClient(connId connection.ConnectionId, intersectPoint ocommon.Point) (*ChainsyncClientState, error)
  • func (s *State) GetClientConnId() *ouroboros.ConnectionId
  • func (s *State) RemoveClient(connId connection.ConnectionId)
  • func (s *State) RemoveClientConnId(connId ouroboros.ConnectionId)
  • func (s *State) SetClientConnId(connId ouroboros.ConnectionId)

Types

type ChainsyncClientState

type ChainsyncClientState struct {
	Cursor               ocommon.Point
	ChainIter            *state.ChainIterator
	NeedsInitialRollback bool
}

type State

type State struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewState

func NewState(
	eventBus *event.EventBus,
	ledgerState *state.LedgerState,
) *State

func (*State) AddClient

func (s *State) AddClient(
	connId connection.ConnectionId,
	intersectPoint ocommon.Point,
) (*ChainsyncClientState, error)

func (*State) GetClientConnId

func (s *State) GetClientConnId() *ouroboros.ConnectionId

TODO: replace with handling of multiple chainsync clients

func (*State) RemoveClient

func (s *State) RemoveClient(connId connection.ConnectionId)

func (*State) RemoveClientConnId

func (s *State) RemoveClientConnId(connId ouroboros.ConnectionId)

TODO: replace with handling of multiple chainsync clients

func (*State) SetClientConnId

func (s *State) SetClientConnId(connId ouroboros.ConnectionId)

TODO: replace with handling of multiple chainsync clients