notify

package

v0.5.8 Latest Latest Go to latest Published: May 20, 2026 License: BSD-2-Clause Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Service struct {
	CH map[string]broadcast.Broadcaster
	// contains filtered or unexported fields
}

func New(ctx context.Context, cfg *model.Cfg, log *logger.Log) (*Service, error)

func (s *Service) Close(ctx context.Context) error

func (s *Service) CloseListener(id string, listener chan any)

func (s *Service) HasListener(id string) bool

HasListener returns true if there's an active listener for the given session ID

func (s *Service) Notify(id string) broadcast.Broadcaster

func (s *Service) OpenListener(id string) chan any

func (s *Service) Submit(id string, msg any)