srv

Documentation

Index

• Constants
• func GetMQSource(ctx micro.Context, name string) (source.Source, error)
• func Reg(s *grpc.Server)
• type MQService
  • func GetMQService(ctx micro.Context, name string) (*MQService, error)
  • func (s *MQService) Config() interface{}
  • func (s *MQService) Name() string
  • func (s *MQService) OnInit(ctx micro.Context) error
  • func (s *MQService) OnValid(ctx micro.Context) error
  • func (s *MQService) Recycle()

Constants

const (
	SERVICE_ABI_MQ = "abi-mq"
)

Functions

func GetMQSource

func GetMQSource(ctx micro.Context, name string) (source.Source, error)

func Reg

func Reg(s *grpc.Server)

Types

type MQService

type MQService struct {
	Driver string        `json:"driver"`
	Source source.Source `json:"-"`
	// contains filtered or unexported fields
}

func GetMQService

func GetMQService(ctx micro.Context, name string) (*MQService, error)

func (*MQService) Config

func (s *MQService) Config() interface{}

* * 服务配置 *

func (*MQService) Name

func (s *MQService) Name() string

* * 服务名称 *

func (*MQService) OnInit

func (s *MQService) OnInit(ctx micro.Context) error

* * 初始化服务 *

func (*MQService) OnValid

func (s *MQService) OnValid(ctx micro.Context) error

* * 校验服务是否可用 *

func (*MQService) Recycle

func (s *MQService) Recycle()