async

README

Utilities for asynchronous programming (go routines, wait groups, etc.)

Documentation

Index

• func Schedule(delay time.Duration, fun ScheduledFunc)
• type ScheduledFunc
• type Timestamp
  • func NewAsyncTimestamp(lastTimestamp time.Time) *Timestamp
  • func (at *Timestamp) LastTimestamp() time.Time
  • func (at *Timestamp) Mark()

Functions

func Schedule

func Schedule(delay time.Duration, fun ScheduledFunc)

Schedule runs the function after the delay

Types

type ScheduledFunc

type ScheduledFunc func()

type Timestamp

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

Timestamp is a thread safe timestamp

func NewAsyncTimestamp

func NewAsyncTimestamp(lastTimestamp time.Time) *Timestamp

func (*Timestamp) LastTimestamp

func (at *Timestamp) LastTimestamp() time.Time

LastTimestamp returns the last set timestamp

func (*Timestamp) Mark

func (at *Timestamp) Mark()

Mark sets the timestamp with the current time