Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ByTimestamp ¶
type ByTimestamp []*LogMessage
ByTimestamp used to sort log messages
func (ByTimestamp) Len ¶
func (a ByTimestamp) Len() int
func (ByTimestamp) Less ¶
func (a ByTimestamp) Less(i, j int) bool
func (ByTimestamp) Swap ¶
func (a ByTimestamp) Swap(i, j int)
type KinesisHelper ¶
type KinesisHelper struct {
// contains filtered or unexported fields
}
KinesisHelper simple helper for general high level kinesis operations
func New ¶
func New(svc kinesisiface.KinesisAPI, logger *logrus.Logger) *KinesisHelper
New build a new configured kinesis helper
func (*KinesisHelper) GetStreamIterators ¶
func (kh *KinesisHelper) GetStreamIterators(streamName string, timestamp int64) (map[string]*string, error)
GetStreamIterators build a list of iterators for the stream
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 ¶
LogMessage log message after decompression and parsing
Click to show internal directories.
Click to hide internal directories.