config

Documentation

Index

• func InitRegistryConfig(registryConfig *RegistryConfig)
• type ConfigCenterConfig
• type EtcdConfig
• type EtcdConfigCenter
• type GettySessionParam
• type NacosConfig
• type NacosConfigCenter
• type RegistryConfig
  • func GetRegistryConfig() *RegistryConfig

Functions

func InitRegistryConfig

func InitRegistryConfig(registryConfig *RegistryConfig)

InitRegistryConfig init registry config

Types

type ConfigCenterConfig

type ConfigCenterConfig struct {
	Mode        string            `yaml:"type" json:"type,omitempty"` //类型
	NacosConfig NacosConfigCenter `yaml:"nacos" json:"nacos,omitempty"`
	ETCDConfig  EtcdConfigCenter  `yaml:"etcdv3" json:"etcdv3,omitempty"`
}

ConfigCenterConfig config center config

type EtcdConfig

type EtcdConfig struct {
	ClusterName string        `default:"seata-golang-etcdv3" yaml:"cluster_name" json:"cluster_name,omitempty"`
	Endpoints   string        `yaml:"endpoints" json:"endpoints,omitempty"`
	Heartbeats  int           `yaml:"heartbeats" json:"heartbeats"`
	Timeout     time.Duration `yaml:"timeout" json:"timeout"`
}

type EtcdConfigCenter

type EtcdConfigCenter struct {
	Name       string        `default:"seata-config-center" yaml:"name" json:"name"`
	ConfigKey  string        `default:"config-seata" yaml:"config_key" json:"config_key,omitempty"`
	Endpoints  string        `yaml:"endpoints" json:"endpoints,omitempty"`
	Heartbeats int           `yaml:"heartbeats" json:"heartbeats"`
	Timeout    time.Duration `yaml:"timeout" json:"timeout"`
}

type GettySessionParam

type GettySessionParam struct {
	CompressEncoding bool          `default:"false" yaml:"compress_encoding" json:"compress_encoding,omitempty"`
	TCPNoDelay       bool          `default:"true" yaml:"tcp_no_delay" json:"tcp_no_delay,omitempty"`
	TCPKeepAlive     bool          `default:"true" yaml:"tcp_keep_alive" json:"tcp_keep_alive,omitempty"`
	KeepAlivePeriod  time.Duration `default:"180s" yaml:"keep_alive_period" json:"keep_alive_period,omitempty"`
	TCPRBufSize      int           `default:"262144" yaml:"tcp_r_buf_size" json:"tcp_r_buf_size,omitempty"`
	TCPWBufSize      int           `default:"65536" yaml:"tcp_w_buf_size" json:"tcp_w_buf_size,omitempty"`
	TCPReadTimeout   time.Duration `default:"1s" yaml:"tcp_read_timeout" json:"tcp_read_timeout,omitempty"`
	TCPWriteTimeout  time.Duration `default:"5s" yaml:"tcp_write_timeout" json:"tcp_write_timeout,omitempty"`
	WaitTimeout      time.Duration `default:"7s" yaml:"wait_timeout" json:"wait_timeout,omitempty"`
	MaxMsgLen        int           `default:"4096" yaml:"max_msg_len" json:"max_msg_len,omitempty"`
	SessionName      string        `default:"rpc" yaml:"session_name" json:"session_name,omitempty"`
}

GettySessionParam getty session param

type NacosConfig

type NacosConfig struct {
	Application string `yaml:"application" json:"application,omitempty"`
	ServerAddr  string `yaml:"server_addr" json:"server_addr,omitempty"`
	Group       string `default:"SEATA_GROUP" yaml:"group" json:"group,omitempty"`
	Namespace   string `yaml:"namespace" json:"namespace,omitempty"`
	Cluster     string `yaml:"cluster" json:"cluster,omitempty"`
	UserName    string `yaml:"username" json:"username,omitempty"`
	Password    string `yaml:"password" json:"password,omitempty"`
}

NacosConfig nacos config

type NacosConfigCenter

type NacosConfigCenter struct {
	ServerAddr string `yaml:"server_addr" json:"server_addr,omitempty"`
	Group      string `default:"SEATA_GROUP" yaml:"group" json:"group,omitempty"`
	Namespace  string `yaml:"namespace" json:"namespace,omitempty"`
	Cluster    string `yaml:"cluster" json:"cluster,omitempty"`
	UserName   string `yaml:"username" json:"username,omitempty"`
	Password   string `yaml:"password" json:"password,omitempty"`
	DataID     string `default:"seata" yaml:"data_id" json:"data_id,omitempty"`
}

NacosConfigCenter nacos config center

type RegistryConfig

type RegistryConfig struct {
	Mode        string      `yaml:"type" json:"type,omitempty"` //类型
	NacosConfig NacosConfig `yaml:"nacos" json:"nacos,omitempty"`
	EtcdConfig  EtcdConfig  `yaml:"etcdv3" json:"etcdv3"`
}

RegistryConfig registry config

func GetRegistryConfig

func GetRegistryConfig() *RegistryConfig

GetRegistryConfig get registry config