Documentation
¶
Index ¶
- func AppDone()
- func DefaultConfig() *ds.Config
- func DefaultDevConfig() *ds.Config
- func Disable(disconnect bool)
- func Enable()
- func Enabled() bool
- func GetAppRunId() string
- func Init(cfgParam *ds.Config) error
- func OrigStderr() *os.File
- func OrigStdout() *os.File
- func SetGoRoutineName(name string)
- func Shutdown()
- func TrackCounter[T constraints.Integer | constraints.Float](name string, val T)
- func TrackValue(name string, val any)
- func WatchAtomic[T any](name string, val AtomicLoader[T])
- func WatchAtomicCounter[T constraints.Integer | constraints.Float](name string, val AtomicLoader[T])
- func WatchCounterFunc[T constraints.Integer | constraints.Float](name string, getFn func() T)
- func WatchCounterSync[T constraints.Integer | constraints.Float](name string, lock sync.Locker, val *T)
- func WatchFunc[T any](name string, getFn func() T, setFn func(T))
- func WatchSync[T any](name string, lock sync.Locker, val *T)
- type AtomicLoader
- type AtomicStorer
- type Config
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AppDone ¶
func AppDone()
AppDone signals that the application is done This should be deferred in the program's main function
func DefaultConfig ¶
DefaultConfig returns the default configuration
func DefaultDevConfig ¶
func GetAppRunId ¶
func GetAppRunId() string
GetAppRunId returns the unique identifier for the current application run
func OrigStderr ¶
OrigStderr returns the original stderr stream that was captured during initialization
func OrigStdout ¶
OrigStdout returns the original stdout stream that was captured during initialization
func SetGoRoutineName ¶
func SetGoRoutineName(name string)
SetGoRoutineName sets a name for the current goroutine
func TrackCounter ¶
func TrackCounter[T constraints.Integer | constraints.Float](name string, val T)
func TrackValue ¶
func WatchAtomic ¶
func WatchAtomic[T any](name string, val AtomicLoader[T])
func WatchAtomicCounter ¶
func WatchAtomicCounter[T constraints.Integer | constraints.Float](name string, val AtomicLoader[T])
func WatchCounterFunc ¶
func WatchCounterFunc[T constraints.Integer | constraints.Float](name string, getFn func() T)
func WatchCounterSync ¶
func WatchCounterSync[T constraints.Integer | constraints.Float](name string, lock sync.Locker, val *T)
Types ¶
type AtomicLoader ¶
type AtomicLoader[T any] interface { Load() T }
type AtomicStorer ¶
type AtomicStorer[T any] interface { Store(val T) }
Directories
¶
| Path | Synopsis |
|---|---|
|
pkg
|
|
|
collector/loginitex
Package loginitex provides external process-based log capture functionality
|
Package loginitex provides external process-based log capture functionality |
|
ioutrig
internal outrig package (used to get around circular references for internal outrig SDK calls)
|
internal outrig package (used to get around circular references for internal outrig SDK calls) |
|
rpc
RPC PubSub
|
RPC PubSub |
|
server
module
|
Click to show internal directories.
Click to hide internal directories.