utsm

Documentation

Index

• type Manager
  • func NewManager(options ...ManagerOption) *Manager
  • func (m *Manager) Publish(id int, data interface{})
  • func (m *Manager) Subscribe(start int, end int, options ...SubscriberOption) ([]interface{}, error)
• type ManagerOption
  • func DefaultSubscriberLastReceivedTimeout(timeout time.Duration) ManagerOption
  • func DefaultSubscriberTimeout(timeout time.Duration) ManagerOption
• type SubscriberOption

Types

type Manager

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

Manager handles subscriptions and publications. Each manager is thread-safe

func NewManager

func NewManager(options ...ManagerOption) *Manager

NewManager initializes a manager's internals. Do not allocate a struct of the manager directly.

func (*Manager) Publish

func (m *Manager) Publish(id int, data interface{})

func (*Manager) Subscribe

func (m *Manager) Subscribe(start int, end int, options ...SubscriberOption) ([]interface{}, error)

Subscribe receives data meant for ids that fall between the start and end range.

type ManagerOption

type ManagerOption func(m *Manager)

ManagerOption are function passed to NewManager to configure the manager

func DefaultSubscriberLastReceivedTimeout

func DefaultSubscriberLastReceivedTimeout(timeout time.Duration) ManagerOption

DefaultSubscriberLastReceivedTimeout option sets a a timeout period when we have not received any packages to a subscriber for the timeout period

func DefaultSubscriberTimeout

func DefaultSubscriberTimeout(timeout time.Duration) ManagerOption

DefaultSubscriberTimeout option sets a a timeout period when we have not received any packages to a subscriber for the timeout period

type SubscriberOption

type SubscriberOption func(s *subscriber)

SubscriberOption are options passed to a particular subscribe function