Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Client ¶
type Client interface {
CloseConn(ctx context.Context) error
IsReady(ctx context.Context, in *emptypb.Empty) (bool, error)
RetrieveSideInput(ctx context.Context, in *emptypb.Empty) (*sideinputpb.SideInputResponse, error)
}
Client contains methods to call a gRPC client for side input.
func NewFromClient ¶
func NewFromClient(c sideinputpb.SideInputClient) (Client, error)
NewFromClient creates a new client object from a grpc client. This is used for testing.
type Option ¶
type Option func(*options)
Option is the interface to apply options.
func WithMaxMessageSize ¶
WithMaxMessageSize sets the max message size to the given size.
func WithSideInputTimeout ¶
WithSideInputTimeout sets the side input timeout to the given timeout.
func WithSockAddr ¶
WithSockAddr start the client with the given sock addr. This is mainly used for testing purpose.
Source Files
Click to show internal directories.
Click to hide internal directories.