shipper

Documentation

Index

• type Config
  • func (cfg *Config) SetDefaults()
• type Shipper
  • func New(ctx context.Context, logger *zerolog.Logger, cfg *Config, natsCli *nats.Conn, ...) (*Shipper, error)
  • func (s *Shipper) Shutdown()

Types

type Config

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"`
}

func (*Config) SetDefaults

func (cfg *Config) SetDefaults()

type Shipper

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

func New

func New(ctx context.Context, logger *zerolog.Logger, cfg *Config, natsCli *nats.Conn, scf scribe.ClientFactory) (*Shipper, error)

func (*Shipper) Shutdown

func (s *Shipper) Shutdown()