ingestm3msg

package
Version: v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 7, 2022 License: Apache-2.0 Imports: 21 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Configuration

type Configuration struct {
	WorkerPoolSize int                          `yaml:"workerPoolSize"`
	OpPool         pool.ObjectPoolConfiguration `yaml:"opPool"`
	Retry          retry.Configuration          `yaml:"retry"`
	LogSampleRate  *float64                     `yaml:"logSampleRate" validate:"min=0.0,max=1.0"`
}

Configuration configs the ingester.

func (Configuration) NewIngester

func (cfg Configuration) NewIngester(
	appender storage.Appender,
	tagOptions models.TagOptions,
	instrumentOptions instrument.Options,
) (*Ingester, error)

NewIngester creates an ingester with an appender.

type Ingester

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

Ingester ingests metrics with a worker pool.

func NewIngester

func NewIngester(
	opts Options,
) *Ingester

NewIngester creates an ingester.

func (*Ingester) Ingest

func (i *Ingester) Ingest(
	ctx context.Context,
	id []byte,
	metricNanos, encodeNanos int64,
	value float64,
	annotation []byte,
	sp policy.StoragePolicy,
	callback m3msg.Callbackable,
)

Ingest ingests a metric asynchronously with callback.

type Options

type Options struct {
	Appender          storage.Appender
	Workers           xsync.PooledWorkerPool
	PoolOptions       pool.ObjectPoolOptions
	TagDecoderPool    serialize.TagDecoderPool
	RetryOptions      retry.Options
	Sampler           *sampler.Sampler
	InstrumentOptions instrument.Options
	TagOptions        models.TagOptions
}

Options configures the ingester.

Jump to

Keyboard shortcuts

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