endtoend

Documentation

Index

• type FirehoseReader
  • func NewFirehoseReader(tcPort int) *FirehoseReader
  • func (r *FirehoseReader) Close()
  • func (r *FirehoseReader) Read()
• type MetronStreamWriter
  • func NewMetronStreamWriter(metronPort int) *MetronStreamWriter
  • func (w *MetronStreamWriter) Write(b []byte)

Types

type FirehoseReader

type FirehoseReader struct {
	TestMetricCount             float64
	NonTestMetricCount          float64
	MetronSentMessageCount      float64
	DopplerReceivedMessageCount float64
	DopplerSentMessageCount     float64

	LogMessages chan *events.Envelope
	// contains filtered or unexported fields
}

func NewFirehoseReader

func NewFirehoseReader(tcPort int) *FirehoseReader

func (*FirehoseReader) Close

func (r *FirehoseReader) Close()

func (*FirehoseReader) Read

func (r *FirehoseReader) Read()

type MetronStreamWriter

type MetronStreamWriter struct {
	Writes int
	// contains filtered or unexported fields
}

func NewMetronStreamWriter

func NewMetronStreamWriter(metronPort int) *MetronStreamWriter

func (*MetronStreamWriter) Write

func (w *MetronStreamWriter) Write(b []byte)