mem

Documentation

Index

• type Queues
  • func Singleton() *Queues
  • func (m *Queues) Queue(resource *mbus.Resource) chan *mbus.Message
• type Service
  • func New() *Service
  • func (s *Service) Push(ctx context.Context, dest *mbus.Resource, message *mbus.Message) (*mbus.Confirmation, error)

Types

type Queues

type Queues struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func Singleton

func Singleton() *Queues

Singleton returns message queue

func (*Queues) Queue

func (m *Queues) Queue(resource *mbus.Resource) chan *mbus.Message

type Service

type Service struct{}

Service in memory service

func New

func New() *Service

New creates a new in memory service

func (*Service) Push

func (s *Service) Push(ctx context.Context, dest *mbus.Resource, message *mbus.Message) (*mbus.Confirmation, error)