config

Documentation

Index

• func InitConf(confFile string) error
• type ClientConfig
  • func GetClientConfig() *ClientConfig
  • func GetDefaultClientConfig(applicationID string) ClientConfig
• type ClientConfigListener
  • func (ClientConfigListener) Process(event *config_center.ConfigChangeEvent)
• type GettyConfig
  • func GetDefaultGettyConfig() GettyConfig
• type TMConfig
  • func GetDefaultTmConfig() TMConfig
  • func GetTMConfig() TMConfig

Functions

func InitConf

func InitConf(confFile string) error

InitConf init ClientConfig from a file path

Types

type ClientConfig

type ClientConfig struct {
	ApplicationID                string      `yaml:"application_id" json:"application_id,omitempty"`
	TransactionServiceGroup      string      `yaml:"transaction_service_group" json:"transaction_service_group,omitempty"`
	EnableClientBatchSendRequest bool        `yaml:"enable-rpc_client-batch-send-request" json:"enable-rpc_client-batch-send-request,omitempty"`
	SeataVersion                 string      `yaml:"seata_version" json:"seata_version,omitempty"`
	GettyConfig                  GettyConfig `yaml:"getty" json:"getty,omitempty"`

	TMConfig TMConfig `yaml:"tm" json:"tm,omitempty"`

	ATConfig struct {
		DSN                 string        `yaml:"dsn" json:"dsn,omitempty"`
		ReportRetryCount    int           `default:"5" yaml:"report_retry_count" json:"report_retry_count,omitempty"`
		ReportSuccessEnable bool          `default:"false" yaml:"report_success_enable" json:"report_success_enable,omitempty"`
		LockRetryInterval   time.Duration `default:"10ms" yaml:"lock_retry_interval" json:"lock_retry_interval,omitempty"`
		LockRetryTimes      int           `default:"30" yaml:"lock_retry_times" json:"lock_retry_times,omitempty"`
	} `yaml:"at" json:"at,omitempty"`

	RegistryConfig     config.RegistryConfig     `yaml:"registry_config" json:"registry_config,omitempty"` //注册中心配置信息
	ConfigCenterConfig config.ConfigCenterConfig `yaml:"config_center" json:"config_center,omitempty"`     //配置中心配置信息
}

func GetClientConfig

func GetClientConfig() *ClientConfig

func GetDefaultClientConfig

func GetDefaultClientConfig(applicationID string) ClientConfig

type ClientConfigListener

type ClientConfigListener struct {
}

func (ClientConfigListener) Process

func (ClientConfigListener) Process(event *config_center.ConfigChangeEvent)

type GettyConfig

type GettyConfig struct {
	ReconnectInterval int `default:"0" yaml:"reconnect_interval" json:"reconnect_interval,omitempty"`
	// getty_session pool
	ConnectionNum int `default:"16" yaml:"connection_number" json:"connection_number,omitempty"`

	// heartbeat
	HeartbeatPeriod time.Duration `default:"15s" yaml:"heartbeat_period" json:"heartbeat_period,omitempty"`

	// getty_session tcp parameters
	GettySessionParam config2.GettySessionParam `required:"true" yaml:"getty_session_param" json:"getty_session_param,omitempty"`
}

GettyConfig Config holds supported types by the multiconfig package

func GetDefaultGettyConfig

func GetDefaultGettyConfig() GettyConfig

GetDefaultGettyConfig ...

type TMConfig

type TMConfig struct {
	CommitRetryCount   int32 `default:"5" yaml:"commit_retry_count" json:"commit_retry_count,omitempty"`
	RollbackRetryCount int32 `default:"5" yaml:"rollback_retry_count" json:"rollback_retry_count,omitempty"`
}

func GetDefaultTmConfig

func GetDefaultTmConfig() TMConfig

func GetTMConfig

func GetTMConfig() TMConfig