config

Documentation

Index

• type GrpcConfig
  • func DefaultGrpcConfig() *GrpcConfig
• type GrpcTransConfig
  • func DefaultGrpcTransConfig() *GrpcTransConfig
  • func LoadOverrideGrpcTransConfig(config *GrpcTransConfig, configPath string) (*GrpcTransConfig, error)
  • func (c *GrpcTransConfig) Check() error
• type ServerConfig
  • func DefaultServerConfig() *ServerConfig
• type TransConfig
  • func DefaultTransConfig() *TransConfig
  • func LoadOverrideConfig(config *TransConfig, configPath string) (*TransConfig, error)
  • func LoadTransConfig(configPath string) (*TransConfig, error)
  • func (c *TransConfig) Check() error

Types

type GrpcConfig

type GrpcConfig struct {
	Port                 int    `yaml:"port,omitempty"`
	MaxConns             int    `yaml:"maxConns,omitempty"`
	MaxConcurrentStreams uint32 `yaml:"maxConcurrentStreams,omitempty"`
	MaxRecvMsgSize       int    `yaml:"maxRecvMsgSize,omitempty"`
	MaxSendMsgSize       int    `yaml:"maxSendMsgSize,omitempty"`
	ConnectionTimeout    uint32 `yaml:"connectionTimeout,omitempty"`
	ReadBufferSize       int    `yaml:"readBufferSize,omitempty"`
	WriteBufferSize      int    `yaml:"writeBufferSize,omitempty"`
}

func DefaultGrpcConfig

func DefaultGrpcConfig() *GrpcConfig

type GrpcTransConfig

type GrpcTransConfig struct {
	MsqConfig  *msq.Config `yaml:"msqConfig,omitempty"`
	GrpcConfig *GrpcConfig `yaml:"grpcConfig,omitempty"`
}

func DefaultGrpcTransConfig

func DefaultGrpcTransConfig() *GrpcTransConfig

func LoadOverrideGrpcTransConfig

func LoadOverrideGrpcTransConfig(config *GrpcTransConfig, configPath string) (*GrpcTransConfig, error)

func (*GrpcTransConfig) Check

func (c *GrpcTransConfig) Check() error

type ServerConfig

type ServerConfig struct {
	Port           int   `yaml:"port,omitempty"`
	ReadTimeout    int   `yaml:"readTimeout,omitempty"`
	WriteTimeout   int   `yaml:"writeTimeout,omitempty"`
	IdleTimeout    int   `yaml:"idleTimeout,omitempty"`
	ReqBodyMaxSize int64 `yaml:"reqBodyMaxSize,omitempty"`
}

func DefaultServerConfig

func DefaultServerConfig() *ServerConfig

type TransConfig

type TransConfig struct {
	MsqConfig  *msq.Config   `yaml:"msqConfig,omitempty"`
	HTTPConfig *ServerConfig `yaml:"httpConfig,omitempty"`
}

func DefaultTransConfig

func DefaultTransConfig() *TransConfig

func LoadOverrideConfig

func LoadOverrideConfig(config *TransConfig, configPath string) (*TransConfig, error)

func LoadTransConfig

func LoadTransConfig(configPath string) (*TransConfig, error)

func (*TransConfig) Check

func (c *TransConfig) Check() error