helpers

Documentation

Index

• Constants
• func ConnectToFirehose() (<-chan *events.Envelope, <-chan error)
• func ConnectToStream(appID string) (<-chan *events.Envelope, <-chan error)
• func EmitToMetron(envelope *events.Envelope)
• func FindMatchingEnvelope(msgChan <-chan *events.Envelope, envelope *events.Envelope) *events.Envelope
• func FindMatchingEnvelopeByID(id string, msgChan <-chan *events.Envelope) (*events.Envelope, error)
• func FindMatchingEnvelopeByOrigin(msgChan <-chan *events.Envelope, origin string) *events.Envelope
• func Initialize(testConfig *TestConfig)
• func RequestContainerMetrics(appID string) ([]*events.ContainerMetric, error)
• func RequestRecentLogs(appID string) ([]*events.LogMessage, error)
• func WaitForWebsocketConnection(printer *TestDebugPrinter)
• func WriteToEtcd(urls []string, key, value string) func()
• type TestDebugPrinter
  • func SetUpConsumer() (*consumer.Consumer, *TestDebugPrinter)
  • func (printer *TestDebugPrinter) Dump() string
  • func (printer *TestDebugPrinter) Print(title, dump string)

Constants

const ORIGIN_NAME = "LATs"

Functions

func ConnectToFirehose

func ConnectToFirehose() (<-chan *events.Envelope, <-chan error)

func ConnectToStream

func ConnectToStream(appID string) (<-chan *events.Envelope, <-chan error)

func EmitToMetron

func EmitToMetron(envelope *events.Envelope)

func FindMatchingEnvelope

func FindMatchingEnvelope(msgChan <-chan *events.Envelope, envelope *events.Envelope) *events.Envelope

func FindMatchingEnvelopeByID

func FindMatchingEnvelopeByID(id string, msgChan <-chan *events.Envelope) (*events.Envelope, error)

func FindMatchingEnvelopeByOrigin

func FindMatchingEnvelopeByOrigin(msgChan <-chan *events.Envelope, origin string) *events.Envelope

func Initialize

func Initialize(testConfig *TestConfig)

func RequestContainerMetrics

func RequestContainerMetrics(appID string) ([]*events.ContainerMetric, error)

func RequestRecentLogs

func RequestRecentLogs(appID string) ([]*events.LogMessage, error)

func WaitForWebsocketConnection

func WaitForWebsocketConnection(printer *TestDebugPrinter)

func WriteToEtcd

func WriteToEtcd(urls []string, key, value string) func()

Types

type TestDebugPrinter

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

func SetUpConsumer

func SetUpConsumer() (*consumer.Consumer, *TestDebugPrinter)

func (*TestDebugPrinter) Dump

func (printer *TestDebugPrinter) Dump() string

func (*TestDebugPrinter) Print

func (printer *TestDebugPrinter) Print(title, dump string)