rpc

Documentation

Index

• type BeaconClient
  • func NewBeaconClient(endpoint string, assignmentsCacheSize int) (*BeaconClient, error)
  • func (bc *BeaconClient) AddCachedEpochAssignments(epoch uint64, epochAssignments *rpctypes.EpochAssignments)
  • func (bc *BeaconClient) GetBlobSidecarsByBlockroot(blockroot []byte) (*rpctypes.StandardV1BlobSidecarsResponse, error)
  • func (bc *BeaconClient) GetBlockBodyByBlockroot(blockroot []byte) (*rpctypes.StandardV2BeaconBlockResponse, error)
  • func (bc *BeaconClient) GetBlockHeaderByBlockroot(blockroot []byte) (*rpctypes.StandardV1BeaconHeaderResponse, error)
  • func (bc *BeaconClient) GetBlockHeaderBySlot(slot uint64) (*rpctypes.StandardV1BeaconHeaderResponse, error)
  • func (bc *BeaconClient) GetEpochAssignments(epoch uint64) (*rpctypes.EpochAssignments, error)
  • func (bc *BeaconClient) GetFinalizedBlockHead() (*rpctypes.StandardV1BeaconHeaderResponse, error)
  • func (bc *BeaconClient) GetGenesis() (*rpctypes.StandardV1GenesisResponse, error)
  • func (bc *BeaconClient) GetLatestBlockHead() (*rpctypes.StandardV1BeaconHeaderResponse, error)
  • func (bc *BeaconClient) GetProposerDuties(epoch uint64) (*rpctypes.StandardV1ProposerDutiesResponse, error)
  • func (bc *BeaconClient) GetStateValidators(stateroot []byte) (*rpctypes.StandardV1StateValidatorsResponse, error)
  • func (bc *BeaconClient) NewBlockStream() *BeaconStream
• type BeaconStream
  • func (bs *BeaconStream) Close()
  • func (bs *BeaconStream) Start()

Types

type BeaconClient

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

func NewBeaconClient

func NewBeaconClient(endpoint string, assignmentsCacheSize int) (*BeaconClient, error)

NewBeaconClient is used to create a new beacon client

func (*BeaconClient) AddCachedEpochAssignments

func (bc *BeaconClient) AddCachedEpochAssignments(epoch uint64, epochAssignments *rpctypes.EpochAssignments)

func (*BeaconClient) GetBlobSidecarsByBlockroot

func (bc *BeaconClient) GetBlobSidecarsByBlockroot(blockroot []byte) (*rpctypes.StandardV1BlobSidecarsResponse, error)

func (*BeaconClient) GetBlockBodyByBlockroot

func (bc *BeaconClient) GetBlockBodyByBlockroot(blockroot []byte) (*rpctypes.StandardV2BeaconBlockResponse, error)

func (*BeaconClient) GetBlockHeaderByBlockroot

func (bc *BeaconClient) GetBlockHeaderByBlockroot(blockroot []byte) (*rpctypes.StandardV1BeaconHeaderResponse, error)

func (*BeaconClient) GetBlockHeaderBySlot

func (bc *BeaconClient) GetBlockHeaderBySlot(slot uint64) (*rpctypes.StandardV1BeaconHeaderResponse, error)

func (*BeaconClient) GetEpochAssignments

func (bc *BeaconClient) GetEpochAssignments(epoch uint64) (*rpctypes.EpochAssignments, error)

func (*BeaconClient) GetFinalizedBlockHead

func (bc *BeaconClient) GetFinalizedBlockHead() (*rpctypes.StandardV1BeaconHeaderResponse, error)

func (*BeaconClient) GetGenesis

func (bc *BeaconClient) GetGenesis() (*rpctypes.StandardV1GenesisResponse, error)

func (*BeaconClient) GetLatestBlockHead

func (bc *BeaconClient) GetLatestBlockHead() (*rpctypes.StandardV1BeaconHeaderResponse, error)

func (*BeaconClient) GetProposerDuties

func (bc *BeaconClient) GetProposerDuties(epoch uint64) (*rpctypes.StandardV1ProposerDutiesResponse, error)

func (*BeaconClient) GetStateValidators

func (bc *BeaconClient) GetStateValidators(stateroot []byte) (*rpctypes.StandardV1StateValidatorsResponse, error)

func (*BeaconClient) NewBlockStream

func (bc *BeaconClient) NewBlockStream() *BeaconStream

type BeaconStream

type BeaconStream struct {
	CloseChan chan bool
	BlockChan chan *rpctypes.StandardV1StreamedBlockEvent
	HeadChan  chan *rpctypes.StandardV1StreamedHeadEvent
	// contains filtered or unexported fields
}

func (*BeaconStream) Close

func (bs *BeaconStream) Close()

func (*BeaconStream) Start

func (bs *BeaconStream) Start()