beaconclient

package
v0.8.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 21, 2022 License: AGPL-3.0 Imports: 13 Imported by: 2

Documentation

Overview

Package beaconclient provides a beacon-node client

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrBeaconNodeSyncing      = errors.New("beacon node is syncing or unavailable")
	ErrBeaconNodesUnavailable = errors.New("all beacon nodes responded with error")
)
View Source 
var ErrHTTPErrorResponse = errors.New("got an HTTP error response")

Functions

This section is empty.

Types

type AllValidatorsResponse 

type AllValidatorsResponse struct {
	Data []ValidatorResponseEntry
}

type GetBlockResponse 

type GetBlockResponse struct {
	Data struct {
		Message struct {
			Slot uint64 `json:"slot,string"`
			Body struct {
				ExecutionPayload types.ExecutionPayload `json:"execution_payload"`
			}
		}
	}
}

type GetHeaderResponse 

type GetHeaderResponse struct {
	Data struct {
		Root   string `json:"root"`
		Header struct {
			Message *GetHeaderResponseMessage
		}
	}
}

type GetHeaderResponseMessage 

type GetHeaderResponseMessage struct {
	Slot          uint64 `json:"slot,string"`
	ProposerIndex uint64 `json:"proposer_index,string"`
	ParentRoot    string `json:"parent_root"`
}

type HeadEventData 

type HeadEventData struct {
	Slot  uint64 `json:"slot,string"`
	Block string `json:"block"`
	State string `json:"state"`
}

HeadEventData represents the data of a head event {"slot":"827256","block":"0x56b683afa68170c775f3c9debc18a6a72caea9055584d037333a6fe43c8ceb83","state":"0x419e2965320d69c4213782dae73941de802a4f436408fddd6f68b671b3ff4e55","epoch_transition":false,"execution_optimistic":false,"previous_duty_dependent_root":"0x5b81a526839b7fb67c3896f1125451755088fb578ad27c2690b3209f3d7c6b54","current_duty_dependent_root":"0x5f3232c0d5741e27e13754e1d88285c603b07dd6164b35ca57e94344a9e42942"}

type IBeaconInstance added in v0.5.1 

type IBeaconInstance interface {
	SyncStatus() (*SyncStatusPayloadData, error)
	CurrentSlot() (uint64, error)
	SubscribeToHeadEvents(slotC chan HeadEventData)
	FetchValidators(headSlot uint64) (map[types.PubkeyHex]ValidatorResponseEntry, error)
	GetProposerDuties(epoch uint64) (*ProposerDutiesResponse, error)
	GetURI() string
	PublishBlock(block *types.SignedBeaconBlock) (code int, err error)
}

IBeaconInstance is the interface for a single beacon client instance

type IMultiBeaconClient added in v0.5.1 

type IMultiBeaconClient interface {
	BestSyncStatus() (*SyncStatusPayloadData, error)
	SubscribeToHeadEvents(slotC chan HeadEventData)
	FetchValidators(headSlot uint64) (map[types.PubkeyHex]ValidatorResponseEntry, error)
	GetProposerDuties(epoch uint64) (*ProposerDutiesResponse, error)
	PublishBlock(block *types.SignedBeaconBlock) (code int, err error)
}

IMultiBeaconClient is the interface for the MultiBeaconClient, which can manage several beacon client instances under the hood

type MockBeaconInstance added in v0.5.1 

type MockBeaconInstance struct {
	MockSyncStatus         *SyncStatusPayloadData
	MockSyncStatusErr      error
	MockProposerDuties     *ProposerDutiesResponse
	MockProposerDutiesErr  error
	MockFetchValidatorsErr error

	ResponseDelay time.Duration
	// contains filtered or unexported fields
}

func NewMockBeaconInstance added in v0.5.1 

func NewMockBeaconInstance() *MockBeaconInstance

func (*MockBeaconInstance) AddValidator added in v0.5.1 

func (c *MockBeaconInstance) AddValidator(entry ValidatorResponseEntry)

func (*MockBeaconInstance) CurrentSlot added in v0.5.1 

func (c *MockBeaconInstance) CurrentSlot() (uint64, error)

func (*MockBeaconInstance) FetchValidators added in v0.5.1 

func (c *MockBeaconInstance) FetchValidators(headSlot uint64) (map[types.PubkeyHex]ValidatorResponseEntry, error)

func (*MockBeaconInstance) GetProposerDuties added in v0.5.1 

func (c *MockBeaconInstance) GetProposerDuties(epoch uint64) (*ProposerDutiesResponse, error)

func (*MockBeaconInstance) GetURI added in v0.5.1 

func (c *MockBeaconInstance) GetURI() string

func (*MockBeaconInstance) IsValidator added in v0.5.1 

func (c *MockBeaconInstance) IsValidator(pubkey types.PubkeyHex) bool

func (*MockBeaconInstance) NumValidators added in v0.5.1 

func (c *MockBeaconInstance) NumValidators() uint64

func (*MockBeaconInstance) PublishBlock added in v0.6.0 

func (c *MockBeaconInstance) PublishBlock(block *types.SignedBeaconBlock) (code int, err error)

func (*MockBeaconInstance) SetValidators added in v0.5.1 

func (c *MockBeaconInstance) SetValidators(validatorSet map[types.PubkeyHex]ValidatorResponseEntry)

func (*MockBeaconInstance) SubscribeToHeadEvents added in v0.5.1 

func (c *MockBeaconInstance) SubscribeToHeadEvents(slotC chan HeadEventData)

func (*MockBeaconInstance) SyncStatus added in v0.5.1 

func (c *MockBeaconInstance) SyncStatus() (*SyncStatusPayloadData, error)

type MultiBeaconClient added in v0.5.1 

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

func NewMultiBeaconClient added in v0.5.1 

func NewMultiBeaconClient(log *logrus.Entry, beaconInstances []IBeaconInstance) *MultiBeaconClient

func (*MultiBeaconClient) BestSyncStatus added in v0.5.1 

func (c *MultiBeaconClient) BestSyncStatus() (*SyncStatusPayloadData, error)

func (*MultiBeaconClient) FetchValidators added in v0.5.1 

func (c *MultiBeaconClient) FetchValidators(headSlot uint64) (map[types.PubkeyHex]ValidatorResponseEntry, error)

func (*MultiBeaconClient) GetProposerDuties added in v0.5.1 

func (c *MultiBeaconClient) GetProposerDuties(epoch uint64) (*ProposerDutiesResponse, error)

func (*MultiBeaconClient) PublishBlock added in v0.6.0 

func (c *MultiBeaconClient) PublishBlock(block *types.SignedBeaconBlock) (code int, err error)

PublishBlock publishes the signed beacon block via https://ethereum.github.io/beacon-APIs/#/ValidatorRequiredApi/publishBlock

func (*MultiBeaconClient) SubscribeToHeadEvents added in v0.5.1 

func (c *MultiBeaconClient) SubscribeToHeadEvents(slotC chan HeadEventData)

SubscribeToHeadEvents subscribes to head events from all beacon nodes. A single head event will be received multiple times, likely once for every beacon nodes.

type ProdBeaconInstance added in v0.5.1 

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

func NewProdBeaconInstance added in v0.5.1 

func NewProdBeaconInstance(log *logrus.Entry, beaconURI string) *ProdBeaconInstance

func (*ProdBeaconInstance) CurrentSlot added in v0.5.1 

func (c *ProdBeaconInstance) CurrentSlot() (uint64, error)

func (*ProdBeaconInstance) FetchValidators added in v0.5.1 

func (c *ProdBeaconInstance) FetchValidators(headSlot uint64) (map[types.PubkeyHex]ValidatorResponseEntry, error)

func (*ProdBeaconInstance) GetBlock added in v0.5.1 

func (c *ProdBeaconInstance) GetBlock() (*GetBlockResponse, error)

GetBlock returns the latest block - https://ethereum.github.io/beacon-APIs/#/Beacon/getBlockV2

func (*ProdBeaconInstance) GetHeader added in v0.5.1 

func (c *ProdBeaconInstance) GetHeader() (*GetHeaderResponse, error)

GetHeader returns the latest header - https://ethereum.github.io/beacon-APIs/#/Beacon/getBlockHeader

func (*ProdBeaconInstance) GetProposerDuties added in v0.5.1 

func (c *ProdBeaconInstance) GetProposerDuties(epoch uint64) (*ProposerDutiesResponse, error)

GetProposerDuties returns proposer duties for every slot in this epoch https://ethereum.github.io/beacon-APIs/#/Validator/getProposerDuties

func (*ProdBeaconInstance) GetURI added in v0.5.1 

func (c *ProdBeaconInstance) GetURI() string

func (*ProdBeaconInstance) PublishBlock added in v0.6.0 

func (c *ProdBeaconInstance) PublishBlock(block *types.SignedBeaconBlock) (code int, err error)

func (*ProdBeaconInstance) SubscribeToHeadEvents added in v0.5.1 

func (c *ProdBeaconInstance) SubscribeToHeadEvents(slotC chan HeadEventData)

func (*ProdBeaconInstance) SyncStatus added in v0.5.1 

func (c *ProdBeaconInstance) SyncStatus() (*SyncStatusPayloadData, error)

SyncStatus returns the current node sync-status https://ethereum.github.io/beacon-APIs/#/ValidatorRequiredApi/getSyncingStatus

type ProposerDutiesResponse 

type ProposerDutiesResponse struct {
	Data []ProposerDutiesResponseData
}

type ProposerDutiesResponseData 

type ProposerDutiesResponseData struct {
	Pubkey string `json:"pubkey"`
	Slot   uint64 `json:"slot,string"`
}

type SyncStatusPayload 

type SyncStatusPayload struct {
	Data SyncStatusPayloadData
}

SyncStatusPayload is the response payload for /eth/v1/node/syncing {"data":{"head_slot":"251114","sync_distance":"0","is_syncing":false,"is_optimistic":false}}

type SyncStatusPayloadData 

type SyncStatusPayloadData struct {
	HeadSlot  uint64 `json:"head_slot,string"`
	IsSyncing bool   `json:"is_syncing"`
}

type ValidatorResponseEntry 

type ValidatorResponseEntry struct {
	Index     uint64                         `json:"index,string"` // Index of validator in validator registry.
	Balance   string                         `json:"balance"`      // Current validator balance in gwei.
	Status    string                         `json:"status"`
	Validator ValidatorResponseValidatorData `json:"validator"`
}

type ValidatorResponseValidatorData 

type ValidatorResponseValidatorData struct {
	Pubkey string `json:"pubkey"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.