incoming

Documentation

Index

• type Data
• type FirehoseRequest
  • func UnmarshalFirehoseRequest(data []byte) (FirehoseRequest, error)
  • func (r *FirehoseRequest) Marshal() ([]byte, error)
• 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"`
	LogEvents           []LogEvent `json:"logEvents"`
}

type FirehoseRequest

type FirehoseRequest struct {
	RequestID string   `json:"requestId"`
	Timestamp int64    `json:"timestamp"`
	Records   []Record `json:"records"`
}

func UnmarshalFirehoseRequest

func UnmarshalFirehoseRequest(data []byte) (FirehoseRequest, error)

func (*FirehoseRequest) Marshal

func (r *FirehoseRequest) Marshal() ([]byte, error)

type LogEvent

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

type Record

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