eventbus

README

eventbus

Work in progress

Documentation

Index

• type AzureServiceBus
  • func (t *AzureServiceBus) Init()
  • func (t *AzureServiceBus) Publish(event *EventContainer)
  • func (t *AzureServiceBus) Subscribe(subscriber *Subscriber) error
• type EventBus
• type EventContainer
  • func NewEventContainer(name string, topicName string, payload interface{}, ...) *EventContainer
  • func NewEventContainerReflected(payload interface{}, metadata *map[string]interface{}) *EventContainer
  • func (e *EventContainer) GetName() string
  • func (e *EventContainer) GetTopicName() string
• type Memory
  • func (t *Memory) Init()
  • func (t *Memory) Publish(event *EventContainer)
  • func (t *Memory) Subscribe(subscriber *Subscriber) error
• type Subscriber

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

type Memory

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

Memory EventBus implementation

func (*Memory) Init

func (t *Memory) Init()

func (*Memory) Publish

func (t *Memory) Publish(event *EventContainer)

func (*Memory) Subscribe

func (t *Memory) Subscribe(subscriber *Subscriber) error

type Subscriber

type Subscriber interface {
	GetEventName() string
	GetEventType() reflect.Type
	GetTopicName() string
	AcceptEvent(event interface{})
}