client

Aug 2, 2023

Changes in this version

+ func New(inputOptions ...Option) (*client, error)

+ type Client interface

+ CloseConn func(ctx context.Context) error

+ IsReady func(ctx context.Context, in *emptypb.Empty) (bool, error)

+ SinkFn func(ctx context.Context, datumList []*sinkpb.DatumRequest) ([]*sinkpb.Response, error)

+ type Option func(*options)

+ func WithMaxMessageSize(size int) Option

+ func WithServerInfoFilePath(f string) Option

+ func WithServerInfoReadinessTimeout(t time.Duration) Option

+ func WithSockAddr(addr string) Option