lazy

Documentation

Index

• Variables
• func GetAddr(sv string) string
• func GetPortMust(sv string) int
• func GrpcHttpHandleFunc(grpcServer any) http.HandlerFunc
• func HttpReturn(w http.ResponseWriter, value interface{})
• func Init(serviceName string)
• func MakeMsg(value any, override map[string]any) []byte
• func MakeRouteMsg(value any, route any) []byte
• func NewGrpcClient[T any](name string, fn func(cc grpc.ClientConnInterface) T) (ret T)
• func Serve()
• func ServeFn(fn func())
• func SetClientCodec(name string, codec grpc.DialOption)
• func StartGrpcTestHttpServer(addr string, grpcServer any)
• func WrapMsg(value any) map[string]any
• type HttpContext

Variables

var (
	BUILD_TIME = ""
	GO_VERSION = ""
	AUTHOR     = ""
)

var ConfigManager *cfgmgr.ConfigManager

var GrpcClient *rpc1.ClientManager

var GrpcServer *rpc1.Server

var PortProvider discovery.PortProvider

var ServiceDiscovery discovery.Discovery

var ServiceName string

var ServiceRegister discovery.Register

Functions

func GetAddr

func GetAddr(sv string) string

获取地址

func GetPortMust

func GetPortMust(sv string) int

func GrpcHttpHandleFunc

func GrpcHttpHandleFunc(grpcServer any) http.HandlerFunc

func HttpReturn

func HttpReturn(w http.ResponseWriter, value interface{})

func Init

func Init(serviceName string)

初始化

func MakeMsg

func MakeMsg(value any, override map[string]any) []byte

func MakeRouteMsg

func MakeRouteMsg(value any, route any) []byte

func NewGrpcClient

func NewGrpcClient[T any](name string, fn func(cc grpc.ClientConnInterface) T) (ret T)

创建并连接Grpc服务

func Serve

func Serve()

启动服务

func ServeFn

func ServeFn(fn func())

func SetClientCodec

func SetClientCodec(name string, codec grpc.DialOption)

func StartGrpcTestHttpServer

func StartGrpcTestHttpServer(addr string, grpcServer any)

func WrapMsg

func WrapMsg(value any) map[string]any

Types

type HttpContext

type HttpContext struct {
	context.Context
	Request *http.Request
}