common

package

v1.0.1 Latest Latest Go to latest Published: Jun 21, 2015 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

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

func Assert(test bool)

Assert test is true, panic otherwise

func CheckFatal(e error)

func CheckWarn(e error)

func InitDefaultLogging(debug bool)

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

func OnOff(b bool) string

func SignalHandlerLoop(ss ...SignalReceiver)

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

SchedQueue is queue of scheduled callables

func NewSchedQueue(clock clock.Clock) *SchedQueue

NewSchedQueue creates a new scheduled queue

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 (cq *SchedQueue) Count() uint64

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

func (cq *SchedQueue) Flush()

ensure that the background goroutine has executed any pending callbacks

func (cq *SchedQueue) Start()

Start starts the scheduled queue

func (cq *SchedQueue) Stop()

Stop stops the scheduled queue

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

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

Path	Synopsis
docker