utils

Documentation

Index

• Variables
• type BuilderUtils
  • func (builderInterface *BuilderUtils) GetBuilders(ponPool ponpool.PonRegistrySubgraph, db database.DatabaseInterface)
  • func (builderInterface *BuilderUtils) SetBuilderStatus(builder string, status string) error
• type GetHeaderResponse
• type GetPayloadUtils
• type ProposerHeaderResponse
• type ProposerUpdates
• type ProposerUtils
  • func (proposer *ProposerUtils) GetValidators(ponPool ponpool.PonRegistrySubgraph, db database.DatabaseInterface)
  • func (proposerInterface *ProposerUtils) SetValidatorStatus(validator string, status string) error
  • func (proposer *ProposerUtils) ValidatorIndex(proposers []string)
• type PublicKey
  • func (p *PublicKey) FromSlice(x []byte) error
  • func (p PublicKey) String() string
  • func (p *PublicKey) UnmarshalText(input []byte) error
• type RelayUtils
  • func NewRelayUtils(db *database.DatabaseInterface, beaconClient *beaconclient.MultiBeaconClient, ...) *RelayUtils
  • func (relay *RelayUtils) BuilderStatus(builder string) (BuilderStatus bool, err error)
  • func (relay *RelayUtils) BuilderUpdate()
  • func (relay *RelayUtils) ProposerUpdate()
  • func (relay *RelayUtils) ReporterUpdate()
  • func (relayUtils *RelayUtils) StartUtils() (err error)
  • func (relay *RelayUtils) ValidatorIndexToPubkey(index uint64, network uint64) (PublicKey, error)
• type ReporterUtils
  • func (reporterInterface *ReporterUtils) GetReporters(ponPool ponpool.PonRegistrySubgraph, db database.DatabaseInterface)
  • func (reporterInterface *ReporterUtils) SetReporterStatus(reporter string, status bool) error

Variables

var EpochDuration = 12 * 32 * time.Second

Types

type BuilderUtils

type BuilderUtils struct {
	BuilderLast    map[string]string
	Mu             sync.Mutex
	Log            logrus.Entry
	RedisInterface *redisPackage.RedisInterface
}

func (*BuilderUtils) GetBuilders

func (builderInterface *BuilderUtils) GetBuilders(ponPool ponpool.PonRegistrySubgraph, db database.DatabaseInterface)

func (*BuilderUtils) SetBuilderStatus

func (builderInterface *BuilderUtils) SetBuilderStatus(builder string, status string) error

type GetHeaderResponse

type GetHeaderResponse struct {
	Version string                       `json:"version"`
	Data    *capellaAPI.SignedBuilderBid `json:"data"`
}

type GetPayloadUtils

type GetPayloadUtils struct {
	Version              string
	Data                 *capella.ExecutionPayloadHeader
	API                  string
	BuilderWalletAddress string
}

type ProposerHeaderResponse

type ProposerHeaderResponse struct {
	Slot              uint64
	ProposerPubKeyHex string
	Bid               GetHeaderResponse
}

type ProposerUpdates

type ProposerUpdates struct {
	ValidatorsLast map[string]string
	Mu             sync.Mutex
}

type ProposerUtils

type ProposerUtils struct {
	Log            logrus.Entry
	RedisInterface *redisPackage.RedisInterface
	BeaconClient   *beaconclient.MultiBeaconClient
	Validators     relayTypes.ValidatorIndexes
	ProposerStatus ProposerUpdates
}

func (*ProposerUtils) GetValidators

func (proposer *ProposerUtils) GetValidators(ponPool ponpool.PonRegistrySubgraph, db database.DatabaseInterface)

func (*ProposerUtils) SetValidatorStatus

func (proposerInterface *ProposerUtils) SetValidatorStatus(validator string, status string) error

func (*ProposerUtils) ValidatorIndex

func (proposer *ProposerUtils) ValidatorIndex(proposers []string)

type PublicKey

type PublicKey [48]byte

func (*PublicKey) FromSlice

func (p *PublicKey) FromSlice(x []byte) error

func (PublicKey) String

func (p PublicKey) String() string

func (*PublicKey) UnmarshalText

func (p *PublicKey) UnmarshalText(input []byte) error

type RelayUtils

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

func NewRelayUtils

func NewRelayUtils(db *database.DatabaseInterface, beaconClient *beaconclient.MultiBeaconClient, ponPool ponpool.PonRegistrySubgraph, redisInterface redisPackage.RedisInterface) *RelayUtils

func (*RelayUtils) BuilderStatus

func (relay *RelayUtils) BuilderStatus(builder string) (BuilderStatus bool, err error)

func (*RelayUtils) BuilderUpdate

func (relay *RelayUtils) BuilderUpdate()

func (*RelayUtils) ProposerUpdate

func (relay *RelayUtils) ProposerUpdate()

func (*RelayUtils) ReporterUpdate

func (relay *RelayUtils) ReporterUpdate()

func (*RelayUtils) StartUtils

func (relayUtils *RelayUtils) StartUtils() (err error)

func (*RelayUtils) ValidatorIndexToPubkey

func (relay *RelayUtils) ValidatorIndexToPubkey(index uint64, network uint64) (PublicKey, error)

type ReporterUtils

type ReporterUtils struct {
	ReporterLast   map[string]bool
	Mu             sync.Mutex
	Log            logrus.Entry
	RedisInterface *redisPackage.RedisInterface
}

func (*ReporterUtils) GetReporters

func (reporterInterface *ReporterUtils) GetReporters(ponPool ponpool.PonRegistrySubgraph, db database.DatabaseInterface)

func (*ReporterUtils) SetReporterStatus

func (reporterInterface *ReporterUtils) SetReporterStatus(reporter string, status bool) error