client

Dec 18, 2023

Changes in this version

type Client

+ PartitionsFn func(ctx context.Context, req *emptypb.Empty) (*sourcepb.PartitionsResponse, error)

Sep 6, 2023

Changes in this version

+ type Client interface

+ AckFn func(ctx context.Context, req *sourcepb.AckRequest) (*sourcepb.AckResponse, error)

+ CloseConn func(ctx context.Context) error

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

+ PendingFn func(ctx context.Context, req *emptypb.Empty) (*sourcepb.PendingResponse, error)

+ ReadFn func(ctx context.Context, req *sourcepb.ReadRequest, ...) error

+ func New(inputOptions ...Option) (Client, error)

+ func NewFromClient(c sourcepb.SourceClient) (Client, 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