memory

Documentation

Index

• Constants
• type Config
• type Queue
  • func (c *Queue) Category() api.Category
  • func (c *Queue) Config() interface{}
  • func (c *Queue) Consume(event api.Event) api.Result
  • func (c *Queue) In(event api.Event)
  • func (c *Queue) Init(context api.Context) error
  • func (c *Queue) Out() api.Batch
  • func (c *Queue) OutChan() chan api.Batch
  • func (c *Queue) Start() error
  • func (c *Queue) Stop()
  • func (c *Queue) String() string
  • func (c *Queue) Type() api.Type

Constants

const (
	Type = "memory"
)

Types

type Config

type Config struct {
	BatchSize          int           `yaml:"batchSize" default:"2048"`
	BatchBufferFactor  int           `yaml:"batchBufferFactor" default:"2"` // BufferSize = BatchSize * BatchBufferFactor
	BatchBytes         int64         `yaml:"batchBytes" default:"33554432"` // default:32MB
	BatchAggMaxTimeout time.Duration `yaml:"batchAggTimeout" default:"1s"`
	CleanDataTimeout   time.Duration `yaml:"cleanDataTimeout" default:"5s"`
}

type Queue

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

func (*Queue) Category

func (c *Queue) Category() api.Category

func (*Queue) Config

func (c *Queue) Config() interface{}

func (*Queue) Consume

func (c *Queue) Consume(event api.Event) api.Result

func (*Queue) In

func (c *Queue) In(event api.Event)

func (*Queue) Init

func (c *Queue) Init(context api.Context) error

func (*Queue) Out

func (c *Queue) Out() api.Batch

func (*Queue) OutChan

func (c *Queue) OutChan() chan api.Batch

func (*Queue) Start

func (c *Queue) Start() error

func (*Queue) Stop

func (c *Queue) Stop()

func (*Queue) String

func (c *Queue) String() string

func (*Queue) Type

func (c *Queue) Type() api.Type