rule

Documentation

Index

• type Manager
  • func NewManager(c []config.Subscription, b broker, r report) (*Manager, error)
  • func (m *Manager) AddRuleSess(id string, persistent bool, publish, republish common.Publish) error
  • func (m *Manager) AddSinkSub(ruleid, subid string, subqos uint32, subtopic string, pubqos uint32, ...) error
  • func (m *Manager) Close()
  • func (m *Manager) RemoveRule(id string) error
  • func (m *Manager) RemoveSinkSub(id, topic string) error
  • func (m *Manager) Start()
  • func (m *Manager) StartRule(id string) error

Types

type Manager

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

Manager manages all rules of message routing

func NewManager

func NewManager(c []config.Subscription, b broker, r report) (*Manager, error)

NewManager creates a new rule manager

func (*Manager) AddRuleSess

func (m *Manager) AddRuleSess(id string, persistent bool, publish, republish common.Publish) error

AddRuleSess adds a new rule for session during running

func (*Manager) AddSinkSub

func (m *Manager) AddSinkSub(ruleid, subid string, subqos uint32, subtopic string, pubqos uint32, pubtopic string) error

AddSinkSub adds a sink subscription

func (*Manager) Close

func (m *Manager) Close()

Close closes this manager

func (*Manager) RemoveRule

func (m *Manager) RemoveRule(id string) error

RemoveRule removes a sink for session

func (*Manager) RemoveSinkSub

func (m *Manager) RemoveSinkSub(id, topic string) error

RemoveSinkSub removes a sink subscription

func (*Manager) Start

func (m *Manager) Start()

Start starts all rules

func (*Manager) StartRule

func (m *Manager) StartRule(id string) error

StartRule starts a rule