config

Documentation

Index

• func GetClientParameters() keepalive.ClientParameters
• func SetConfiguration(config *Configuration)
• type ATConfig
  • func GetATConfig() ATConfig
• type Configuration
  • func InitConfiguration(configurationPath string) *Configuration
  • func (configuration *Configuration) GetClientParameters() keepalive.ClientParameters
• type TMConfig
  • func GetTMConfig() TMConfig

Functions

func GetClientParameters

func GetClientParameters() keepalive.ClientParameters

GetClientParameters used to config grpc connection keep alive

func SetConfiguration

func SetConfiguration(config *Configuration)

Types

type ATConfig

type ATConfig struct {
	DSN                 string        `yaml:"dsn" json:"dsn,omitempty"`
	ReportRetryCount    int           `default:"5" yaml:"reportRetryCount" json:"reportRetryCount,omitempty"`
	ReportSuccessEnable bool          `default:"false" yaml:"reportSuccessEnable" json:"reportSuccessEnable,omitempty"`
	LockRetryInterval   time.Duration `default:"10ms" yaml:"lockRetryInterval" json:"lockRetryInterval,omitempty"`
	LockRetryTimes      int           `default:"30" yaml:"lockRetryTimes" json:"lockRetryTimes,omitempty"`
}

ATConfig

func GetATConfig

func GetATConfig() ATConfig

GetATConfig return ATConfig

type Configuration

type Configuration struct {
	Addressing       string `yaml:"addressing" json:"addressing"`
	ServerAddressing string `yaml:"serverAddressing" json:"serverAddressing"`

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

	ATConfig ATConfig `yaml:"at" json:"at,omitempty"`

	ClientParameters struct {
		Time                time.Duration `yaml:"time"`
		Timeout             time.Duration `yaml:"timeout"`
		PermitWithoutStream bool          `yaml:"permitWithoutStream"`
	} `yaml:"clientParameters"`

	Log struct {
		LogPath  string    `yaml:"logPath"`
		LogLevel log.Level `yaml:"logLevel"`
	} `yaml:"log"`
}

Configuration client configuration

func InitConfiguration

func InitConfiguration(configurationPath string) *Configuration

InitConfiguration init configuration from a file path

func (*Configuration) GetClientParameters

func (configuration *Configuration) GetClientParameters() keepalive.ClientParameters

GetClientParameters used to config grpc connection keep alive

type TMConfig

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

TMConfig

func GetTMConfig

func GetTMConfig() TMConfig

GetTMConfig return TMConfig