client

Documentation

Index

• Variables
• type DiscoveryClient
  • func NewDiscoveryClient(logger hclog.Logger, metrics Metrics, clt proto.DiscoveryClient, ...) DiscoveryClient
• type GrpcClientCloser
• type IdentityClient
  • func NewIdentityClient(logger hclog.Logger, metrics Metrics, clt proto.IdentityClient, ...) IdentityClient
• type Metrics
  • func NewMetrics() Metrics
  • func NilMetrics() Metrics
• type SyncerV1Client
  • func NewSyncerV1Client(logger hclog.Logger, metrics Metrics, clt proto.V1Client, ...) SyncerV1Client

Variables

var (
	ErrClientClosed = errors.New("client is closed")
)

Types

type DiscoveryClient

type DiscoveryClient interface {
	GrpcClientCloser

	FindPeers(ctx context.Context, in *proto.FindPeersReq) (*proto.FindPeersResp, error)
}

func NewDiscoveryClient

func NewDiscoveryClient(
	logger hclog.Logger,
	metrics Metrics,
	clt proto.DiscoveryClient,
	conn *rawGrpc.ClientConn,
) DiscoveryClient

type GrpcClientCloser

type GrpcClientCloser interface {
	io.Closer

	IsClose() bool
}

type IdentityClient

type IdentityClient interface {
	GrpcClientCloser

	Hello(ctx context.Context, in *proto.Status) (*proto.Status, error)
}

func NewIdentityClient

func NewIdentityClient(
	logger hclog.Logger,
	metrics Metrics,
	clt proto.IdentityClient,
	conn *rawGrpc.ClientConn,
) IdentityClient

type Metrics

type Metrics interface {
	// contains filtered or unexported methods
}

Metrics represents the grpc client metrics

func NewMetrics

func NewMetrics() Metrics

func NilMetrics

func NilMetrics() Metrics

type SyncerV1Client

type SyncerV1Client interface {
	GrpcClientCloser

	GetCurrent(ctx context.Context, in *emptypb.Empty) (*proto.V1Status, error)
	GetObjectsByHash(ctx context.Context, in *proto.HashRequest) (*proto.Response, error)
	GetHeaders(ctx context.Context, in *proto.GetHeadersRequest) (*proto.Response, error)

	Notify(ctx context.Context, in *proto.NotifyReq) (*emptypb.Empty, error)
	// Returns blocks from begin to end (which is determined by server)
	GetBlocks(ctx context.Context, in *proto.GetBlocksRequest) (*proto.GetBlocksResponse, error)
	// Returns server's status
	GetStatus(ctx context.Context, in *emptypb.Empty) (*proto.SyncPeerStatus, error)
}

func NewSyncerV1Client

func NewSyncerV1Client(
	logger hclog.Logger,
	metrics Metrics,
	clt proto.V1Client,
	conn *rawGrpc.ClientConn,
) SyncerV1Client