utils

Documentation

Index

• type Observer
  • func NewObserver[T any](name string, log *logging.Logger, inChSize, outChSize int) Observer[T]
  • func (o *Observer[T]) GetSubscribersCount() int32
  • func (o *Observer[T]) Notify(values []T)
  • func (o *Observer[T]) Observe(ctx context.Context, retries int, filter func(T) bool) (<-chan []T, uint64)
  • func (o *Observer[T]) Subscribe(ctx context.Context, filter func(T) bool) (chan []T, uint64)
  • func (o *Observer[T]) Unsubscribe(ctx context.Context, ref uint64) error

Types

type Observer

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

func NewObserver

func NewObserver[T any](name string, log *logging.Logger, inChSize, outChSize int) Observer[T]

func (*Observer[T]) GetSubscribersCount

func (o *Observer[T]) GetSubscribersCount() int32

func (*Observer[T]) Notify

func (o *Observer[T]) Notify(values []T)

func (*Observer[T]) Observe

func (o *Observer[T]) Observe(ctx context.Context, retries int, filter func(T) bool) (<-chan []T, uint64)

func (*Observer[T]) Subscribe

func (o *Observer[T]) Subscribe(ctx context.Context, filter func(T) bool) (chan []T, uint64)

func (*Observer[T]) Unsubscribe

func (o *Observer[T]) Unsubscribe(ctx context.Context, ref uint64) error