Documentation
¶
Index ¶
Constants ¶
View Source
const ( DefaultShift time.Duration = 1 * time.Second // controls the time shift in past for the first call to CloudwatchLogs API DefaultPollingInterval time.Duration = 5 * time.Second // time between two calls to CloudwatchLogs API DefaultBufferSize uint64 = 200 // buffer size of the channel that transmits Logs to the Plugin )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
*cloudwatchlogs.CloudWatchLogs
}
Client represents a client for CloudwatchLogs API
func CreateClient ¶
CreateFilter returns a Filter for CloudwatchLogs API
func (*Client) Open ¶
func (client *Client) Open(context context.Context, filter *Filter, options *Options) (chan *cloudwatchlogs.FilteredLogEvent, chan error)
Open returns an instance with the functionn called to retrieve logs
type Filter ¶
type Filter struct {
FilterPattern string
LogGroupName string
LogStreamNamePrefix string
LogStreamNames []string
}
Filter represents a filter for retrieving logs from CloudwatchLogs API
func CreateFilter ¶
func CreateFilter(filterPattern, logGroupName, logStreamNamePrefix string, logStreamNames []string) *Filter
CreateFilter returns a Client for retrieving logs from CloudwatchLogs API
Source Files
Click to show internal directories.
Click to hide internal directories.