endtoend

package
v0.0.0-...-db3f45c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 26, 2024 License: Apache-2.0, BSD-3-Clause, MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL