outgoing

Documentation

Index

• type Data
• type Document
• type LogEvent
• type Record

Types

type Data

type Data struct {
	MessageType         string   `json:"messageType"`
	Owner               string   `json:"owner"`
	LogGroup            string   `json:"logGroup"`
	LogStream           string   `json:"logStream"`
	SubscriptionFilters []string `json:"subscriptionFilters"`
	LogEvent            LogEvent `json:"logEvents"`
}

type Document

type Document struct {
	RequestID string    `json:"requestId"`
	TimeStamp time.Time `json:"@timestamp"`
	Record    Record    `json:"records"`
}

Document is the body sent to OpenSearch It tries to closly resumble the FirehoseRequest as much as possible It deviates from the FirehoseRequest in that it does not contain nested events Each event is sent as a separate document

type LogEvent

type LogEvent struct {
	ID        string          `json:"id"`
	Timestamp time.Time       `json:"timestamp"`
	Message   json.RawMessage `json:"message"`
}

type Record

type Record struct {
	Data Data `json:"data"`
}