stream

type BellatrixHeaderWithSlot struct {
	ExecutionPayloadHeader bellatrix.ExecutionPayloadHeader
	HeaderSlot             uint64
}

type CapellaHeaderWithSlot struct {
	ExecutionPayloadHeader capella.ExecutionPayloadHeader
	HeaderSlot             uint64
}

type Client struct {
	Logger                log.Logger
	Bids, Cache           PubSub
	QueueSize, NumWorkers int

	Metrics Metrics
	// contains filtered or unexported fields
}

type EncoderSSZ interface {
	MarshalSSZ() ([]byte, error)
}

type HeaderWithSlot struct {
	ExecutionPayloadHeader structs.ExecutionPayloadHeader
	HeaderSlot             uint64
}

type Metrics interface {
	Register(prometheus.Collector) error
}

type PubSub interface {
	String() string
	Publish(context.Context, transport.Message) error
	Subscribe(context.Context) transport.Subscription
}

type State interface {
	ForkVersion(epoch structs.Slot) structs.ForkVersion
	HeadSlot() structs.Slot
}