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) (*reducepb.ReduceResponse, error)
}
Client contains methods to call a gRPC client.
func NewFromClient ¶
func NewFromClient(c reducepb.ReduceClient) (Client, error)
type Option ¶
type Option func(*options)
Option is the interface to apply options.
func WithMaxMessageSize ¶
WithMaxMessageSize sets the server max receive message size and the server max send message size to the given size.
func WithServerInfoFilePath ¶
WithServerInfoFilePath sets the server info file path to the given path.
func WithServerInfoReadinessTimeout ¶
WithServerInfoReadinessTimeout sets the server info readiness timeout to the given timeout.
func WithTcpSockAddr ¶
WithTcpSockAddr start the client with the given TCP sock addr. This is mainly used for testing purpose.
func WithUdsSockAddr ¶
WithUdsSockAddr start the client with the given UDS sock addr. This is mainly used for testing purpose.
Source Files
Click to show internal directories.
Click to hide internal directories.