listen

Documentation

Index

• Constants
• func KqMqs(c config.Config, ctx context.Context, svcContext *svc.ServiceContext) []service.Service
• func Mqs(c config.Config) []service.Service

Constants

const (
	EnvHeader = "X_XH_ENV" // 使用正确的header名称
)

Functions

func KqMqs

func KqMqs(c config.Config, ctx context.Context, svcContext *svc.ServiceContext) []service.Service

pub sub use kq (kafka)

func Mqs

func Mqs(c config.Config) []service.Service