memory

Documentation

Index

• func CreateMemoryMessageBus() *message_bus.MessageBus
• type MessageDriverMemory
  • func (m *MessageDriverMemory) AsyncPublish(message message_bus.Message) (<-chan message_bus.Message, error)
  • func (m *MessageDriverMemory) Publish(message message_bus.Message) (result []message_bus.Message, err error)
  • func (m *MessageDriverMemory) Subscribe(topic string, handler message_bus.MessageRunner)
  • func (m *MessageDriverMemory) Unsubscribe(topic string, handler message_bus.MessageRunner)

Functions

func CreateMemoryMessageBus

func CreateMemoryMessageBus() *message_bus.MessageBus

Types

type MessageDriverMemory

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

func (*MessageDriverMemory) AsyncPublish

func (m *MessageDriverMemory) AsyncPublish(message message_bus.Message) (<-chan message_bus.Message, error)

func (*MessageDriverMemory) Publish

func (m *MessageDriverMemory) Publish(message message_bus.Message) (result []message_bus.Message, err error)

func (*MessageDriverMemory) Subscribe

func (m *MessageDriverMemory) Subscribe(topic string, handler message_bus.MessageRunner)

func (*MessageDriverMemory) Unsubscribe

func (m *MessageDriverMemory) Unsubscribe(topic string, handler message_bus.MessageRunner)