Versions in this module Expand all Collapse all v1 v1.3.0 Jan 10, 2026 Changes in this version + type ContextBag struct + func NewContextBag(ctx context.Context) *ContextBag + func (cb *ContextBag) Cancel(key string) + func (cb *ContextBag) CancelAll() + func (cb *ContextBag) Context(key string) context.Context v1.1.0 Sep 25, 2025 Changes in this version + var ErrLockerLocked = errors.Sentinel("locker: cannot acquire lock, already locked") + var Version = "dev" + func FirstNotEmpty(v ...string) string + func FormatBytes[T int | int16 | int32 | int64 | uint | uint16 | uint32 | uint64](b T) string + func GetDockerInfo(ctx context.Context) (types.Version, system.Info, error) + func MustInt(v string) int + func ScanReader(r io.Reader, callback func(line []byte)) error + type Atomic struct + func NewAtomic[T any](v T) *Atomic[T] + func (a *Atomic[T]) Load() T + func (a *Atomic[T]) MarshalJSON() ([]byte, error) + func (a *Atomic[T]) Store(v T) + func (a *Atomic[T]) UnmarshalJSON(b []byte) error + type AtomicBool struct + func NewAtomicBool(v bool) *AtomicBool + func (ab *AtomicBool) Load() bool + func (ab *AtomicBool) MarshalJSON() ([]byte, error) + func (ab *AtomicBool) Store(v bool) + func (ab *AtomicBool) SwapIf(v bool) bool + func (ab *AtomicBool) UnmarshalJSON(b []byte) error + type AtomicString struct + func NewAtomicString(v string) *AtomicString + func (as *AtomicString) Load() string + func (as *AtomicString) MarshalJSON() ([]byte, error) + func (as *AtomicString) Store(v string) + func (as *AtomicString) UnmarshalJSON(b []byte) error + type DockerCgroups struct + Driver string + Version string + type DockerContainers struct + Paused int + Running int + Stopped int + Total int + type DockerInformation struct + Cgroups DockerCgroups + Containers DockerContainers + Runc DockerRunc + Storage DockerStorage + Version string + type DockerRunc struct + Version string + type DockerStorage struct + Driver string + Filesystem string + type Information struct + Docker DockerInformation + System System + Version string + func GetSystemInformation() (*Information, error) + type Locker struct + func NewLocker() *Locker + func (l *Locker) Acquire() error + func (l *Locker) Destroy() + func (l *Locker) IsLocked() bool + func (l *Locker) Release() + func (l *Locker) TryAcquire(ctx context.Context) error + type Rate struct + func NewRate(limit uint64, duration time.Duration) *Rate + func (r *Rate) Reset() + func (r *Rate) Try() bool + type SinkName string + const InstallSink + const LogSink + type SinkPool struct + func NewSinkPool() *SinkPool + func (p *SinkPool) Destroy() + func (p *SinkPool) Off(c chan []byte) + func (p *SinkPool) On(c chan []byte) + func (p *SinkPool) Push(data []byte) + type System struct + Architecture string + CPUThreads int + KernelVersion string + MemoryBytes int64 + OS string + OSType string
Go to main page