cyclebreaker

Documentation

Overview

© 2020–present Harald Rudell <harald.rudell@gmail.com> (https://haraldrudell.github.io/haraldrudell/) ISC License

Index

• Constants
• Variables
• func Annotation() (a string)
• func ChannelSend[T any](ch chan<- T, value T, nonBlocking ...bool) (didSend, isNilChannel, isClosedChannel bool, err error)
• func Close(closable io.Closer, errp *error)
• func Closer[T any](ch chan T, errp *error)
• func CloserSend[T any](ch chan<- T, errp *error)
• func EndCallbacks(err error) (err2 error)
• func EnsureError(panicValue any) (err error)
• func ErrChWait(errCh <-chan error, errp *error)
• func Infallible(err error)
• func InvokeIf[T comparable](tp *T, fn func())
• func Log(format string, a ...any)
• func NilError(valueName string) (err error)
• func NoOnError(err error)
• func PanicToErr(errp *error, isPanic ...*bool)
• func Recover(annotation string, errp *error, onError OnError)
• func Recover2(annotation string, errp *error, onError OnError)
• func RecoverDA(deferredLocation func() DA, errp *error, onError OnError)
• func RecoverDA2(deferredLocation func() DA, errp *error, onError OnError)
• func RecoverErr(deferredLocation func() DA, errp *error, isPanic ...*bool)
• func SendErr(errCh chan<- error, errp *error)
• func Sprintf(format string, a ...interface{}) string
• func Uintptr(v any) (p uintptr)
• type AtomicMax
  • func NewAtomicMax[T constraints.Integer](value T) (atomicMax *AtomicMax[T])
  • func (max *AtomicMax[T]) Max() (value T, hasValue bool)
  • func (max *AtomicMax[T]) Max1() (value T)
  • func (max *AtomicMax[T]) Value(value T) (isNewMax bool)
• type Awaitable
  • func NewAwaitable() (awaitable *Awaitable)
  • func (a *Awaitable) Ch() (ch AwaitableCh)
  • func (a *Awaitable) Close() (didClose bool)
  • func (a *Awaitable) IsClosed() (isClosed bool)
• type AwaitableCh
• type DA
  • func A() DA
• type OnError

Constants

const (
	Rfc3339s  = "2006-01-02 15:04:05Z07:00"
	Rfc3339ms = "2006-01-02 15:04:05.000Z07:00"
	Rfc3339us = "2006-01-02 15:04:05.000000Z07:00"
	Rfc3339ns = "2006-01-02 15:04:05.000000000Z07:00"
)

const SendNonBlocking = true

with nonBlocking set to SendNonBlocking, ChannelSend will never block

Variables

var ErrEndCallbacks = EndCallbacks(errors.New("end callbacks error"))

ErrEndCallbacks indicates upon retun from a callback function that no more callbacks are desired. It does not indicate an error and is not returned as an error by any other function than the callback.

callback invocations may be thread-safe, re-entrant and panic-handling but this depends on the callback-invoking implementation used.

Usage:

if errors.Is(err, parl.ErrEndCallbacks) { …

var ErrNil = &nilValue{"value"}

ErrNil is used with errors.Is to detect that a panic or error value was caused by a value that cannot be nil, such as a function argument to a new function, was nil

• —
• a nilValue type implements:
• — a dummy NilValueError method
• — an Is method returning true for errors implementing a NilValueError method

Usage:

if errors.Is(err, parl.ErrNil) { …

Functions

func Annotation

func Annotation() (a string)

Annotation provides a default reovered-panic code annotation

• “Recover from panic in mypackage.MyFunc”
• [base package].[function]: "mypackage.MyFunc"

func ChannelSend

func ChannelSend[T any](ch chan<- T, value T, nonBlocking ...bool) (didSend, isNilChannel, isClosedChannel bool, err error)

ChannelSend is channel send without panics and possibly non-blocking

• if nonBlocking is SendNonBlocking or true, channel send will be attempted but not block
• didSend is true if value was successfully sent on ch
• err is non-nil if a panic occurred or ch is nil
• isNilChannel is true if the channel is nil, ie. send would block indefinitely
• isClosedChannel is true if the panic was caused by ch being closed
• there should be no panics other than from ch being closed

func Close

func Close(closable io.Closer, errp *error)

Close is a deferrable function that closes an io.Closer object. Close handles panics. if errp is non-nil, panic values updates it using errors.AppendError.

func Closer

func Closer[T any](ch chan T, errp *error)

Closer is a deferrable function that closes a channel. Closer handles panics. if errp is non-nil, panic values updates it using errors.AppendError.

func CloserSend

func CloserSend[T any](ch chan<- T, errp *error)

CloserSend is a deferrable function that closes a send-channel. CloserSend handles panics. if errp is non-nil, panic values updates it using errors.AppendError.

func EndCallbacks

func EndCallbacks(err error) (err2 error)

func EnsureError

func EnsureError(panicValue any) (err error)

ensureError interprets a panic values as an error

• returned value is either nil or an error value with stack trace
• the error is ensured to have stack trace

func ErrChWait

func ErrChWait(errCh <-chan error, errp *error)

ErrChWait is a deferrable function receiving an error value on a channel

• used to wait for a goroutine

Usage:

var err error
defer errorHandler(&err)

var errCh = make(chan error, 1)
go someFunc(errCh)
defer parl.ErrChWait(errCh, &err)

func someFunc(errCh chan<- error) {
  var err error
  defer parl.SendErr(errCh, &err)
  defer parl.PanicToErr(errp)

func Infallible

func Infallible(err error)

func InvokeIf

func InvokeIf[T comparable](tp *T, fn func())

InvokeIf is a deferrable function invoking its function argument when:

• the pointer tp is non-nil and the function fn is non-nil
• what tp points to is not a T zero-value

Usage:

someFlag := false
defer InvokeIf(&someFlag, someFunction)
…
someFlag = someValue

func Log

func Log(format string, a ...any)

func NilError

func NilError(valueName string) (err error)

NilError returns an error used with panic() indicating that a value that cannot be nil, such as a function argument to a new function, was nil

• such panics typically indicate compile-time issues with code

Usage:

func NewX(xValue *int) (x *X) {
  if xValue == nil {
    panic(parl.NilError("xValue")) // “somePackage.NewX xValue cannot be nil”

func NoOnError

func NoOnError(err error)

NoOnError is used with Recover and Recover2 to silence the default error logging

func PanicToErr

func PanicToErr(errp *error, isPanic ...*bool)

PanicToErr recovers active panic, aggregating errors in errp

• PanicToErr does not provide enclosing function. For that, use RecoverErr: “recover from panic in pack.Func…”
• errp cannot be nil
• if isPanic is non-nil and active panic, it is set to true

sample error message, including message in the panic value and the code line causing the panic:

recover from panic: message: “runtime error: invalid memory address or nil pointer dereference” at parl.panicFunction()-panic-to-err_test.go:96

Usage:

func someFunc() (isPanic bool, err error) {
  defer parl.PanicToErr(&err, &isPanic)

func someGoroutine(g parl.Go) {
  var err error
  defer g.Register().Done(&err)
  defer parl.PanicToErr(&err)

func Recover

func Recover(annotation string, errp *error, onError OnError)

Recover recovers from panic invoking onError exactly once with an aggregate error value

• annotation may be empty, errp and onError may be nil
• errors in *errp and panic are aggregated into a single error value
• if onError non-nil, the function is invoked once with the aggregate error
• if onError nil, the aggregate error is logged to standard error
• if onError is [Parl.NoOnErrror], logging is suppressed
• if errp is non-nil, it is updated with the aggregate error
• if annotation is empty, a default annotation is used for the immediate caller of Recover

func Recover2

func Recover2(annotation string, errp *error, onError OnError)

Recover2 recovers from panic invoking onError for any eror in *errp and any panic

• annotation may be empty, errp and onError may be nil
• if onError non-nil, the function is invoked with any error in *errp and any panic
• if onError nil, the errors are logged to standard error
• if onError is [Parl.NoOnErrror], logging is suppressed
• if errp is non-nil, it is updated with an aggregate error
• if annotation is empty, a default annotation is used for the immediate caller of Recover

func RecoverDA

func RecoverDA(deferredLocation func() DA, errp *error, onError OnError)

RecoverDA recovers panic using deferred annotation

Usage:

func someFunc() (err error) {
  defer parl.RecoverDA(func() parl.DA { return parl.A() }, &err, parl.NoOnError)

func RecoverDA2

func RecoverDA2(deferredLocation func() DA, errp *error, onError OnError)

RecoverDA2 recovers panic using deferred annotation

func RecoverErr

func RecoverErr(deferredLocation func() DA, errp *error, isPanic ...*bool)

RecoverErr recovers panic using deferred annotation

Usage:

func someFunc() (isPanic bool, err error) {
  defer parl.RecoverErr(func() parl.DA { return parl.A() }, &err, &isPanic)

func SendErr

func SendErr(errCh chan<- error, errp *error)

SendErr sends error as the final action of a goroutine

• SendErr should only panic from structural coding problems

func Sprintf

func Sprintf(format string, a ...interface{}) string

Sprintf is a printer that supports comma in large numbers

func Uintptr

func Uintptr(v any) (p uintptr)

Uintptr returns v as a pointer

• usable with fmt.Printf %x
• if uintptr is not used, Printf may go off interpreting the value pointed to, depending on its type

Usage:

var p = &SomeStruct{}
parl.Log("p: 0x%x", parl.Uintptr(p))

Types

type AtomicMax

type AtomicMax[T constraints.Integer] struct {
	// contains filtered or unexported fields
}

func NewAtomicMax

func NewAtomicMax[T constraints.Integer](value T) (atomicMax *AtomicMax[T])

func (*AtomicMax[T]) Max

func (max *AtomicMax[T]) Max() (value T, hasValue bool)

func (*AtomicMax[T]) Max1

func (max *AtomicMax[T]) Max1() (value T)

func (*AtomicMax[T]) Value

func (max *AtomicMax[T]) Value(value T) (isNewMax bool)

type Awaitable

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

Awaitable is a semaphore allowing any number of threads to observe and await an event

• one-to-many, happens-before
• the synchronization mechanic is closing channel, allowing consumers to await multiple events
• IsClosed provides thread-safe observability
• Close is idempotent, thread-safe, deferrable and panic-free
• [parl.CyclicAwaitable] is re-armable, cyclic version
• —
• alternative low-blocking inter-thread mechanics are sync.WaitGroup and sync.RWMutex but those are less performant for the managing thread

func NewAwaitable

func NewAwaitable() (awaitable *Awaitable)

NewAwaitable returns a one-to-many sempahore

func (*Awaitable) Ch

func (a *Awaitable) Ch() (ch AwaitableCh)

Ch returns an awaitable channel. Thread-safe

func (*Awaitable) Close

func (a *Awaitable) Close() (didClose bool)

Close triggers awaitable by closing the channel

• upon return, the channel is guaranteed to be closed
• idempotent, deferrable, panic-free, thread-safe

func (*Awaitable) IsClosed

func (a *Awaitable) IsClosed() (isClosed bool)

isClosed inspects whether the awaitable has been triggered

• Thread-safe

type AwaitableCh

type AwaitableCh <-chan struct{}

AwaitableCh is a one-to-many inter-thread wait-mechanic with happens-before

• AwaitableCh implements a semaphore
• implementation is a channel whose only allowed operation is channel receive
• AwaitableCh transfers no data, instead channel close is the significant event

Usage:

<-ch // waits for event

select {
  case <-ch:
    hasHappened = true
  default:
    hasHappened = false
}

type DA

type DA *pruntime.CodeLocation

DA is the value returned by a deferred code location function

func A

func A() DA

A is a thunk returning a deferred code location

type OnError

type OnError func(err error)

OnError is a function that receives error values from an errp error pointer or a panic