cloudwatchlogs

package

Go to main page

Versions in this module

v1

v1.5.0

Aug 24, 2026

Changes in this version

+ var ErrS3TableIntegrationNotFound = errors.New("ResourceNotFoundException")

type AggregateLogGroupSummary

+ GroupingIdentifiers []GroupingIdentifier

+ LogGroupCount int32

type Delivery

+ DeliveryDestinationType string

+ type GroupingIdentifier struct

+ Key string

+ Value string

type InMemoryBackend

+ func (b *InMemoryBackend) DisassociateSourceFromS3TableIntegration(identifier string) error

+ func (b *InMemoryBackend) ListSourcesForS3TableIntegration(integrationArn, nextToken string, maxResults int) ([]s3TableIntegrationEntry, string, error)

type IndexPolicy

+ LastUpdateTime int64

+ Source string

type QueryDefinition

+ Parameters []QueryParameter

+ QueryLanguage string

+ type QueryParameter struct

+ DefaultValue string

+ Description string

+ Name string

type ResourcePolicy

+ LastUpdatedTime int64

+ PolicyScope string

+ ResourceArn string

+ RevisionID string

type StorageBackend

+ DisassociateSourceFromS3TableIntegration func(identifier string) error

v1.4.0

Aug 19, 2026

v1.3.5

Aug 19, 2026

v1.3.4

Aug 18, 2026

v1.3.3

Aug 17, 2026

v1.3.2

Aug 16, 2026

v1.3.1

Aug 16, 2026

Changes in this version

+ const AnomalyStateActive

+ const AnomalyStateBaseline

+ const AnomalyStateSuppressed

+ var ErrValidationException = errors.New("ValidationException")

type Anomaly

+ Histogram map[string]int64

+ IsPatternLevelSuppression *bool

+ LogSamples []AnomalyLogSample

+ PatternID string

+ PatternRegex string

+ PatternString string

+ PatternTokens []PatternToken

+ Priority string

+ State string

+ Suppressed *bool

+ SuppressedUntil int64

+ type AnomalyLogSample struct

+ Message string

+ Timestamp int64

type CWLIntegration

+ OpenSearchResourceConfig *OpenSearchResourceConfig

type InMemoryBackend

+ func (b *InMemoryBackend) PutBearerTokenAuthentication(ctx context.Context, logGroupIdentifier string, enabled bool) error

type LogGroup

+ BearerTokenAuthenticationEnabled *bool

+ type OpenSearchResourceConfig struct

+ ApplicationArn string

+ DashboardViewerPrincipals []string

+ DataSourceRoleArn string

+ KmsKeyArn string

+ RetentionDays *int32

+ type PatternToken struct

+ DynamicTokenPosition int32

+ Enumerations map[string]int64

+ InferredTokenName string

+ IsDynamic *bool

+ TokenString string

type ScheduledQueryDestinationConfig

+ LookupTableConfiguration *ScheduledQueryLookupTableConfiguration

+ type ScheduledQueryLookupTableConfiguration struct

+ Description string

+ KmsKeyID string

+ RoleArn string

+ TableName string

+ Tags map[string]string

v1.3.0

Aug 3, 2026

v1.2.0

Aug 3, 2026

Changes in this version

+ const StorageTierIntelligentTiering

+ const StorageTierStandard

+ var ErrLookupTableAlreadyExists = errors.New("ResourceAlreadyExistsException")

+ var ErrLookupTableNotFound = errors.New("ResourceNotFoundException")

+ var ErrSyslogConfigurationNotFound = errors.New("ResourceNotFoundException")

type AccountPolicy

+ AccountID string

+ LastUpdatedTime int64

type Delivery

+ S3DeliveryConfiguration *DeliveryS3Configuration

type DeliveryDestination

+ DeliveryDestinationType string

+ type DeliveryS3Configuration struct

+ EnableHiveCompatiblePath bool

+ SuffixPath string

type DeliverySource

+ Service string

type Handler

+ func (h *Handler) GetTagsForResource(resourceARN string) map[string]string

+ func (h *Handler) TagResource(resourceARN string, kv map[string]string)

+ func (h *Handler) TaggedResources() []TaggedEntry

+ func (h *Handler) UntagResource(resourceARN string, keys []string)

type InMemoryBackend

+ func (b *InMemoryBackend) CreateLookupTable(name, tableBody, description, kmsKeyID string) (*LookupTable, error)

+ func (b *InMemoryBackend) DeleteLookupTable(lookupTableArn string) error

+ func (b *InMemoryBackend) DeleteSyslogConfiguration(logGroupIdentifier, vpcEndpointID string) error

+ func (b *InMemoryBackend) DescribeLookupTables(namePrefix, nextToken string, limit int) ([]LookupTable, string)

+ func (b *InMemoryBackend) GetLookupTable(lookupTableArn string) (*LookupTable, error)

+ func (b *InMemoryBackend) GetStorageTierPolicy() StorageTierPolicy

+ func (b *InMemoryBackend) ListSyslogConfigurations(logGroupIdentifier, vpcEndpointID, nextToken string, limit int) ([]SyslogConfiguration, string)

+ func (b *InMemoryBackend) PutStorageTierPolicy(tier string) (*StorageTierPolicy, error)

+ func (b *InMemoryBackend) PutSyslogConfiguration(ctx context.Context, logGroupIdentifier, vpcEndpointID string) (*SyslogConfiguration, error)

+ func (b *InMemoryBackend) UpdateLookupTable(lookupTableArn, tableBody string, description, kmsKeyID *string) (*LookupTable, error)

type LogAnomalyDetector

+ AnomalyDetectorStatus string

+ type LookupTable struct

+ CreatedAt int64

+ Description string

+ KmsKeyID string

+ LastUpdatedTime int64

+ LookupTableArn string

+ LookupTableName string

+ RecordsCount int64

+ SizeBytes int64

+ TableBody string

+ TableFields []string

type ScheduledQuery

+ Description string

+ DestinationConfiguration *ScheduledQueryDestinationConfig

+ EndTimeOffset int64

+ ExecutionRoleArn string

+ LastExecutionStatus string

+ LastTriggeredTime int64

+ LastUpdatedTime int64

+ LogGroupIdentifiers []string

+ QueryLanguage string

+ ScheduleEndTime int64

+ ScheduleStartTime int64

+ ScheduleType string

+ ScheduledQueryArn string

+ StartTimeOffset int64

+ Timezone string

+ type ScheduledQueryCreateParams struct

+ Description string

+ DestinationConfiguration *ScheduledQueryDestinationConfig

+ EndTimeOffset int64

+ ExecutionRoleArn string

+ LogGroupIdentifiers []string

+ Name string

+ QueryLanguage string

+ QueryString string

+ ScheduleEndTime int64

+ ScheduleExpression string

+ ScheduleStartTime int64

+ StartTimeOffset int64

+ State string

+ Timezone string

+ type ScheduledQueryDestinationConfig struct

+ S3Configuration *ScheduledQueryS3Configuration

+ type ScheduledQueryS3Configuration struct

+ DestinationIdentifier string

+ KmsKeyID string

+ OwnerAccountID string

+ RoleArn string

+ type StorageTierPolicy struct

+ LastUpdatedTime int64

+ StorageTier string

+ type SyslogConfiguration struct

+ CreatedAt int64

+ LogGroupArn string

+ LogGroupIdentifier string

+ SourceType string

+ VpcEndpointID string

+ type TaggedEntry struct

+ ARN string

+ Tags map[string]string

v1.1.4

Jul 20, 2026

v1.1.3

Jul 20, 2026

v1.1.2

Jul 20, 2026

v1.1.1

Jul 20, 2026

v1.1.0

Jul 19, 2026

Changes in this version

+ const DistributionByLogStream

+ const DistributionRandom

+ const LogGroupClassInfrequentAccess

+ const LogGroupClassStandard

+ var ErrDeliveryDestinationNotFound = errors.New("ResourceNotFoundException")

+ var ErrDeliveryNotFound = errors.New("ResourceNotFoundException")

+ var ErrDeliverySourceNotFound = errors.New("ResourceNotFoundException")

+ var ErrDestinationNotFound = errors.New("ResourceNotFoundException")

+ var ErrExportTaskNotFound = errors.New("ResourceNotFoundException")

+ var ErrImportTaskNotFound = errors.New("ResourceNotFoundException")

+ var ErrIndexPolicyNotFound = errors.New("ResourceNotFoundException")

+ var ErrIntegrationNotFound = errors.New("ResourceNotFoundException")

+ var ErrInvalidOperation = errors.New("InvalidOperationException")

+ var ErrLogAnomalyDetectorNotFound = errors.New("ResourceNotFoundException")

+ var ErrLogGroupAlreadyExists = errors.New("ResourceAlreadyExistsException")

+ var ErrLogGroupNotFound = errors.New("ResourceNotFoundException")

+ var ErrLogStreamAlreadyExist = errors.New("ResourceAlreadyExistsException")

+ var ErrLogStreamNotFound = errors.New("ResourceNotFoundException")

+ var ErrMetricFilterNotFound = errors.New("ResourceNotFoundException")

+ var ErrNilAppContext = errors.New("AppContext is required")

+ var ErrOperationAborted = errors.New("OperationAbortedException")

+ var ErrParseExpr = errors.New("parse expression")

+ var ErrQueryDefinitionNotFound = errors.New("ResourceNotFoundException")

+ var ErrQueryNotFound = errors.New("ResourceNotFoundException")

+ var ErrResourcePolicyNotFound = errors.New("ResourceNotFoundException")

+ var ErrScheduledQueryNotFound = errors.New("ResourceNotFoundException")

+ var ErrSubscriptionFilterLimitExceed = errors.New("LimitExceededException")

+ var ErrSubscriptionFilterNotFound = errors.New("ResourceNotFoundException")

+ var ErrTransformerNotFound = errors.New("ResourceNotFoundException")

+ var ErrValidation = errors.New("InvalidParameterException")

+ type AccountPolicy struct

+ PolicyDocument string

+ PolicyName string

+ PolicyType string

+ Scope string

+ SelectionCriteria string

+ type AggregateLogGroupSummary struct

+ LogEventCount int64

+ LogGroupArn string

+ LogGroupClass string

+ LogGroupName string

+ StoredBytes int64

+ type Anomaly struct

+ Active bool

+ AnomalyDetectorArn string

+ AnomalyID string

+ Description string

+ FirstSeen int64

+ LastSeen int64

+ SuppressedDate int64

+ SuppressedState string

+ type CWLDestination struct

+ AccessPolicy string

+ Arn string

+ CreatedAt time.Time

+ DestinationName string

+ RoleArn string

+ TargetArn string

+ type CWLIntegration struct

+ CreatedAt time.Time

+ Name string

+ Status string

+ Type string

+ type ConfigProvider interface

+ GetCloudWatchLogsSettings func() Settings

+ type Delivery struct

+ Arn string

+ CreationTime int64

+ DeliveryDestinationArn string

+ DeliverySourceName string

+ FieldDelimiter string

+ ID string

+ RecordFields []string

+ Tags map[string]string

+ type DeliveryDestination struct

+ Arn string

+ CreatedAt time.Time

+ Name string

+ OutputFormat string

+ Policy string

+ Tags map[string]string

+ TargetArn string

+ type DeliverySource struct

+ Arn string

+ CreatedAt time.Time

+ LogType string

+ Name string

+ ResourceArns []string

+ Tags map[string]string

+ type ExportSink interface

+ PutObject func(ctx context.Context, bucket, key string, body []byte) error

+ type ExportTask struct

+ CompletionTime int64

+ CreationTime int64

+ Destination string

+ DestinationPrefix string

+ From int64

+ LogGroupName string

+ LogStreamNamePrefix string

+ Status string

+ StatusMessage string

+ TaskID string

+ TaskName string

+ To int64

+ type FilterLogEventsParams struct

+ EndTime *int64

+ FilterPattern string

+ GroupName string

+ Limit int

+ LogStreamNamePrefix string

+ NextToken string

+ StartTime *int64

+ StreamNames []string

+ type FilteredLogEvent struct

+ EventID string

+ IngestionTime int64

+ LogStreamName string

+ Message string

+ Timestamp int64

+ type Handler struct

+ Backend StorageBackend

+ func NewHandler(backend StorageBackend) *Handler

+ func (h *Handler) ChaosOperations() []string

+ func (h *Handler) ChaosRegions() []string

+ func (h *Handler) ChaosServiceName() string

+ func (h *Handler) ExtractOperation(c *echo.Context) string

+ func (h *Handler) ExtractResource(c *echo.Context) string

+ func (h *Handler) GetSupportedOperations() []string

+ func (h *Handler) Handler() echo.HandlerFunc

+ func (h *Handler) MatchPriority() int

+ func (h *Handler) Name() string

+ func (h *Handler) Reset()

+ func (h *Handler) Restore(ctx context.Context, data []byte) error

+ func (h *Handler) RouteMatcher() service.Matcher

+ func (h *Handler) Snapshot(ctx context.Context) []byte

+ func (h *Handler) StartWorker(ctx context.Context) error

+ func (h *Handler) WithJanitor(interval time.Duration, taskTimeout ...time.Duration) *Handler

+ type ImportTask struct

+ CreationTime int64

+ ImportDestinationArn string

+ ImportID string

+ ImportRoleArn string

+ ImportSourceArn string

+ LastUpdatedTime int64

+ Status string

+ type InMemoryBackend struct

+ func NewInMemoryBackend() *InMemoryBackend

+ func NewInMemoryBackendWithConfig(accountID, region string) *InMemoryBackend

+ func NewInMemoryBackendWithContext(svcCtx context.Context, accountID, region string) *InMemoryBackend

+ func (b *InMemoryBackend) AddAnomalyInternal(anomaly Anomaly)

+ func (b *InMemoryBackend) AddDeliveryInternal(delivery Delivery)

+ func (b *InMemoryBackend) AddExportTaskInternal(task ExportTask)

+ func (b *InMemoryBackend) AddImportTaskInternal(task ImportTask)

+ func (b *InMemoryBackend) AddLogAnomalyDetectorInternal(detector LogAnomalyDetector)

+ func (b *InMemoryBackend) AddScheduledQueryRunInternal(scheduledQueryArn string, run ScheduledQueryRunSummary)

+ func (b *InMemoryBackend) AssociateKmsKey(logGroupName, resourceIdentifier, kmsKeyID string) error

+ func (b *InMemoryBackend) AssociateSourceToS3TableIntegration(integrationArn, _, _ string) (string, error)

+ func (b *InMemoryBackend) CancelExportTask(taskID string) error

+ func (b *InMemoryBackend) CancelImportTask(importID string) (*ImportTask, error)

+ func (b *InMemoryBackend) Close()

+ func (b *InMemoryBackend) CreateDelivery(deliverySourceName, deliveryDestinationArn string, tags map[string]string) (*Delivery, error)

+ func (b *InMemoryBackend) CreateExportTask(...) (string, error)

+ func (b *InMemoryBackend) CreateImportTask(importRoleArn, importSourceArn string) (*ImportTask, error)

+ func (b *InMemoryBackend) CreateLogAnomalyDetector(logGroupArnList []string, ...) (string, error)

+ func (b *InMemoryBackend) CreateLogGroup(ctx context.Context, name, logGroupClass, kmsKeyID string) (*LogGroup, error)

+ func (b *InMemoryBackend) CreateLogStream(ctx context.Context, groupName, streamName string) (*LogStream, error)

+ func (b *InMemoryBackend) CreateScheduledQuery(name, queryString, scheduleExpression, _, state string) (string, error)

+ func (b *InMemoryBackend) DeleteAccountPolicy(policyName, policyType string) error

+ func (b *InMemoryBackend) DeleteDataProtectionPolicy(logGroupIdentifier string) error

+ func (b *InMemoryBackend) DeleteDelivery(id string) error

+ func (b *InMemoryBackend) DeleteDeliveryDestination(name string) error

+ func (b *InMemoryBackend) DeleteDeliveryDestinationPolicy(name string) error

+ func (b *InMemoryBackend) DeleteDeliverySource(name string) error

+ func (b *InMemoryBackend) DeleteDestination(name string) error

+ func (b *InMemoryBackend) DeleteIndexPolicy(logGroupIdentifier string) error

+ func (b *InMemoryBackend) DeleteIntegration(name string) error

+ func (b *InMemoryBackend) DeleteLogAnomalyDetector(detectorArn string) error

+ func (b *InMemoryBackend) DeleteLogGroup(ctx context.Context, name string) error

+ func (b *InMemoryBackend) DeleteLogStream(ctx context.Context, groupName, streamName string) error

+ func (b *InMemoryBackend) DeleteMetricFilter(ctx context.Context, logGroupName, filterName string) error

+ func (b *InMemoryBackend) DeleteQueryDefinition(queryDefinitionID string) error

+ func (b *InMemoryBackend) DeleteResourcePolicy(policyName string) error

+ func (b *InMemoryBackend) DeleteScheduledQuery(scheduledQueryArn string) error

+ func (b *InMemoryBackend) DeleteSubscriptionFilter(ctx context.Context, groupName, filterName string) error

+ func (b *InMemoryBackend) DeleteTransformer(logGroupIdentifier string) error

+ func (b *InMemoryBackend) DescribeAccountPolicies(policyType, policyName string, _ []string, limit int, nextToken string) ([]AccountPolicy, string, error)

+ func (b *InMemoryBackend) DescribeDeliveries(limit int, nextToken string) ([]Delivery, string, error)

+ func (b *InMemoryBackend) DescribeDeliveryDestinations() []DeliveryDestination

+ func (b *InMemoryBackend) DescribeDeliverySources() []DeliverySource

+ func (b *InMemoryBackend) DescribeDestinations(namePrefix string) []CWLDestination

+ func (b *InMemoryBackend) DescribeExportTasks(taskID, statusCode string, limit int, nextToken string) ([]ExportTask, string, error)

+ func (b *InMemoryBackend) DescribeImportTasks(taskID string, limit int, nextToken string) ([]ImportTask, string, error)

+ func (b *InMemoryBackend) DescribeIndexPolicies() []IndexPolicy

+ func (b *InMemoryBackend) DescribeLogGroups(ctx context.Context, prefix, nextToken string, limit int) ([]LogGroup, string, error)

+ func (b *InMemoryBackend) DescribeLogStreams(ctx context.Context, groupName, prefix, nextToken, orderBy string, ...) ([]LogStream, string, error)

+ func (b *InMemoryBackend) DescribeMetricFilters(ctx context.Context, ...) ([]MetricFilter, string, error)

+ func (b *InMemoryBackend) DescribeQueries(logGroupName, statusFilter, nextToken string, maxResults int) ([]QueryInfo, string, error)

+ func (b *InMemoryBackend) DescribeQueryDefinitions(queryDefinitionNamePrefix string, limit int, nextToken string) ([]QueryDefinition, string, error)

+ func (b *InMemoryBackend) DescribeResourcePolicies() []ResourcePolicy

+ func (b *InMemoryBackend) DescribeSubscriptionFilters(ctx context.Context, groupName, filterNamePrefix, nextToken string, limit int) ([]SubscriptionFilter, string, error)

+ func (b *InMemoryBackend) DisassociateKmsKey(logGroupName, resourceIdentifier string) error

+ func (b *InMemoryBackend) DiscoverLogFields(ctx context.Context, logGroupName string) ([]string, error)

+ func (b *InMemoryBackend) Drain()

+ func (b *InMemoryBackend) FilterLogEvents(ctx context.Context, p FilterLogEventsParams) ([]FilteredLogEvent, string, []SearchedLogStream, error)

+ func (b *InMemoryBackend) GetDataProtectionPolicy(logGroupIdentifier string) (string, error)

+ func (b *InMemoryBackend) GetDelivery(id string) (*Delivery, error)

+ func (b *InMemoryBackend) GetDeliveryDestination(name string) (*DeliveryDestination, error)

+ func (b *InMemoryBackend) GetDeliveryDestinationPolicy(name string) (string, error)

+ func (b *InMemoryBackend) GetDeliverySource(name string) (*DeliverySource, error)

+ func (b *InMemoryBackend) GetIntegration(name string) (*CWLIntegration, error)

+ func (b *InMemoryBackend) GetLogAnomalyDetector(detectorArn string) (*LogAnomalyDetector, error)

+ func (b *InMemoryBackend) GetLogEvents(ctx context.Context, groupName, streamName string, startTime, endTime *int64, ...) ([]OutputLogEvent, string, string, error)

+ func (b *InMemoryBackend) GetLogGroupFields(ctx context.Context, logGroupName string) ([]LogGroupField, error)

+ func (b *InMemoryBackend) GetLogRecord(ctx context.Context, logRecordPointer string) (map[string]string, error)

+ func (b *InMemoryBackend) GetQueryResults(queryID string) ([][]ResultField, QueryStatistics, QueryStatus, error)

+ func (b *InMemoryBackend) GetScheduledQuery(scheduledQueryArn string) (*ScheduledQuery, error)

+ func (b *InMemoryBackend) GetScheduledQueryHistory(scheduledQueryArn string, nextToken string, maxResults int) ([]ScheduledQueryRunSummary, string, error)

+ func (b *InMemoryBackend) GetTransformer(logGroupIdentifier string) (*Transformer, error)

+ func (b *InMemoryBackend) IsLogGroupDeletionProtected(logGroupIdentifier string) bool

+ func (b *InMemoryBackend) ListAggregateLogGroupSummaries(ctx context.Context) []AggregateLogGroupSummary

+ func (b *InMemoryBackend) ListAnomalies(anomalyDetectorArn string, limit int, nextToken string) ([]Anomaly, string, error)

+ func (b *InMemoryBackend) ListIntegrations() []CWLIntegration

+ func (b *InMemoryBackend) ListLogAnomalyDetectors(filterLogGroupArnList []string, limit int, nextToken string) ([]LogAnomalyDetector, string, error)

+ func (b *InMemoryBackend) ListLogGroups(ctx context.Context, namePrefix, nextToken string, limit int) ([]LogGroup, string, error)

+ func (b *InMemoryBackend) ListLogGroupsForQuery(queryID string) ([]string, error)

+ func (b *InMemoryBackend) ListScheduledQueries(limit int, nextToken string) ([]ScheduledQuery, string, error)

+ func (b *InMemoryBackend) PutAccountPolicy(policyName, policyType, policyDocument, scope, selectionCriteria string) (*AccountPolicy, error)

+ func (b *InMemoryBackend) PutDataProtectionPolicy(logGroupIdentifier, policyDocument string) error

+ func (b *InMemoryBackend) PutDeliveryDestination(name, targetArn, outputFormat string, tags map[string]string) (*DeliveryDestination, error)

+ func (b *InMemoryBackend) PutDeliveryDestinationPolicy(name, policy string) error

+ func (b *InMemoryBackend) PutDeliverySource(name, logType string, resourceArns []string, tags map[string]string) (*DeliverySource, error)

+ func (b *InMemoryBackend) PutDestination(name, targetArn, roleArn string) (*CWLDestination, error)

+ func (b *InMemoryBackend) PutDestinationPolicy(name, policy string) error

+ func (b *InMemoryBackend) PutIndexPolicy(logGroupIdentifier, policyDocument string) (*IndexPolicy, error)

+ func (b *InMemoryBackend) PutIntegration(name, integrationType string) (*CWLIntegration, error)

+ func (b *InMemoryBackend) PutLogEvents(ctx context.Context, groupName, streamName, _ string, events []InputLogEvent) (*PutLogEventsResult, error)

+ func (b *InMemoryBackend) PutMetricFilter(ctx context.Context, logGroupName, filterName, filterPattern string, ...) error

+ func (b *InMemoryBackend) PutQueryDefinition(name, queryString, queryDefinitionID string, logGroupNames []string) (string, error)

+ func (b *InMemoryBackend) PutResourcePolicy(policyName, policyDocument string) (*ResourcePolicy, error)

+ func (b *InMemoryBackend) PutSubscriptionFilter(ctx context.Context, ...) error

+ func (b *InMemoryBackend) PutTransformer(logGroupIdentifier string, processors []map[string]any) error

+ func (b *InMemoryBackend) Reset()

+ func (b *InMemoryBackend) Restore(ctx context.Context, data []byte) error

+ func (b *InMemoryBackend) SetDeliveryTimeout(d time.Duration)

+ func (b *InMemoryBackend) SetDeliveryWorkers(n int)

+ func (b *InMemoryBackend) SetExportSink(sink ExportSink)

+ func (b *InMemoryBackend) SetLogGroupDeletionProtection(logGroupIdentifier string, protected bool) error

+ func (b *InMemoryBackend) SetMaxQueries(n int)

+ func (b *InMemoryBackend) SetMetricEmitter(e MetricEmitter)

+ func (b *InMemoryBackend) SetQueryStatusInternal(queryID string, status QueryStatus)

+ func (b *InMemoryBackend) SetQueryTTL(d time.Duration)

+ func (b *InMemoryBackend) SetRetentionPolicy(ctx context.Context, groupName string, days *int32) error

+ func (b *InMemoryBackend) SetSettings(s Settings)

+ func (b *InMemoryBackend) SetSubscriptionDeliverer(d SubscriptionDeliverer)

+ func (b *InMemoryBackend) Snapshot(ctx context.Context) []byte

+ func (b *InMemoryBackend) StartQuery(ctx context.Context, queryID, queryString string, logGroupNames []string, ...) (*QueryInfo, error)

+ func (b *InMemoryBackend) StopQuery(queryID string) error

+ func (b *InMemoryBackend) TestMetricFilter(filterPattern string, logEventMessages []string) ([]MetricFilterMatchRecord, error)

+ func (b *InMemoryBackend) UpdateAnomaly(anomalyID, anomalyDetectorArn, suppressionType string) error

+ func (b *InMemoryBackend) UpdateDeliveryConfiguration(id, fieldDelimiter string, recordFields []string) error

+ func (b *InMemoryBackend) UpdateLogAnomalyDetector(detectorArn, evaluationFrequency string, anomalyVisibilityTime int64) error

+ func (b *InMemoryBackend) UpdateScheduledQuery(scheduledQueryArn, state string) error

+ func (b *InMemoryBackend) ValidateLiveTailLogGroups(ctx context.Context, logGroupIdentifiers []string) error

+ type IndexPolicy struct

+ LastUpdated time.Time

+ LogGroupIdentifier string

+ PolicyDocument string

+ type InputLogEvent struct

+ Message string

+ Timestamp int64

+ type Janitor struct

+ Backend *InMemoryBackend

+ Interval time.Duration

+ TaskTimeout time.Duration

+ func NewJanitor(backend *InMemoryBackend, interval time.Duration) *Janitor

+ func (j *Janitor) Run(ctx context.Context)

+ func (j *Janitor) SweepOnce(ctx context.Context)

+ type LogAnomalyDetector struct

+ AnomalyDetectorArn string

+ AnomalyVisibilityTime int64

+ CreationTimeStamp int64

+ DetectorName string

+ DetectorStatus string

+ EvaluationFrequency string

+ EvaluationLookback int64

+ FilterAnomalies bool

+ FilterPattern string

+ KmsKeyID string

+ LastModifiedTimeStamp int64

+ LogGroupArnList []string

+ type LogGroup struct

+ Arn string

+ CreationTime int64

+ KmsKeyID string

+ LogGroupClass string

+ LogGroupName string

+ MetricFilterCount int32

+ RetentionInDays *int32

+ StoredBytes int64

+ type LogGroupField struct

+ Name string

+ Percent int32

+ type LogStream struct

+ Arn string

+ CreationTime int64

+ FirstEventTimestamp *int64

+ LastEventTimestamp *int64

+ LastIngestionTime *int64

+ LogStreamName string

+ StoredBytes int64

+ UploadSequenceToken string

+ type MetricEmitter interface

+ EmitMetric func(namespace, name string, value float64, unit string) error

+ type MetricEmitterFunc func(namespace, name string, value float64, unit string) error

+ func (f MetricEmitterFunc) EmitMetric(namespace, name string, value float64, unit string) error

+ type MetricFilter struct

+ CreationTime int64

+ FilterName string

+ FilterPattern string

+ LogGroupName string

+ MetricTransformations []MetricTransformation

+ RetentionInDays *int32

+ type MetricFilterMatchRecord struct

+ EventMessage string

+ EventNumber int64

+ ExtractedValues map[string]string

+ type MetricTransformation struct

+ DefaultValue *float64

+ Dimensions map[string]string

+ MetricName string

+ MetricNamespace string

+ MetricValue string

+ Unit string

+ type OutputLogEvent struct

+ IngestionTime int64

+ Message string

+ Ptr string

+ Timestamp int64

+ type Provider struct

+ func (p *Provider) Init(ctx *service.AppContext) (service.Registerable, error)

+ func (p *Provider) Name() string

+ type PutLogEventsResult struct

+ NextSequenceToken string

+ RejectedLogEventsInfo *RejectedLogEventsInfo

+ type QueryDefinition struct

+ LastModified int64

+ LogGroupNames []string

+ Name string

+ QueryDefinitionID string

+ QueryString string

+ type QueryInfo struct

+ CreateTime int64

+ LogGroupName string

+ QueryID string

+ QueryString string

+ Status QueryStatus

+ type QueryStatistics struct

+ BytesScanned float64

+ RecordsMatched float64

+ RecordsScanned float64

+ type QueryStatus string

+ const QueryStatusCancelled

+ const QueryStatusComplete

+ const QueryStatusFailed

+ const QueryStatusRunning

+ const QueryStatusScheduled

+ type RejectedLogEventsInfo struct

+ ExpiredLogEventEndIndex *int32

+ TooNewLogEventStartIndex *int32

+ TooOldLogEventEndIndex *int32

+ type ResourcePolicy struct

+ LastUpdated time.Time

+ PolicyDocument string

+ PolicyName string

+ type ResultField struct

+ Field string

+ Value string

+ type ScheduledQuery struct

+ Arn string

+ CreationTime int64

+ Name string

+ QueryString string

+ ScheduleExpression string

+ State string

+ type ScheduledQueryRunSummary struct

+ Arn string

+ ExecutionTime int64

+ FailureReason string

+ InvocationTime int64

+ RunStatus string

+ type SearchedLogStream struct

+ LogStreamName string

+ SearchedCompletely bool

+ type Settings struct

+ JanitorInterval time.Duration

+ MaxRetentionDays int

+ type StorageBackend interface

+ AssociateKmsKey func(logGroupName, resourceIdentifier, kmsKeyID string) error

+ AssociateSourceToS3TableIntegration func(integrationArn, dataSourceName, dataSourceType string) (string, error)

+ CancelExportTask func(taskID string) error

+ CancelImportTask func(importID string) (*ImportTask, error)

+ CreateDelivery func(deliverySourceName, deliveryDestinationArn string, tags map[string]string) (*Delivery, error)

+ CreateExportTask func(...) (string, error)

+ CreateImportTask func(importRoleArn, importSourceArn string) (*ImportTask, error)

+ CreateLogAnomalyDetector func(logGroupArnList []string, ...) (string, error)

+ CreateLogGroup func(ctx context.Context, name, logGroupClass, kmsKeyID string) (*LogGroup, error)

+ CreateLogStream func(ctx context.Context, groupName, streamName string) (*LogStream, error)

+ CreateScheduledQuery func(name, queryString, scheduleExpression, executionRoleArn, state string) (string, error)

+ DeleteAccountPolicy func(policyName, policyType string) error

+ DeleteDelivery func(id string) error

+ DeleteLogAnomalyDetector func(detectorArn string) error

+ DeleteLogGroup func(ctx context.Context, name string) error

+ DeleteLogStream func(ctx context.Context, groupName, streamName string) error

+ DeleteMetricFilter func(ctx context.Context, logGroupName, filterName string) error

+ DeleteQueryDefinition func(queryDefinitionID string) error

+ DeleteScheduledQuery func(scheduledQueryArn string) error

+ DeleteSubscriptionFilter func(ctx context.Context, groupName, filterName string) error

+ DescribeAccountPolicies func(policyType, policyName string, accountIdentifiers []string, limit int, ...) ([]AccountPolicy, string, error)

+ DescribeDeliveries func(limit int, nextToken string) ([]Delivery, string, error)

+ DescribeExportTasks func(taskID, statusCode string, limit int, nextToken string) ([]ExportTask, string, error)

+ DescribeImportTasks func(taskID string, limit int, nextToken string) ([]ImportTask, string, error)

+ DescribeLogGroups func(ctx context.Context, prefix, nextToken string, limit int) ([]LogGroup, string, error)

+ DescribeLogStreams func(ctx context.Context, groupName, prefix, nextToken, orderBy string, ...) ([]LogStream, string, error)

+ DescribeMetricFilters func(ctx context.Context, ...) ([]MetricFilter, string, error)

+ DescribeQueries func(logGroupName, statusFilter, nextToken string, maxResults int) ([]QueryInfo, string, error)

+ DescribeQueryDefinitions func(queryDefinitionNamePrefix string, limit int, nextToken string) ([]QueryDefinition, string, error)

+ DescribeSubscriptionFilters func(ctx context.Context, groupName, filterNamePrefix, nextToken string, limit int) ([]SubscriptionFilter, string, error)

+ DisassociateKmsKey func(logGroupName, resourceIdentifier string) error

+ FilterLogEvents func(ctx context.Context, p FilterLogEventsParams) ([]FilteredLogEvent, string, []SearchedLogStream, error)

+ GetDelivery func(id string) (*Delivery, error)

+ GetLogAnomalyDetector func(detectorArn string) (*LogAnomalyDetector, error)

+ GetLogEvents func(ctx context.Context, groupName, streamName string, startTime, endTime *int64, ...) ([]OutputLogEvent, string, string, error)

+ GetLogGroupFields func(ctx context.Context, logGroupName string) ([]LogGroupField, error)

+ GetLogRecord func(ctx context.Context, logRecordPointer string) (map[string]string, error)

+ GetQueryResults func(queryID string) ([][]ResultField, QueryStatistics, QueryStatus, error)

+ GetScheduledQuery func(scheduledQueryArn string) (*ScheduledQuery, error)

+ GetScheduledQueryHistory func(scheduledQueryArn string, nextToken string, maxResults int) ([]ScheduledQueryRunSummary, string, error)

+ ListAnomalies func(anomalyDetectorArn string, limit int, nextToken string) ([]Anomaly, string, error)

+ ListLogAnomalyDetectors func(filterLogGroupArnList []string, limit int, nextToken string) ([]LogAnomalyDetector, string, error)

+ ListLogGroups func(ctx context.Context, namePrefix, nextToken string, limit int) ([]LogGroup, string, error)

+ ListLogGroupsForQuery func(queryID string) ([]string, error)

+ ListScheduledQueries func(limit int, nextToken string) ([]ScheduledQuery, string, error)

+ PutAccountPolicy func(policyName, policyType, policyDocument, scope, selectionCriteria string) (*AccountPolicy, error)

+ PutLogEvents func(ctx context.Context, groupName, streamName, sequenceToken string, ...) (*PutLogEventsResult, error)

+ PutMetricFilter func(ctx context.Context, logGroupName, filterName, filterPattern string, ...) error

+ PutQueryDefinition func(name, queryString, queryDefinitionID string, logGroupNames []string) (string, error)

+ PutSubscriptionFilter func(ctx context.Context, ...) error

+ SetRetentionPolicy func(ctx context.Context, groupName string, days *int32) error

+ StartQuery func(ctx context.Context, queryID, queryString string, logGroupNames []string, ...) (*QueryInfo, error)

+ StopQuery func(queryID string) error

+ TestMetricFilter func(filterPattern string, logEventMessages []string) ([]MetricFilterMatchRecord, error)

+ UpdateAnomaly func(anomalyID, anomalyDetectorArn string, suppressionType string) error

+ UpdateLogAnomalyDetector func(detectorArn, evaluationFrequency string, anomalyVisibilityTime int64) error

+ UpdateScheduledQuery func(scheduledQueryArn, state string) error

+ type SubscriptionDeliverer interface

+ DeliverLogEvents func(ctx context.Context, destinationArn string, payload []byte) error

+ type SubscriptionDelivererFunc func(ctx context.Context, destinationArn string, payload []byte) error

+ func (f SubscriptionDelivererFunc) DeliverLogEvents(ctx context.Context, destinationArn string, payload []byte) error

+ type SubscriptionFilter struct

+ CreationTime int64

+ DestinationArn string

+ Distribution string

+ FilterName string

+ FilterPattern string

+ LogGroupName string

+ RoleArn string

+ type TestTransformerOutput struct

+ EventMessage string

+ EventNumber int64

+ TransformedEventMessage string

+ func ApplyTransformer(messages []string, processors []map[string]any) []TestTransformerOutput

+ type Transformer struct

+ CreatedAt time.Time

+ LogGroupIdentifier string

+ Processors []map[string]any

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL