Documentation
¶
Index ¶
- func FilterAwsLogs(dst *Destination, goroutines int, timePeriod []common.TimeDuration)
- func LimitHandler(num *string) (int64, int64)
- func ListLogGroups(dst *Destination)
- func ListStreams(dst *Destination)
- func SetupCloseHandler()
- func WatchAwsLogs(dst *Destination, timePeriod []common.TimeDuration)
- func WriteToCli(data []*cloudwatchlogs.FilterLogEventsOutput)
- func WriteToFile(filename string, data []*cloudwatchlogs.FilterLogEventsOutput)
- type Destination
- func (dst *Destination) FilterAwsLogs(startTime, endTime int64) ([]*cloudwatchlogs.FilterLogEventsOutput, error)
- func (dst *Destination) ListLogGroups() []*string
- func (dst *Destination) ListStreams() []*string
- func (dst *Destination) NewFilter(startTime, endTime int64) *cloudwatchlogs.FilterLogEventsInput
- func (dst *Destination) NewListGroup() *cloudwatchlogs.DescribeLogGroupsInput
- func (dst *Destination) NewStreams() *cloudwatchlogs.DescribeLogStreamsInput
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FilterAwsLogs ¶
func FilterAwsLogs(dst *Destination, goroutines int, timePeriod []common.TimeDuration)
func LimitHandler ¶
func ListLogGroups ¶
func ListLogGroups(dst *Destination)
func ListStreams ¶
func ListStreams(dst *Destination)
func SetupCloseHandler ¶
func SetupCloseHandler()
func WatchAwsLogs ¶
func WatchAwsLogs(dst *Destination, timePeriod []common.TimeDuration)
func WriteToCli ¶
func WriteToCli(data []*cloudwatchlogs.FilterLogEventsOutput)
func WriteToFile ¶
func WriteToFile(filename string, data []*cloudwatchlogs.FilterLogEventsOutput)
Types ¶
type Destination ¶
type Destination struct {
Group string
NextToken string
Limit int64
MaxItems int64
FilterPattern string
Streams []*string
StreamPrefix string
WatchInterval int
Watch bool
Descending bool
OrderBy string
WriteToFile bool
Svc *cloudwatchlogs.CloudWatchLogs
// contains filtered or unexported fields
}
func (*Destination) FilterAwsLogs ¶
func (dst *Destination) FilterAwsLogs(startTime, endTime int64) ([]*cloudwatchlogs.FilterLogEventsOutput, error)
func (*Destination) ListLogGroups ¶
func (dst *Destination) ListLogGroups() []*string
func (*Destination) ListStreams ¶
func (dst *Destination) ListStreams() []*string
func (*Destination) NewFilter ¶
func (dst *Destination) NewFilter(startTime, endTime int64) *cloudwatchlogs.FilterLogEventsInput
func (*Destination) NewListGroup ¶
func (dst *Destination) NewListGroup() *cloudwatchlogs.DescribeLogGroupsInput
func (*Destination) NewStreams ¶
func (dst *Destination) NewStreams() *cloudwatchlogs.DescribeLogStreamsInput
Source Files
Click to show internal directories.
Click to hide internal directories.