Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client interface {
CloseConn(ctx context.Context) error
IsReady(ctx context.Context, in *emptypb.Empty) (bool, error)
AccumulatorFn(ctx context.Context, datumStreamCh <-chan *accumlatorpb.AccumulatorRequest) (<-chan *accumlatorpb.AccumulatorResponse, <-chan error)
}
Client contains methods to call a gRPC client.
func New ¶
func New(ctx context.Context, serverInfo *serverinfo.ServerInfo, inputOptions ...sdkclient.Option) (Client, error)
New creates a new client object.
func NewFromClient ¶
func NewFromClient(ctx context.Context, c accumulatorpb.AccumulatorClient) (Client, error)
NewFromClient creates a new client object from a grpc client. This is used for testing.
Source Files
Click to show internal directories.
Click to hide internal directories.