cloudwatch

Documentation

Index

• Constants
• func New(opts *Options) (tcpip.LinkEndpointID, *endpoint)
• func NewBridge(opts *Options) (tcpip.LinkEndpointID, *endpointBridge)
• type CloudwatchLinkAddress
  • func NewCloudwatchLinkAddress(laddr, raddr tcpip.LinkAddress, netName string) *CloudwatchLinkAddress
  • func (cw *CloudwatchLinkAddress) Dest() tcpip.LinkAddress
  • func (cw *CloudwatchLinkAddress) FullPath() string
  • func (cw *CloudwatchLinkAddress) LogGroupName() string
  • func (cw *CloudwatchLinkAddress) LogStreamName() string
  • func (cw *CloudwatchLinkAddress) Src() tcpip.LinkAddress
• type LogConfig
• type LogLink
  • func NewLogLink(config *LogConfig) *LogLink
  • func (ll *LogLink) OpenLogStream(l CloudwatchLinkAddress) error
  • func (ll *LogLink) ProtocolToString(protocol tcpip.NetworkProtocolNumber) string
  • func (ll *LogLink) Read() (*buffer.VectorisedView, error)
  • func (ll *LogLink) Start()
  • func (ll *LogLink) StringToProtocol(protocol string) tcpip.NetworkProtocolNumber
  • func (ll *LogLink) Write(l CloudwatchLinkAddress, protocol tcpip.NetworkProtocolNumber, header []byte, ...) (int, error)
• type Options
• type PacketLog
• type PutEventInput
• type ReadPollOutput
  • func (p *ReadPollOutput) Data() []byte
  • func (p *ReadPollOutput) Error() error
• type ReadPoller
  • func NewReadPoller(client cloudwatchlogsiface.CloudWatchLogsAPI) *ReadPoller
  • func (p *ReadPoller) ReadPollForBroadcast(groupName string)
  • func (p *ReadPoller) ReadPollForLogGroup(groupName string)
• type WritePollInput
  • func NewWritePollInput(data []byte, link *CloudwatchLinkAddress) WritePollInput
• type WritePoller
  • func NewWritePoller(client cloudwatchlogsiface.CloudWatchLogsAPI) *WritePoller
  • func (p *WritePoller) WritePoll()

Constants

const MTU = 1024

todo: configure this

Functions

func New

func New(opts *Options) (tcpip.LinkEndpointID, *endpoint)

New creates a new endpoint for transmitting data using Amazon Cloudwathc gorups

func NewBridge

func NewBridge(opts *Options) (tcpip.LinkEndpointID, *endpointBridge)

New creates a new endpoint for transmitting data using Amazon Cloudwathc gorups

Types

type CloudwatchLinkAddress

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

func NewCloudwatchLinkAddress

func NewCloudwatchLinkAddress(laddr, raddr tcpip.LinkAddress, netName string) *CloudwatchLinkAddress

func (*CloudwatchLinkAddress) Dest

func (cw *CloudwatchLinkAddress) Dest() tcpip.LinkAddress

func (*CloudwatchLinkAddress) FullPath

func (cw *CloudwatchLinkAddress) FullPath() string

func (*CloudwatchLinkAddress) LogGroupName

func (cw *CloudwatchLinkAddress) LogGroupName() string

func (*CloudwatchLinkAddress) LogStreamName

func (cw *CloudwatchLinkAddress) LogStreamName() string

func (*CloudwatchLinkAddress) Src

func (cw *CloudwatchLinkAddress) Src() tcpip.LinkAddress

type LogConfig

type LogConfig struct {
	LogService   cloudwatchlogsiface.CloudWatchLogsAPI
	Endpoint     stack.LinkEndpoint
	NetName      string
	LogGroupName string
}

type LogLink

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

LogLink reads/writes L2 data to AWS service(s)

func NewLogLink

func NewLogLink(config *LogConfig) *LogLink

func (*LogLink) OpenLogStream

func (ll *LogLink) OpenLogStream(l CloudwatchLinkAddress) error

func (*LogLink) ProtocolToString

func (ll *LogLink) ProtocolToString(protocol tcpip.NetworkProtocolNumber) string

func (*LogLink) Read

func (ll *LogLink) Read() (*buffer.VectorisedView, error)

Read reads one packet from the internal buffers

func (*LogLink) Start

func (ll *LogLink) Start()

func (*LogLink) StringToProtocol

func (ll *LogLink) StringToProtocol(protocol string) tcpip.NetworkProtocolNumber

func (*LogLink) Write

func (ll *LogLink) Write(l CloudwatchLinkAddress, protocol tcpip.NetworkProtocolNumber, header []byte, payload []byte) (int, error)

Write writes one packet to the internal buffers

type Options

type Options struct {
	Address        tcpip.LinkAddress
	RemoteAddress  tcpip.LinkAddress // for point-to-point configuration
	PointToPoint   bool
	EthernetHeader bool
	NetworkName    string
	LinkEndpoint   tcpip.LinkEndpointID
}

type PacketLog

type PacketLog struct {
	Type    string `json:"type"`
	Src     string `json:"src"`
	Dest    string `json:"dest"`
	Header  string `json:"header"`
	Payload string `json:"payload"`
}

PacketLog represents the log event emitted from Amazon Cloudwatch

type PutEventInput

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

type ReadPollOutput

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

func (*ReadPollOutput) Data

func (p *ReadPollOutput) Data() []byte

func (*ReadPollOutput) Error

func (p *ReadPollOutput) Error() error

type ReadPoller

type ReadPoller struct {
	Cr chan ReadPollOutput
	// contains filtered or unexported fields
}

func NewReadPoller

func NewReadPoller(client cloudwatchlogsiface.CloudWatchLogsAPI) *ReadPoller

func (*ReadPoller) ReadPollForBroadcast

func (p *ReadPoller) ReadPollForBroadcast(groupName string)

func (*ReadPoller) ReadPollForLogGroup

func (p *ReadPoller) ReadPollForLogGroup(groupName string)

type WritePollInput

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

func NewWritePollInput

func NewWritePollInput(data []byte, link *CloudwatchLinkAddress) WritePollInput

type WritePoller

type WritePoller struct {
	Cw chan WritePollInput
	// contains filtered or unexported fields
}

func NewWritePoller

func NewWritePoller(client cloudwatchlogsiface.CloudWatchLogsAPI) *WritePoller

func (*WritePoller) WritePoll

func (p *WritePoller) WritePoll()