Documentation
¶
Index ¶
- func NewFakeStream(from int, quantity int) logproto.Stream
- func NewFakeStreamIterator(from int, quantity int) iter.EntryIterator
- func NewFakeStreamWithLabels(from int, quantity int, labels string) logproto.Stream
- type MockLimits
- func (m *MockLimits) BlockedQueries(_ context.Context, _ string) []*validation.BlockedQuery
- func (m *MockLimits) EnableMultiVariantQueries(_ string) bool
- func (m *MockLimits) MaxConcurrentTailRequests(_ context.Context, _ string) int
- func (m *MockLimits) MaxEntriesLimitPerQuery(_ context.Context, _ string) int
- func (m *MockLimits) MaxQueryLength(_ context.Context, _ string) time.Duration
- func (m *MockLimits) MaxQueryLookback(_ context.Context, _ string) time.Duration
- func (m *MockLimits) MaxQueryRange(_ context.Context, _ string) time.Duration
- func (m *MockLimits) MaxQuerySeries(_ context.Context, _ string) int
- func (m *MockLimits) MaxStreamsMatchersPerQuery(_ context.Context, _ string) int
- func (m *MockLimits) QueryTimeout(_ context.Context, _ string) time.Duration
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFakeStream ¶
mockStream return a stream with quantity entries, where entries timestamp and line string are constructed as sequential numbers starting at from
func NewFakeStreamIterator ¶
func NewFakeStreamIterator(from int, quantity int) iter.EntryIterator
mockStreamIterator returns an iterator with 1 stream and quantity entries, where entries timestamp and line string are constructed as sequential numbers starting at from
Types ¶
type MockLimits ¶
type MockLimits struct {
MaxQueryLookbackVal time.Duration
MaxQueryLengthVal time.Duration
MaxQueryTimeoutVal time.Duration
MaxQueryRangeVal time.Duration
MaxQuerySeriesVal int
MaxConcurrentTailRequestsVal int
MaxEntriesLimitPerQueryVal int
MaxStreamsMatchersPerQueryVal int
EnableMultiVariantQueriesVal bool
}
MockLimits is a mock implementation of limits.Limits interface that can be used in tests
func (*MockLimits) BlockedQueries ¶
func (m *MockLimits) BlockedQueries(_ context.Context, _ string) []*validation.BlockedQuery
func (*MockLimits) EnableMultiVariantQueries ¶
func (m *MockLimits) EnableMultiVariantQueries(_ string) bool
func (*MockLimits) MaxConcurrentTailRequests ¶
func (m *MockLimits) MaxConcurrentTailRequests(_ context.Context, _ string) int
func (*MockLimits) MaxEntriesLimitPerQuery ¶
func (m *MockLimits) MaxEntriesLimitPerQuery(_ context.Context, _ string) int
func (*MockLimits) MaxQueryLength ¶
func (*MockLimits) MaxQueryLookback ¶
func (*MockLimits) MaxQueryRange ¶
func (*MockLimits) MaxQuerySeries ¶
func (m *MockLimits) MaxQuerySeries(_ context.Context, _ string) int
func (*MockLimits) MaxStreamsMatchersPerQuery ¶
func (m *MockLimits) MaxStreamsMatchersPerQuery(_ context.Context, _ string) int
func (*MockLimits) QueryTimeout ¶
Source Files
Click to show internal directories.
Click to hide internal directories.