cloudwatchlogs

Documentation

Overview

Generated by go-decorator, DO NOT EDIT

Index

• Constants
• type CloudWatchLogs
  • func (this *CloudWatchLogs) CreateLogGroup(logGroupName string) error
  • func (this *CloudWatchLogs) DeleteLogGroup(logGroupName string) error
  • func (this *CloudWatchLogs) DescribeLogGroups(logGroupNamePrefix string, nextToken *string) ([]*LogGroup, error)
  • func (this *CloudWatchLogs) DescribeLogStreams(logGroupName, orderBy string) ([]*LogStream, error)
  • func (this *CloudWatchLogs) FilterLogEvents(filterPattern, logGroupName, nextToken *string, logStreamNames []*string, ...) ([]*FilteredLogEvent, []*SearchedLogStream, error)
  • func (this *CloudWatchLogs) GetLogEvents(logGroupName string, logStreamName string, start string, end string, ...) ([]*OutputLogEvent, error)
• type CloudWatchLogsInternal
  • func Connect(credProvider provider.CredProvider, region string) (CloudWatchLogsInternal, error)
• type FilteredLogEvent
• type LogGroup
• type LogStream
  • func NewLogStream(name string) *LogStream
• type OutputLogEvent
  • func NewOutputLogEvent(message string) *OutputLogEvent
• type Provider
  • func NewCloudWatchLogs(credProvider provider.CredProvider, region string) (Provider, error)
• type ProviderDecorator
  • func (this *ProviderDecorator) CreateLogGroup(p0 string) (err error)
  • func (this *ProviderDecorator) DeleteLogGroup(p0 string) (err error)
  • func (this *ProviderDecorator) DescribeLogGroups(p0 string, p1 *string) (v0 []*LogGroup, err error)
  • func (this *ProviderDecorator) DescribeLogStreams(p0 string, p1 string) (v0 []*LogStream, err error)
  • func (this *ProviderDecorator) FilterLogEvents(p0 *string, p1 *string, p2 *string, p3 []*string, p4 *int64, p5 *int64, ...) (v0 []*FilteredLogEvent, v1 []*SearchedLogStream, err error)
  • func (this *ProviderDecorator) GetLogEvents(p0 string, p1 string, p2 string, p3 string, p4 int64) (v0 []*OutputLogEvent, err error)
• type SearchedLogStream

Constants

const (
	// DescribeLogStreams is throttled after five transactions per second.
	// With 50 streams/transaction, 1000 gives a reasonable streams:time ratio
	MAX_DESCRIBE_STREAMS_COUNT = 1000
	// 'YYYY-MM-DD HH:MM' time layout as described by https://golang.org/src/time/format.go
	TIME_LAYOUT = "2006-01-02 15:04"
)

Types

type CloudWatchLogs

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

func (*CloudWatchLogs) CreateLogGroup

func (this *CloudWatchLogs) CreateLogGroup(logGroupName string) error

func (*CloudWatchLogs) DeleteLogGroup

func (this *CloudWatchLogs) DeleteLogGroup(logGroupName string) error

func (*CloudWatchLogs) DescribeLogGroups

func (this *CloudWatchLogs) DescribeLogGroups(logGroupNamePrefix string, nextToken *string) ([]*LogGroup, error)

func (*CloudWatchLogs) DescribeLogStreams

func (this *CloudWatchLogs) DescribeLogStreams(logGroupName, orderBy string) ([]*LogStream, error)

func (*CloudWatchLogs) FilterLogEvents

func (this *CloudWatchLogs) FilterLogEvents(
	filterPattern,
	logGroupName,
	nextToken *string,
	logStreamNames []*string,
	endTime,
	startTime *int64,
	interleaved *bool) ([]*FilteredLogEvent, []*SearchedLogStream, error)

func (*CloudWatchLogs) GetLogEvents

func (this *CloudWatchLogs) GetLogEvents(
	logGroupName string,
	logStreamName string,
	start string,
	end string,
	limit int64,
) ([]*OutputLogEvent, error)

type CloudWatchLogsInternal

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)
}

func Connect

func Connect(credProvider provider.CredProvider, region string) (CloudWatchLogsInternal, error)

type FilteredLogEvent

type FilteredLogEvent struct {
	*cloudwatchlogs.FilteredLogEvent
}

type LogGroup

type LogGroup struct {
	*cloudwatchlogs.LogGroup
}

type LogStream

type LogStream struct {
	*cloudwatchlogs.LogStream
}

func NewLogStream

func NewLogStream(name string) *LogStream

type OutputLogEvent

type OutputLogEvent struct {
	*cloudwatchlogs.OutputLogEvent
}

func NewOutputLogEvent

func NewOutputLogEvent(message string) *OutputLogEvent

type Provider

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)
}

func NewCloudWatchLogs

func NewCloudWatchLogs(credProvider provider.CredProvider, region string) (Provider, error)

type ProviderDecorator

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

func (*ProviderDecorator) CreateLogGroup

func (this *ProviderDecorator) CreateLogGroup(p0 string) (err error)

func (*ProviderDecorator) DeleteLogGroup

func (this *ProviderDecorator) DeleteLogGroup(p0 string) (err error)

func (*ProviderDecorator) DescribeLogGroups

func (this *ProviderDecorator) DescribeLogGroups(p0 string, p1 *string) (v0 []*LogGroup, err error)

func (*ProviderDecorator) DescribeLogStreams

func (this *ProviderDecorator) DescribeLogStreams(p0 string, p1 string) (v0 []*LogStream, err error)

func (*ProviderDecorator) FilterLogEvents

func (this *ProviderDecorator) FilterLogEvents(p0 *string, p1 *string, p2 *string, p3 []*string, p4 *int64, p5 *int64, p6 *bool) (v0 []*FilteredLogEvent, v1 []*SearchedLogStream, err error)

func (*ProviderDecorator) GetLogEvents

func (this *ProviderDecorator) GetLogEvents(p0 string, p1 string, p2 string, p3 string, p4 int64) (v0 []*OutputLogEvent, err error)

type SearchedLogStream

type SearchedLogStream struct {
	*cloudwatchlogs.SearchedLogStream
}