observer

Documentation

Index

• type Notifier
  • func NewUserNotifier[event any](channel string) Notifier[event]
• type Observer
  • func NewUserObserver[event any](client *redis.Client, channel string) Observer[event]

Types

type Notifier

type Notifier[event any] interface {
	Register(o Observer[event])
	Unregister(o Observer[event])
	Notify(e event)
}

func NewUserNotifier

func NewUserNotifier[event any](channel string) Notifier[event]

type Observer

type Observer[event any] interface {
	OnNotify(handler func(msg string))
}

func NewUserObserver

func NewUserObserver[event any](client *redis.Client, channel string) Observer[event]