scribe

Aug 1, 2023

Changes in this version

+ var ErrAck = errors.New("ack wait must be > 0")

+ var ErrAckTimeout = errors.New("timed out waiting for acknowldgement")

+ type AckWaitSeconds int

+ type Client struct

+ func NewClient(ctx context.Context, conn grpc.ClientConnInterface, opts ...ClientOpt) (*Client, error)

+ func (c *Client) WriteBatch(ctx context.Context, batch []*anypb.Any, cb ClientBatchFunc) error

+ type ClientBatchFunc func(ack bool, err error)

+ type ClientFactory func() (*Client, error)

+ func NewClientFactory(ctx context.Context, cfg *Config, dop client.DialOptionsProvider) ClientFactory

+ type ClientOpt interface

+ type Config struct

+ AckWaitSeconds int

+ DisableTLS bool

+ MaxInflightBatches int