records

Documentation

Index

• type LogBatch
• type LogEntry
• type LogMessage
  • func UncompressLogs(ts *time.Time, data []byte) ([]*LogMessage, error)

Types

type LogBatch

type LogBatch struct {
	MessageType         string      `json:"messageType,omitempty"`
	Owner               string      `json:"owner,omitempty"`
	LogGroup            string      `json:"logGroup,omitempty"`
	LogStream           string      `json:"logStream,omitempty"`
	SubscriptionFilters []string    `json:"subscriptionFilters,omitempty"`
	LogEvents           []*LogEntry `json:"logEvents,omitempty"`
}

LogBatch matches the cloudwatch logs batch structure

type LogEntry

type LogEntry struct {
	ID        string `json:"id,omitempty"`
	Timestamp int64  `json:"timestamp,omitempty"`
	Message   string `json:"message,omitempty"`
}

LogEntry matches the cloudwatch log entry structure

type LogMessage

type LogMessage struct {
	LogGroup  string // optional log group
	Message   string
	Timestamp string
}

LogMessage log message after decompression and parsing

func UncompressLogs

func UncompressLogs(ts *time.Time, data []byte) ([]*LogMessage, error)

UncompressLogs takes gziped CloudWatch Log batch data and returns LogMessage(s)