config

Documentation

Index

• func NewMiniBatcher(config *MiniBatchConfig) (*minibatch.MiniBatcher, error)
• type MiniBatchConfig
  • func (inst *MiniBatchConfig) FromContext(nameTransf config.NameTransformFunc, ctx *cli.Context) (nMessages int)
  • func (inst *MiniBatchConfig) ToCliFlags(nameTransf config.NameTransformFunc, envVarNameTransf config.NameTransformFunc) []cli.Flag
  • func (inst *MiniBatchConfig) Validate(force bool) (nMessages int)

Functions

func NewMiniBatcher

func NewMiniBatcher(config *MiniBatchConfig) (*minibatch.MiniBatcher, error)

Types

type MiniBatchConfig

type MiniBatchConfig struct {
	SizeCriteria     int           `json:"sizeCriteria"`
	DurationCriteria time.Duration `json:"durationCriteria"`
	CountCriteria    int           `json:"countCriteria"`
	// contains filtered or unexported fields
}

func (*MiniBatchConfig) FromContext

func (inst *MiniBatchConfig) FromContext(nameTransf config.NameTransformFunc, ctx *cli.Context) (nMessages int)

func (*MiniBatchConfig) ToCliFlags

func (inst *MiniBatchConfig) ToCliFlags(nameTransf config.NameTransformFunc, envVarNameTransf config.NameTransformFunc) []cli.Flag

func (*MiniBatchConfig) Validate

func (inst *MiniBatchConfig) Validate(force bool) (nMessages int)