legacy

package
v1.3.1 Latest Latest
Warning

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

Go to latest
Published: May 10, 2021 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ParseSelectedEvents

func ParseSelectedEvents(orgEnvValue string) []events.Envelope_EventType

func Run

func Run(conf *config.Config)

Types

type EventHandler

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

EventHandler receive CF events and send metrics to WF

func CreateEventHandler

func CreateEventHandler(conf *config.WavefrontConfig) *EventHandler

CreateEventHandler create a new EventHandler

func (*EventHandler) BuildContainerEvent

func (w *EventHandler) BuildContainerEvent(event *events.Envelope, appInfo *api.AppInfo)

BuildContainerEvent parse and report metrics

func (*EventHandler) BuildCounterEvent

func (w *EventHandler) BuildCounterEvent(event *events.Envelope)

BuildCounterEvent parse and report metrics

func (*EventHandler) BuildValueMetricEvent

func (w *EventHandler) BuildValueMetricEvent(event *events.Envelope)

BuildValueMetricEvent parse and report metrics

func (*EventHandler) ReportError

func (w *EventHandler) ReportError(err error)

ReportError increments the error counter

type Nozzle

type Nozzle struct {
	APIClient *api.APIClient
	// contains filtered or unexported fields
}

Nozzle will read all CF events and sent it to the Forwarder

func NewNozzle

func NewNozzle(conf *config.Config, eventsChannel chan *events.Envelope, errorsChannel chan error) *Nozzle

NewNozzle create a new Nozzle

Jump to

Keyboard shortcuts

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