constraint

Documentation

Overview

信息总线相关定义

Index

• Variables
• type AfterRegistration
• type Broker
• type Construct
• type Exit
• type Job
• type JobConfig
• type KernelServer
• type RedisClient
• type Route
• type RunAfter
• type ServiceProvider
• type SetGroup
• type SetQueue
• type SetRoute
• type SetSerial
• type Task
• type Worker

Variables

var QueueGroup = "home_default_stream_group"

var QueueName = "home_default_stream"

Types

type AfterRegistration

type AfterRegistration interface {
	Boot()
}

AfterRegistration 注册完成后, 统一处理

type Broker

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

信息中间人

type Construct

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

Construct 具备结构体Bean

type Exit

type Exit interface {
	Exit()
}

type Job

type Job interface {
	Handler()
}

type JobConfig

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

type KernelServer

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

每个独立服务的业务配置

type RedisClient

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

type Route

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

type RunAfter

type RunAfter interface {
	RunAfter()
}

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

type ServiceProvider

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

type SetGroup

type SetGroup interface {
	SetGroup() string
}

type SetQueue

type SetQueue interface {
	SetQueue() string
}

type SetRoute

type SetRoute interface {
	SetRoute() string
}

type SetSerial

type SetSerial interface {
	SetSerial() bool
}

SetSerial 设置为穿行消费

type Task

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

type Worker

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