aggregate

Documentation

Index

• func ReleaseSample(s *Sample)
• type LoggingResultListener
  • func (rl *LoggingResultListener) Sink() chan<- *Sample
  • func (rl *LoggingResultListener) Start(ctx context.Context) error
• type PhoutResultListener
  • func (rl *PhoutResultListener) Sink() chan<- *Sample
  • func (rl *PhoutResultListener) Start(ctx context.Context) error
• type ResultListener
  • func GetPhoutResultListener(c *config.ResultListener) (ResultListener, error)
  • func NewLoggingResultListener(*config.ResultListener) (ResultListener, error)
  • func NewPhoutResultListener(filename string) (rl ResultListener, err error)
• type Sample
  • func AcquireSample(ts float64, tag string) *Sample
  • func Drain(ctx context.Context, results <-chan *Sample) []*Sample
  • func (ps *Sample) AppendToPhout(dst []byte) []byte
  • func (ps *Sample) String() string

Functions

func ReleaseSample

func ReleaseSample(s *Sample)

Types

type LoggingResultListener

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

Implements ResultListener interface

func (*LoggingResultListener) Sink

func (rl *LoggingResultListener) Sink() chan<- *Sample

func (*LoggingResultListener) Start

func (rl *LoggingResultListener) Start(ctx context.Context) error

type PhoutResultListener

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

func (*PhoutResultListener) Sink

func (rl *PhoutResultListener) Sink() chan<- *Sample

func (*PhoutResultListener) Start

func (rl *PhoutResultListener) Start(ctx context.Context) error

type ResultListener

type ResultListener interface {
	Start(context.Context) error
	Sink() chan<- *Sample
}

func GetPhoutResultListener

func GetPhoutResultListener(c *config.ResultListener) (ResultListener, error)

GetPhoutResultListener is not thread safe.

func NewLoggingResultListener

func NewLoggingResultListener(*config.ResultListener) (ResultListener, error)

func NewPhoutResultListener

func NewPhoutResultListener(filename string) (rl ResultListener, err error)

type Sample

type Sample struct {
	TS            float64
	Tag           string
	RT            int
	Connect       int
	Send          int
	Latency       int
	Receive       int
	IntervalEvent int
	Egress        int
	Igress        int
	NetCode       int
	ProtoCode     int
	Err           error
}

func AcquireSample

func AcquireSample(ts float64, tag string) *Sample

func Drain

func Drain(ctx context.Context, results <-chan *Sample) []*Sample

func (*Sample) AppendToPhout

func (ps *Sample) AppendToPhout(dst []byte) []byte

func (*Sample) String

func (ps *Sample) String() string