golug_grpc

Documentation

Index

• Constants
• type Cfg
  • func GetDefaultCfg() Cfg
  • func (t Cfg) Build(opt ...grpc.ServerOption) *grpc.Server
  • func (t Cfg) BuildOpts() []grpc.ServerOption
• type KeepaliveParams
  • func (t KeepaliveParams) ToCfg() keepalive.ServerParameters
• type KeepalivePolicy

Constants

const (
	Name               = "grpc_entry"
	DefaultContentType = "application/grpc"
	DefaultMaxMsgSize  = 1024 * 1024 * 4
)

Types

type Cfg

type Cfg struct {
	SleepAfterDeregister time.Duration `json:"SleepAfterDeregister"`
	// The interval on which to register
	RegisterInterval time.Duration `json:"RegisterInterval"`
	// The register expiry time
	RegisterTTL           time.Duration   `json:"register_ttl"`
	Address               string          `json:"address"`
	Advertise             string          `json:"advertise"`
	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

func (Cfg) Build

func (t Cfg) Build(opt ...grpc.ServerOption) *grpc.Server

func (Cfg) BuildOpts

func (t Cfg) BuildOpts() []grpc.ServerOption

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() keepalive.ServerParameters

type KeepalivePolicy

type KeepalivePolicy struct {
	MinTime             time.Duration `json:"min_time"`
	PermitWithoutStream bool          `json:"permit_without_stream"`
}