ring

Documentation

Index

• Variables
• type Measure
• type Ring
  • func (r *Ring) Capacity() int
  • func (r *Ring) Dequeue() Measure
  • func (r *Ring) DumpLine() (string, error)
  • func (r *Ring) Enqueue(c TimeMeasure)
  • func (r *Ring) SetCapacity(size int)
  • func (r *Ring) Values() []TimeMeasure
• type Time
• type TimeMeasure

Variables

var (

	// DefaultCapacity is max size of ring
	DefaultCapacity = 256
)

Types

type Measure

type Measure interface {
	//Value from the measure
	Value() float64
}

Measure value of the measure

type Ring

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

Ring structure

func (*Ring) Capacity

func (r *Ring) Capacity() int

Capacity returns the capacity of ringbuffer

func (*Ring) Dequeue

func (r *Ring) Dequeue() Measure

Dequeue dequeues measure of the ring

func (*Ring) DumpLine

func (r *Ring) DumpLine() (string, error)

DumpLine return String of ring

func (*Ring) Enqueue

func (r *Ring) Enqueue(c TimeMeasure)

Enqueue enqueues measure of the ring

func (*Ring) SetCapacity

func (r *Ring) SetCapacity(size int)

SetCapacity fix the maximum capacity of the ring

func (*Ring) Values

func (r *Ring) Values() []TimeMeasure

Values return array of timeMeasure

type Time

type Time interface {
	//Timestamp from the measure
	TimeStamp() time.Time
}

Time is the timestamp of enqueue

type TimeMeasure

type TimeMeasure interface {
	Time
	Measure
}

TimeMeasure compose Time and Measure