config

Documentation

Index

• type DataSetConfig
  • func New(opts ...DataSetConfigOption) (*DataSetConfig, error)
  • func (cfg *DataSetConfig) Update(opts ...DataSetConfigOption) (*DataSetConfig, error)
• type DataSetConfigOption
  • func FromEnv() DataSetConfigOption
  • func WithEndpoint(endpoint string) DataSetConfigOption
  • func WithGroupBy(groupBy []string) DataSetConfigOption
  • func WithMaxBufferDelay(maxBufferDelay time.Duration) DataSetConfigOption
  • func WithMaxPayloadB(maxPayloadB int64) DataSetConfigOption
  • func WithRetryBase(retryBase time.Duration) DataSetConfigOption
  • func WithTokens(tokens DataSetTokens) DataSetConfigOption
• type DataSetTokens

Types

type DataSetConfig

type DataSetConfig struct {
	Endpoint       string
	Tokens         DataSetTokens
	MaxBufferDelay time.Duration
	MaxPayloadB    int64
	GroupBy        []string
	RetryBase      time.Duration
}

func New

func New(opts ...DataSetConfigOption) (*DataSetConfig, error)

func (*DataSetConfig) Update

func (cfg *DataSetConfig) Update(opts ...DataSetConfigOption) (*DataSetConfig, error)

type DataSetConfigOption

type DataSetConfigOption func(*DataSetConfig) error

func FromEnv

func FromEnv() DataSetConfigOption

func WithEndpoint

func WithEndpoint(endpoint string) DataSetConfigOption

func WithGroupBy

func WithGroupBy(groupBy []string) DataSetConfigOption

func WithMaxBufferDelay

func WithMaxBufferDelay(maxBufferDelay time.Duration) DataSetConfigOption

func WithMaxPayloadB

func WithMaxPayloadB(maxPayloadB int64) DataSetConfigOption

func WithRetryBase

func WithRetryBase(retryBase time.Duration) DataSetConfigOption

func WithTokens

func WithTokens(tokens DataSetTokens) DataSetConfigOption

type DataSetTokens

type DataSetTokens struct {
	WriteLog    string
	ReadLog     string
	WriteConfig string
	ReadConfig  string
}