chainsync

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

type ClientAddedEvent struct {
	ConnId       ouroboros.ConnectionId
	TotalClients int
}

type ClientRemoveRequestedEvent struct {
	ConnId  ouroboros.ConnectionId
	ConnKey string
	Reason  string
}

type ClientRemovedEvent struct {
	ConnId       ouroboros.ConnectionId
	TotalClients int
	WasPrimary   bool
}

type ClientStalledEvent struct {
	ConnId ouroboros.ConnectionId
	Slot   uint64
}

type ClientStatus int

type ClientSyncedEvent struct {
	ConnId ouroboros.ConnectionId
	Slot   uint64
}

type Config struct {
	MaxClients   int
	StallTimeout time.Duration
}

type ForkDetectedEvent struct {
	Slot    uint64
	HashA   []byte
	HashB   []byte
	ConnIdA ouroboros.ConnectionId
	ConnIdB ouroboros.ConnectionId
	Point   ocommon.Point
}

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

type TrackedClient struct {
	ConnId ouroboros.ConnectionId
	Cursor ocommon.Point
	Tip    ochainsync.Tip
	Status ClientStatus
	// ObservabilityOnly marks connections that should keep
	// tip/activity metrics but must not consume the eligible
	// client pool or become active for ledger ingress.
	ObservabilityOnly bool
	LastActivity      time.Time
	HeadersRecv       uint64
	// TODO: BytesRecv needs to be wired to the underlying
	// connection's byte counter. Currently unused.
	BytesRecv uint64
}