Documentation
¶
Index ¶
- type BusServiceImpl
- func (b *BusServiceImpl) Close(ctx context.Context)
- func (b *BusServiceImpl) GetConsumer(group, topic string) *kafka.Reader
- func (b *BusServiceImpl) GetProducer(topic string) *kafka.Writer
- func (b *BusServiceImpl) Init() error
- func (b *BusServiceImpl) Name() string
- func (b *BusServiceImpl) Publish(ctx context.Context, e *bus.Event) error
- func (b *BusServiceImpl) Queue(ctx context.Context, subject string, group string, cb bus.EventHandler) error
- func (b *BusServiceImpl) Subscribe(ctx context.Context, subject string, cb bus.EventHandler) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BusServiceImpl ¶
type BusServiceImpl struct {
ioc.ObjectImpl
sync.Mutex
// contains filtered or unexported fields
}
func (*BusServiceImpl) Close ¶
func (b *BusServiceImpl) Close(ctx context.Context)
func (*BusServiceImpl) GetConsumer ¶
func (b *BusServiceImpl) GetConsumer(group, topic string) *kafka.Reader
func (*BusServiceImpl) GetProducer ¶
func (b *BusServiceImpl) GetProducer(topic string) *kafka.Writer
func (*BusServiceImpl) Init ¶
func (b *BusServiceImpl) Init() error
func (*BusServiceImpl) Name ¶
func (b *BusServiceImpl) Name() string
func (*BusServiceImpl) Queue ¶ added in v2.0.66
func (b *BusServiceImpl) Queue(ctx context.Context, subject string, group string, cb bus.EventHandler) error
订阅队列
func (*BusServiceImpl) Subscribe ¶
func (b *BusServiceImpl) Subscribe(ctx context.Context, subject string, cb bus.EventHandler) error
订阅事件
Source Files
Click to show internal directories.
Click to hide internal directories.