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, arg2 WriteOptions) BatchError
- type MockDownsamplerAndWriterMockRecorder
- type WriteOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BatchError ¶
BatchError allows for access to individual errors.
type DownsampleAndWriteIter ¶
type DownsampleAndWriteIter interface {
Next() bool
Current() (models.Tags, ts.Datapoints, xtime.Unit, []byte)
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,
annotation []byte,
overrides WriteOptions,
) error
WriteBatch(
ctx context.Context,
iter DownsampleAndWriteIter,
overrides WriteOptions,
) 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 []byte, arg5 WriteOptions) error
Write mocks base method
func (*MockDownsamplerAndWriter) WriteBatch ¶
func (m *MockDownsamplerAndWriter) WriteBatch(arg0 context.Context, arg1 DownsampleAndWriteIter, arg2 WriteOptions) 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, arg5 interface{}) *gomock.Call
Write indicates an expected call of Write
func (*MockDownsamplerAndWriterMockRecorder) WriteBatch ¶
func (mr *MockDownsamplerAndWriterMockRecorder) WriteBatch(arg0, arg1, arg2 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.
Source Files
Directories