Documentation ¶
Index ¶
- Constants
- func EnableDebug(s *grpc.Server)
- func EnableHealth(srv string, s *grpc.Server)
- func EnableReflection(s *grpc.Server)
- func ListGRPCResources(server *grpc.Server) []string
- type Builder
- func (t *Builder) Build(cfg Cfg) (err error)
- func (t *Builder) BuildOpts(cfg Cfg) []grpc.ServerOption
- func (t *Builder) Get() *grpc.Server
- func (t *Builder) StreamInterceptor(interceptors ...grpc.StreamServerInterceptor)
- func (t *Builder) UnaryInterceptor(interceptors ...grpc.UnaryServerInterceptor)
- type Cfg
- type GRPCStats
- type KeepaliveParams
- type KeepalivePolicy
Constants ¶
View Source
const ( DefaultContentType = "application/grpc" DefaultMaxMsgSize = 1024 * 1024 * 4 DefaultTimeout = time.Second * 2 )
Variables ¶
This section is empty.
Functions ¶
func EnableDebug ¶
func EnableHealth ¶
func EnableReflection ¶
func ListGRPCResources ¶
ListGRPCResources is a helper function that lists all URLs that are registered on gRPC server.
This makes it easy to register all the relevant routes in your HTTP router of choice.
Types ¶
type Builder ¶
type Builder struct { grpchan.HandlerMap // contains filtered or unexported fields }
func (*Builder) StreamInterceptor ¶
func (t *Builder) StreamInterceptor(interceptors ...grpc.StreamServerInterceptor)
func (*Builder) UnaryInterceptor ¶
func (t *Builder) UnaryInterceptor(interceptors ...grpc.UnaryServerInterceptor)
type Cfg ¶
type Cfg struct { Codec string `json:"codec"` ConnectionTimeout time.Duration `json:"connection_timeout"` Cp string `json:"cp"` Creds string `json:"creds"` Dc string `json:"dc"` HeaderTableSize int64 `json:"header_table_size"` InitialConnWindowSize int64 `json:"initial_conn_window_size"` InitialWindowSize int64 `json:"initial_window_size"` KeepaliveParams KeepaliveParams `json:"keepalive_params"` KeepalivePolicy KeepalivePolicy `json:"keepalive_policy"` MaxConcurrentStreams int64 `json:"max_concurrent_streams"` MaxHeaderListSize int64 `json:"max_header_list_size"` MaxRecvMsgSize int `json:"max_recv_msg_size"` MaxSendMsgSize int `json:"max_send_msg_size"` ReadBufferSize int64 `json:"read_buffer_size"` WriteBufferSize int64 `json:"write_buffer_size"` }
func GetDefaultCfg ¶
func GetDefaultCfg() Cfg
type KeepaliveParams ¶
type KeepaliveParams struct { MaxConnectionAge time.Duration `json:"max_connection_age"` MaxConnectionAgeGrace time.Duration `json:"max_connection_age_grace"` MaxConnectionIdle time.Duration `json:"max_connection_idle"` Time time.Duration `json:"time"` Timeout time.Duration `json:"timeout"` }
func (KeepaliveParams) ToCfg ¶
func (t KeepaliveParams) ToCfg() (sp keepalive.ServerParameters)
type KeepalivePolicy ¶
Click to show internal directories.
Click to hide internal directories.