timer

Documentation

Index

• Variables
• type AdaptiveTimeoutConfig
• type AdaptiveTimeoutManager
  • func (tm *AdaptiveTimeoutManager) Dispatch()
  • func (tm *AdaptiveTimeoutManager) Initialize(config *AdaptiveTimeoutConfig) error
  • func (tm *AdaptiveTimeoutManager) Put(id ids.ID, handler func()) time.Time
  • func (tm *AdaptiveTimeoutManager) Remove(id ids.ID)
  • func (tm *AdaptiveTimeoutManager) Stop()
  • func (tm *AdaptiveTimeoutManager) Timeout()
• type Clock
  • func (c *Clock) Set(time time.Time)
  • func (c *Clock) Sync()
  • func (c *Clock) Time() time.Time
  • func (c *Clock) Unix() uint64
• type Executor
  • func (e *Executor) Add(event func())
  • func (e *Executor) Dispatch()
  • func (e *Executor) Initialize()
  • func (e *Executor) Stop()
• type Meter
• type Repeater
  • func NewRepeater(handler func(), frequency time.Duration) *Repeater
  • func (r *Repeater) Dispatch()
  • func (r *Repeater) Stop()
• type TimedMeter
  • func (tm *TimedMeter) Tick()
  • func (tm *TimedMeter) Ticks() int
• type TimeoutManager
  • func (tm *TimeoutManager) Dispatch()
  • func (tm *TimeoutManager) Initialize(duration time.Duration)
  • func (tm *TimeoutManager) Put(id ids.ID, handler func())
  • func (tm *TimeoutManager) Remove(id ids.ID)
  • func (tm *TimeoutManager) Stop()
  • func (tm *TimeoutManager) Timeout()
• type Timer
  • func NewTimer(handler func()) *Timer
  • func (t *Timer) Cancel()
  • func (t *Timer) Dispatch()
  • func (t *Timer) SetTimeoutIn(duration time.Duration)
  • func (t *Timer) Stop()

Variables

var (
	MillisecondsBuckets = []float64{
		10,
		100,
		250,
		500,
		1000,
		1500,
		2000,
		3000,
		5000,
		10000,
	}
	NanosecondsBuckets = []float64{
		float64(100 * time.Nanosecond),
		float64(time.Microsecond),
		float64(10 * time.Microsecond),
		float64(100 * time.Microsecond),
		float64(time.Millisecond),
		float64(10 * time.Millisecond),
		float64(100 * time.Millisecond),
		float64(time.Second),
	}
)

Useful latency buckets

var (
	// MaxTime was taken from https://stackoverflow.com/questions/25065055/what-is-the-maximum-time-time-in-go/32620397#32620397
	MaxTime = time.Unix(1<<63-62135596801, 0) // 0 is used because we drop the nano-seconds
)

Types

type AdaptiveTimeoutConfig

type AdaptiveTimeoutConfig struct {
	InitialTimeout time.Duration
	MinimumTimeout time.Duration
	MaximumTimeout time.Duration
	TimeoutInc     time.Duration
	TimeoutDec     time.Duration

	Namespace  string
	Registerer prometheus.Registerer
}

AdaptiveTimeoutConfig contains the parameters that should be provided to the adaptive timeout manager.

type AdaptiveTimeoutManager

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

AdaptiveTimeoutManager is a manager for timeouts.

func (*AdaptiveTimeoutManager) Dispatch

func (tm *AdaptiveTimeoutManager) Dispatch()

Dispatch ...

func (*AdaptiveTimeoutManager) Initialize

func (tm *AdaptiveTimeoutManager) Initialize(config *AdaptiveTimeoutConfig) error

Initialize this timeout manager with the provided config

func (*AdaptiveTimeoutManager) Put

func (tm *AdaptiveTimeoutManager) Put(id ids.ID, handler func()) time.Time

Put puts hash into the hash map

func (*AdaptiveTimeoutManager) Remove

func (tm *AdaptiveTimeoutManager) Remove(id ids.ID)

Remove the item that no longer needs to be there.

func (*AdaptiveTimeoutManager) Stop

func (tm *AdaptiveTimeoutManager) Stop()

Stop executing timeouts

func (*AdaptiveTimeoutManager) Timeout

func (tm *AdaptiveTimeoutManager) Timeout()

Timeout registers a timeout

type Clock

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

Clock acts as a thin wrapper around global time that allows for easy testing

func (*Clock) Set

func (c *Clock) Set(time time.Time)

Set the time on the clock

func (*Clock) Sync

func (c *Clock) Sync()

Sync this clock with global time

func (*Clock) Time

func (c *Clock) Time() time.Time

Time returns the time on this clock

func (*Clock) Unix

func (c *Clock) Unix() uint64

Unix returns the unix time on this clock.

type Executor

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

Executor ...

func (*Executor) Add

func (e *Executor) Add(event func())

Add new function to call

func (*Executor) Dispatch

func (e *Executor) Dispatch()

Dispatch the events. Will only return after stop is called.

func (*Executor) Initialize

func (e *Executor) Initialize()

Initialize ...

func (*Executor) Stop

func (e *Executor) Stop()

Stop executing functions

type Meter

type Meter interface {
	// Notify this meter of a new event for it to rate
	Tick()
	// Return the number of events this meter is currently tracking
	Ticks() int
}

Meter tracks the number of occurrences of a specified event

type Repeater

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

Repeater ...

func NewRepeater

func NewRepeater(handler func(), frequency time.Duration) *Repeater

NewRepeater ...

func (*Repeater) Dispatch

func (r *Repeater) Dispatch()

Dispatch ...

func (*Repeater) Stop

func (r *Repeater) Stop()

Stop ...

type TimedMeter

type TimedMeter struct {

	// Amount of time to keep a tick
	Duration time.Duration
	// contains filtered or unexported fields
}

TimedMeter is a meter that discards old events

func (*TimedMeter) Tick

func (tm *TimedMeter) Tick()

Tick implements the Meter interface

func (*TimedMeter) Ticks

func (tm *TimedMeter) Ticks() int

Ticks implements the Meter interface

type TimeoutManager

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

TimeoutManager is a manager for timeouts.

func (*TimeoutManager) Dispatch

func (tm *TimeoutManager) Dispatch()

Dispatch ...

func (*TimeoutManager) Initialize

func (tm *TimeoutManager) Initialize(duration time.Duration)

Initialize is a constructor b/c Golang, in its wisdom, doesn't ... have them?

func (*TimeoutManager) Put

func (tm *TimeoutManager) Put(id ids.ID, handler func())

Put puts hash into the hash map

func (*TimeoutManager) Remove

func (tm *TimeoutManager) Remove(id ids.ID)

Remove the item that no longer needs to be there.

func (*TimeoutManager) Stop

func (tm *TimeoutManager) Stop()

Stop executing timeouts

func (*TimeoutManager) Timeout

func (tm *TimeoutManager) Timeout()

Timeout registers a timeout

type Timer

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

Timer wraps a timer object. This allows a user to specify a handler. Once specifying the handler, the dispatch thread can be called. The dispatcher will only return after calling Stop. SetTimeoutIn will result in calling the handler in the specified amount of time.

func NewTimer

func NewTimer(handler func()) *Timer

NewTimer creates a new timer object

func (*Timer) Cancel

func (t *Timer) Cancel()

Cancel the currently scheduled event

func (*Timer) Dispatch

func (t *Timer) Dispatch()

Dispatch ...

func (*Timer) SetTimeoutIn

func (t *Timer) SetTimeoutIn(duration time.Duration)

SetTimeoutIn will set the timer to fire the handler in [duration]

func (*Timer) Stop

func (t *Timer) Stop()

Stop this timer from executing any more.