bus

type Event struct {
	Subject string
	Header  map[string][]string
	Data    []byte
}

type EventHandler func(*Event)

type Publisher interface {
	// 事件发送
	Publish(ctx context.Context, e *Event) error
}

type Service interface {
	Publisher
	SubScriber
}

type SubScriber interface {
	// 订阅事件
	Subscribe(ctx context.Context, subject string, cb EventHandler) error
	// 订阅队列
	// subject: 主题
	// queue: 队列名称, kafka则为消费组名称
	Queue(ctx context.Context, subject string, queue string, cb EventHandler) error
}