notify

Documentation

Index

• type Service
  • func NewDefaultService(k []byte, h *mercure.Hub, l *slog.Logger) (*Service, error)
  • func (s *Service) Notify(data []byte, id int, topics ...Topic) error
  • func (s *Service) Subscribe(c echo.Context, topics []string) error
• type Topic

Types

type Service

type Service struct {
	// contains filtered or unexported fields
}

func NewDefaultService

func NewDefaultService(k []byte, h *mercure.Hub, l *slog.Logger) (*Service, error)

func (*Service) Notify

func (s *Service) Notify(data []byte, id int, topics ...Topic) error

func (*Service) Subscribe

func (s *Service) Subscribe(c echo.Context, topics []string) error

type Topic

type Topic struct {
	Type  string
	Topic string
}