cloudwatchlogsqueue

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

const (
	QueueActivated            = iota //On Queue Activation
	QueueDeactivated                 // On Queue Deactivation
	LoggingDestinationChanged        // On Change in logging destination
)

Variables

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 GetLogGroup

func GetLogGroup() string

GetLogGroup returns the log group intended for logging

func GetSharingDestination

func GetSharingDestination() string

GetSharingDestination returns the destination for sharing

func IsActive

func IsActive() bool

IsActive returns true if the queue is active

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