client

Documentation

Index

• type P2PClient
  • func NewP2PClient(address string) (*P2PClient, error)
  • func (p *P2PClient) Close() error
  • func (p *P2PClient) GetApproval(ctx context.Context, object *storagetypes.ObjectInfo, expected int64, ...) (map[string]*p2ptypes.GetApprovalResponse, ...)

Types

type P2PClient

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

P2PClient is a p2p server gRPC service client wrapper

func NewP2PClient

func NewP2PClient(address string) (*P2PClient, error)

NewP2PClient return a P2PClient instance

func (*P2PClient) Close

func (p *P2PClient) Close() error

Close the p2p server gPRC connection

func (*P2PClient) GetApproval

func (p *P2PClient) GetApproval(ctx context.Context, object *storagetypes.ObjectInfo, expected int64, timeout int64, opts ...grpc.CallOption) (
	map[string]*p2ptypes.GetApprovalResponse, map[string]*p2ptypes.GetApprovalResponse, error)

GetApproval asks the approval to other SP.