ingest

Documentation

Index

• type Configuration
  • func (cfg Configuration) NewIngester(appender storage.Appender, instrumentOptions instrument.Options) (*Ingester, error)
• type Ingester
  • func NewIngester(opts Options) *Ingester
  • func (i *Ingester) Ingest(ctx context.Context, id []byte, metricTime time.Time, value float64, ...)
• type Options

Types

type Configuration

type Configuration struct {
	WorkerPoolSize int                          `yaml:"workerPoolSize"`
	OpPool         pool.ObjectPoolConfiguration `yaml:"opPool"`
	Retry          retry.Configuration          `yaml:"retry"`
}

Configuration configs the ingester.

func (Configuration) NewIngester

func (cfg Configuration) NewIngester(
	appender storage.Appender,
	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,
	metricTime time.Time,
	value float64,
	sp policy.StoragePolicy,
	callback *m3msg.RefCountedCallback,
)

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
	InstrumentOptions instrument.Options
}

Options configures the ingester.