transport

package
v0.0.0-...-8a8a2d9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 30, 2020 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL