incite

Feb 15, 2023

Changes in this version

type Config

+ DisableAdaptation bool

Feb 8, 2022

Changes in this version

type Stats

+ RangeMaxed time.Duration

Dec 22, 2021

Changes in this version

type QuerySpec

+ SplitUntil time.Duration

type Stats

+ RangeDone time.Duration

+ RangeFailed time.Duration

+ RangeRequested time.Duration

+ RangeStarted time.Duration

Oct 18, 2021

Changes in this version

type Config

+ Name string

Aug 14, 2021

Changes in this version

+ var RPSDefaults = map[CloudWatchLogsAction]int

type CloudWatchLogsActions

+ GetQueryResultsWithContext func(context.Context, *cloudwatchlogs.GetQueryResultsInput, ...request.Option) (*cloudwatchlogs.GetQueryResultsOutput, error)

+ StartQueryWithContext func(context.Context, *cloudwatchlogs.StartQueryInput, ...request.Option) (*cloudwatchlogs.StartQueryOutput, error)

+ StopQueryWithContext func(context.Context, *cloudwatchlogs.StopQueryInput, ...request.Option) (*cloudwatchlogs.StopQueryOutput, error)

Jul 18, 2021

Changes in this version

type QueryManager

+ Query func(QuerySpec) (Stream, error)

type Stream

+ Read func(p []Result) (n int, err error)

Jul 16, 2021

Changes in this version

+ const DefaultLimit

+ const MaxLimit

type QuerySpec

+ Limit int64

+ type StartQueryError struct

+ Cause error

+ End time.Time

+ Start time.Time

+ Text string

+ func (err *StartQueryError) Error() string

+ func (err *StartQueryError) Unwrap() error

+ type TerminalQueryStatusError struct

+ QueryID string

+ Status string

+ Text string

+ func (err *TerminalQueryStatusError) Error() string

+ type UnexpectedQueryError struct

+ Cause error

+ QueryID string

+ Text string

+ func (err *UnexpectedQueryError) Error() string

+ func (err *UnexpectedQueryError) Unwrap() error

Jul 15, 2021

Changes in this version

+ const DefaultParallel

+ const QueryConcurrencyQuotaLimit

+ const TimeLayout

+ var DefaultRPS = map[CloudWatchLogsAction]int

+ var ErrClosed = errors.New("incite: operation on a closed object")

+ var NopLogger = nopLogger(0)

+ var RPSQuotaLimits = map[CloudWatchLogsAction]int

+ func Unmarshal(data []Result, v interface{}) error

+ type CloudWatchLogsAction int

+ const GetQueryResults

+ const StartQuery

+ const StopQuery

+ type CloudWatchLogsActions interface

+ type CloudWatchLogsQueryResultsGetter interface

+ GetQueryResultsWithContext func(context.Context, *cloudwatchlogs.GetQueryResultsInput, ...request.Option) (*cloudwatchlogs.GetQueryResultsOutput, error)

+ type CloudWatchLogsQueryStarter interface

+ StartQueryWithContext func(context.Context, *cloudwatchlogs.StartQueryInput, ...request.Option) (*cloudwatchlogs.StartQueryOutput, error)

+ type CloudWatchLogsQueryStopper interface

+ StopQueryWithContext func(context.Context, *cloudwatchlogs.StopQueryInput, ...request.Option) (*cloudwatchlogs.StopQueryOutput, error)

+ type Config struct

+ Actions CloudWatchLogsActions

+ Logger Logger

+ Parallel int

+ RPS map[CloudWatchLogsAction]int

+ type InvalidUnmarshalError struct

+ Field string

+ FieldType reflect.Type

+ Message string

+ RowType reflect.Type

+ Type reflect.Type

+ func (e *InvalidUnmarshalError) Error() string

+ type Logger interface

+ Printf func(format string, v ...interface{})

+ type QueryManager interface

+ func NewQueryManager(cfg Config) QueryManager

+ type QuerySpec struct

+ Chunk time.Duration

+ End time.Time

+ Groups []string

+ Hint uint16

+ Preview bool

+ Priority int

+ Start time.Time

+ Text string

+ type Queryer interface

+ Query func(QuerySpec) (Stream, error)

+ type Reader interface

+ Read func(p []Result) (n int, err error)

+ type Result []ResultField

+ func Query(caps CloudWatchLogsActions, q interface{}) ([]Result, error)

+ func ReadAll(r Reader) ([]Result, error)

+ type ResultField struct

+ Field string

+ Value string

+ type Stats struct

+ BytesScanned float64

+ RecordsMatched float64

+ RecordsScanned float64

+ func (a *Stats) Add(b Stats)

+ type StatsGetter interface

+ GetStats func() Stats

+ type Stream interface

+ type UnmarshalResultFieldValueError struct

+ Cause error

+ FieldIndex int

+ ResultIndex int

+ func (e *UnmarshalResultFieldValueError) Error() string