shipper

type Config struct {
	MaxBytes              int64 `json:"max_bytes"`
	MaxBatchSize          int   `json:"max_batch_size"`
	PublishTimeoutSeconds int   `json:"publish_timeout_seconds"`
	MaxInflightBatches    int   `json:"max_inflight_batches"`
	AckWaitSeconds        int   `json:"ack_wait_seconds"`
	DeleteStreamOnDone    bool  `json:"delete_stream_on_done"`
	BackoffSeconds        []int `json:"backoff_seconds"`
}

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