grpcs

Documentation

Index

• func New() lava.Service
• func NewInner(handlers []lava.GrpcRouter, grpcProxy []lava.GrpcProxy, ...) *lava.InnerServer
• type Config
• type DefaultQueryParser
  • func (*DefaultQueryParser) Parse(msg proto.Message, values url.Values, filter *utilities.DoubleArray) error
• type GrpcServerConfigLoader

Functions

func New

func New() lava.Service

func NewInner

func NewInner(handlers []lava.GrpcRouter, grpcProxy []lava.GrpcProxy, dixMiddlewares []lava.Middleware, metric metrics.Metric, log log.Logger) *lava.InnerServer

NewInner grpc 服务内部通信

Types

type Config

type Config struct {
	EnablePrintRoutes bool                 `yaml:"enable_print_routes"`
	BaseUrl           string               `yaml:"base_url"`
	GrpcConfig        *grpc_builder.Config `yaml:"grpc_config"`
	EnableCors        bool                 `yaml:"enable_cors"`
	EnablePingPong    bool                 `yaml:"enable_ping_pong"`

	// unix seconds
	PingPongTime int32 `yaml:"ping_pong_time"`
	GrpcPort     *int  `yaml:"grpc_port"`
	HttpPort     *int  `yaml:"http_port"`

	WsReadLimit *int `yaml:"ws_read_limit"`
}

type DefaultQueryParser

type DefaultQueryParser struct{}

func (*DefaultQueryParser) Parse

func (*DefaultQueryParser) Parse(msg proto.Message, values url.Values, filter *utilities.DoubleArray) error

Parse populates "values" into "msg". A value is ignored if its key starts with one of the elements in "filter".

type GrpcServerConfigLoader

type GrpcServerConfigLoader struct {
	GrpcServer *Config `yaml:"grpc_server"`
}