ktail

type ByTimestamp []*LogMessage

type KinesisHelper struct {
	// contains filtered or unexported fields
}

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"`
}

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

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