limits

Sep 10, 2021

Changes in this version

type LookbackLimit

+ func NewLookbackLimit(name string, opts LookbackLimitOptions, instrumentOpts instrument.Options, ...) LookbackLimit

+ Start func()

+ Stop func()

type LookbackLimitOptions

+ ForceWaited bool

type Options

+ func DefaultLimitsOptions(iOpts instrument.Options) Options

+ AggregateDocsLimitOpts func() LookbackLimitOptions

+ SetAggregateDocsLimitOpts func(LookbackLimitOptions) Options

type QueryLimits

+ AggregateDocsLimit func() LookbackLimit

+ AnyFetchExceeded func() error

+ FetchDocsLimit func() LookbackLimit

Jan 21, 2021

Changes in this version

+ func IsQueryLimitExceededError(err error) bool

+ func NewQueryLimitExceededError(msg string) error

+ type Key string

+ const SourceContextKey

type LookbackLimit

+ Options func() LookbackLimitOptions

+ Update func(opts LookbackLimitOptions) error

type LookbackLimitOptions

+ ForceExceeded bool

+ func (opts LookbackLimitOptions) Equals(other LookbackLimitOptions) bool

+ type Options interface

+ BytesReadLimitOpts func() LookbackLimitOptions

+ DiskSeriesReadLimitOpts func() LookbackLimitOptions

+ DocsLimitOpts func() LookbackLimitOptions

+ InstrumentOptions func() instrument.Options

+ SetBytesReadLimitOpts func(value LookbackLimitOptions) Options

+ SetDiskSeriesReadLimitOpts func(value LookbackLimitOptions) Options

+ SetDocsLimitOpts func(value LookbackLimitOptions) Options

+ SetInstrumentOptions func(value instrument.Options) Options

+ SetSourceLoggerBuilder func(value SourceLoggerBuilder) Options

+ SourceLoggerBuilder func() SourceLoggerBuilder

+ Validate func() error

+ func NewOptions() Options

type QueryLimits

+ DiskSeriesReadLimit func() LookbackLimit

+ type SourceLogger interface

+ LogSourceValue func(val int64, source []byte)

+ type SourceLoggerBuilder interface

+ NewSourceLogger func(name string, opts instrument.Options) SourceLogger

Sep 21, 2020

Changes in this version

+ type LookbackLimit interface

+ Inc func(new int) error

+ type LookbackLimitOptions struct

+ Limit int64

+ Lookback time.Duration

+ func DefaultLookbackLimitOptions() LookbackLimitOptions

+ type QueryLimits interface

+ AnyExceeded func() error

+ BytesReadLimit func() LookbackLimit

+ DocsLimit func() LookbackLimit

+ Start func()

+ Stop func()

+ func NewQueryLimits(docsLimitOpts LookbackLimitOptions, bytesReadLimitOpts LookbackLimitOptions, ...) (QueryLimits, error)

+ func NoOpQueryLimits() QueryLimits