transport

Documentation

Index

• type CloudwatchState
  • func (c *CloudwatchState) Initialize()
  • func (c *CloudwatchState) Publish(msgs []*utils.ExtendedFlowMessage)
• type ExtendedWrapperState
  • func (s ExtendedWrapperState) Publish(msgs []*flowmessage.FlowMessage)
• type LogStream
  • func (l *LogStream) IngestEvents(msgs []*utils.ExtendedFlowMessage)
  • func (l *LogStream) UploadBufferedEvents()
• type NullState
  • func (s NullState) Publish(msgs []*utils.ExtendedFlowMessage)
• type SysoutState
  • func (s SysoutState) Publish(msgs []*utils.ExtendedFlowMessage)

Types

type CloudwatchState

type CloudwatchState struct {
	LogGroupName      string
	LogStream         *LogStream
	CloudwatchLogsSvc *cloudwatchlogs.CloudWatchLogs
}

func (*CloudwatchState) Initialize

func (c *CloudwatchState) Initialize()

func (*CloudwatchState) Publish

func (c *CloudwatchState) Publish(msgs []*utils.ExtendedFlowMessage)

type ExtendedWrapperState

type ExtendedWrapperState struct {
	ExtendedTransports []utils.ExtendedTransport
	Enrichers          []utils.Enricher
}

func (ExtendedWrapperState) Publish

func (s ExtendedWrapperState) Publish(msgs []*flowmessage.FlowMessage)

type LogStream

type LogStream struct {
	LogStreamName     string
	LogGroupName      string
	LastSequenceToken *string
	// contains filtered or unexported fields
}

func (*LogStream) IngestEvents

func (l *LogStream) IngestEvents(msgs []*utils.ExtendedFlowMessage)

func (*LogStream) UploadBufferedEvents

func (l *LogStream) UploadBufferedEvents()

type NullState

type NullState struct {
}

func (NullState) Publish

func (s NullState) Publish(msgs []*utils.ExtendedFlowMessage)

type SysoutState

type SysoutState struct {
}

func (SysoutState) Publish

func (s SysoutState) Publish(msgs []*utils.ExtendedFlowMessage)