cloudwatch

Documentation

Index

• func EnsureGroupNameIsValid(name string) string
• func EnsureStreamNameIsValid(name string) string
• type Administration
  • func GetAdministration() (Administration, errors.TracerError)
• type EventQueue
  • func NewEventQueue() EventQueue

Functions

func EnsureGroupNameIsValid

func EnsureGroupNameIsValid(name string) string

EnsureGroupNameIsValid based upon the rules from aws:

• Log group names must be unique within a region for an AWS account.
• Log group names can be between 1 and 512 characters long.
• Log group names consist of the following characters: a-z, A-Z, 0-9, '_' (underscore), '-' (hyphen), '/' (forward slash), and '.' (period).

func EnsureStreamNameIsValid

func EnsureStreamNameIsValid(name string) string

EnsureStreamNameIsValid based upon the provided rules from AWS

• Log stream names must be unique within the log group.
• Log stream names can be between 1 and 512 characters long.
• The ':' (colon) and '*' (asterisk) characters are not allowed.

Types

type Administration

type Administration interface {
	// GetOutput for the specified group and output name.
	GetOutput(groupName, outputName string, logLevel log.LevelFlag) (log.Output, errors.TracerError)
}

Administration provides a layer that manages the control of cloud watch logs to behave like a standard log output.

func GetAdministration

func GetAdministration() (Administration, errors.TracerError)

GetAdministration for cloud watch logs

type EventQueue

type EventQueue interface {
	// Size of this queue
	Size() int
	// Push the passed event onto this queue
	Push(event *cloudwatchlogs.InputLogEvent)
	// Pop the last event pushed off this queue
	Pop() (*cloudwatchlogs.InputLogEvent, error)
	// Peek at the next event that will be popped.
	Peek() (*cloudwatchlogs.InputLogEvent, error)
}

EventQueue for buffering cloud watch events.

func NewEventQueue

func NewEventQueue() EventQueue

NewEventQueue that is empty.