scribe

type AckWaitSeconds int

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

type ClientBatchFunc func(ack bool, err error)

type ClientFactory func() (*Client, error)

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

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"`
	DisableTLS         bool `json:"disable_tls"`
}