deglobber

package

v0.0.0-...-7e90556 Latest Latest Go to latest Published: Jan 29, 2018 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/twitchscience/spade

Links

Open Source Insights

Documentation ¶

Overview ¶

Package deglobber decompresses and unglobs events and checks for duplicates.

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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.

Source Files ¶

View all Source files

deglobber.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL