Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

ysgrpc

package

Go to main page

Versions in this module

v1

v1.0.5

Feb 10, 2023

v1.0.4

Feb 10, 2023

v1.0.3

Feb 9, 2023

v1.0.2

Feb 9, 2023

v1.0.1

Feb 9, 2023

Changes in this version

+ const CONFIG_NODE_NAME

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

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

+ func GenSubCfgNodeName(sub ...string) string

+ func MQEmptyJsonMessage() []byte

+ func RegisterMqServer(registrar grpc.ServiceRegistrar)

+ type FlagHostBuilder struct

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

+ type FlagPubSizeBuilder struct

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

type IMQModule

+ Cfg func() MQModuleCfg

+ Run func()

+ type MQBaseModule struct

+ AppCfg *gjson.Json

+ TopicTool *MQTopicTool

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

+ func (m *MQBaseModule) AddTopic(topic string)

+ func (m *MQBaseModule) Cfg() MQModuleCfg

+ func (m *MQBaseModule) Client() *MQClient

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

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

+ func (m *MQBaseModule) DeleteTopic(topic string)

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

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

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

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

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

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

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

+ func (m *MQBaseModule) Run()

+ func (m *MQBaseModule) SetCfg(cfg MQModuleCfg)

+ func (m *MQBaseModule) Stop()

+ func (m *MQBaseModule) UnSub() error

+ type MQCfg struct

+ Host string

+ PubSize int

+ type MQClient struct

+ MQ proto.MQClient

+ func NewMQClient(ctx context.Context) *MQClient

+ func (m *MQClient) Close() error

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

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

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

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

+ type MQModuleCfg struct

+ HasSubAllTopic bool

+ Name string

+ UseConfigCenter bool

+ UseHeartHandler bool

+ UseLoggerHandler bool

+ UseUnPack bool

+ func NewDefaultMQModuleCfg() MQModuleCfg

+ type MQServer struct

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

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

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

+ type MQTopicInput struct

+ Base string

+ Ex string

+ Name string

+ type MQTopicTool struct

+ CFG string

+ CFG_ASK string

+ DATA string

+ DATA_LTTB string

+ DATA_RAW string

+ HEART string

+ HEART_ASK string

+ LOG string

+ REQ string

+ RES string

+ func NewMQTopicTool(name string) *MQTopicTool

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

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

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

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

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

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

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

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

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

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

+ func (t *MQTopicTool) Name() string

+ func (t *MQTopicTool) SetName(name string)

+ type RegistrarHandler func(registrar grpc.ServiceRegistrar)

+ type Server struct

+ func NewServer(ctx context.Context) *Server

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

+ func (s *Server) AddRegistrarHandler(handler RegistrarHandler)

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

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

+ func (s *Server) Stop()

+ type ServerCfg struct

+ Host string

v0

v0.9.1

Nov 2, 2022

Changes in this version

+ func GetGRPCConnect(host string) *grpc.ClientConn

+ func GetGRPCConnectInstance(host string, name ...string) *grpc.ClientConn

+ func GetGRPCConnectInstanceWithFlag(name ...string) *grpc.ClientConn

+ type IMQModule interface

+ Init func()

+ Stop func()

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

+ type MQModelCfg struct

+ HasSubAllTopic bool

+ Name string

+ UseConfigCenter bool

+ UseHeartHandler bool

+ UseLoggerHandler bool

+ UseUnPack bool

+ type VoidFunc = func() error