ingest

Documentation

Overview

Package ingest is a generated GoMock package.

Index

• type BatchError
• type DownsampleAndWriteIter
• type DownsamplerAndWriter
  • func NewDownsamplerAndWriter(store storage.Storage, downsampler downsample.Downsampler, ...) DownsamplerAndWriter
• type MockDownsamplerAndWriter
  • func NewMockDownsamplerAndWriter(ctrl *gomock.Controller) *MockDownsamplerAndWriter
  • func (m *MockDownsamplerAndWriter) EXPECT() *MockDownsamplerAndWriterMockRecorder
  • func (m *MockDownsamplerAndWriter) Storage() storage.Storage
  • func (m *MockDownsamplerAndWriter) Write(arg0 context.Context, arg1 models.Tags, arg2 ts.Datapoints, arg3 time.Unit, ...) error
  • func (m *MockDownsamplerAndWriter) WriteBatch(arg0 context.Context, arg1 DownsampleAndWriteIter) BatchError
• type MockDownsamplerAndWriterMockRecorder
  • func (mr *MockDownsamplerAndWriterMockRecorder) Storage() *gomock.Call
  • func (mr *MockDownsamplerAndWriterMockRecorder) Write(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
  • func (mr *MockDownsamplerAndWriterMockRecorder) WriteBatch(arg0, arg1 interface{}) *gomock.Call
• type WriteOptions

Types

type BatchError

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

BatchError allows for access to individual errors.

type DownsampleAndWriteIter

type DownsampleAndWriteIter interface {
	Next() bool
	Current() (models.Tags, ts.Datapoints, xtime.Unit)
	Reset() error
	Error() error
}

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

type DownsamplerAndWriter

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

	// TODO(rartoul): Batch interface should also support downsampling rules.
	WriteBatch(
		ctx context.Context,
		iter DownsampleAndWriteIter,
	) BatchError

	Storage() storage.Storage
}

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

func NewDownsamplerAndWriter

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

NewDownsamplerAndWriter creates a new downsampler and writer.

type MockDownsamplerAndWriter

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

MockDownsamplerAndWriter is a mock of DownsamplerAndWriter interface

func NewMockDownsamplerAndWriter

func NewMockDownsamplerAndWriter(ctrl *gomock.Controller) *MockDownsamplerAndWriter

NewMockDownsamplerAndWriter creates a new mock instance

func (*MockDownsamplerAndWriter) EXPECT

func (m *MockDownsamplerAndWriter) EXPECT() *MockDownsamplerAndWriterMockRecorder

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

func (*MockDownsamplerAndWriter) Storage

func (m *MockDownsamplerAndWriter) Storage() storage.Storage

Storage mocks base method

func (*MockDownsamplerAndWriter) Write

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

Write mocks base method

func (*MockDownsamplerAndWriter) WriteBatch

func (m *MockDownsamplerAndWriter) WriteBatch(arg0 context.Context, arg1 DownsampleAndWriteIter) BatchError

WriteBatch mocks base method

type MockDownsamplerAndWriterMockRecorder

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

MockDownsamplerAndWriterMockRecorder is the mock recorder for MockDownsamplerAndWriter

func (*MockDownsamplerAndWriterMockRecorder) Storage

func (mr *MockDownsamplerAndWriterMockRecorder) Storage() *gomock.Call

Storage indicates an expected call of Storage

func (*MockDownsamplerAndWriterMockRecorder) Write

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

Write indicates an expected call of Write

func (*MockDownsamplerAndWriterMockRecorder) WriteBatch

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

WriteBatch indicates an expected call of WriteBatch

type WriteOptions

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

	DownsampleOverride bool
	WriteOverride      bool
}

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