pipeline

Documentation

Index

• type Config
• type Pipeline
  • func New(conf *Config) *Pipeline

Types

type Config

type Config struct {
	MaxSize  int
	Interval time.Duration
	Buffer   int
	Worker   int
}

type Pipeline

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

func New

func New(conf *Config) *Pipeline