api

Documentation

Index

• Constants
• Variables
• func ParseHeaderRequest(r *http.Request) structs.HeaderRequest
• type API
  • func NewApi(l log.Logger, r Relay, reg Registrations, st State, lim RateLimitter) (a *API)
  • func (api *API) AttachMetrics(m *metrics.Metrics)
  • func (a *API) AttachToHandler(m *http.ServeMux)
• type APIMetrics
• type Limitter
  • func NewLimitter(ratel int, burst int, ab map[[48]byte]struct{}) *Limitter
  • func (l *Limitter) Allow(ctx context.Context, pubkey [48]byte) error
• type RateLimitter
• type Registrations
• type Relay
• type State

Constants

const (
	// proposer endpoints
	PathStatus            = "/eth/v1/builder/status"
	PathRegisterValidator = "/eth/v1/builder/validators"
	PathGetHeader         = "/eth/v1/builder/header/{slot:[0-9]+}/{parent_hash:0x[a-fA-F0-9]+}/{pubkey:0x[a-fA-F0-9]+}"
	PathGetPayload        = "/eth/v1/builder/blinded_blocks"

	// builder endpoints
	PathGetValidators = "/relay/v1/builder/validators"
	PathSubmitBlock   = "/relay/v1/builder/blocks"

	// data api
	PathBuilderBlocksReceived     = "/relay/v1/data/bidtraces/builder_blocks_received"
	PathProposerPayloadsDelivered = "/relay/v1/data/bidtraces/proposer_payload_delivered"
	PathSpecificRegistration      = "/relay/v1/data/validator_registration"
)

Router paths

const (
	DataLimit = 450
)

const LimitterCacheSize = 100

Variables

var (
	ErrParamNotFound = errors.New("not found")
)

var ErrTooManyCalls = errors.New("too many calls")

Functions

func ParseHeaderRequest

func ParseHeaderRequest(r *http.Request) structs.HeaderRequest

Types

type API

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

func NewApi

func NewApi(l log.Logger, r Relay, reg Registrations, st State, lim RateLimitter) (a *API)

func (*API) AttachMetrics

func (api *API) AttachMetrics(m *metrics.Metrics)

func (*API) AttachToHandler

func (a *API) AttachToHandler(m *http.ServeMux)

type APIMetrics

type APIMetrics struct {
	ApiReqCounter *prometheus.CounterVec
	ApiReqTiming  *prometheus.HistogramVec
	ApiReqElCount *prometheus.HistogramVec

	RelayTiming *prometheus.HistogramVec
}

type Limitter

type Limitter struct {
	AllowedBuilders map[[48]byte]struct{}

	RateLimit rate.Limit
	Burst     int
	// contains filtered or unexported fields
}

func NewLimitter

func NewLimitter(ratel int, burst int, ab map[[48]byte]struct{}) *Limitter

func (*Limitter) Allow

func (l *Limitter) Allow(ctx context.Context, pubkey [48]byte) error

type RateLimitter

type RateLimitter interface {
	Allow(ctx context.Context, pubkey [48]byte) error
}

type Registrations

type Registrations interface {
	// Proposer APIs (builder spec https://github.com/ethereum/builder-specs)
	RegisterValidator(context.Context, *structs.MetricGroup, []types.SignedValidatorRegistration) error
	// Data APIs
	Registration(context.Context, types.PublicKey) (types.SignedValidatorRegistration, error)
	// Builder APIs (relay spec https://flashbots.notion.site/Relay-API-Spec-5fb0819366954962bc02e81cb33840f5)
	GetValidators(*structs.MetricGroup) structs.BuilderGetValidatorsResponseEntrySlice
}

type Relay

type Relay interface {
	// Proposer APIs (builder spec https://github.com/ethereum/builder-specs)
	GetHeader(context.Context, *structs.MetricGroup, structs.HeaderRequest) (structs.GetHeaderResponse, error)
	GetPayload(context.Context, *structs.MetricGroup, structs.SignedBlindedBeaconBlock) (structs.GetPayloadResponse, error)

	// Builder APIs (relay spec https://flashbots.notion.site/Relay-API-Spec-5fb0819366954962bc02e81cb33840f5)
	SubmitBlock(context.Context, *structs.MetricGroup, structs.SubmitBlockRequest) error

	// Data APIs
	GetPayloadDelivered(context.Context, structs.PayloadTraceQuery) ([]structs.BidTraceExtended, error)
	GetBlockReceived(context.Context, structs.HeaderTraceQuery) ([]structs.BidTraceWithTimestamp, error)
}

type State

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