endtoend

Documentation

Index

• func BasicCounterEvent(origin string) *events.Envelope
• func BasicLogMessageEnvelope(origin string, appID string) *events.Envelope
• func BasicLogMessageEnvelopeV2(appID string) *loggregator_v2.Envelope
• func BasicValueMetric() []byte
• func BasicValueMetricEnvelope(origin string) *events.Envelope
• type BurstParameters
• type BurstWriteStrategy
  • func NewBurstWriteStrategy(generator MessageGenerator, writer MessageWriter, params BurstParameters) *BurstWriteStrategy
  • func (s *BurstWriteStrategy) StartWriter()
  • func (s *BurstWriteStrategy) Stop()
• type ConstantWriteStrategy
  • func NewConstantWriteStrategy(generator MessageGenerator, writer MessageWriter, writeRate int) *ConstantWriteStrategy
  • func (s *ConstantWriteStrategy) StartWriter()
  • func (s *ConstantWriteStrategy) Stop()
• type FirehoseReader
  • func NewFirehoseReader(tcPort int) *FirehoseReader
  • func (r *FirehoseReader) Close()
  • func (r *FirehoseReader) Read()
• type LogMessageGenerator
  • func NewLogMessageGenerator(appID string) *LogMessageGenerator
  • func (l *LogMessageGenerator) Generate() []byte
• type MessageGenerator
• type MessageWriter
• type ValueMetricGenerator
  • func NewValueMetricGenerator() *ValueMetricGenerator
  • func (*ValueMetricGenerator) Generate() []byte

Functions

func BasicCounterEvent

func BasicCounterEvent(origin string) *events.Envelope

func BasicLogMessageEnvelope

func BasicLogMessageEnvelope(origin string, appID string) *events.Envelope

func BasicLogMessageEnvelopeV2

func BasicLogMessageEnvelopeV2(appID string) *loggregator_v2.Envelope

func BasicValueMetric

func BasicValueMetric() []byte

func BasicValueMetricEnvelope

func BasicValueMetricEnvelope(origin string) *events.Envelope

Types

type BurstParameters

type BurstParameters struct {
	Minimum   int
	Maximum   int
	Frequency time.Duration
}

type BurstWriteStrategy

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

func NewBurstWriteStrategy

func NewBurstWriteStrategy(generator MessageGenerator, writer MessageWriter, params BurstParameters) *BurstWriteStrategy

func (*BurstWriteStrategy) StartWriter

func (s *BurstWriteStrategy) StartWriter()

func (*BurstWriteStrategy) Stop

func (s *BurstWriteStrategy) Stop()

type ConstantWriteStrategy

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

func NewConstantWriteStrategy

func NewConstantWriteStrategy(generator MessageGenerator, writer MessageWriter, writeRate int) *ConstantWriteStrategy

func (*ConstantWriteStrategy) StartWriter

func (s *ConstantWriteStrategy) StartWriter()

func (*ConstantWriteStrategy) Stop

func (s *ConstantWriteStrategy) Stop()

type FirehoseReader

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

	LogMessageAppIDs chan string
	// 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 LogMessageGenerator

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

func NewLogMessageGenerator

func NewLogMessageGenerator(appID string) *LogMessageGenerator

func (*LogMessageGenerator) Generate

func (l *LogMessageGenerator) Generate() []byte

type MessageGenerator

type MessageGenerator interface {
	Generate() []byte
}

type MessageWriter

type MessageWriter interface {
	Write([]byte)
}

type ValueMetricGenerator

type ValueMetricGenerator struct{}

func NewValueMetricGenerator

func NewValueMetricGenerator() *ValueMetricGenerator

func (*ValueMetricGenerator) Generate

func (*ValueMetricGenerator) Generate() []byte