bus

Documentation

Index

• type Bus
  • func New(util util.Resource, logger *logger.Logger) *Bus
  • func (b *Bus) AddPublisher(name string, chCapacity, consumer int) chan<- *message.Message
  • func (b *Bus) Close()
  • func (b *Bus) Subscribe(cb func(*message.Message), reList ...string) error
• type Resource

Types

type Bus

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

Bus AFAIRE.

func New

func New(util util.Resource, logger *logger.Logger) *Bus

New AFAIRE.

func (*Bus) AddPublisher

func (b *Bus) AddPublisher(name string, chCapacity, consumer int) chan<- *message.Message

AddPublisher AFAIRE.

func (*Bus) Close

func (b *Bus) Close()

Close AFAIRE.

func (*Bus) Subscribe

func (b *Bus) Subscribe(cb func(*message.Message), reList ...string) error

Subscribe AFAIRE.

type Resource

type Resource interface {
	resources.Bus
}

Resource AFAIRE.