batcher

Documentation

Index

• Variables
• type Batcher
  • func NewBatcher(fn DoFuntion, opts ...Option) *Batcher
  • func (b *Batcher) Add(key string, val interface{}) error
  • func (b *Batcher) Close()
  • func (b *Batcher) Start() error
• type Config
• type DoFuntion
• type Option
  • func WithBuffer(b int) Option
  • func WithInterval(i time.Duration) Option
  • func WithSize(s int) Option
  • func WithWorker(w int) Option

Variables

var (
	DefaultSize     = 100
	DefaultBuffer   = 100
	DefaultWorker   = 5
	DefaultInterval = time.Second
)

var (
	ErrorNotSetFunction = errors.New("not set do function")
)

Types

type Batcher

type Batcher struct {
	Do       func(ctx context.Context, val map[string][]interface{})
	Sharding func(key string) int
	// contains filtered or unexported fields
}

func NewBatcher

func NewBatcher(fn DoFuntion, opts ...Option) *Batcher

func (*Batcher) Add

func (b *Batcher) Add(key string, val interface{}) error

func (*Batcher) Close

func (b *Batcher) Close()

func (*Batcher) Start

func (b *Batcher) Start() error

type Config

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

type DoFuntion

type DoFuntion func(ctx context.Context, val map[string][]interface{})

type Option

type Option func(c *Config)

func WithBuffer

func WithBuffer(b int) Option

func WithInterval

func WithInterval(i time.Duration) Option

func WithSize

func WithSize(s int) Option

func WithWorker

func WithWorker(w int) Option