Versions in this module Expand all Collapse all v2 v2.0.0 Jul 18, 2025 Changes in this version + const DefaultLimit + const DefaultParallel + const MaxLimit + const QueryConcurrencyQuotaLimit + const TimeLayout + var ErrClosed = errors.New("incite: operation on a closed object") + var NopLogger = nopLogger(0) + var RPSDefaults = map[CloudWatchLogsAction]int + var RPSQuotaLimits = map[CloudWatchLogsAction]int + func Unmarshal(data []Result, v interface{}) error + type CloudWatchLogsAction int + const GetQueryResults + const StartQuery + const StopQuery + type CloudWatchLogsActions interface + GetQueryResults func(context.Context, *cloudwatchlogs.GetQueryResultsInput, ...) (*cloudwatchlogs.GetQueryResultsOutput, error) + StartQuery func(context.Context, *cloudwatchlogs.StartQueryInput, ...) (*cloudwatchlogs.StartQueryOutput, error) + StopQuery func(context.Context, *cloudwatchlogs.StopQueryInput, ...) (*cloudwatchlogs.StopQueryOutput, error) + type Config struct + Actions CloudWatchLogsActions + DisableAdaptation bool + Logger Logger + Name string + 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 + Query func(QuerySpec) (Stream, error) + func NewQueryManager(cfg Config) QueryManager + type QuerySpec struct + Chunk time.Duration + End time.Time + Groups []string + Limit int32 + Preview bool + Priority int + SplitUntil time.Duration + Start time.Time + Text string + type Result []ResultField + func Query(ctx context.Context, a CloudWatchLogsActions, q QuerySpec) ([]Result, error) + func ReadAll(s Stream) ([]Result, error) + type ResultField struct + Field string + Value string + type StartQueryError struct + Cause error + End time.Time + Start time.Time + Text string + func (err *StartQueryError) Error() string + func (err *StartQueryError) Unwrap() error + type Stats struct + BytesScanned float64 + RangeDone time.Duration + RangeFailed time.Duration + RangeMaxed time.Duration + RangeRequested time.Duration + RangeStarted time.Duration + RecordsMatched float64 + RecordsScanned float64 + type StatsGetter interface + GetStats func() Stats + type Stream interface + Read func(p []Result) (n int, err 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 + type UnmarshalResultFieldValueError struct + Cause error + FieldIndex int + ResultIndex int + func (e *UnmarshalResultFieldValueError) Error() string Other modules containing this package github.com/gogama/incite
Go to main page