client

package

v1.2.5 Latest Latest Go to latest Published: Jun 20, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dogechain-lab/dogechain

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

View Source

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

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL