common

Documentation

Index

• Variables
• func Assert(test bool)
• func CheckFatal(e error)
• func CheckWarn(e error)
• func InitDefaultLogging(debug bool)
• func InitLogging(debugHandle io.Writer, infoHandle io.Writer, warningHandle io.Writer, ...)
• func OnOff(b bool) string
• func SignalHandlerLoop(ss ...SignalReceiver)
• type SchedQueue
  • func NewSchedQueue(clock clock.Clock) *SchedQueue
  • func (cq *SchedQueue) Add(c callable, t time.Time)
  • func (cq *SchedQueue) Count() uint64
  • func (cq *SchedQueue) Flush()
  • func (cq *SchedQueue) Start()
  • func (cq *SchedQueue) Stop()
• type SignalReceiver

Variables

var (
	Debug   *log.Logger
	Info    *log.Logger
	Warning *log.Logger
	Error   *log.Logger
)

Functions

func Assert

func Assert(test bool)

Assert test is true, panic otherwise

func CheckFatal

func CheckFatal(e error)

func CheckWarn

func CheckWarn(e error)

func InitDefaultLogging

func InitDefaultLogging(debug bool)

func InitLogging

func InitLogging(debugHandle io.Writer,
	infoHandle io.Writer,
	warningHandle io.Writer,
	errorHandle io.Writer)

func OnOff

func OnOff(b bool) string

func SignalHandlerLoop

func SignalHandlerLoop(ss ...SignalReceiver)

Types

type SchedQueue

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

SchedQueue is queue of scheduled callables

func NewSchedQueue

func NewSchedQueue(clock clock.Clock) *SchedQueue

NewSchedQueue creates a new scheduled queue

func (*SchedQueue) Add

func (cq *SchedQueue) Add(c callable, t time.Time)

Add schedules a call. The callable should not modify the scheduled queue in any way.

func (*SchedQueue) Count

func (cq *SchedQueue) Count() uint64

Counter returns the number of calls invoked in the queued Note: the result will wrap over time.

func (*SchedQueue) Flush

func (cq *SchedQueue) Flush()

ensure that the background goroutine has executed any pending callbacks

func (*SchedQueue) Start

func (cq *SchedQueue) Start()

Start starts the scheduled queue

func (*SchedQueue) Stop

func (cq *SchedQueue) Stop()

Stop stops the scheduled queue

type SignalReceiver

type SignalReceiver interface {
	Stop() error
	Status() string
}

A subsystem/server/... that can be stopped or queried about the status with a signal