stream

Documentation

Index

• Constants
• type BellatrixHeaderWithSlot
  • func (b BellatrixHeaderWithSlot) Header() structs.ExecutionPayloadHeader
  • func (b BellatrixHeaderWithSlot) Slot() uint64
• type CapellaHeaderWithSlot
  • func (b CapellaHeaderWithSlot) Header() structs.ExecutionPayloadHeader
  • func (b CapellaHeaderWithSlot) Slot() uint64
• type Client
  • func NewClient(l log.Logger, m *metrics.Metrics, s State, bids, cache PubSub, ...) *Client
  • func (s *Client) BlockCache() <-chan structs.BlockAndTraceExtended
  • func (s *Client) BuilderBid() <-chan structs.BuilderBidExtended
  • func (c *Client) Close() error
  • func (s *Client) PublishBlockCache(ctx context.Context, block structs.BlockAndTraceExtended) error
  • func (s *Client) PublishBuilderBid(ctx context.Context, bid structs.BuilderBidExtended) error
  • func (s *Client) PublishSlotDelivered(ctx context.Context, slot structs.Slot) error
• type EncoderSSZ
• type HeaderWithSlot
• type Metrics
• type PubSub
• type State

Constants

const (
	CacheTopic         = "/block/cache"
	BidTopic           = "/block/bid"
	SlotDeliveredTopic = "/slot/delivered"
)

Types

type BellatrixHeaderWithSlot

type BellatrixHeaderWithSlot struct {
	ExecutionPayloadHeader bellatrix.ExecutionPayloadHeader
	HeaderSlot             uint64
}

func (BellatrixHeaderWithSlot) Header

func (b BellatrixHeaderWithSlot) Header() structs.ExecutionPayloadHeader

func (BellatrixHeaderWithSlot) Slot

func (b BellatrixHeaderWithSlot) Slot() uint64

type CapellaHeaderWithSlot

type CapellaHeaderWithSlot struct {
	ExecutionPayloadHeader capella.ExecutionPayloadHeader
	HeaderSlot             uint64
}

func (CapellaHeaderWithSlot) Header

func (b CapellaHeaderWithSlot) Header() structs.ExecutionPayloadHeader

func (CapellaHeaderWithSlot) Slot

func (b CapellaHeaderWithSlot) Slot() uint64

type Client

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

	Metrics Metrics
	// contains filtered or unexported fields
}

func NewClient

func NewClient(l log.Logger, m *metrics.Metrics, s State, bids, cache PubSub, cfg *config.DistributedConfig) *Client

func (*Client) BlockCache

func (s *Client) BlockCache() <-chan structs.BlockAndTraceExtended

func (*Client) BuilderBid

func (s *Client) BuilderBid() <-chan structs.BuilderBidExtended

func (*Client) Close

func (c *Client) Close() error

func (*Client) PublishBlockCache

func (s *Client) PublishBlockCache(ctx context.Context, block structs.BlockAndTraceExtended) error

func (*Client) PublishBuilderBid

func (s *Client) PublishBuilderBid(ctx context.Context, bid structs.BuilderBidExtended) error

func (*Client) PublishSlotDelivered

func (s *Client) PublishSlotDelivered(ctx context.Context, slot structs.Slot) error

type EncoderSSZ

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

type HeaderWithSlot

type HeaderWithSlot struct {
	ExecutionPayloadHeader structs.ExecutionPayloadHeader
	HeaderSlot             uint64
}

type Metrics

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

type PubSub

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

type State

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