grpc_builder

Documentation

Index

• type Config
  • func GetDefaultCfg() *Config
  • func (t *Config) Build(opts ...grpc.ServerOption) (r result.Result[*grpc.Server])
• type KeepaliveParams
  • func (t *KeepaliveParams) ToOpts() grpc.ServerOption
• type KeepalivePolicy
  • func (t *KeepalivePolicy) ToOpts() grpc.ServerOption

Types

type Config

type Config struct {
	Codec                 string           `yaml:"codec"`
	ConnectionTimeout     time.Duration    `yaml:"connection_timeout"`
	Cp                    string           `yaml:"cp"`
	Creds                 string           `yaml:"creds"`
	Dc                    string           `yaml:"dc"`
	HeaderTableSize       int64            `yaml:"header_table_size"`
	InitialConnWindowSize int64            `yaml:"initial_conn_window_size"`
	InitialWindowSize     int64            `yaml:"initial_window_size"`
	KeepaliveParams       *KeepaliveParams `yaml:"keepalive_params"`
	KeepalivePolicy       *KeepalivePolicy `yaml:"keepalive_policy"`
	MaxConcurrentStreams  int64            `yaml:"max_concurrent_streams"`
	MaxHeaderListSize     int64            `yaml:"max_header_list_size"`
	MaxRecvMsgSize        int              `yaml:"max_recv_msg_size"`
	MaxSendMsgSize        int              `yaml:"max_send_msg_size"`
	ReadBufferSize        int64            `yaml:"read_buffer_size"`
	WriteBufferSize       int64            `yaml:"write_buffer_size"`
}

func GetDefaultCfg

func GetDefaultCfg() *Config

func (*Config) Build

func (t *Config) Build(opts ...grpc.ServerOption) (r result.Result[*grpc.Server])

type KeepaliveParams

type KeepaliveParams struct {
	MaxConnectionAge      time.Duration `yaml:"max_connection_age"`
	MaxConnectionAgeGrace time.Duration `yaml:"max_connection_age_grace"`
	MaxConnectionIdle     time.Duration `yaml:"max_connection_idle"`
	Time                  time.Duration `yaml:"time"`
	Timeout               time.Duration `yaml:"timeout"`
}

func (*KeepaliveParams) ToOpts

func (t *KeepaliveParams) ToOpts() grpc.ServerOption

type KeepalivePolicy

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

func (*KeepalivePolicy) ToOpts

func (t *KeepalivePolicy) ToOpts() grpc.ServerOption