client

Documentation

Index

• type GRPCClient
  • func Dial(ctx context.Context, rawurl string, grpcRetryDelay time.Duration, ...) (*GRPCClient, error)
  • func (vanClient *GRPCClient) CanonicalHeadSlot() (types.Slot, error)
  • func (ec *GRPCClient) Close()
  • func (vanClient *GRPCClient) NextEpochProposerList() (*ethpb.ValidatorAssignments, error)
  • func (vanClient *GRPCClient) StreamNewPendingBlocks() (stream ethpb.BeaconChain_StreamNewPendingBlocksClient, err error)
• type VanguardClient

Types

type GRPCClient

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

GRPCClient

func Dial

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

Dial connects a client to the given URL.

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) NextEpochProposerList

func (vanClient *GRPCClient) NextEpochProposerList() (*ethpb.ValidatorAssignments, error)

NextEpochProposerList

func (*GRPCClient) StreamNewPendingBlocks

func (vanClient *GRPCClient) StreamNewPendingBlocks() (
	stream ethpb.BeaconChain_StreamNewPendingBlocksClient,
	err error,
)

StreamNewPendingBlocks

type VanguardClient

type VanguardClient interface {
	CanonicalHeadSlot() (types.Slot, error)
	NextEpochProposerList() (*ethpb.ValidatorAssignments, error)
	StreamNewPendingBlocks() (ethpb.BeaconChain_StreamNewPendingBlocksClient, error)
	Close()
}