Documentation
¶
Overview ¶
Package ingest is a generated GoMock package.
Index ¶
- 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) error
- type MockDownsamplerAndWriterMockRecorder
- type WriteOptions
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
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) error
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.
Source Files
Directories