Versions in this module Expand all Collapse all v0 v0.1.1 Oct 8, 2024 v0.1.0 Oct 8, 2024 Changes in this version + type Batch struct + MaxDurationMs int + MaxElements int + func (b *Batch) Clone() *Batch + func (b *Batch) MaxDuration() time.Duration + type Config struct + Batch *Batch + Concurrency int + FastMapSize int + ID string + LoadDelayEveryNExec int + LoadDelayMaxMs int + LoadDelayOnlyOnce bool + LoadDelaySeedPart int + Loader *config.Config + MaxMessageSize int + Retry *Retry + Stream *tconfig.Stream + StreamDisabled bool + UseFastMap bool + func NewConfigFromURL(ctx context.Context, URL string) (*Config, error) + func (c *Config) Clone() *Config + func (c *Config) IsStreamEnabled() bool + func (c *Config) Validate() error + type Retry struct + EveryInSec int + Max int + func (r Retry) Clone() *Retry
Go to main page