Documentation ¶
Overview ¶
Package ingest is a generated GoMock package.
Index ¶
- type BatchError
- type DownsampleAndWriteIter
- type DownsamplerAndWriter
- type 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
- type WriteOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BatchError ¶ added in v0.10.0
BatchError allows for access to individual errors.
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, ) 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 ¶ 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
func (m *MockDownsamplerAndWriter) EXPECT() *MockDownsamplerAndWriterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockDownsamplerAndWriter) Storage ¶ added in v0.5.0
func (m *MockDownsamplerAndWriter) Storage() storage.Storage
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
func (m *MockDownsamplerAndWriter) WriteBatch(arg0 context.Context, arg1 DownsampleAndWriteIter) BatchError
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
func (mr *MockDownsamplerAndWriterMockRecorder) Storage() *gomock.Call
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.