service

Documentation

Index

• func RegisterMQService(s *server.Server, d Dependency) error
• type Dependency

Functions

func RegisterMQService

func RegisterMQService(s *server.Server, d Dependency) error

注册 MQ demo 服务

Types

type Dependency

type Dependency struct {
	StringKafka func(context.Context) (kafka.Client, error)
	JSONKafka   func(context.Context) (kafka.Client, error)
}