relay

type Datastore interface {
	CheckSlotDelivered(context.Context, uint64) (bool, error)
	PutDelivered(context.Context, structs.Slot, structs.DeliveredTrace, time.Duration) error
	GetDelivered(context.Context, structs.PayloadQuery) (structs.BidTraceWithTimestamp, error)

	PutPayload(context.Context, structs.PayloadKey, *structs.BlockBidAndTrace, time.Duration) error
	GetPayload(context.Context, structs.PayloadKey) (*structs.BlockBidAndTrace, error)

	PutHeader(ctx context.Context, hd structs.HeaderData, ttl time.Duration) error
	GetMaxProfitHeader(ctx context.Context, slot uint64) (structs.HeaderAndTrace, error)

	PutRegistrationRaw(context.Context, structs.PubKey, []byte, time.Duration) error
	GetRegistration(context.Context, structs.PubKey) (types.SignedValidatorRegistration, error)
}

type FlowControl struct {
	RespCh chan Resp

	FailureCh chan struct{}
	ExitCh    chan error
	// contains filtered or unexported fields
}

type ProcessManager struct {
	LastRegTime map[string]uint64 // [pubkey]timestamp

	VerifySubmitBlockCh       chan VerifyReq
	VerifyRegisterValidatorCh chan VerifyReq
	VerifyOtherCh             chan VerifyReq

	StoreCh chan StoreReq
	// contains filtered or unexported fields
}

type ProcessManagerMetrics struct {
	VerifyTiming *prometheus.HistogramVec

	MapSize prometheus.Gauge

	RunningWorkers *prometheus.GaugeVec
}

type RegistrationManager interface {
	GetStoreChan() chan StoreReq
	GetVerifyChan(buffer uint) chan VerifyReq
	Set(k string, value uint64)
	Get(k string) (value uint64, ok bool)
}

type Relay struct {
	// contains filtered or unexported fields
}

type RelayConfig struct {
	BuilderSigningDomain  types.Domain
	ProposerSigningDomain types.Domain
	PubKey                types.PublicKey
	SecretKey             *bls.SecretKey

	// RegisterValidatorMaxNum is needed to set size of the buffer queue
	// describing the queue of results before it would be processed by registerSync
	RegisterValidatorMaxNum uint64
	TTL                     time.Duration
}

type RelayMetrics struct {
	Timing *prometheus.HistogramVec
}

type Resp struct {
	ID     int
	Type   int8
	Commit bool
	Err    error
}

type State interface {
	Beacon() *structs.BeaconState
}

type StoreReq struct {
	RawPayload json.RawMessage
	Pubkey     types.PublicKey
	ID         int
	Response   chan Resp
}

type TimestampRegistry interface {
	Get(pubkey string) (timestamp uint64, ok bool)
}

type VerifyReq struct {
	Signature [96]byte
	Pubkey    [48]byte
	Msg       [32]byte
	// Unique identifier of payload
	// if needed to be passed back in response
	ID       int
	Response chan Resp
}