utils

Documentation

Index

• func DeepCopy(dst, src any) error
• func DeepEqualArray[T any](a, b []T) bool
• type StateContext
  • func NewStateContext() *StateContext
  • func (s *StateContext) Cancel()
  • func (s *StateContext) IsCanceled() bool
• type StopWatch
  • func NewStopWatch(name string) *StopWatch
  • func (t *StopWatch) Log(e *zerolog.Event, hist telemetry.Histogram)
  • func (t *StopWatch) Stop() time.Duration
• type TimeoutPublisher
  • func AutoResetEventTimer(bus EventBus.Bus, eventName string, duration time.Duration) *TimeoutPublisher
  • func NewTimeoutPublisher(duration time.Duration) *TimeoutPublisher
  • func (t *TimeoutPublisher) Channel() <-chan time.Time
  • func (t *TimeoutPublisher) Reset()
  • func (t *TimeoutPublisher) Stop()

Functions

func DeepCopy

func DeepCopy(dst, src any) error

func DeepEqualArray

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