ysgrpc

package
v1.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 10, 2023 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const CONFIG_NODE_NAME = "ys.grpc"

Variables

This section is empty.

Functions

func FlagHost added in v1.0.1 

func FlagHost(ctx context.Context, group ...string) *yscmd.Flag

func FlagPubSize added in v1.0.1 

func FlagPubSize(ctx context.Context, group ...string) *yscmd.Flag

func GenSubCfgNodeName added in v1.0.1 

func GenSubCfgNodeName(sub ...string) string

GenSubCfgNodeName 生成字子配置节点名

func MQEmptyJsonMessage added in v1.0.1 

func MQEmptyJsonMessage() []byte

func RegisterMqServer added in v1.0.1 

func RegisterMqServer(registrar grpc.ServiceRegistrar)

Types

type FlagHostBuilder added in v1.0.1 

type FlagHostBuilder struct {
	yscmd.FlagBuilderCore
}

func (*FlagHostBuilder) Init added in v1.0.1 

func (b *FlagHostBuilder) Init(ctx context.Context, group ...string)

type FlagPubSizeBuilder added in v1.0.1 

type FlagPubSizeBuilder struct {
	yscmd.FlagBuilderCore
}

func (*FlagPubSizeBuilder) Init added in v1.0.1 

func (b *FlagPubSizeBuilder) Init(ctx context.Context, group ...string)

type IMQModule 

type IMQModule interface {
	Cfg() MQModuleCfg
	Init(ctx context.Context)
	Run()
	Stop()
}

type MQBaseModule added in v1.0.1 

type MQBaseModule struct {
	TopicTool *MQTopicTool
	AppCfg    *gjson.Json
	// contains filtered or unexported fields
}

func (*MQBaseModule) AddHandlerFunc added in v1.0.1 

func (m *MQBaseModule) AddHandlerFunc(topic string, handler MQHandlerFunc)

func (*MQBaseModule) AddTopic added in v1.0.1 

func (m *MQBaseModule) AddTopic(topic string)

func (*MQBaseModule) Cfg added in v1.0.1 

func (m *MQBaseModule) Cfg() MQModuleCfg

func (*MQBaseModule) Client added in v1.0.1 

func (m *MQBaseModule) Client() *MQClient

func (*MQBaseModule) Ctx added in v1.0.1 

func (m *MQBaseModule) Ctx() context.Context

func (*MQBaseModule) DeleteHandlerFunc added in v1.0.1 

func (m *MQBaseModule) DeleteHandlerFunc(topic string, handler MQHandlerFunc)

func (*MQBaseModule) DeleteTopic added in v1.0.1 

func (m *MQBaseModule) DeleteTopic(topic string)

func (*MQBaseModule) Init added in v1.0.1 

func (m *MQBaseModule) Init(ctx context.Context)

func (*MQBaseModule) Log added in v1.0.1 

func (m *MQBaseModule) Log() *glog.Logger

func (*MQBaseModule) Pub added in v1.0.1 

func (m *MQBaseModule) Pub(topic string, message []byte) int32

func (*MQBaseModule) PubJson added in v1.0.1 

func (m *MQBaseModule) PubJson(topic string, message g.MapStrAny) int32

func (*MQBaseModule) PubJsonRes added in v1.0.1 

func (m *MQBaseModule) PubJsonRes(topic string, code int, message string, data interface{}) int32

func (*MQBaseModule) PubJsonResError added in v1.0.1 

func (m *MQBaseModule) PubJsonResError(topic string, code int, message string) int32

func (*MQBaseModule) PubJsonResOk added in v1.0.1 

func (m *MQBaseModule) PubJsonResOk(topic string, data interface{}) int32

func (*MQBaseModule) Run added in v1.0.1 

func (m *MQBaseModule) Run()

Run 阻塞运行模块

func (*MQBaseModule) SetCfg added in v1.0.1 

func (m *MQBaseModule) SetCfg(cfg MQModuleCfg)

func (*MQBaseModule) Stop added in v1.0.1 

func (m *MQBaseModule) Stop()

func (*MQBaseModule) UnSub added in v1.0.1 

func (m *MQBaseModule) UnSub() error

type MQCfg added in v1.0.1 

type MQCfg struct {
	Host    string
	PubSize int
}

type MQClient added in v1.0.1 

type MQClient struct {
	MQ proto.MQClient
	// contains filtered or unexported fields
}

func NewMQClient added in v1.0.1 

func NewMQClient(ctx context.Context) *MQClient

NewMQClient 构建 YS-MQ 的 GRPC 连接客户端

func (*MQClient) Close added in v1.0.1 

func (m *MQClient) Close() error

func (*MQClient) Pub added in v1.0.1 

func (m *MQClient) Pub(topic string, message []byte) (int32, error)

func (*MQClient) Sub added in v1.0.1 

func (m *MQClient) Sub(topics string) (proto.MQ_SubClient, error)

func (*MQClient) UnSub added in v1.0.1 

func (m *MQClient) UnSub(id int32) error

type MQHandlerFunc added in v1.0.1 

type MQHandlerFunc = func(topic string, msg []byte)

type MQModuleCfg added in v1.0.1 

type MQModuleCfg struct {
	Name             string `json:"name"`            // 名称
	UseHeartHandler  bool   `json:"useHeartHandler"` // 心跳
	HasSubAllTopic   bool   `json:"hasSubAllTopic"`  //
	UseLoggerHandler bool   `json:"useLoggerHandler"`
	UseUnPack        bool   `json:"useUnPack"`
	UseConfigCenter  bool   `json:"useConfigCenter"`
}

func NewDefaultMQModuleCfg added in v1.0.1 

func NewDefaultMQModuleCfg() MQModuleCfg

NewDefaultMQModuleCfg 生成默认的 MQModule 配置参数

type MQServer added in v1.0.1 

type MQServer struct {
	proto.UnimplementedMQServer
	// contains filtered or unexported fields
}

func (*MQServer) Pub added in v1.0.1 

func (s *MQServer) Pub(ctx context.Context, request *proto.Message) (*proto.PubReply, error)

func (*MQServer) Sub added in v1.0.1 

func (s *MQServer) Sub(request *proto.SubRequest, subServer proto.MQ_SubServer) error

func (*MQServer) UnSub added in v1.0.1 

func (s *MQServer) UnSub(ctx context.Context, request *proto.UnSubRequest) (*proto.Message, error)

type MQTopicInput added in v1.0.1 

type MQTopicInput struct {
	Base string
	Ex   string
	Name string
}

type MQTopicTool added in v1.0.1 

type MQTopicTool struct {
	HEART     string
	HEART_ASK string

	REQ string
	RES string

	DATA      string
	DATA_RAW  string
	DATA_LTTB string

	CFG     string
	CFG_ASK string

	LOG string
	// contains filtered or unexported fields
}

func NewMQTopicTool added in v1.0.1 

func NewMQTopicTool(name string) *MQTopicTool

NewMQTopicTool 构造 MQ MQTopicTool 工具类型

func (*MQTopicTool) GenCfgAskTopic added in v1.0.1 

func (t *MQTopicTool) GenCfgAskTopic(in MQTopicInput) string

func (*MQTopicTool) GenCfgTopic added in v1.0.1 

func (t *MQTopicTool) GenCfgTopic(in MQTopicInput) string

func (*MQTopicTool) GenDataLttbTopic added in v1.0.1 

func (t *MQTopicTool) GenDataLttbTopic(in MQTopicInput) string

func (*MQTopicTool) GenDataRawTopic added in v1.0.1 

func (t *MQTopicTool) GenDataRawTopic(in MQTopicInput) string

func (*MQTopicTool) GenDataTopic added in v1.0.1 

func (t *MQTopicTool) GenDataTopic(in MQTopicInput) string

func (*MQTopicTool) GenHeartTopic added in v1.0.1 

func (t *MQTopicTool) GenHeartTopic(in MQTopicInput) string

func (*MQTopicTool) GenLogTopic added in v1.0.1 

func (t *MQTopicTool) GenLogTopic(in MQTopicInput) string

func (*MQTopicTool) GenReqTopic added in v1.0.1 

func (t *MQTopicTool) GenReqTopic(in MQTopicInput) string

func (*MQTopicTool) GenResTopic added in v1.0.1 

func (t *MQTopicTool) GenResTopic(in MQTopicInput) string

func (*MQTopicTool) GenTopic added in v1.0.1 

func (t *MQTopicTool) GenTopic(in MQTopicInput) string

func (*MQTopicTool) Name added in v1.0.1 

func (t *MQTopicTool) Name() string

func (*MQTopicTool) SetName added in v1.0.1 

func (t *MQTopicTool) SetName(name string)

type RegistrarHandler added in v1.0.1 

type RegistrarHandler func(registrar grpc.ServiceRegistrar)

type Server added in v1.0.1 

type Server struct {
	// contains filtered or unexported fields
}

func NewServer added in v1.0.1 

func NewServer(ctx context.Context) *Server

func NewServerWithCustom added in v1.0.1 

func NewServerWithCustom(ctx context.Context, server *grpc.Server) *Server

func (*Server) AddRegistrarHandler added in v1.0.1 

func (s *Server) AddRegistrarHandler(handler RegistrarHandler)

func (*Server) Run added in v1.0.1 

func (s *Server) Run(force ...bool) error

Run 启动 grpc 服务，阻塞

func (*Server) Server added in v1.0.1 

func (s *Server) Server() *grpc.Server

func (*Server) Stop added in v1.0.1 

func (s *Server) Stop()

Stop 关闭 grpc 服务

type ServerCfg added in v1.0.1 

type ServerCfg struct {
	Host string
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.