client

Documentation

Index

• type GRPCClient
  • func (vanClient *GRPCClient) CanonicalHeadSlot() (types.Slot, error)
  • func (ec *GRPCClient) Close()
  • func (vanClient *GRPCClient) StreamMinimalConsensusInfo(epoch uint64) (stream ethpb.BeaconChain_StreamMinimalConsensusInfoClient, err error)
  • func (vanClient *GRPCClient) StreamNewPendingBlocks(blockRoot []byte, fromSlot types.Slot) (stream ethpb.BeaconChain_StreamNewPendingBlocksClient, err error)
• type VanguardClient
  • func Dial(ctx context.Context, rawurl string, grpcRetryDelay time.Duration, ...) (VanguardClient, error)

Types

type GRPCClient

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

GRPCClient

func (*GRPCClient) CanonicalHeadSlot

func (vanClient *GRPCClient) CanonicalHeadSlot() (types.Slot, error)

CanonicalHeadSlot returns the slot of canonical block currently found in the beacon chain via RPC.

func (*GRPCClient) Close

func (ec *GRPCClient) Close()

Close

func (*GRPCClient) StreamMinimalConsensusInfo

func (vanClient *GRPCClient) StreamMinimalConsensusInfo(epoch uint64) (
	stream ethpb.BeaconChain_StreamMinimalConsensusInfoClient,
	err error,
)

func (*GRPCClient) StreamNewPendingBlocks

func (vanClient *GRPCClient) StreamNewPendingBlocks(blockRoot []byte, fromSlot types.Slot) (
	stream ethpb.BeaconChain_StreamNewPendingBlocksClient,
	err error,
)

StreamNewPendingBlocks

type VanguardClient

type VanguardClient interface {
	CanonicalHeadSlot() (types.Slot, error)
	StreamNewPendingBlocks(blockRoot []byte, fromSlot types.Slot) (ethpb.BeaconChain_StreamNewPendingBlocksClient, error)
	StreamMinimalConsensusInfo(epoch uint64) (stream ethpb.BeaconChain_StreamMinimalConsensusInfoClient, err error)
	Close()
}

func Dial

func Dial(ctx context.Context, rawurl string, grpcRetryDelay time.Duration,
	grpcRetries uint, maxCallRecvMsgSize int) (VanguardClient, error)

Dial connects a client to the given URL.