ingest

package
Version: v1.4.2 Latest Latest
Warning

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

Go to latest
Published: Jan 18, 2022 License: Apache-2.0 Imports: 16 Imported by: 9

Documentation

Overview

Package ingest is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchError added in v0.10.0

type BatchError interface {
	error
	Errors() []error
	LastError() error
}

BatchError allows for access to individual errors.

type DownsampleAndWriteIter added in v0.5.0

type DownsampleAndWriteIter interface {
	Next() bool
	Current() IterValue
	Reset() error
	Error() error
	SetCurrentMetadata(ts.Metadata)
}

DownsampleAndWriteIter is an interface that can be implemented to use the WriteBatch method.

type DownsamplerAndWriter added in v0.5.0

type DownsamplerAndWriter interface {
	Write(
		ctx context.Context,
		tags models.Tags,
		datapoints ts.Datapoints,
		unit xtime.Unit,
		annotation []byte,
		overrides WriteOptions,
		source ts.SourceType,
	) error

	WriteBatch(
		ctx context.Context,
		iter DownsampleAndWriteIter,
		overrides WriteOptions,
	) BatchError

	Storage() storage.Storage

	Downsampler() downsample.Downsampler
}

DownsamplerAndWriter is the interface for the downsamplerAndWriter which writes metrics to the downsampler as well as to storage in unaggregated form.

func NewDownsamplerAndWriter added in v0.5.0

func NewDownsamplerAndWriter(
	store storage.Storage,
	downsampler downsample.Downsampler,
	workerPool xsync.PooledWorkerPool,
	instrumentOpts instrument.Options,
) DownsamplerAndWriter

NewDownsamplerAndWriter creates a new downsampler and writer.

type IterValue added in v0.15.3

type IterValue struct {
	Tags       models.Tags
	Datapoints ts.Datapoints
	Attributes ts.SeriesAttributes
	Unit       xtime.Unit
	Metadata   ts.Metadata
	Annotation []byte
}

IterValue is the value returned by the iterator.

type LatencyBuckets added in v1.0.1

type LatencyBuckets struct {
	WriteLatencyBuckets  tally.DurationBuckets
	IngestLatencyBuckets tally.DurationBuckets
}

LatencyBuckets are a set of latency buckets useful for measuring things.

func NewLatencyBuckets added in v1.0.1

func NewLatencyBuckets() (LatencyBuckets, error)

NewLatencyBuckets returns write and ingest latency buckets useful for measuring ingest latency (i.e. time from datapoint/sample created to time ingested) and write latency (i.e. time from received a sample from remote source to completion of that write locally).

type MockDownsamplerAndWriter added in v0.5.0

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

MockDownsamplerAndWriter is a mock of DownsamplerAndWriter interface.

func NewMockDownsamplerAndWriter added in v0.5.0

func NewMockDownsamplerAndWriter(ctrl *gomock.Controller) *MockDownsamplerAndWriter

NewMockDownsamplerAndWriter creates a new mock instance.

func (*MockDownsamplerAndWriter) Downsampler added in v1.4.2

Downsampler mocks base method.

func (*MockDownsamplerAndWriter) EXPECT added in v0.5.0

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDownsamplerAndWriter) Storage added in v0.5.0

Storage mocks base method.

func (*MockDownsamplerAndWriter) Write added in v0.5.0

func (m *MockDownsamplerAndWriter) Write(arg0 context.Context, arg1 models.Tags, arg2 ts.Datapoints, arg3 time.Unit, arg4 []byte, arg5 WriteOptions, arg6 ts.SourceType) error

Write mocks base method.

func (*MockDownsamplerAndWriter) WriteBatch added in v0.5.0

WriteBatch mocks base method.

type MockDownsamplerAndWriterMockRecorder added in v0.5.0

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

MockDownsamplerAndWriterMockRecorder is the mock recorder for MockDownsamplerAndWriter.

func (*MockDownsamplerAndWriterMockRecorder) Downsampler added in v1.4.2

Downsampler indicates an expected call of Downsampler.

func (*MockDownsamplerAndWriterMockRecorder) Storage added in v0.5.0

Storage indicates an expected call of Storage.

func (*MockDownsamplerAndWriterMockRecorder) Write added in v0.5.0

func (mr *MockDownsamplerAndWriterMockRecorder) Write(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call

Write indicates an expected call of Write.

func (*MockDownsamplerAndWriterMockRecorder) WriteBatch added in v0.5.0

func (mr *MockDownsamplerAndWriterMockRecorder) WriteBatch(arg0, arg1, arg2 interface{}) *gomock.Call

WriteBatch indicates an expected call of WriteBatch.

type WriteOptions added in v0.5.0

type WriteOptions struct {
	DownsampleMappingRules []downsample.AutoMappingRule
	WriteStoragePolicies   []policy.StoragePolicy

	DownsampleOverride bool
	WriteOverride      bool
}

WriteOptions contains overrides for the downsampling mapping rules and storage policies for a given write.

Directories

Path Synopsis
Package ingestcarbon implements a carbon ingester.
Package ingestcarbon implements a carbon ingester.

Jump to

Keyboard shortcuts

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