bus

README

事件总线

支持:

• kafka
• nats

Documentation

Index

• Constants
• type Event
• type EventHandler
• type Publisher
• type Service
  • func GetService() Service
• type SubScriber

Constants

const (
	APP_NAME = "bus"
)

const (
	APP_PRIORITY = 595
)

Types

type Event

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

type EventHandler

type EventHandler func(*Event)

type Publisher

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

type Service

type Service interface {
	Publisher
	SubScriber
}

func GetService

func GetService() Service

type SubScriber

type SubScriber interface {
	// 主题订阅, 应用的多个实例 都会收到一份消息(广播)
	TopicSubscribe(ctx context.Context, subject string, cb EventHandler) error
	// 队列订阅, 默认应用名称为队列名称, 同一个队列中 只能收到一份消息
	QueueSubscribe(ctx context.Context, subject string, cb EventHandler) error
}