utils

package
v0.8.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 27, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DeepCopy added in v0.8.5

func DeepCopy(dst, src any) error

func DeepEqualArray added in v0.8.5

func DeepEqualArray[T any](a, b []T) bool

Types

type StateContext

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

func NewStateContext

func NewStateContext() *StateContext

func (*StateContext) Cancel

func (s *StateContext) Cancel()

func (*StateContext) IsCanceled

func (s *StateContext) IsCanceled() bool

type StopWatch

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

func NewStopWatch

func NewStopWatch(name string) *StopWatch

func (*StopWatch) Log

func (t *StopWatch) Log(e *zerolog.Event, hist telemetry.Histogram)

func (*StopWatch) Stop

func (t *StopWatch) Stop() time.Duration

type TimeoutPublisher

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

func AutoResetEventTimer

func AutoResetEventTimer(bus EventBus.Bus, eventName string, duration time.Duration) *TimeoutPublisher

func NewTimeoutPublisher

func NewTimeoutPublisher(duration time.Duration) *TimeoutPublisher

func (*TimeoutPublisher) Channel

func (t *TimeoutPublisher) Channel() <-chan time.Time

func (*TimeoutPublisher) Reset

func (t *TimeoutPublisher) Reset()

func (*TimeoutPublisher) Stop

func (t *TimeoutPublisher) Stop()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL