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)
SinkFn(ctx context.Context, datumList []*sinkpb.SinkRequest) (*sinkpb.SinkResponse, error)
}
Client contains methods to call a gRPC client.
func NewFromClient ¶
func NewFromClient(c sinkpb.SinkClient) (Client, error)
NewFromClient creates a new client object from a grpc client, which is useful 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 WithServerInfoFilePath ¶
WithServerInfoFilePath start the client with the given server info file path. This is mainly used for testing purpose.
func WithServerInfoReadinessTimeout ¶
WithServerInfoReadinessTimeout sets the server info readiness 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.