deglobber

Documentation

Overview

Package deglobber decompresses and unglobs events and checks for duplicates.

Index

• type Pool
  • func NewPool(config PoolConfig) *Pool
  • func (dp *Pool) Close()
  • func (dp *Pool) Start()
  • func (dp *Pool) Submit(glob []byte)
• type PoolConfig

Types

type Pool

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

Pool turns byte streams into lists of events, then sends them to a processor.Pool. It also handles deduping globs.

func NewPool

func NewPool(config PoolConfig) *Pool

NewPool returns a pool for turning globs into lists of events.

func (*Pool) Close

func (dp *Pool) Close()

Close stops all processing goroutines.

func (*Pool) Start

func (dp *Pool) Start()

Start starts the pool's goroutines.

func (*Pool) Submit

func (dp *Pool) Submit(glob []byte)

Submit submits a glob to the pool for processing.

type PoolConfig

type PoolConfig struct {
	ProcessorPool      processor.Pool
	Stats              statsd.Statter
	DuplicateCache     *cache.Cache
	PoolSize           int
	CompressionVersion byte
	ReplayMode         bool
}

PoolConfig collects the configuration information for a Pool.