Documentation ¶
Index ¶
- Variables
- type Manager
- func (m *Manager) CreatePublisher(options interfaces.PublisherOptions) (*interfaces.Publisher, error)
- func (m *Manager) CreateSubscriber(options interfaces.SubscriberOptions) (*interfaces.Subscriber, error)
- func (m *Manager) DeletePublisher(name string) error
- func (m *Manager) DeleteSubscriber(name string) error
- func (m *Manager) GetPublisherByName(name string) (*interfaces.Publisher, error)
- func (m *Manager) GetSubscriberByName(name string) (*interfaces.Subscriber, error)
- func (m *Manager) Init() error
- func (m *Manager) PublishMessageByName(name string, data []byte) error
- func (m *Manager) Retry() error
- func (m *Manager) Stop() error
- func (m *Manager) Teardown() error
- type ManagerOptions
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrInvalidInput required input was not found ErrInvalidInput = errors.New("required input was not found") // ErrPublisherNotFound the rabbit publisher was not found ErrPublisherNotFound = errors.New("the rabbit publisher was not found") // ErrSubscriberNotFound the rabbit publisher was not found ErrSubscriberNotFound = errors.New("the rabbit subscriber was not found") )
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
func New ¶
func New(options ManagerOptions) (*Manager, error)
func (*Manager) CreatePublisher ¶
func (m *Manager) CreatePublisher(options interfaces.PublisherOptions) (*interfaces.Publisher, error)
func (*Manager) CreateSubscriber ¶
func (m *Manager) CreateSubscriber(options interfaces.SubscriberOptions) (*interfaces.Subscriber, error)
func (*Manager) DeletePublisher ¶
func (*Manager) DeleteSubscriber ¶
func (*Manager) GetPublisherByName ¶
func (m *Manager) GetPublisherByName(name string) (*interfaces.Publisher, error)
func (*Manager) GetSubscriberByName ¶
func (m *Manager) GetSubscriberByName(name string) (*interfaces.Subscriber, error)
func (*Manager) PublishMessageByName ¶
type ManagerOptions ¶
type ManagerOptions struct {
*interfaces.ManagerOptions
}
The one that manages everything
Click to show internal directories.
Click to hide internal directories.