ingest

package
v0.9.3 Latest Latest
Warning

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

Go to latest
Published: May 21, 2019 License: Apache-2.0 Imports: 12 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 DownsampleAndWriteIter added in v0.5.0

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 added in v0.5.0

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,
	) error

	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 added in v0.5.0

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

NewDownsamplerAndWriter creates a new downsampler and writer.

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) 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 WriteOptions) 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) 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 interface{}) *gomock.Call

Write indicates an expected call of Write

func (*MockDownsamplerAndWriterMockRecorder) WriteBatch added in v0.5.0

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

WriteBatch indicates an expected call of WriteBatch

type WriteOptions added in v0.5.0

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.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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