eventBus

README

责任链模式实现

Documentation

Index

• type AsyncEventBus
  • func NewEventBus() *AsyncEventBus
  • func (bus *AsyncEventBus) Publish(ctx context.Context, topic string, args ...interface{})
  • func (bus *AsyncEventBus) Subscribe(topic string, f interface{}) error
• type Bus

Types

type AsyncEventBus

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

AsyncEventBus 异步事件总线

func NewEventBus

func NewEventBus() *AsyncEventBus

NewEventBus new

func (*AsyncEventBus) Publish

func (bus *AsyncEventBus) Publish(ctx context.Context, topic string, args ...interface{})

Publish 发布 这里异步执行，并且不会等待返回结果

func (*AsyncEventBus) Subscribe

func (bus *AsyncEventBus) Subscribe(topic string, f interface{}) error

Subscribe 订阅

type Bus

type Bus interface {
	Subscribe(topic string, handler interface{}) error
	Publish(ctx context.Context, topic string, args ...interface{})
}