chainsync

package

v0.13.0 Latest Latest Go to latest Published: Jul 21, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

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

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

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

TODO: replace with handling of multiple chainsync clients (#385)

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

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

TODO: replace with handling of multiple chainsync clients (#385)

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

TODO: replace with handling of multiple chainsync clients (#385)