Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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)
Source Files
Click to show internal directories.
Click to hide internal directories.