cloudwatchlogs

package

Go to main page

Versions in this module

v1

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