cloudwatchlogs

type CloudWatchLogs struct {
	Connect func() (CloudWatchLogsInternal, error)
	// contains filtered or unexported fields
}

type CloudWatchLogsInternal interface {
	CreateLogGroup(input *cloudwatchlogs.CreateLogGroupInput) (*cloudwatchlogs.CreateLogGroupOutput, error)
	DeleteLogGroup(input *cloudwatchlogs.DeleteLogGroupInput) (*cloudwatchlogs.DeleteLogGroupOutput, error)
	DescribeLogGroups(input *cloudwatchlogs.DescribeLogGroupsInput) (*cloudwatchlogs.DescribeLogGroupsOutput, error)
	DescribeLogStreamsPages(input *cloudwatchlogs.DescribeLogStreamsInput, fn func(p *cloudwatchlogs.DescribeLogStreamsOutput, lastPage bool) (shouldContinue bool)) error
	GetLogEventsPages(input *cloudwatchlogs.GetLogEventsInput, fn func(p *cloudwatchlogs.GetLogEventsOutput, lastPage bool) (shouldContinue bool)) error
	FilterLogEvents(input *cloudwatchlogs.FilterLogEventsInput) (*cloudwatchlogs.FilterLogEventsOutput, error)
}

type FilteredLogEvent struct {
	*cloudwatchlogs.FilteredLogEvent
}

type LogGroup struct {
	*cloudwatchlogs.LogGroup
}

type LogStream struct {
	*cloudwatchlogs.LogStream
}

type OutputLogEvent struct {
	*cloudwatchlogs.OutputLogEvent
}

type Provider interface {
	CreateLogGroup(logGroupName string) error
	DeleteLogGroup(logGroupName string) error
	DescribeLogGroups(logGroupNamePrefix string, nextToken *string) ([]*LogGroup, error)
	DescribeLogStreams(logGroupName, orderBy string) ([]*LogStream, error)
	GetLogEvents(logGroupName, logStreamName, start, stop string, limit int64) ([]*OutputLogEvent, error)
	FilterLogEvents(filterPattern, logGroupName, nextToken *string, logStreamNames []*string, endTime, startTime *int64, interleaved *bool) ([]*FilteredLogEvent, []*SearchedLogStream, error)
}

type ProviderDecorator struct {
	Inner     Provider
	Decorator func(name string, call func() error) error
}

type SearchedLogStream struct {
	*cloudwatchlogs.SearchedLogStream
}