Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AzureServiceBus ¶
type AzureServiceBus struct {
// contains filtered or unexported fields
}
func (*AzureServiceBus) Init ¶
func (t *AzureServiceBus) Init()
func (*AzureServiceBus) Publish ¶
func (t *AzureServiceBus) Publish(event *EventContainer)
func (*AzureServiceBus) Subscribe ¶
func (t *AzureServiceBus) Subscribe(subscriber *Subscriber) error
type EventBus ¶
type EventBus interface { Init() Publish(event *EventContainer) Subscribe(subscriber *Subscriber) error }
EventBus is base implementation of IEventBus
type EventContainer ¶
type EventContainer struct { Metadata *map[string]interface{} Payload interface{} // contains filtered or unexported fields }
func NewEventContainer ¶
func NewEventContainer(name string, topicName string, payload interface{}, metadata *map[string]interface{}) *EventContainer
func NewEventContainerReflected ¶
func NewEventContainerReflected(payload interface{}, metadata *map[string]interface{}) *EventContainer
func (*EventContainer) GetName ¶
func (e *EventContainer) GetName() string
func (*EventContainer) GetTopicName ¶
func (e *EventContainer) GetTopicName() string
Source Files ¶
Click to show internal directories.
Click to hide internal directories.