constraint

package

v0.5.7 Latest Latest Go to latest Published: Feb 13, 2023 License: MIT Imports: 3 Imported by: 6

Details

信息总线相关定义

This section is empty.

View Source

var QueueGroup = "home_default_stream_group"

View Source

var QueueName = "home_default_stream"

This section is empty.

type AfterRegistration interface {
	Boot()
}

AfterRegistration 注册完成后, 统一处理

type Broker interface {
	Push(event interface{}, names ...string)
	Consumer(job Job)
	Loop()
}

信息中间人

type Construct interface {
	// Init 初始化
	Init()
}

Construct 具备结构体Bean

type Exit interface {
	Exit()
}

type Job interface {
	Handler()
}

type JobConfig struct {
	Message   interface{}
	GroupName string
	QueueName string
}

type KernelServer interface {
	Init()
	Run()
	Exit()
}

每个独立服务的业务配置

type RedisClient interface {
	GetClient() *redis.Client
}

type Route interface {
	GetGroup() string
	GetRoutes() map[*api.Config]func(c *gin.Context)
}

type RunAfter interface {
	RunAfter()
}

RunAfter 在Run执行后执行, 可以做服务准备好状态维护等

type ServiceProvider interface {
	// contains filtered or unexported methods
}

type SetGroup interface {
	SetGroup() string
}

type SetQueue interface {
	SetQueue() string
}

type SetRoute interface {
	SetRoute() string
}

type SetSerial interface {
	SetSerial() bool
}

SetSerial 设置为穿行消费

type Task struct {
	ID    string
	Group string
	Queue string
	Event interface{}
}

type Worker interface {
	Run(job Job, task Task)
}