scribe

Documentation

Index

• Variables
• type AckWaitSeconds
• type Client
  • func NewClient(ctx context.Context, conn *grpc.ClientConn, opts ...ClientOpt) (*Client, error)
  • func (c *Client) WriteBatch(ctx context.Context, batch []*anypb.Any, cb ClientBatchFunc) error
• type ClientBatchFunc
• type ClientFactory
  • func NewClientFactory(ctx context.Context, cfg *Config, dopts ...grpc.DialOption) (ClientFactory, error)
• type ClientOpt
• type Config

Variables

var (
	ErrAck        = errors.New("ack wait must be > 0")
	ErrAckTimeout = errors.New("timed out waiting for acknowledgement")
)

Types

type AckWaitSeconds

type AckWaitSeconds int

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

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

func (*Client) WriteBatch

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

type ClientBatchFunc

type ClientBatchFunc func(ack bool, err error)

type ClientFactory

type ClientFactory func() (*Client, error)

func NewClientFactory

func NewClientFactory(ctx context.Context, cfg *Config, dopts ...grpc.DialOption) (ClientFactory, error)

type ClientOpt

type ClientOpt interface {
	// contains filtered or unexported methods
}

type Config

type Config struct {
	client.Config `json:",squash"` // nolint:staticcheck // squash is used by mapstructure

	MaxInflightBatches int `json:"max_inflight_batches"`
	AckWaitSeconds     int `json:"ack_wait_seconds"`
	// Deprecated: use NoTLS instead
	DisableTLS bool `json:"disable_tls"`
}