utils

Documentation

Index

• Variables
• type Agent
  • func NewAgent[T any](value T) *Agent[T]
  • func (a *Agent[T]) Get() (value T, err error)
  • func (a *Agent[T]) Serve(ctx context.Context) (err error)
  • func (a *Agent[T]) Update(update func(T) (T, error)) (T, error)
• type Debouncer
  • func (d Debouncer) Stop()
  • func (d *Debouncer) Trigger()
• type Dispatcher
  • func NewDispatcher[T any]() *Dispatcher[T]
  • func (d *Dispatcher[T]) Dispatch(value T, ctx context.Context) (err error)
  • func (d *Dispatcher[T]) OnNewSubscriber(hook func(chan<- T))
  • func (d *Dispatcher[T]) Subscribe() (c <-chan T, cancel func())

Variables

var (
	Log = log.New()
)

Types

type Agent

type Agent[T any] struct {
	// contains filtered or unexported fields
}

func NewAgent

func NewAgent[T any](value T) *Agent[T]

func (*Agent[T]) Get

func (a *Agent[T]) Get() (value T, err error)

func (*Agent[T]) Serve

func (a *Agent[T]) Serve(ctx context.Context) (err error)

func (*Agent[T]) Update

func (a *Agent[T]) Update(update func(T) (T, error)) (T, error)

type Debouncer

type Debouncer struct {
	Delay time.Duration
	Func  func()
	// contains filtered or unexported fields
}

func (Debouncer) Stop

func (d Debouncer) Stop()

func (*Debouncer) Trigger

func (d *Debouncer) Trigger()

type Dispatcher

type Dispatcher[T any] struct {
	*Agent[subscribers[T]]
	NewSubscriberHook func(chan<- T)
}

func NewDispatcher

func NewDispatcher[T any]() *Dispatcher[T]

func (*Dispatcher[T]) Dispatch

func (d *Dispatcher[T]) Dispatch(value T, ctx context.Context) (err error)

func (*Dispatcher[T]) OnNewSubscriber

func (d *Dispatcher[T]) OnNewSubscriber(hook func(chan<- T))

func (*Dispatcher[T]) Subscribe

func (d *Dispatcher[T]) Subscribe() (c <-chan T, cancel func())