endtoend

Documentation

Index

• func BasicCounterEvent(origin string) *events.Envelope
• func BasicLogMessageEnvelope(origin string, appID string) *events.Envelope
• func BasicValueMetric() []byte
• func BasicValueMetricEnvelope(origin string) *events.Envelope
• type AgentStreamWriter
  • func NewAgentStreamWriter(agentPort int) *AgentStreamWriter
  • func (w *AgentStreamWriter) Write(b []byte)
• 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 Experiment
  • func NewExperiment(reader MessageReader) *Experiment
  • func (e *Experiment) AddWriteStrategy(strategy WriteStrategy)
  • func (e *Experiment) Start()
  • func (e *Experiment) Stop()
  • func (e *Experiment) Warmup()
• 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 MessageReader
• type MessageWriter
• type ValueMetricGenerator
  • func NewValueMetricGenerator() *ValueMetricGenerator
  • func (*ValueMetricGenerator) Generate() []byte
• type WriteStrategy

Functions

func BasicCounterEvent

func BasicCounterEvent(origin string) *events.Envelope

func BasicLogMessageEnvelope

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

func BasicValueMetric

func BasicValueMetric() []byte

func BasicValueMetricEnvelope

func BasicValueMetricEnvelope(origin string) *events.Envelope

Types

type AgentStreamWriter

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

func NewAgentStreamWriter

func NewAgentStreamWriter(agentPort int) *AgentStreamWriter

func (*AgentStreamWriter) Write

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

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 Experiment

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

func NewExperiment

func NewExperiment(reader MessageReader) *Experiment

func (*Experiment) AddWriteStrategy

func (e *Experiment) AddWriteStrategy(strategy WriteStrategy)

func (*Experiment) Start

func (e *Experiment) Start()

func (*Experiment) Stop

func (e *Experiment) Stop()

func (*Experiment) Warmup

func (e *Experiment) Warmup()

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 MessageReader

type MessageReader interface {
	Read()
	Close()
}

type MessageWriter

type MessageWriter interface {
	Write([]byte)
}

type ValueMetricGenerator

type ValueMetricGenerator struct{}

func NewValueMetricGenerator

func NewValueMetricGenerator() *ValueMetricGenerator

func (*ValueMetricGenerator) Generate

func (*ValueMetricGenerator) Generate() []byte

type WriteStrategy

type WriteStrategy interface {
	StartWriter()
	Stop()
}