Documentation
¶
Index ¶
- func JsonifySignedVoluntaryExits(voluntaryExits []*ethpb.SignedVoluntaryExit) []*structs.SignedVoluntaryExit
- func NewBeaconApiChainClientWithFallback(jsonRestHandler RestHandler, fallbackClient iface.ChainClient) iface.ChainClient
- func NewBeaconApiValidatorClient(jsonRestHandler RestHandler, opts ...ValidatorClientOpt) iface.ValidatorClient
- func NewNodeClientWithFallback(jsonRestHandler RestHandler, fallbackClient iface.NodeClient) iface.NodeClient
- func NewPrysmChainClient(jsonRestHandler RestHandler, nodeClient iface.NodeClient) iface.PrysmChainClient
- type BeaconApiRestHandler
- func (c *BeaconApiRestHandler) Get(ctx context.Context, endpoint string, resp any) error
- func (c *BeaconApiRestHandler) GetSSZ(ctx context.Context, endpoint string) ([]byte, http.Header, error)
- func (c *BeaconApiRestHandler) Host() string
- func (c *BeaconApiRestHandler) HttpClient() *http.Client
- func (c *BeaconApiRestHandler) Post(ctx context.Context, apiEndpoint string, headers map[string]string, ...) error
- func (c *BeaconApiRestHandler) PostSSZ(ctx context.Context, apiEndpoint string, headers map[string]string, ...) ([]byte, http.Header, error)
- func (c *BeaconApiRestHandler) SetHost(host string)
- type BeaconBlockConverter
- type DoppelGangerInfo
- type GenesisProvider
- type IndexNotFoundError
- type RestHandler
- type StateValidatorsProvider
- type ValidatorClientOpt
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func JsonifySignedVoluntaryExits ¶
func JsonifySignedVoluntaryExits(voluntaryExits []*ethpb.SignedVoluntaryExit) []*structs.SignedVoluntaryExit
JsonifySignedVoluntaryExits converts an array of voluntary exit structs to a JSON hex string compatible format.
func NewBeaconApiChainClientWithFallback ¶
func NewBeaconApiChainClientWithFallback(jsonRestHandler RestHandler, fallbackClient iface.ChainClient) iface.ChainClient
func NewBeaconApiValidatorClient ¶
func NewBeaconApiValidatorClient(jsonRestHandler RestHandler, opts ...ValidatorClientOpt) iface.ValidatorClient
func NewNodeClientWithFallback ¶
func NewNodeClientWithFallback(jsonRestHandler RestHandler, fallbackClient iface.NodeClient) iface.NodeClient
func NewPrysmChainClient ¶
func NewPrysmChainClient(jsonRestHandler RestHandler, nodeClient iface.NodeClient) iface.PrysmChainClient
NewPrysmChainClient returns implementation of iface.PrysmChainClient.
Types ¶
type BeaconApiRestHandler ¶
type BeaconApiRestHandler struct {
// contains filtered or unexported fields
}
func (*BeaconApiRestHandler) Get ¶
Get sends a GET request and decodes the response body as a JSON object into the passed in object. If an HTTP error is returned, the body is decoded as a DefaultJsonError JSON object and returned as the first return value.
func (*BeaconApiRestHandler) Host ¶
func (c *BeaconApiRestHandler) Host() string
Host returns the underlying HTTP host
func (*BeaconApiRestHandler) HttpClient ¶
func (c *BeaconApiRestHandler) HttpClient() *http.Client
HttpClient returns the underlying HTTP client of the handler
func (*BeaconApiRestHandler) Post ¶
func (c *BeaconApiRestHandler) Post( ctx context.Context, apiEndpoint string, headers map[string]string, data *bytes.Buffer, resp any, ) error
Post sends a POST request and decodes the response body as a JSON object into the passed in object. If an HTTP error is returned, the body is decoded as a DefaultJsonError JSON object and returned as the first return value.
func (*BeaconApiRestHandler) PostSSZ ¶
func (c *BeaconApiRestHandler) PostSSZ( ctx context.Context, apiEndpoint string, headers map[string]string, data *bytes.Buffer, ) ([]byte, http.Header, error)
PostSSZ sends a POST request and prefers an SSZ (application/octet-stream) response body.
func (*BeaconApiRestHandler) SetHost ¶
func (c *BeaconApiRestHandler) SetHost(host string)
type BeaconBlockConverter ¶
type BeaconBlockConverter interface {
ConvertRESTPhase0BlockToProto(block *structs.BeaconBlock) (*ethpb.BeaconBlock, error)
ConvertRESTAltairBlockToProto(block *structs.BeaconBlockAltair) (*ethpb.BeaconBlockAltair, error)
ConvertRESTBellatrixBlockToProto(block *structs.BeaconBlockBellatrix) (*ethpb.BeaconBlockBellatrix, error)
ConvertRESTCapellaBlockToProto(block *structs.BeaconBlockCapella) (*ethpb.BeaconBlockCapella, error)
}
type DoppelGangerInfo ¶
type DoppelGangerInfo struct {
// contains filtered or unexported fields
}
type GenesisProvider ¶
type IndexNotFoundError ¶
type IndexNotFoundError struct {
// contains filtered or unexported fields
}
IndexNotFoundError represents an error scenario where no validator index matches a pubkey.
func NewIndexNotFoundError ¶
func NewIndexNotFoundError(pubkey string) IndexNotFoundError
NewIndexNotFoundError creates a new error instance.
func (*IndexNotFoundError) Error ¶
func (e *IndexNotFoundError) Error() string
Error returns the underlying error message.
type RestHandler ¶
type RestHandler interface {
Get(ctx context.Context, endpoint string, resp any) error
GetSSZ(ctx context.Context, endpoint string) ([]byte, http.Header, error)
Post(ctx context.Context, endpoint string, headers map[string]string, data *bytes.Buffer, resp any) error
PostSSZ(ctx context.Context, endpoint string, headers map[string]string, data *bytes.Buffer) ([]byte, http.Header, error)
HttpClient() *http.Client
Host() string
SetHost(host string)
}
func NewBeaconApiRestHandler ¶
func NewBeaconApiRestHandler(client http.Client, host string) RestHandler
NewBeaconApiRestHandler returns a RestHandler
type StateValidatorsProvider ¶
type StateValidatorsProvider interface {
StateValidators(context.Context, []string, []primitives.ValidatorIndex, []string) (*structs.GetValidatorsResponse, error)
StateValidatorsForSlot(context.Context, primitives.Slot, []string, []primitives.ValidatorIndex, []string) (*structs.GetValidatorsResponse, error)
StateValidatorsForHead(context.Context, []string, []primitives.ValidatorIndex, []string) (*structs.GetValidatorsResponse, error)
}
type ValidatorClientOpt ¶
type ValidatorClientOpt func(*beaconApiValidatorClient)
Source Files
¶
- attestation_data.go
- beacon_api_beacon_chain_client.go
- beacon_api_helpers.go
- beacon_api_node_client.go
- beacon_api_validator_client.go
- beacon_block_converter.go
- beacon_block_json_helpers.go
- beacon_block_proto_helpers.go
- beacon_committee_selections.go
- domain_data.go
- doppelganger.go
- duties.go
- genesis.go
- get_beacon_block.go
- index.go
- log.go
- metrics.go
- prepare_beacon_proposer.go
- propose_attestation.go
- propose_beacon_block.go
- propose_exit.go
- prysm_beacon_chain_client.go
- registration.go
- rest_handler_client.go
- state_validators.go
- status.go
- stream_blocks.go
- submit_aggregate_selection_proof.go
- submit_signed_aggregate_proof.go
- submit_signed_contribution_and_proof.go
- subscribe_committee_subnets.go
- sync_committee.go
- sync_committee_selections.go
Directories
¶
| Path | Synopsis |
|---|---|
|
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
Click to show internal directories.
Click to hide internal directories.