config

Documentation

Index

• type Batch
  • func (b *Batch) Clone() *Batch
  • func (b *Batch) MaxDuration() time.Duration
• type Config
  • 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
  • func (r Retry) Clone() *Retry

Types

type Batch

type Batch struct {
	MaxElements int

	MaxDurationMs int
	// contains filtered or unexported fields
}

func (*Batch) Clone

func (b *Batch) Clone() *Batch

func (*Batch) MaxDuration

func (b *Batch) MaxDuration() time.Duration

type Config

type Config struct {
	ID                  string
	Loader              *config.Config
	Stream              *tconfig.Stream
	UseFastMap          bool
	FastMapSize         int
	MaxMessageSize      int
	Concurrency         int
	Batch               *Batch
	Retry               *Retry
	StreamDisabled      bool
	LoadDelayMaxMs      int
	LoadDelaySeedPart   int
	LoadDelayEveryNExec int
	LoadDelayOnlyOnce   bool
}

func NewConfigFromURL

func NewConfigFromURL(ctx context.Context, URL string) (*Config, error)

func (*Config) Clone

func (c *Config) Clone() *Config

func (*Config) IsStreamEnabled

func (c *Config) IsStreamEnabled() bool

func (*Config) Validate

func (c *Config) Validate() error

type Retry

type Retry struct {
	EveryInSec int
	Max        int
}

func (Retry) Clone

func (r Retry) Clone() *Retry