ingestm3msg

Documentation

Index

• type Configuration
  • func (cfg Configuration) NewIngester(appender storage.Appender, tagOptions models.TagOptions, ...) (*Ingester, error)
• type Ingester
  • func NewIngester(opts Options) *Ingester
  • func (i *Ingester) Ingest(ctx context.Context, id []byte, metricNanos, encodeNanos int64, value float64, ...)
• type Options

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,
	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.