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)
ReduceFn(ctx context.Context, datumStreamCh <-chan *reducepb.ReduceRequest) (<-chan *reducepb.ReduceResponse, <-chan error)
}
Client contains methods to call a gRPC client.
func NewFromClient ¶
func NewFromClient(c reducepb.ReduceClient) (Client, error)
Source Files
Click to show internal directories.
Click to hide internal directories.