bus

Documentation

Index

• type AnswerFunc
• type EventHandler
• type Manager
  • func New(slog *slog.Logger, name string) (*Manager, error)
  • func (m *Manager) Close()
  • func (m *Manager) EnsureConnected() error
  • func (m *Manager) Publish(subject string, data []byte) error
  • func (m *Manager) Request(subject string, data []byte) (*Message, error)
  • func (m *Manager) Respond(subject string, answerFunc AnswerFunc) (unsubscribeFunc, error)
  • func (m *Manager) SetTimeout(d time.Duration)
  • func (m *Manager) Subscribe(subject string, recFunc ReceiveFunc) (unsubscribeFunc, error)
  • func (m *Manager) WaitMsgProcessed()
• type Message
• type ReceiveFunc

Types

type AnswerFunc

type AnswerFunc func(subject string, msg *Message) ([]byte, error)

type EventHandler

type EventHandler[M eventer] func(*M)

EventHandler handles events

type Manager

type Manager struct {
	Szenario *eventHandler[msg.SzenarioEvtMsg]
	Alert    *eventHandler[msg.AlertMsg]
	Incident *eventHandler[msg.IncidentMsg]
	// contains filtered or unexported fields
}

func New

func New(slog *slog.Logger, name string) (*Manager, error)

func (*Manager) Close

func (m *Manager) Close()

func (*Manager) EnsureConnected

func (m *Manager) EnsureConnected() error

func (*Manager) Publish

func (m *Manager) Publish(subject string, data []byte) error

func (*Manager) Request

func (m *Manager) Request(subject string, data []byte) (*Message, error)

func (*Manager) Respond

func (m *Manager) Respond(subject string, answerFunc AnswerFunc) (unsubscribeFunc, error)

func (*Manager) SetTimeout

func (m *Manager) SetTimeout(d time.Duration)

func (*Manager) Subscribe

func (m *Manager) Subscribe(subject string, recFunc ReceiveFunc) (unsubscribeFunc, error)

func (*Manager) WaitMsgProcessed

func (m *Manager) WaitMsgProcessed()

WaitMsgProcessed waits until the managed cannels have their messages sent

type Message

type Message struct {
	Subject string

	Body []byte
}

type ReceiveFunc

type ReceiveFunc func(subject string, msg *Message)