subscription

Documentation

Index

• type Manager
  • func NewManager() *Manager
  • func (m *Manager) Publish(resourceID string, message any)
  • func (m *Manager) PublishUpdate(message Message)
  • func (m *Manager) Subscribe(resourceID string, subscriber Subscriber)
  • func (m *Manager) Unsubscribe(resourceID string, subscriptionID string)
• type Message
• type Subscriber
  • func NewSubscriberFunction(function func(Message) error) Subscriber
• type SubscriberFunction
  • func (sf *SubscriberFunction) ID() string
  • func (sf *SubscriberFunction) Notify(message Message) error
• type Subscription

Types

type Manager

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

func NewManager

func NewManager() *Manager

func (*Manager) Publish

func (m *Manager) Publish(resourceID string, message any)

func (*Manager) PublishUpdate

func (m *Manager) PublishUpdate(message Message)

func (*Manager) Subscribe

func (m *Manager) Subscribe(resourceID string, subscriber Subscriber)

func (*Manager) Unsubscribe

func (m *Manager) Unsubscribe(resourceID string, subscriptionID string)

type Message

type Message struct {
	ResourceID string
	Type       string
	Content    interface{}
}

type Subscriber

type Subscriber interface {
	ID() string
	Notify(message Message) error
}

func NewSubscriberFunction

func NewSubscriberFunction(function func(Message) error) Subscriber

type SubscriberFunction

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

func (*SubscriberFunction) ID

func (sf *SubscriberFunction) ID() string

func (*SubscriberFunction) Notify

func (sf *SubscriberFunction) Notify(message Message) error

type Subscription

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

Subscription represents a group of subscribers that are waiting for updates of a specific resource