mem

package

v1.11.0 Latest Latest Go to latest Published: Sep 11, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

func NewNotifier() mbus.Notifier

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

func (n *Notifier) IsClosed() bool

func (n *Notifier) Notify(ctx context.Context, messenger mbus.Messenger, options ...mbus.NotifierOption) error

func (n *Notifier) Observe(ctx context.Context, messanger mbus.Messenger, opts ...mbus.NotifierOption) error

func (n *Notifier) Stop() error

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

Service in memory service

func New() *Service

New creates a new in memory service

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