gauge

Documentation

Index

• func CalcRates(trips []*Trip) (sendRate float64, receiveRate float64)
• type LogReducer
  • func NewLogReducer() *LogReducer
  • func (t *LogReducer) CheckIns() []*dccp.Trace
  • func (t *LogReducer) Init()
  • func (t *LogReducer) Places() map[string]*Place
  • func (t *LogReducer) Trips() map[int64]*Trip
  • func (t *LogReducer) Write(r *dccp.Trace)
• type Place
• type TraceChrono
  • func (t TraceChrono) Len() int
  • func (t TraceChrono) Less(i, j int) bool
  • func (t TraceChrono) Swap(i, j int)
• type Trip
  • func TripMapToSlice(m map[int64]*Trip) []*Trip

Functions

func CalcRates

func CalcRates(trips []*Trip) (sendRate float64, receiveRate float64)

TODO: Don't count drops after one side closes

Types

type LogReducer

type LogReducer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

LogReducer is a dccp.TraceWriter which processes the logs to a form that is convenient as input to illustration tools

func NewLogReducer

func NewLogReducer() *LogReducer

Make a new log reducer

func (*LogReducer) CheckIns

func (t *LogReducer) CheckIns() []*dccp.Trace

CheckIns returns a list of all check-ins

func (*LogReducer) Init

func (t *LogReducer) Init()

Init (re)initializes an existing log reducer structure

func (*LogReducer) Places

func (t *LogReducer) Places() map[string]*Place

Places returns places' histories, keyed by place name

func (*LogReducer) Trips

func (t *LogReducer) Trips() map[int64]*Trip

Trips returns trip records, keyed by SeqNo

func (*LogReducer) Write

func (t *LogReducer) Write(r *dccp.Trace)

type Place

type Place struct {
	CheckIns []*dccp.Trace
	// contains filtered or unexported fields
}

type TraceChrono

type TraceChrono []*dccp.Trace

TraceChrono is a chronological sort driver for []*dccp.Trace

func (TraceChrono) Len

func (t TraceChrono) Len() int

func (TraceChrono) Less

func (t TraceChrono) Less(i, j int) bool

func (TraceChrono) Swap

func (t TraceChrono) Swap(i, j int)

type Trip

type Trip struct {
	SeqNo    int64
	Forward  []*dccp.Trace
	Backward []*dccp.Trace
	Source   string
	Sink     string
	Round    bool
}

A Trip instance captures all packet check-ins whose SeqNo or AckNo are related

func TripMapToSlice

func TripMapToSlice(m map[int64]*Trip) []*Trip