Versions in this module Expand all Collapse all v0 v0.1.2 Jan 20, 2016 v0.1.1 Jan 19, 2016 Changes in this version + func ReleaseSample(s *Sample) + type LoggingResultListener struct + func (rl *LoggingResultListener) Sink() chan<- *Sample + func (rl *LoggingResultListener) Start(ctx context.Context) error + type PhoutResultListener struct + func (rl *PhoutResultListener) Sink() chan<- *Sample + func (rl *PhoutResultListener) Start(ctx context.Context) error + type ResultListener interface + Sink func() chan<- *Sample + Start func(context.Context) error + func GetPhoutResultListener(c *config.ResultListener) (ResultListener, error) + func NewLoggingResultListener(*config.ResultListener) (ResultListener, error) + func NewPhoutResultListener(filename string) (rl ResultListener, err error) + type Sample struct + Connect int + Egress int + Err error + Igress int + IntervalEvent int + Latency int + NetCode int + ProtoCode int + RT int + Receive int + Send int + TS float64 + Tag string + 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
Go to main page