grpc

Documentation

Index

• type PortCaller
  • func NewPortCaller(stop <-chan struct{}, cc *grpc.ClientConn) *PortCaller
  • func (caller *PortCaller) DownloadStream(ctx context.Context, stream chan<- *proto.Payload) error
  • func (caller *PortCaller) UploadStream(ctx context.Context, stream <-chan *proto.Payload) error

Types

type PortCaller

type PortCaller struct {
	proto.StorageClient
	// contains filtered or unexported fields
}

PortCaller is an RPC service caller.

func NewPortCaller

func NewPortCaller(stop <-chan struct{}, cc *grpc.ClientConn) *PortCaller

NewPortCaller returns a new caller for RPC service.

func (*PortCaller) DownloadStream

func (caller *PortCaller) DownloadStream(ctx context.Context, stream chan<- *proto.Payload) error

DownloadStream calls streaming RPC to fetch the data.

func (*PortCaller) UploadStream

func (caller *PortCaller) UploadStream(ctx context.Context, stream <-chan *proto.Payload) error

UploadStream calls streaming RPC to upload the data.