Documentation
¶
Index ¶
- type MsgBusHandler
- func (m *MsgBusHandler) CreateServiceMsgBusHandler() error
- func (m *MsgBusHandler) Publish(service string, key string, msg *anypb.Any) error
- func (m *MsgBusHandler) RemoveServiceQueueListening(service string) error
- func (m *MsgBusHandler) RemoveServiceQueuePublisher(service string) error
- func (m *MsgBusHandler) RestartServiceQueueListening(service string) (err error)
- func (m *MsgBusHandler) StartQueueListeners()
- func (m *MsgBusHandler) StopQueueListener()
- func (m *MsgBusHandler) StopServiceQueueHandler(service string) (err error)
- func (m *MsgBusHandler) StopServiceQueueListening(service string) (err error)
- func (m *MsgBusHandler) UpdateServiceQueueHandler(s *db.Service) error
- type MsgBusHandlerInterface
- type QueueListener
- type QueuePublisher
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MsgBusHandler ¶
type MsgBusHandler struct {
// contains filtered or unexported fields
}
func NewMessageBusHandler ¶
func NewMessageBusHandler(s db.ServiceRepo, r db.RouteRepo, miss uint32, period time.Duration) *MsgBusHandler
func (*MsgBusHandler) CreateServiceMsgBusHandler ¶
func (m *MsgBusHandler) CreateServiceMsgBusHandler() error
func (*MsgBusHandler) RemoveServiceQueueListening ¶
func (m *MsgBusHandler) RemoveServiceQueueListening(service string) error
func (*MsgBusHandler) RemoveServiceQueuePublisher ¶
func (m *MsgBusHandler) RemoveServiceQueuePublisher(service string) error
func (*MsgBusHandler) RestartServiceQueueListening ¶
func (m *MsgBusHandler) RestartServiceQueueListening(service string) (err error)
func (*MsgBusHandler) StartQueueListeners ¶
func (m *MsgBusHandler) StartQueueListeners()
func (*MsgBusHandler) StopQueueListener ¶
func (m *MsgBusHandler) StopQueueListener()
func (*MsgBusHandler) StopServiceQueueHandler ¶
func (m *MsgBusHandler) StopServiceQueueHandler(service string) (err error)
func (*MsgBusHandler) StopServiceQueueListening ¶
func (m *MsgBusHandler) StopServiceQueueListening(service string) (err error)
func (*MsgBusHandler) UpdateServiceQueueHandler ¶
func (m *MsgBusHandler) UpdateServiceQueueHandler(s *db.Service) error
start/Update Message queue parameters
type MsgBusHandlerInterface ¶
type MsgBusHandlerInterface interface {
CreateServiceMsgBusHandler() error
StopServiceQueueHandler(service string) (err error)
UpdateServiceQueueHandler(s *db.Service) (err error)
Publish(service string, key string, msg *anypb.Any) error
RemoveServiceQueuePublisher(service string) error
RemoveServiceQueueListening(service string) error
}
type QueueListener ¶
type QueueListener struct {
// contains filtered or unexported fields
}
func NewQueueListener ¶
func NewQueueListener(s db.Service) (*QueueListener, error)
type QueuePublisher ¶
type QueuePublisher struct {
// contains filtered or unexported fields
}
func NewQueuePublisher ¶
func NewQueuePublisher(s db.Service) (*QueuePublisher, error)
func (*QueuePublisher) Close ¶
func (p *QueuePublisher) Close() error
Source Files
Click to show internal directories.
Click to hide internal directories.