Documentation
¶
Index ¶
- Constants
- Variables
- func CreateCloudWatchDataInstance(initArgs seelog.CustomReceiverInitArgs) (err error)
- func Dequeue(pollingWaitTime time.Duration) ([]*cloudwatchlogs.InputLogEvent, error)
- func DestroyCloudWatchDataInstance()
- func Enqueue(message *cloudwatchlogs.InputLogEvent) error
- func GetLogGroup() string
- func GetSharingDestination() string
- func IsActive() bool
- func IsLogSharingEnabled() bool
- type CloudWatchLogsEvents
Constants ¶
View Source
const ( QueueActivated = iota //On Queue Activation QueueDeactivated // On Queue Deactivation LoggingDestinationChanged // On Change in logging destination )
Variables ¶
View Source
var CloudWatchLogsEventsChannel = make(chan CloudWatchLogsEvents)
CloudWatchLogsEventsChannel channel used for communication with cloudwatch publisher
Functions ¶
func CreateCloudWatchDataInstance ¶
func CreateCloudWatchDataInstance(initArgs seelog.CustomReceiverInitArgs) (err error)
CreateCloudWatchDataInstance creates an instance of logDataFacade if not created
func Dequeue ¶
func Dequeue(pollingWaitTime time.Duration) ([]*cloudwatchlogs.InputLogEvent, error)
Dequeue Returns the batch of messages present in the queue. Returns nil if no messages or no queue present
func DestroyCloudWatchDataInstance ¶
func DestroyCloudWatchDataInstance()
DestroyCloudWatchDataInstance to clear the memory of queue and enable new instance creation
func Enqueue ¶
func Enqueue(message *cloudwatchlogs.InputLogEvent) error
Enqueue to add message to queue
func GetSharingDestination ¶
func GetSharingDestination() string
GetSharingDestination returns the destination for sharing
func IsLogSharingEnabled ¶
func IsLogSharingEnabled() bool
IsLogSharingEnabled returns true if log sharing is enabled
Types ¶
type CloudWatchLogsEvents ¶
type CloudWatchLogsEvents int
CloudWatchLogsEvents event codes for changes in cloudwatchlogs publishing
Source Files
Click to show internal directories.
Click to hide internal directories.