parl

May 23, 2024

Changes in this version

+ var NoErrp *error

+ func DeferredErrorSource(errorSource ErrorSource1, errp *error)

+ type AtomicError struct

+ func (a *AtomicError) AddError(err error)

+ func (a *AtomicError) Error() (err error, hasValue bool)

type ErrSlice

+ func (e *ErrSlice) AppendErrors(errp *error)

+ func (e *ErrSlice) EndCh() (ch AwaitableCh)

+ func (e *ErrSlice) EndErrors()

type ErrorSink

+ func NewErrorSinkEndable(errorSink1 ErrorSink1) (errorSink ErrorSink)

+ EndErrors func()

+ type ErrorSink1 interface

+ AddError func(err error)

type ErrorSource

+ EndCh func() (ch AwaitableCh)

+ type ErrorSource1 interface

+ Error func() (err error, hasValue bool)

type NBChan

+ func (n *NBChan[T]) GetError() (err error)

May 22, 2024

Changes in this version

type AwaitableSlice

+ func (s *AwaitableSlice[T]) SendClone(values []T)

May 20, 2024

Changes in this version

+ const LoserWait

+ func DeferredErrorSink(errorSink ErrorSink, errp *error)

type AwaitableSlice

+ func (s *AwaitableSlice[T]) Condition(valuep *T) (hasValue bool)

+ func (s *AwaitableSlice[T]) Init() (value T)

+ type ValueSink interface

+ EmptyCh func(doNotInitialize ...bool) (ch AwaitableCh)

+ Send func(value T)

+ SendSlice func(values []T)

+ type ValueSource interface

+ Condition func(valuep *T) (hasValue bool)

+ DataWaitCh func() (ch AwaitableCh)

+ EmptyCh func(doNotInitialize ...bool) (ch AwaitableCh)

+ Get func() (value T, hasValue bool)

+ GetAll func() (values []T)

+ GetSlice func() (values []T)

+ Init func() (value T)

May 19, 2024

Changes in this version

type ErrSlice

+ func (e *ErrSlice) EmptyCh(doNotInitialize ...bool) (ch AwaitableCh)

May 17, 2024

Changes in this version

+ const CloseAwaiter

+ const EvCon

type AwaitableSlice

+ func (s *AwaitableSlice[T]) GetSlice() (values []T)

May 14, 2024

Changes in this version

type Awaitable

+ func (a *Awaitable) CloseEv() (didClose bool)

type AwaitableSlice

+ func (s *AwaitableSlice[T]) EmptyCh() (ch AwaitableCh)

+ func (s *AwaitableSlice[T]) GetAll() (values []T)

type CyclicAwaitable

+ func (a *CyclicAwaitable) CloseEv() (didClose bool)

+ type ErrSlice struct

+ func (e *ErrSlice) AddError(err error)

+ func (e *ErrSlice) Error() (error, bool)

+ func (e *ErrSlice) Errors() (errs []error)

+ func (e *ErrSlice) WaitCh() (ch AwaitableCh)

+ type ErrorSource interface

+ Error func() (err error, hasValue bool)

+ WaitCh func() (ch AwaitableCh)

+ type ErrorsSource interface

+ Errors func() (errs []error)

+ type Errs interface

+ type LazyCyclic struct

+ Cyclic CyclicAwaitable

+ IsActive atomic.Bool

+ Lock sync.Mutex

May 13, 2024

Changes in this version

+ type AwaitableSlice struct

+ func (s *AwaitableSlice[T]) DataWaitCh() (ch AwaitableCh)

+ func (s *AwaitableSlice[T]) Get() (values []T)

+ func (s *AwaitableSlice[T]) Get1() (value T, hasValue bool)

+ func (s *AwaitableSlice[T]) Send(value T)

+ func (s *AwaitableSlice[T]) SendSlice(values []T)

+ func (s *AwaitableSlice[T]) SetSize(size int)

May 12, 2024

Changes in this version

type NBChan

+ func (n *NBChan[T]) SetOnDemandThread() (nb *NBChan[T])

type NBChanThreadType

+ const NBChanOnDemand

+ type NBRareChan struct

+ func (n *NBRareChan[T]) Ch() (ch <-chan T)

+ func (n *NBRareChan[T]) Close(values *[]T, errp *error)

+ func (n *NBRareChan[T]) IsClose() (isClose bool)

+ func (n *NBRareChan[T]) PanicCh() (emptyAwaitable AwaitableCh)

+ func (n *NBRareChan[T]) Send(value T)

+ func (n *NBRareChan[T]) StopSend() (emptyAwaitable AwaitableCh)

May 11, 2024

Changes in this version

+ const HasValue

+ const HonorProgressRaised

+ const IgnoreProgressRaised

+ const NoValue

May 8, 2024

Changes in this version

+ const AwaitThread

+ type Done interface

+ Done func()

+ type LacyChan struct

+ func (c *LacyChan[T]) Get(n ...int) (ch chan T)

+ type NBChanTState string

+ const NBChanNoLaunch

type PeriodWaiter

+ func (p *PeriodWaiter) Ch() (ch AwaitableCh)

+ type Send interface

+ Send func(value T)

May 3, 2024

Changes in this version

+ type IdempotentCloser struct

+ func NewIdemPotentCloser[C io.Closer](closer C) (idempotentCloser *IdempotentCloser[C])

+ func (c *IdempotentCloser[C]) Close() (err error)

+ func (c *IdempotentCloser[C]) IsClose() (isClose bool)

Apr 30, 2024

Changes in this version

type AddError

+ var NoAddErr AddError

Apr 28, 2024

Changes in this version

type OnceCh

+ func (o *OnceCh) IsInvoked() (isInvoked bool)

Feb 1, 2024

Changes in this version

+ const NoOnceWait

+ type OnceCh struct

+ func (o *OnceCh) Ch() (ch AwaitableCh)

+ func (o *OnceCh) IsClosed() (isClosed bool)

+ func (o *OnceCh) IsWinner(noWait ...bool) (isWinner bool, closeFunc func())

Jan 29, 2024

Changes in this version

+ func NoopPrintf(format string, a ...any)

Dec 26, 2023

Changes in this version

+ const AllowTermination

+ const PreventTermination

+ type Atomic64 struct

+ func (a *Atomic64[T]) Add(delta T) (new T)

+ func (a *Atomic64[T]) CompareAndSwap(old, new T) (swapped bool)

+ func (a *Atomic64[T]) Load() (value T)

+ func (a *Atomic64[T]) Store(val T)

+ func (a *Atomic64[T]) Swap(new T) (old T)

+ type WaitGroupCh struct

+ func (w *WaitGroupCh) Add(delta int)

+ func (w *WaitGroupCh) Ch() (awaitableCh AwaitableCh)

+ func (w *WaitGroupCh) Count(delta ...int) (currentCount, totalAdds int)

+ func (w *WaitGroupCh) Done()

+ func (w *WaitGroupCh) DoneBool() (isExit bool)

+ func (w *WaitGroupCh) IsZero() (isZero bool)

+ func (w *WaitGroupCh) Reset() (w2 *WaitGroupCh)

+ func (w *WaitGroupCh) String() (s string)

+ func (w *WaitGroupCh) Wait()

Dec 22, 2023

Changes in this version

type GoError

+ ErrString func() (errString string)

Dec 21, 2023

Changes in this version

type GoResult

+ func NewGoResult2(n ...int) (goResult GoResult)

+ func (g GoResult) IsValid() (isValid bool)

Dec 18, 2023

Changes in this version

+ type Atomic32 struct

+ func (x *Atomic32[T]) Add(delta T) (new T)

+ func (x *Atomic32[T]) CompareAndSwap(old, new T) (swapped bool)

+ func (x *Atomic32[T]) Load() (value T)

+ func (x *Atomic32[T]) Store(val T)

+ func (x *Atomic32[T]) Swap(new T) (old T)

Dec 17, 2023

Changes in this version

+ type Uint32 struct

+ func (x *Uint32[T]) Add(delta T) (new T)

+ func (x *Uint32[T]) CompareAndSwap(old, new T) (swapped bool)

+ func (x *Uint32[T]) Load() T

+ func (x *Uint32[T]) Store(val T)

+ func (x *Uint32[T]) Swap(new T) (old T)

Dec 13, 2023

Changes in this version

type GoResult

+ func (g GoResult) Count() (count int)

Dec 3, 2023

Changes in this version

+ func RecoverAnnotation(annotation string, errp *error, onError OnError)

+ type OnErrorStrategy uint8

Nov 27, 2023

Changes in this version

+ type GoResult chan error

+ func NewGoResult(n ...int) (goResult GoResult)

+ func (g GoResult) ReceiveError(errp *error, n ...int) (err error)

+ func (g GoResult) SendError(errp *error)

Nov 25, 2023

Changes in this version

type EchoModerator

+ func (m *EchoModerator) Ticket() (returnTicket func())

+ type Invocation struct

+ Next atomic.Pointer[Invocation[T]]

+ Prev atomic.Pointer[Invocation[T]]

+ ThreadID ThreadID

+ Value T

+ func NewInvocation[T any](invocationEnd func(invocation *Invocation[T], duration time.Duration), value T) (invocation *Invocation[T])

+ func (i *Invocation[T]) Age() (age time.Duration)

+ func (i *Invocation[T]) DeferFunc()

+ type InvocationTimer struct

+ func NewInvocationTimer[T any](callback CBFunc, endCb func(T), latencyWarningPoint time.Duration, ...) (invokeTimer *InvocationTimer[T])

+ func (i *InvocationTimer[T]) Invocation(value T) (deferFunc func())

+ func (i *InvocationTimer[T]) Oldest() (age time.Duration, threadID ThreadID)

Nov 25, 2023

Changes in this version

type DBPartition

+ const NoPartition

Nov 23, 2023

Changes in this version

type DSNrFactory

+ DataSourceNamer func(appName string) (dsnr DataSourceNamer, err error)

+ type DataSourceName string

Nov 17, 2023

Changes in this version

+ type CountingAwaitable struct

+ func NewCountingAwaitable() (awaitable *CountingAwaitable)

+ func (a *CountingAwaitable) Add(delta int)

+ func (a *CountingAwaitable) Count(delta ...int) (counter, adds int)

+ func (a *CountingAwaitable) Done()

+ func (a *CountingAwaitable) IsTriggered() (isTriggered bool)

type CyclicAwaitable

+ func NewCyclicAwaitableField(fieldp *CyclicAwaitable, initiallyClosed ...bool) (awaitable *CyclicAwaitable)

Nov 5, 2023

Changes in this version

+ const NoDebounceMaxDelay

+ const NoDebounceTime

type Future

+ func (f *Future[T]) TResult() (tResult *TResult[T])

Nov 4, 2023

Changes in this version

type TResult

+ func NewTResult3(value *T, isPanic *bool, errp *error) (tResult *TResult[T])

Nov 3, 2023

Changes in this version

+ var ErrNil = &nilValue

+ func NilError(valueName string) (err error)

Oct 30, 2023

Changes in this version

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

+ 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)

type AggregatePriority

+ Index func() (index int)

+ type DA *pruntime.CodeLocation

+ func A() DA

type Go

+ EntityID func() (goEntityID GoEntityID)

+ WaitCh func() (ch AwaitableCh)

+ type GoEntityID uint64

+ func (i GoEntityID) String() (s string)

+ type OnError func(err error)

type UniqueIDTypedUint64

+ var GoEntityIDs UniqueIDTypedUint64[GoEntityID]

Oct 26, 2023

Changes in this version

type AtomicMax

+ func (m *AtomicMax[T]) Init(value T) (atomicMax *AtomicMax[T])

type SlowDetectorCore

+ func (s *SlowDetectorCore) Init(threshold ...time.Duration) (slowDetector *SlowDetectorCore)

Oct 26, 2023

Changes in this version

+ const CyclicAwaitableClosed

+ type Awaitable struct

+ func NewAwaitable() (awaitable *Awaitable)

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

+ func (a *Awaitable) Close() (wasClosed bool)

+ func (a *Awaitable) IsClosed() (isClosed, isAboutToClose bool)

+ type AwaitableCh <-chan struct

+ type CyclicAwaitable struct

+ func NewCyclicAwaitable() (awaitable *CyclicAwaitable)

+ func (a *CyclicAwaitable) Ch() (ch AwaitableCh)

+ func (a *CyclicAwaitable) Close() (wasClosed bool)

+ func (a *CyclicAwaitable) Init(initiallyClosed ...bool) (a2 *CyclicAwaitable)

+ func (a *CyclicAwaitable) IsClosed() (isClosed, isAboutToClose bool)

+ func (a *CyclicAwaitable) Open() (didOpen bool)

Oct 22, 2023

Changes in this version

+ func OnDebug(invokedIfDebug func() string)

Oct 19, 2023

Changes in this version

type AndroidSerial

+ func NewAndroidSerial(s string) (serial AndroidSerial)

type AndroidStatus

+ func NewAndroidStatus(s string) (status AndroidStatus)

+ func (a AndroidStatus) IsOnline() (isOnline bool)

+ func (a AndroidStatus) IsValid() (isValid bool)

+ func (a AndroidStatus) String() (s string)

Oct 12, 2023

Changes in this version

type SubGo

+ WaitCh func() (ch <-chan struct{})

Sep 23, 2023

Changes in this version

type Adbette

+ ShellStream func(command string) (conn io.ReadWriteCloser, err error)

+ type AddError func(err error)

+ type AddErrorIf interface

+ AddError func(err error)

type AndroidSerial

+ func (a AndroidSerial) IsValid() (isValid bool)

+ func (a AndroidSerial) String() (s string)

type AtomicCounter

+ func (max *AtomicCounter) Dec2() (value uint64, didDec bool)

+ func (max *AtomicCounter) Inc2() (value uint64, didInc bool)

type Devicette

+ ShellStream func(command string) (conn io.ReadWriteCloser, err error)

type ModeratorCore

+ func (m *ModeratorCore) Ticket() (returnTicket func())

Jul 9, 2023

Changes in this version

+ const CloseChannelDrain

+ func CloseChannel(ch chan T, errp *error, drainChannel ...bool) (isNilChannel, isCloseOfClosedChannel bool, n int, err error)

Jul 8, 2023

Changes in this version

+ const SendNonBlocking

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

Jul 6, 2023

Changes in this version

+ const NBChanAlert

+ const NBChanExit

+ const NBChanExpectClose

+ const NBChanGets

+ const NBChanRunning

+ const NBChanSendBlock

+ const NBChanSends

+ const NBChanWillNotClose

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

+ func NBChanLogger(label string, n *NBChan[T], expectClose bool, log ...PrintfFunc)

+ func NBChanState(n *NBChan[T]) (s string)

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

type ClosableChan

+ func (c *ClosableChan[T]) ReceiveCh() (ch <-chan T)

+ func (c *ClosableChan[T]) SendCh() (ch chan<- T)

+ type CounterStore interface

+ GetCounter func(name CounterID) (counter Counter)

+ GetNamedCounter func(name CounterID) (counter any)

type CounterValues

+ GetReset func() (value, running, max uint64)

type NBChan

+ func (n *NBChan[T]) Capacity() (capacity int)

+ func (n *NBChan[T]) DataWaitCh() (ch <-chan struct{})

+ func (n *NBChan[T]) SetAllocationSize(size int) (nb *NBChan[T])

+ func (n *NBChan[T]) SetAlwaysThread() (nb *NBChan[T])

+ func (n *NBChan[T]) SetNoThread()

+ func (n *NBChan[T]) ThreadStatus() (threadStatus string)

+ func (n *NBChan[T]) WaitForCloseCh() (ch <-chan struct{})

+ type NBChanThreadType uint8

+ const NBChanAlways

+ const NBChanNone

+ func (n NBChanThreadType) String() (s string)

+ type PeriodWaiter struct

+ func NewPeriodWaiter() (periodWaiter *PeriodWaiter)

+ func (p *PeriodWaiter) Count() (waitingThreads int)

+ func (p *PeriodWaiter) HoldWaiters()

+ func (p *PeriodWaiter) IsHold() (isHold bool)

+ func (p *PeriodWaiter) ReleaseWaiters()

+ func (p *PeriodWaiter) Wait()

Jun 13, 2023

Changes in this version

type Debouncer

+ func (d *Debouncer[T]) Shutdown()

Jun 12, 2023

Changes in this version

+ func AddNotifier1(ctx context.Context, notifier NotifierFunc) (ctx2 context.Context)

+ func DebugThunk(argThunk func() string)

+ func Uintptr(v any) (p uintptr)

type NBChan

+ func (nb *NBChan[T]) Scavenge(setCapacity int) (length, capacity int)

+ type NotifierFunc func(slice pruntime.StackSlice)

Jun 10, 2023

Changes in this version

+ func CollectError(errCh <-chan error, errp *error) (err error)

May 21, 2023

Changes in this version

type Go

+ Creator func() (threadID ThreadID, createLocation *pruntime.CodeLocation)

+ GoRoutine func() (threadID ThreadID, goFunction *pruntime.CodeLocation)

type Stack

+ GoFunction func() (goFunction *pruntime.CodeLocation)

Apr 7, 2023

Changes in this version

type Debouncer

+ func (d *Debouncer[T]) Go()

Mar 16, 2023

Changes in this version

+ type GoDebug uint8

+ const AggregateThread

+ const DebugPrint

+ const NoDebug

Mar 1, 2023

Changes in this version

type GoGroup

+ EnableTermination func(allowTermination bool)

+ IsEnableTermination func() (mayTerminate bool)

Feb 27, 2023

Changes in this version

type WaitGroup

+ func NewWaitGroup() (waitGroup *WaitGroup)

Feb 26, 2023

Changes in this version

type Future

+ func (cn *Future[T]) End(result *T, errp *error)

+ func (cn *Future[T]) IsCompleted() (isCompleted bool)

+ func (cn *Future[T]) Result() (result T, isValid bool)

+ type Promise struct

+ func NewPromise(resolver TFunc[T], g0 Go) (promise *Promise[T])

+ type TFunc func() (value T, err error)

+ type TResult struct

+ Err error

+ IsPanic bool

+ Value T

+ func NewTResult(tFunc TFunc[T]) (tResult *TResult[T])

Feb 20, 2023

Changes in this version

type Once

+ func (o *Once) Result() (isPanic bool, hasResult bool, err error)

Feb 8, 2023

Changes in this version

type SlowDetectorInvocation

+ func (sdi *SlowDetectorInvocation) Intervals() (intervalStr string)

Feb 7, 2023

Changes in this version

+ var Arrival ptime.EpochValue

+ var Result ptime.EpochValue

+ func RecoverInvocationPanicErr(fn func() (err error)) (isPanic bool, err error)

type AtomicCounter

+ var AfterReturn AtomicCounter

+ var Calc AtomicCounter

+ var CancelReturn AtomicCounter

+ var DidOnceReturn AtomicCounter

+ var NewCalculationReturn AtomicCounter

+ var WinnerReturn AtomicCounter

type AtomicReference

+ func (ref *AtomicReference[T]) PutIf(reference *T, expected *T) (swapped bool)

+ type AwaitableCalculation struct

+ func NewAwaitableCalculation() (calculation *AwaitableCalculation[T])

+ func (cn *AwaitableCalculation[T]) End(result T, errp *error)

+ func (cn *AwaitableCalculation[T]) IsCompleted() (isCompleted bool)

+ func (cn *AwaitableCalculation[T]) Result() (result T, isValid bool)

+ type InvokeResult struct

+ Err error

+ IsPanic bool

+ type Invoker struct

+ func NewInvoker(funcErr func() (err error)) (invoker *Invoker)

+ func (i *Invoker) Func()

+ func (i *Invoker) InvokeResult() (invokeResult *InvokeResult)

+ func (i *Invoker) Result() (isDone, isPanic bool, err error)

+ type MutexWait struct

+ func NewMutexWait() (mutexWait *MutexWait)

+ func (mw *MutexWait) IsUnlocked() (isUnlocked bool)

+ func (mw *MutexWait) Unlock()

+ func (mw *MutexWait) Wait()

Feb 2, 2023

Changes in this version

+ type SelectChannel struct

+ func NewSelectChannel() (channelWaiter *SelectChannel)

+ func (cw *SelectChannel) Ch() (ch <-chan struct{})

+ func (cw *SelectChannel) Trig()

Jan 30, 2023

Changes in this version

type SlowDetector

+ func (sd *SlowDetector) IsValid() (isValid bool)

Jan 29, 2023

Changes in this version

type NBChan

+ func (nb *NBChan[T]) SendMany(values []T)

type WinOrWaiterStrategy

+ func (ws WinOrWaiterStrategy) IsValid() (isValid bool)

Jan 28, 2023

Changes in this version

type SlowDetector

+ func (sd *SlowDetector) Values() (last, average, max time.Duration, hasValue bool)

type SlowDetectorCore

+ func (sd *SlowDetectorCore) Values() (last, average, max time.Duration, hasValue bool)

Jan 28, 2023

Changes in this version

type Go

+ GoID func() (threadID ThreadID)

+ type Interval struct

type SlowDetector

+ func (sd *SlowDetector) Status() (s string)

+ func (sd *SlowDetector) Status0() (s string)

type SlowDetectorCore

+ func (sd *SlowDetectorCore) Status() (s string)

type SlowDetectorInvocation

+ func (sdi *SlowDetectorInvocation) Interval(label string, t ...time.Time)

type SlowInvocation

+ Interval func(label string, t ...time.Time)

Jan 27, 2023

Changes in this version

type CounterSetData

+ Get func(name CounterID) (value, running, max uint64)

Jan 25, 2023

Changes in this version

+ var ErrNilValue = NilValueError(errors.New("end callbacks error"))

+ func EndCallbacks(err error) (err2 error)

+ func NilValueError(err error) (err2 error)

type AtomicCounter

+ func (max *AtomicCounter) Set(value uint64) (oldValue uint64)

+ type ErrorString struct

+ func (e *ErrorString) Error() string

Jan 24, 2023

Changes in this version

type SlowDetector

+ func (sd *SlowDetector) Start0() (slowInvocation SlowInvocation)

Jan 23, 2023

Changes in this version

+ const SlowDefault

+ const SlowOwnThread

+ const SlowShutdownThread

type AtomicMax

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

+ type AtomicMaxDuration struct

+ func (ad *AtomicMaxDuration) Max() (max time.Duration, hasValue bool)

+ func (ad *AtomicMaxDuration) Start(value ...time.Time) (tStart time.Time)

+ func (ad *AtomicMaxDuration) Stop(value ...time.Time) (duration time.Duration, isNewMax bool)

+ type CbSlowDetector func(sdi *SlowDetectorInvocation, hasReturned bool, duration time.Duration)

type SlowDetector

+ func (sd *SlowDetector) Max() (max time.Duration, hasValue bool)

+ type SlowDetectorCore struct

+ ID slowID

+ func NewSlowDetectorCore(callback CbSlowDetector, slowTyp slowType, goGen GoGen, ...) (slowDetector *SlowDetectorCore)

+ func (sd *SlowDetectorCore) Max() (max time.Duration, hasValue bool)

+ func (sd *SlowDetectorCore) Start(invoLabel string, value ...time.Time) (invocation *SlowDetectorInvocation)

+ type SlowDetectorInvocation struct

+ func (sdi *SlowDetectorInvocation) Label() (label string)

+ func (sdi *SlowDetectorInvocation) Stop(value ...time.Time)

+ func (sdi *SlowDetectorInvocation) T0() (t0 time.Time)

+ func (sdi *SlowDetectorInvocation) ThreadID() (threadID ThreadID)

+ func (sdi *SlowDetectorInvocation) Time(t time.Time) (previousT time.Time)

+ type SlowDetectorThread struct

+ func NewSlowDetectorThread(slowTyp slowType, nonReturnPeriod time.Duration, goGen GoGen) (sdt *SlowDetectorThread)

+ func (sdt *SlowDetectorThread) Start(sdi *SlowDetectorInvocation)

+ func (sdt *SlowDetectorThread) Stop(sdi *SlowDetectorInvocation)

+ type SlowInvocation interface

+ Stop func(value ...time.Time)

Jan 22, 2023

Changes in this version

type AtomicBool

+ func (ab *AtomicBool) IsFalse() (isFalse bool)

type AtomicCounter

+ func (max *AtomicCounter) Add(value uint64) (newValue uint64)

+ type AtomicMin struct

+ func (min *AtomicMin[T]) Min() (value T, hasValue bool)

+ func (min *AtomicMin[T]) Value(value T) (isNewMin bool)

type GoErrorContext

+ const GeTerminate

type GoGroup

+ NamedThreads func() (threads []ThreadData)

+ SetDebug func(debug bool)

+ Threads func() (threads []ThreadData)

type Once

+ func (o *Once) DoErr(f func() (err error)) (didOnce, isPanic bool, err error)

type SubGo

+ EnableTermination func(allowTermination bool)

+ IsEnableTermination func() (mayTerminate bool)

+ NamedThreads func() (threads []ThreadData)

+ SetDebug func(debug bool)

+ Threads func() (threads []ThreadData)

+ type ThreadData interface

+ Create func() (createLocation *pruntime.CodeLocation)

+ Func func() (funcLocation *pruntime.CodeLocation)

+ Name func() (label string)

+ Short func() (short string)

+ ThreadID func() (threadID ThreadID)

type WaitGroup

+ func (wg *WaitGroup) Count() (remaining int)

Jan 16, 2023

Changes in this version

type NBChan

+ func (nb *NBChan[T]) Get(n ...int) (allItems []T)

Jan 16, 2023

Changes in this version

+ type AtomicCounter uint64

+ func (max *AtomicCounter) Dec() (value uint64)

+ func (max *AtomicCounter) Inc() (value uint64)

+ func (max *AtomicCounter) Value() (value uint64)

+ type AtomicMax uint64

+ func NewAtomicMax(value T) (atomicMax AtomicMax[T])

+ func (max *AtomicMax[T]) Max() (value T)

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

+ type AtomicReference struct

+ func MakeAtomicReference() (reference AtomicReference[T])

+ func (ref *AtomicReference[T]) Get() (reference *T)

+ func (ref *AtomicReference[T]) Put(reference *T)

+ type CBFunc func(reason CBReason, maxParallelism uint64, maxLatency time.Duration, ...)

+ type CBReason uint8

+ const ITLatency

+ const ITParallelism

+ func (ws CBReason) String() (s string)

+ type CounterSetData interface

+ DatapointMax func(name CounterID) (max uint64)

+ DatapointMin func(name CounterID) (min uint64)

+ DatapointValue func(name CounterID) (value uint64)

+ Exists func(name CounterID) (exists bool)

+ GetDatapoint func(name CounterID) (value, max, min uint64, isValid bool, average float64, n uint64)

+ Max func(name CounterID) (max uint64)

+ Rates func(name CounterID) (rates map[RateType]int64)

+ Running func(name CounterID) (running uint64)

+ Value func(name CounterID) (value uint64)

+ type EchoModerator struct

+ func NewEchoModerator(concurrency uint64, latencyWarningPoint time.Duration, ...) (echoModerator *EchoModerator)

+ func (em *EchoModerator) Do(fn func())

+ type InvokeTimer struct

+ func NewInvokeTimer(callback CBFunc, latencyWarningPoint time.Duration, ...) (invokeTimer *InvokeTimer)

+ func (em *InvokeTimer) Do(fn func())

+ func (em *InvokeTimer) Oldest() (age time.Duration, threadID ThreadID)

+ type SlowDetector struct

+ ID slowID

+ IDlock sync.Mutex

+ func NewSlowDetector(label string, threshold ...time.Duration) (slowDetector *SlowDetector)

+ func NewSlowDetectorPrintf(label string, printf PrintfFunc, threshold ...time.Duration) (slowDetector *SlowDetector)

+ func (sd *SlowDetector) Start()

+ func (sd *SlowDetector) Stop()

type WinOrWaiterCore

+ func (ww *WinOrWaiterCore) Invalidate()

+ type WinOrWaiterStrategy uint8

+ const WinOrWaiterAnyValue

+ const WinOrWaiterMustBeLater

+ func (ws WinOrWaiterStrategy) String() (s string)

Jan 14, 2023

Changes in this version

type ThreadID

+ func (threadID ThreadID) IsValid() (isValid bool)

Jan 4, 2023

Changes in this version

+ func IsNil(v any) (isNil bool)

Jan 1, 2023

Changes in this version

+ type Pid uint32

+ func NewPid(pid T) (typedPid Pid, err error)

+ func NewPid1(pid T) (typedPid Pid)

+ func (pid Pid) Int() (pidInt int)

+ func (pid Pid) IsValid() (isValid bool)

+ func (pid Pid) String() (s string)

+ func (pid Pid) Uint32() (pidUint32 uint32)

Dec 31, 2022

Changes in this version

+ type ElementFull interface

+ Description func() (full string)

+ type Enum interface

+ type EnumItem interface

+ Description func() (desc string)

+ Key func() (key K)

+ Value func() (value V)

+ type Iterator interface

+ Cancel func() (err error)

+ Has func() (hasValue bool)

+ HasNext func() (hasValue bool)

+ Next func() (value T, hasValue bool)

+ NextValue func() (value T)

+ Same func() (value T, hasValue bool)

+ SameValue func() (value T)

+ type KeyEnum interface

+ Compare func(value1, value2 T) (result int)

+ Description func(enum T) (desc string)

+ IsKey func(key K) (isKey bool)

+ IsValid func(enum T) (isEnumValue bool)

+ Iterator func() (iterator Iterator[T])

+ Key func(value T) (key K, err error)

+ KeyIterator func() (iterator Iterator[K])

+ Name func() (s string)

+ StringT func(enum T) (s string)

+ Value func(key K) (enum T, err error)

+ ValueAny func(value any) (enum T, err error)

type Set

+ Description func(value T) (s string)

Dec 30, 2022

Changes in this version

+ type AggregatePriority interface

+ Aggregator func() (aggregator Aggregator[V, P])

+ CachedPriority func() (priority P)

+ Update func()

+ type AggregatingPriorityQueue interface

+ Clear func()

+ Get func(valuep *V) (aggregator Aggregator[V, P], ok bool)

+ List func(n ...int) (aggregatorQueue []AggregatePriority[V, P])

+ Put func(valuep *V, aggregator Aggregator[V, P])

+ Update func(valuep *V)

+ type Aggregator interface

+ Aggregate func()

+ Priority func() (priority P)

+ Value func() (valuep *V)

+ type AssignedPriority interface

+ SetPriority func(priority P)

+ type PriorityQueue interface

+ AddOrUpdate func(value *V)

+ List func(n ...int) (valueQueue []*V)

+ type UniqueIDint int

+ func (u *UniqueIDint) ID() (uniqueID int)

+ func (u *UniqueIDint) String() (s string)

Dec 28, 2022

Changes in this version

+ var ErrErrpNil = errors.New("errp cannot be nil")

+ func AddNotifier(ctx context.Context, notifierFn func(slice pruntime.StackSlice)) (ctx2 context.Context)

+ func HasCancel(ctx context.Context) (hasCancel bool)

+ func ImportNewStack(pdebugNewStack func(skipFrames int) (stack Stack))

+ func InitWaitGroup(wgp *WaitGroup)

+ func InvokeIf(tp *T, fn func())

+ func RecoverInvocationPanic(fn func(), errp *error)

+ type AtomicReferece struct

+ func MakeAtomicReferece() (reference AtomicReferece[T])

+ func (ref *AtomicReferece[T]) Get() (reference *T)

+ func (ref *AtomicReferece[T]) Put(reference *T)

+ type Comparable interface

+ Cmp func(b T) (result int)

type Counter

+ Add func(delta int64) (counter Counter)

+ type CounterSet interface

+ GetCounters func() (orderedKeys []CounterID, m map[CounterID]any)

+ ResetCounters func(stopRateCounters bool)

type CounterValues

+ Clone func() (counterValues CounterValues)

+ CloneReset func(stopRateCounters bool) (counterValues CounterValues)

type Counters

+ GetOrCreateDatapoint func(name CounterID, period time.Duration) (datapoint Datapoint)

+ type CyclicWait struct

+ func NewCyclicWait(ctx context.Context) (onceReceiver *CyclicWait)

+ func (cw *CyclicWait) Cancel()

+ func (cw *CyclicWait) CancelAndRearm() (wasRearmed bool)

+ func (cw *CyclicWait) Ch() (ch <-chan struct{})

+ func (cw *CyclicWait) Context() (ctx context.Context)

+ func (cw *CyclicWait) DidOccurer() (didOccurer *OnceWaiterRO)

+ func (cw *CyclicWait) Done() (done <-chan struct{})

+ func (cw *CyclicWait) IsCancel() (isCancel bool)

+ func (cw *CyclicWait) Wait()

+ type Datapoint interface

+ SetValue func(value uint64) (datapoint Datapoint)

+ type DatapointValue interface

+ CloneDatapoint func() (datapoint Datapoint)

+ CloneDatapointReset func() (datapoint Datapoint)

+ DatapointMax func() (max uint64)

+ DatapointMin func() (min uint64)

+ DatapointValue func() (value uint64)

+ GetDatapoint func() (value, max, min uint64, isValid bool, average float64, n uint64)

+ type Element interface

+ Value func() (value T)

type Go

+ CancelGo func()

+ Go func() (g1 Go)

+ SubGroup func(onFirstFatal ...GoFatalCallback) (subGroup SubGroup)

+ ThreadInfo func() (threadID ThreadID, createLocation pruntime.CodeLocation, ...)

+ Wait func()

type GoError

+ Err func() (err error)

+ ErrContext func() (errContext GoErrorContext)

+ Go func() (g0 Go)

+ IsFatal func() (isThreadExit bool)

+ IsThreadExit func() (isThreadExit bool)

+ Time func() time.Time

+ type GoErrorContext uint8

+ const GeLocalChan

+ func (ge GoErrorContext) String() (s string)

+ type GoFactory interface

+ NewGoGroup func(ctx context.Context, onFirstFatal ...GoFatalCallback) (g1 GoGroup)

+ type GoFatalCallback func(goGen GoGen)

+ type GoGen interface

+ Cancel func()

+ Context func() (ctx context.Context)

+ Go func() (g1 Go)

+ SubGo func(onFirstFatal ...GoFatalCallback) (subGo SubGo)

+ SubGroup func(onFirstFatal ...GoFatalCallback) (subGroup SubGroup)

type GoGroup

+ Cancel func()

+ Ch func() (ch <-chan GoError)

+ Context func() (ctx context.Context)

+ Go func() (g1 Go)

+ SubGo func(onFirstFatal ...GoFatalCallback) (subGo SubGo)

+ SubGroup func(onFirstFatal ...GoFatalCallback) (subGroup SubGroup)

type NBChan

+ func (nb *NBChan[T]) GetAll() (allItems []T)

+ type OnceWaiter struct

+ func NewOnceWaiter(ctx context.Context) (onceReceiver *OnceWaiter)

+ func (cw *OnceWaiter) Context() (ctx context.Context)

+ func (ow *OnceWaiter) Cancel()

+ func (ow *OnceWaiter) Ch() (ch <-chan struct{})

+ func (ow *OnceWaiter) DidOccur() (didOccur bool)

+ func (ow *OnceWaiter) Done() (done <-chan struct{})

+ func (ow *OnceWaiter) Wait()

+ type OnceWaiterRO struct

+ func NewOnceWaiterRO(onceWaiter *OnceWaiter) (onceWaiterRO *OnceWaiterRO)

+ func (ow *OnceWaiterRO) Ch() (ch <-chan struct{})

+ func (ow *OnceWaiterRO) Context() (ctx context.Context)

+ func (ow *OnceWaiterRO) DidOccur() (didOccur bool)

+ func (ow *OnceWaiterRO) Done() (done <-chan struct{})

+ func (ow *OnceWaiterRO) Wait()

+ type Ordered interface

+ Clone func() (ordered Ordered[E])

+ Delete func(element E)

+ Index func(element E) (index int)

+ Insert func(element E)

+ type PrintfFunc func(format string, a ...any)

+ type Ranking interface

+ AddOrUpdate func(value *V)

+ List func(n ...int) (rank []*V)

+ type Rate interface

+ Clone func() (rate Rate)

+ Delta func() (delta uint64)

+ Duration func() (duration time.Duration)

+ HasValue func() (hasValue bool)

+ type RateCounterValues interface

+ Rates func() (rates map[RateType]int64)

+ type RateType int

+ const NotAValue

+ const RunningAverage

+ const RunningMaxDecRate

+ const RunningMaxRate

+ const RunningRate

+ const ValueMaxRate

+ const ValueRate

+ const ValueRateAverage

+ type Resolver func() (value T, err error)

+ type Set interface

+ Element func(value T) (element Element[T])

+ IsValid func(value T) (isValid bool)

+ StringT func(value T) (s string)

+ type SetFactory interface

+ NewSet func(elements []Element[T]) (interfaceSet Set[T])

+ type Slice interface

+ Clear func()

+ Element func(index int) (element E)

+ Length func() (length int)

+ List func() (list []E)

type SubGo

+ Context func() (ctx context.Context)

+ Go func() (g1 Go)

+ SubGo func(onFirstFatal ...GoFatalCallback) (subGo SubGo)

+ SubGroup func(onFirstFatal ...GoFatalCallback) (subGroup SubGroup)

+ type SubGroup interface

+ Ch func() (ch <-chan GoError)

+ FirstFatal func() (firstFatal *OnceWaiterRO)

+ type ThreadSafeMap interface

+ Clear func()

+ Clone func() (clone ThreadSafeMap[K, V])

+ Delete func(key K)

+ Get func(key K) (value V, ok bool)

+ GetOrCreate func(key K, newV func() (value *V), makeV func() (value V)) (value V, ok bool)

+ Length func() (length int)

+ List func() (list []V)

+ Put func(key K, value V)

+ type UniqueIDTypedUint64 uint64

+ func (u *UniqueIDTypedUint64[T]) ID() (uniqueT T)

+ func (u *UniqueIDTypedUint64[T]) StringT(t T) (s string)

+ type UniqueIDUint64 uint64

+ func (u *UniqueIDUint64) ID() (uniqueUint64 uint64)

+ func (u *UniqueIDUint64) String() (s string)

+ type WinOrWaiter struct

+ func NewWinOrWaiter(mustBeLater bool, g0 GoGen) (winOrWaiter *WinOrWaiter)

+ type WinOrWaiterCore struct

+ func NewWinOrWaiterCore(mustBeLater bool, g0 ...Go) (winOrWaiter *WinOrWaiterCore)

+ func (ww *WinOrWaiterCore) IsCancel() (isCancel bool)

+ func (ww *WinOrWaiterCore) WinOrWait() (isWinner bool)

+ func (ww *WinOrWaiterCore) WinnerDone(errp *error)

Nov 21, 2022

Changes in this version

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

+ var ErrNotCancelContext = errors.New("context chain does not have CancelContext")

+ func CancelOnError(errp *error, ctx context.Context)

+ func InvokeCancel(ctx context.Context)

+ func ShortSpace(tim ...time.Time) (s string)

Jun 26, 2022

Changes in this version

+ func ShortMs(tim ...time.Time) (s string)

type CertificateAuthority

+ Private func() (privateKey PrivateKey)

Jun 24, 2022

Changes in this version

+ func DoGoGetError(op func() (err error), g0 Go) (err error)

+ func DoProcThread(op func(), g0 Go)

+ func DoThread(op func() (err error), g0 Go)

+ func DoThreadError(op func() (err error), errCh chan<- error, g0 Go)

+ func GetD(skipFrames int) (debug func(format string, a ...interface{}))

+ func Short(tim ...time.Time) (s string)

type CancelContext

+ func NewCancelContextFunc(ctx context.Context, cancel context.CancelFunc) (cancelCtx CancelContext)

+ CancelOnError func(errp *error)

type CancelContextDo

+ func (cc *CancelContextDo) CancelOnError(errp *error)

+ type Certificate interface

+ DER func() (der CertificateDer)

+ PEM func() (pemBytes PemBytes)

+ ParseCertificate func() (certificate *x509.Certificate, err error)

+ type CertificateAuthority interface

+ Check func() (cert *x509.Certificate, err error)

+ DER func() (certificateDer CertificateDer)

+ PEM func() (pemBytes PemBytes)

+ Sign func(template *x509.Certificate, publicKey crypto.PublicKey) (certDER CertificateDer, err error)

+ type CertificateDer []byte

+ type Closers struct

+ func (cl *Closers) Add(closer io.Closer)

+ func (cl *Closers) Close() (err error)

+ func (cl *Closers) EnsureClosed(closer io.Closer) (err error)

+ func (cl *Closers) Remove(closer io.Closer) (ok bool)

+ type Debouncer struct

+ func (db *Debouncer[T]) Wait()

+ type DoErr interface

+ DoErr func(op func() (err error)) (err error)

+ type Future struct

+ func NewFuture(fn func() (value T, err error)) (future *Future[T])

+ func (f *Future[T]) Ch() (ch <-chan FutureValue[T])

+ func (f *Future[T]) IsDone() (isDone bool)

+ func (f *Future[T]) Wait() (value T, err error)

+ type FutureCore struct

+ func InitFutureCore(fn func() (value T, err error), f *FutureCore[T]) (futureCore *FutureCore[T])

+ func NewFutureCore(fn func() (value T, err error)) (futureCore *FutureCore[T])

+ func (f *FutureCore[T]) IsDone() (isDone bool)

+ func (f *FutureCore[T]) Wait() (value T, err error)

+ type FutureValue struct

+ type GoSubLocal string

+ const GoSubIsLocal

type Moderator

+ func NewModeratorFromCore(mc *ModeratorCore, ctx context.Context) (mo *Moderator)

+ func (mo *Moderator) DoErr(fn func() error) (err error)

+ type ModeratorCore struct

+ func NewModeratorCore(parallelism uint64) (mo *ModeratorCore)

+ func (mo *ModeratorCore) Do(fn func())

+ func (mo *ModeratorCore) Status() (parallelism uint64, active uint64, waiting uint64)

+ func (mo *ModeratorCore) String() (s string)

+ type OrderedMap interface

+ Delete func(key K)

+ Get func(key K, newV func() (value *V), makeV func() (value V)) (value V)

+ Has func(key K) (value V, ok bool)

+ List func() (list []V)

+ type OrderedMapAny interface

+ Delete func(order O)

+ Get func(key O, newV func() (value *V), makeV func() (value V)) (value V)

+ Has func(order O) (value V, ok bool)

+ List func() (list []V)

+ type OrderedPointers interface

+ Insert func(element *E)

+ List func() (list []*E)

+ type OrderedValues interface

+ Delete func(element E)

+ Insert func(element E)

+ List func() (list []E)

+ type PemBytes []byte

type Periodically

+ func (p *Periodically) Wait()

+ type PrivateKey interface

+ Algo func() (algo x509.PublicKeyAlgorithm)

+ DER func() (privateKeyDer PrivateKeyDer, err error)

+ DERe func() (privateKeyDer PrivateKeyDer)

+ PEM func() (pemBytes PemBytes, err error)

+ PEMe func() (pemBytes PemBytes)

+ PublicKey func() (publicKey PublicKey)

+ Validate func() (err error)

+ type PrivateKeyDer []byte

+ type PrivateKeyFactory interface

+ NewPrivateKey func(algo x509.PublicKeyAlgorithm) (privateKey PrivateKey, err error)

+ type PublicKey interface

+ Algo func() (algo x509.PublicKeyAlgorithm)

+ DER func() (publicKeyDer PublicKeyDer, err error)

+ DERe func() (publicKeyDer PublicKeyDer)

+ Equal func(x crypto.PublicKey) (isEqual bool)

+ PEM func() (pemBytes PemBytes, err error)

+ PEMe func() (pemBytes PemBytes)

+ type PublicKeyDer []byte

type SerialDo

+ func (sdo *SerialDo) State() (busySince time.Time, pendingSince time.Time, isCancel bool, ...)

+ func (sdo *SerialDo) String() (s string)

+ func (sdo *SerialDo) Wait()

+ type SerialDoCore struct

+ func NewSerialDoCore(thunk func(at time.Time), errFn func(err error), ctx context.Context) (serialDoCore *SerialDoCore)

+ func (sdo *SerialDoCore) Do(now ...time.Time) (isPending bool, isShutdown bool)

+ func (sdo *SerialDoCore) Wait(at time.Time)

type SerialDoEvent

+ ID SerialDoID

+ func NewSerialDoEvent(typ SerialDoType, t time.Time, serialDo *SerialDo) (event *SerialDoEvent)

+ func (e *SerialDoEvent) String() (s string)

+ type SerialDoID string

+ func (id SerialDoID) String() (s string)

+ type SerialDoType uint8

+ func (e SerialDoType) IsValid() (isValid bool)

+ func (e SerialDoType) String() (s string)

type SubGo

+ IsErr func() (isNonFatal bool, isErrorExit bool)

+ type UniqueID struct

+ func (u *UniqueID[T]) ID() (unique T)

May 5, 2022

Changes in this version

+ func GetDebug(skipFrames int) (debug func(format string, a ...interface{}))

+ func IsThisDebugN(skipFrames int) (isDebug bool)

type Stack

+ Shorts func(prepend string) (s string)

May 4, 2022

Changes in this version

type Frame

+ String func() (s string)

type Stack

+ String func() (s string)

May 4, 2022

Changes in this version

+ type CancelAndContext struct

+ func NewCancelAndContext(ctx context.Context) (cc *CancelAndContext)

+ func (cc *CancelAndContext) Cancel()

+ func (cc *CancelAndContext) Context() (ctx context.Context)

+ type ErrorCloser interface

+ Close func()

+ InvokeIfError func(addError func(err error))

+ type ErrorManager interface

+ Ch func() (ch <-chan GoError)

+ type ErrorSink interface

+ AddError func(err error)

+ type Frame interface

+ Args func() (args string)

+ Loc func() (location *pruntime.CodeLocation)

type Go

+ Cancel func()

+ type GoManager interface

+ Cancel func()

+ Ch func() (ch <-chan GoError)

+ Context func() (ctx context.Context)

+ IsExit func() (isExit bool)

+ String func() (s string)

+ Wait func()

type Goer

+ AddError func(err error)

type NBChan

+ func (nb *NBChan[T]) DidClose() (didClose bool)

+ type Stack interface

+ Creator func() (creator *pruntime.CodeLocation)

+ Frames func() (frames []Frame)

+ ID func() ThreadID

+ IsMain func() (isMain bool)

+ Status func() ThreadStatus

+ type SyncAdd interface

+ Add func(delta int)

+ type SyncDone interface

+ Done func()

+ type SyncWait interface

+ Wait func()

+ type TraceGroup struct

+ func (wg *TraceGroup) Add(delta int)

+ func (wg *TraceGroup) Done()

+ func (wg *TraceGroup) DoneBool() (isZero bool)

+ func (wg *TraceGroup) String() (s string)

+ type WaitAction struct

+ Delta int

+ ID ThreadID

+ IsDone bool

+ Loc pruntime.CodeLocation

+ func NewWaitAction(skipFrames int, delta int, isDone bool) (waitAction *WaitAction)

+ func (wa *WaitAction) String() (s string)

+ type WaitDo struct

+ func (w *WaitDo) IsExit() (isExit bool)

type WaitGroup

+ func (wg *WaitGroup) DoneBool() (isExit bool)

+ func (wg *WaitGroup) String() (s string)

+ type WaitedOn interface

+ DoneBool func() (isExit bool)

+ IsZero func() (isZero bool)

+ type Waiter interface

+ type WaitingFor interface

+ Counters func() (adds, dones int)

+ IsZero func() (isZero bool)

+ String func() (s string)

Apr 30, 2022

Changes in this version

+ type GoGroupFactory interface

+ NewGoGroup func(ctx context.Context) (goGroup GoGroup)

+ type GoerGroup interface

+ AddError func(err error)

+ Cancel func()

+ Ch func() (ch <-chan GoError)

+ Context func() (ctx context.Context)

+ Go func() (g0 Go)

+ IsExit func() (isExit bool)

+ String func() (s string)

+ Wait func()

+ type GoerGroupFactory interface

+ NewGoerGroup func(ctx context.Context) (goer GoerGroup)

Apr 29, 2022

Changes in this version

+ type GoGroup interface

+ Add func(conduit ErrorConduit, exitAction ExitAction) (goer Goer)

+ IsExit func() (isExit bool)

+ List func() (s string)

+ Wait func()

+ WaitPeriod func(duration ...time.Duration)

+ Warnings func() (ch <-chan GoError)

type Goer

+ Cancel func()

+ Ch func() (ch <-chan GoError)

+ Context func() (ctx context.Context)

+ type GoerFactory interface

+ NewGoer func(ctx context.Context) (goer SubGoer)

+ type Once struct

+ func (o *Once) Do(f func())

+ func (o *Once) IsDone() (isDone bool)

+ type SubGoer interface

+ AddError func(err error)

+ Cancel func()

+ Ch func() (ch <-chan GoError)

+ Context func() (ctx context.Context)

+ Go func() (g0 Go)

+ IsExit func() (isExit bool)

+ String func() (s string)

+ Wait func()

Apr 27, 2022

Changes in this version

type GoError

+ String func() (s string)

type GoErrorSource

+ func (ge GoErrorSource) String() (s string)

type Goer

+ String func() (s string)

type SubGo

+ String func() (s string)

Apr 27, 2022

Changes in this version

+ type Periodically struct

+ func NewPeriodically(fn func(t time.Time), ctx context.Context, period ...time.Duration) (periodically *Periodically)

Apr 26, 2022

Changes in this version

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

+ func CloserSend(ch chan<- T, errp *error)

type Go

+ SubGo func() (subGo SubGo)

+ type SubGo interface

+ Cancel func()

+ Wait func()

Apr 25, 2022

Changes in this version

type DB

+ QueryInt func(partition DBPartition, query string, ctx context.Context, args ...any) (value int, err error)

+ QueryString func(partition DBPartition, query string, ctx context.Context, args ...any) (value string, err error)

+ type DBPartition string

+ type DSNrFactory interface

+ NewDSNr func(appName string) (dsnr DataSourceNamer)

type DataSource

+ PrepareContext func(ctx context.Context, query string) (stmt *sql.Stmt, err error)

+ type ExecResult interface

+ Get func() (ID int64, rows int64)

+ String func() (s string)

Apr 23, 2022

Changes in this version

type Counter

+ SetValue func(value uint64)

type GoCreator

+ List func() (s string)

Apr 23, 2022

Changes in this version

+ const GeExit

+ const GeInternal

+ const GeNonFatal

+ const GePreDoneExit

+ func Consolew(format string, a ...interface{})

+ func Infallible(err error)

+ func Logw(format string, a ...interface{})

+ func NewThreadResult(err error) (failure error)

+ func NoOnError(err error)

+ func OnCancel(fn func(), ctx context.Context)

+ func Outw(format string, a ...interface{})

+ type CancelContext interface

+ Cancel func()

+ func NewCancelContext(ctx context.Context) (cancelCtx CancelContext)

+ type CancelContextDo struct

+ func (cc *CancelContextDo) Cancel()

+ type Conduit interface

+ func NewConduit(done Doneable, ctx context.Context) (conduit Conduit[T])

+ type ConduitDo struct

+ func (ct *ConduitDo[T]) Count() (count int)

+ func (ct *ConduitDo[T]) Get() (value T, ok bool)

+ func (ct *ConduitDo[T]) GetSlice(max int) (values []T, ok bool)

+ func (ct *ConduitDo[T]) IsCanceled() (IsCanceled bool)

+ func (ct *ConduitDo[T]) IsEmpty() (isEmpty bool)

+ func (ct *ConduitDo[T]) Put(value T) (IsCanceled bool)

+ func (ct *ConduitDo[T]) PutSlice(values []T) (IsCanceled bool)

+ func (ct *ConduitDo[T]) WaitCount() (waitCount int)

+ type DB interface

+ Close func()

+ Exec func(query string, args ...any) (id int64, rows int64, err error)

+ ExecContext func(ctx context.Context, query string, args ...any) (id int64, rows int64, err error)

+ ExecYear func(year string, query string, args ...any) (id int64, rows int64, err error)

+ ExecYearContext func(year string, ctx context.Context, query string, args ...any) (id int64, rows int64, err error)

+ Query func(cb func(sqlRows *sql.Rows) (err error), query string, args ...any) (err error)

+ QueryContext func(ctx context.Context, cb func(sqlRows *sql.Rows) (err error), query string, ...) (err error)

+ QueryRow func(query string, args ...any) (sqlRow *sql.Row, err error)

+ QueryRowContext func(ctx context.Context, query string, args ...any) (sqlRow *sql.Row, err error)

+ QueryRowYear func(year string, query string, args ...any) (sqlRow *sql.Row, err error)

+ QueryRowYearContext func(year string, ctx context.Context, query string, args ...any) (sqlRow *sql.Row, err error)

+ QueryYear func(year string, cb func(sqlRows *sql.Rows) (err error), query string, args ...any) (err error)

+ QueryYearContext func(year string, ctx context.Context, cb func(sqlRows *sql.Rows) (err error), ...) (err error)

+ type DBFactory interface

+ NewDB func(dsnr DataSourceNamer, ctx context.Context, ...) (db DB)

+ type DataSource interface

+ Close func() (err error)

+ ExecContext func(ctx context.Context, query string, args ...any) (id int64, rows int64, err error)

+ QueryContext func(ctx context.Context, cb func(sqlRows *sql.Rows) (err error), query string, ...) (err error)

+ QueryRowContext func(ctx context.Context, query string, args ...any) (sqlRow *sql.Row, err error)

+ type DataSourceNamer interface

+ DSN func(year ...string) (dataSourceName string)

+ DataSource func(dsn string) (dataSource DataSource, err error)

+ type Doneable interface

+ Add func(delta int)

+ Done func()

+ func EnsureDoneable(done Doneable) (done2 Doneable)

+ type DoneableNil struct

+ func (de *DoneableNil) Add(delta int)

+ func (de *DoneableNil) Done()

+ type Err interface

+ type ErrorConduit uint8

+ const EcErrChan

+ const EcSharedChan

+ type ExitAction uint8

+ const ExCancelOnExit

+ const ExCancelOnFailure

+ const ExIgnoreExit

+ type Go interface

+ Add func(delta int)

+ AddError func(err error)

+ Context func() (ctx context.Context)

+ Done func(err error)

+ Register func()

+ type GoCreator interface

+ Add func(conduit ErrorConduit, exitAction ExitAction) (goer Goer)

+ IsExit func() (isExit bool)

+ Wait func()

+ WaitPeriod func(duration ...time.Duration)

+ Warnings func() (ch <-chan GoError)

+ type GoCreatorFactory interface

+ NewGoCreator func(ctx context.Context) (goCreator GoCreator)

+ type GoError interface

+ GetError func() (err error)

+ Goer func() (goer Goer)

+ Source func() (source GoErrorSource)

+ type GoErrorSource uint8

+ type GoIndex int

+ type Goer interface

+ Chan func() (ch <-chan error)

+ Go func() (g0 Go)

+ Wait func()

+ type Receiver interface

+ Count func() (count int)

+ Get func() (value T, ok bool)

+ GetSlice func(max int) (values []T, ok bool)

+ IsCanceled func() (IsCanceled bool)

+ IsEmpty func() (isEmpty bool)

+ WaitCount func() (waitCount int)

+ type Sender interface

+ Put func(value T) (IsCanceled bool)

+ PutSlice func(values []T) (IsCanceled bool)

type ThreadID

+ func (threadID ThreadID) String() (s string)

+ type ThreadStatus string

type WaitGroup

+ func (wg *WaitGroup) Counters() (adds int, dones int)

+ type Waitable interface

+ Wait func()

Apr 14, 2022

Changes in this version

+ type ErrorMethod uint8

+ const EMdedicatedChannel

+ const EMdedicatedParlErrors

+ const EMsharedChannel

+ const EMsharedParlErrors

+ type Thread interface

+ AddError func(err error)

+ Done func()

+ DoneFailure func(err error)

+ NotifyStart func()

+ Receive func(ID channelID) (value interface{})

+ Send func(ID channelID, value interface{})

+ type ThreadControl interface

+ AddChannel func(ID channelID)

+ SetErrorMethod func()

+ type ThreadGroup interface

+ Add func()

+ AddThread func(input bool, errorMethod ErrorMethod) (threadID ThreadID, thread Thread, threadControl ThreadControl)

+ Wait func()

+ WaitForThread func(threadID ThreadID)

+ WaitPeriod func(duration time.Duration) (isDone bool, threadList []ThreadControl)

+ type ThreadGroupFactory interface

+ NewThreadGroup func() (threadGroup ThreadGroup)

+ type ThreadID string

+ type ThreadInput interface

+ Value func() (value T)

+ type ThreadInputFactory interface

+ NewThreadInput func(value T) (input ThreadInput[T])

+ type ThreadResult interface

+ Result func() (result T)

+ type ThreadResultFactory interface

+ NewThreadResult func(thread Thread, result T) ThreadResult[T]

Apr 12, 2022

Changes in this version

type Tracer

+ AssignTaskToThread func(threadID goid.ThreadID, task TracerTaskID) (tracer Tracer)

+ RecordTaskEvent func(threadID goid.ThreadID, text string) (tracer Tracer)

Apr 11, 2022

Changes in this version

type ClosableChan

+ func NewClosableChan(ch ...chan T) (cl *ClosableChan[T])

type NBChan

+ func (nb *NBChan[T]) CloseNow(errp ...*error) (err error, didClose bool)

+ func (nb *NBChan[T]) WaitForClose()

type WaitGroup

+ func (wg *WaitGroup) Counter() (counter int)

+ func (wg *WaitGroup) IsZero() (isZero bool)

Apr 11, 2022

Changes in this version

+ func Closer(ch chan T, errp *error)

+ type AdbAdressProvider interface

+ AdbSocketAddress func() (socketAddress AdbSocketAddress)

+ type AdbResponseID string

+ type AdbSocketAddress string

+ type AdbSyncRequest string

type Adbette

+ ReadBlob func() (byts []byte, err error)

+ ReadBytes func(byts []byte) (err error)

+ ReadResponseID func() (responseID AdbResponseID, err error)

+ SendBlob func(syncRequest AdbSyncRequest, data []byte) (err error)

+ SendBytes func(byts []byte) (err error)

+ type ClosableChan struct

+ func NewCloser(ch chan T) (cl *ClosableChan[T])

+ func (cl *ClosableChan[T]) Ch() (ch chan T)

+ func (cl *ClosableChan[T]) Close(errp ...*error) (err error, didClose bool)

+ func (cl *ClosableChan[T]) IsClosed() (isClosed bool)

type Devicette

+ Serial func() (serial AndroidSerial)

+ type DevicetteFactory interface

+ NewDevicette func(address AdbSocketAddress, serial AndroidSerial, ctx context.Context) (devicette Devicette)

+ type NBChan struct

+ func NewNBChan(ch chan T) (nbChan *NBChan[T])

+ func (nb *NBChan[T]) Ch() (ch chan T)

+ func (nb *NBChan[T]) Close(errp ...*error) (err error, didClose bool)

+ func (nb *NBChan[T]) Count() (unsentCount int)

+ func (nb *NBChan[T]) IsClosed() (isClosed bool)

+ func (nb *NBChan[T]) Send(value T)

type Serverette

+ DeviceStati func() (serials []AndroidSerial, stati []AndroidStatus, err error)

type ServeretteFactory

+ NewServerette func(address AdbSocketAddress, adbetter Adbetter, ctx context.Context) (server Serverette)

Apr 8, 2022

Changes in this version

+ type AdbRequest string

+ type Adbette interface

+ CancelError func() (cancelError error)

+ Closer func(errp *error)

+ ConnectToDevice func(serial AndroidSerial) (err error)

+ DeviceStati func() (serials []AndroidSerial, stati []AndroidStatus, err error)

+ Devices func() (serials []AndroidSerial, err error)

+ LIST func(remoteDir string, ...) (err error)

+ RECV func(remotePath string, blobReceiver func(data []byte) (err error)) (err error)

+ ReadString func() (s string, err error)

+ SendReadOkay func(request AdbRequest) (err error)

+ SetSync func() (err error)

+ Shell func(command string, reader func(conn io.ReadWriteCloser) (err error)) (out string, err error)

+ TrackDevices func() (err error)

+ type Adbetter interface

+ NewConnection func(address string, ctx context.Context) (conn Adbette, err error)

+ type AdressProvider interface

+ DialAddress func() (address string)

+ type AndroidSerial string

+ type AndroidStatus string

+ const AndroidOnline

+ type Counter interface

+ CounterValue func(reset bool) (values CounterValues)

+ Dec func() (counter Counter)

+ Inc func() (counter Counter)

+ type CounterID string

+ type CounterValues interface

+ DecRate func() (decRate uint64)

+ Get func() (value uint64, running uint64, max uint64, incRate uint64, decRate uint64)

+ IncRate func() (incRate uint64)

+ Max func() (max uint64)

+ Running func() (running uint64)

+ Value func() (value uint64)

+ type Counters interface

+ GetCounters func() (orderedKeys []CounterID, m map[CounterID]Counter)

+ GetOrCreateCounter func(name CounterID) (counter Counter)

+ ResetCounters func()

+ type CountersFactory interface

+ NewCounters func(useCounters bool) (counters Counters)

+ type Dent interface

+ IsDir func() (isDir bool)

+ IsRegular func() (isRegular bool)

+ Modified func() (modified time.Time)

+ Name func() (name string)

+ Perm func() (perm fs.FileMode)

+ Size func() (size uint32)

+ type Devicette interface

+ List func(remoteDir string) (dFileInfo []Dent, err error)

+ Pull func(remotePath, nearPath string) (err error)

+ Shell func(command string, reader func(conn io.ReadWriteCloser) (err error)) (out string, err error)

+ type History interface

+ Event func(event string, ID0 ...goid.ThreadID)

+ GetEvents func() (events map[goid.ThreadID][]string)

+ type HistoryFactory interface

+ NewThreadHistory func(useEvents bool, useHistory bool) (history History)

+ type OnceChan struct

+ func (oc *OnceChan) Cancel()

+ func (oc *OnceChan) Deadline() (deadline time.Time, ok bool)

+ func (oc *OnceChan) Done() (ch <-chan struct{})

+ func (oc *OnceChan) Err() (err error)

+ func (oc *OnceChan) IsDone() (isDone bool)

+ func (oc *OnceChan) Value(key any) (value any)

+ type ServerFactory interface

+ Adb func(address string, ctx context.Context) (server Serverette)

+ AdbLocalhost func(ctx context.Context) (server Serverette)

+ type Serverette interface

+ DeviceForSerial func(serial AndroidSerial) (android SkeletonDevice, err error)

+ DeviceSerialList func() (serials []AndroidSerial, err error)

+ TrackDevices func() (tracker Trackerette, err error)

+ type ServeretteFactory interface

+ Adb func(address string, adbetter Adbetter, ctx context.Context) (server Serverette)

+ type SkeletonDevice interface

+ Serial func() (serial AndroidSerial)

+ type Statuser interface

+ Set func(status string) (statuser Statuser)

+ Shutdown func()

+ type StatuserFactory interface

+ NewStatuser func(useStatuser bool, d time.Duration) (statuser Statuser)

+ type Tracer interface

+ Assign func(threadID goid.ThreadID, task TracerTaskID) (tracer Tracer)

+ Record func(threadID goid.ThreadID, text string) (tracer Tracer)

+ Records func(clear bool) (records map[TracerTaskID][]TracerRecord)

+ type TracerFactory interface

+ NewTracer func() (tracer Tracer)

+ type TracerRecord interface

+ Values func() (at time.Time, text string)

+ type TracerTaskID string

+ type Trackerette interface

+ Cancel func()

+ Errs func() (err error)

+ Serials func() (serials <-chan AndroidSerial)

+ type WaitGroup struct

+ func (wg *WaitGroup) Add(delta int)

+ func (wg *WaitGroup) Done()

+ func (wg *WaitGroup) NoneWaiting() (noneWaiting bool)

+ func (wg *WaitGroup) Waiting() (waiting int)

Mar 28, 2022

Changes in this version

+ func HandleErrp(fn func(), errp *error)

+ func HandleParlError(fn func(), storeError func(error))

Mar 21, 2022

Changes in this version

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

Mar 17, 2022

Changes in this version

+ const LogObject

+ const Rfc3339ms

+ const Rfc3339msz

+ const Rfc3339ns

+ const Rfc3339nsz

+ const Rfc3339s

+ const Rfc3339sz

+ const Rfc3339us

+ const Rfc3339usz

+ const SerialDoIdle

+ const SerialDoLaunch

+ const SerialDoPending

+ const SerialDoPendingLaunch

+ const SerialDoReady

+ const TimePointer

+ var ErrModeratorShutdown = errors.New("Moderator shut down")

+ var Errorf = error116.Errorf

+ var New = error116.New

+ var NewCodeLocation = error116.NewCodeLocation

+ var PackFunc = error116.PackFunc

+ func AddToPanic(panicValue interface{}, additionalErr error) (err error)

+ func Annotation() (annotation string)

+ func Console(format string, a ...interface{})

+ func ContextTime(ctx context.Context) (t time.Time, found bool)

+ func D(format string, a ...interface{})

+ func Debug(format string, a ...interface{})

+ func DelFromContext(ctx context.Context, key string) (ok bool)

+ func EnsureError(panicValue interface{}) (err error)

+ func HandlePanic(fn func()) (err error)

+ func Info(format string, a ...interface{})

+ func IsSilent() (isSilent bool)

+ func IsThisDebug() bool

+ func Log(format string, a ...interface{})

+ func NewDebouncer(d time.Duration, receiver ReceiverFunc, sender SenderFunc, ctx context.Context) (err error)

+ func Out(format string, a ...interface{})

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

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

+ func SetDebug(debug bool)

+ func SetRegexp(regExp string) (err error)

+ func SetSilent(silent bool)

+ func StoreInContext(ctx context.Context, key string, value interface{}) (ok bool)

+ type AtomicBool struct

+ func (ab *AtomicBool) Clear() (wasSet bool)

+ func (ab *AtomicBool) IsTrue() (isTrue bool)

+ func (ab *AtomicBool) Set() (wasNotSet bool)

+ type Context struct

+ Map sync.Map

+ func NewContext(ctx ...context.Context) (c *Context)

+ func (c *Context) Delete(key string)

+ func (c *Context) Store(key string, value interface{})

+ func (c *Context) Value(key interface{}) (result interface{})

+ func (c *Context) Value2(key interface{}) (result interface{}, ok bool)

+ type FSLocation interface

+ Directory func() (directory string)

+ type FanOut struct

+ ErrCh chan error

+ Results chan interface{}

+ func NewFanOut() (fo *FanOut)

+ func (cr *FanOut) Do(name string, proc FanProc)

+ func (cr *FanOut) Run(name string, thunk FanThunk)

+ func (cr *FanOut) Wait()

+ type FanProc func() (err error)

+ type FanThunk func() (result interface{}, err error)

+ type LogInstance struct

+ func GetLogAndContext(debug bool, verbose bool, silent bool) (ctx context.Context, log *LogInstance)

+ func GetLogFromContext(ctx context.Context) (log *LogInstance)

+ func NewLog(writers ...io.Writer) (lg *LogInstance)

+ func (lg *LogInstance) D(format string, a ...interface{})

+ func (lg *LogInstance) Debug(format string, a ...interface{})

+ func (lg *LogInstance) Info(format string, a ...interface{})

+ func (lg *LogInstance) IsSilent() (isSilent bool)

+ func (lg *LogInstance) IsThisDebug() bool

+ func (lg *LogInstance) Log(format string, a ...interface{})

+ func (lg *LogInstance) SetDebug(debug bool)

+ func (lg *LogInstance) SetRegexp(regExp string) (err error)

+ func (lg *LogInstance) SetSilent(silent bool)

+ type Moderator struct

+ func NewModerator(parallelism uint64) (mo *Moderator)

+ func (mo *Moderator) Do(fn func() error) (err error)

+ func (mo *Moderator) Shutdown()

+ func (mo *Moderator) Status() (parallelism uint64, available uint64, waiting uint64, isShutdown bool)

+ func (mo *Moderator) String() (s string)

+ type Password interface

+ HasPassword func() (hasPassword bool)

+ Password func() (password string)

+ type ReceiverFunc func(c <-chan time.Time, done <-chan struct{}) (which TriggeringChan, value Value)

+ type SenderFunc func([]Value)

+ type SerialDo struct

+ ErrCh chan error

+ ID string

+ Wg sync.WaitGroup

+ func NewSerialDo(thunk func(), eventReceiver SerialDoFunc, ctx context.Context) (sdo *SerialDo)

+ func (sdo *SerialDo) Do(now time.Time) (nowPending bool)

+ func (sdo *SerialDo) Shutdown()

+ type SerialDoEvent uint8

+ type SerialDoFunc func(SerialDoEvent, *SerialDo, *time.Time)

+ type Timer struct

+ Label string

+ func NewTimer(label string) (t *Timer)

+ func (t *Timer) End() (d time.Duration)

+ func (t *Timer) Endms() (ms string)

+ type TriggeringChan uint8

+ const DoneCh

+ const TimerCh

+ const ValueCh

+ type Value interface