config

package

Go to main page

Versions in this module

v0

v0.5.0

Dec 23, 2022

Changes in this version

type LogicTable

+ SequenceGenerator *SequenceGenerator

+ type SequenceGenerator struct

+ Config Parameters

+ Type SequenceType

+ type SequenceType byte

+ const Segment

+ const Snowflake

+ func (t *SequenceType) UnmarshalText(text []byte) error

+ type ShadowRule struct

+ Column string

+ Expr string

+ ShadowTablePrefix string

+ TableName string

type ShardingConfig

+ GlobalTables []string

+ ShadowRules []*ShadowRule

v0.4.1

Aug 18, 2022

Changes in this version

type TracerConfig

+ ExporterEndpoint *string

+ ExporterType string

v0.4.0

Aug 13, 2022

Changes in this version

+ type AppConfig map[string]*DBPackConfig

type Configuration

+ AppConfig AppConfig

+ ProbePort int

+ Tracer *TracerConfig

+ func (config Configuration) DBPackConfig(appID string) *DBPackConfig

+ type DBPackConfig struct

+ AppID string

+ DataSources []*DataSource

+ DistributedTransaction *DistributedTransaction

+ Executors []*Executor

+ Filters []*Filter

+ Listeners []*Listener

+ func GetDBPackConfig(appID string) *DBPackConfig

+ func (conf *DBPackConfig) GetEtcdConfig() *clientv3.Config

+ func (conf *DBPackConfig) Normalize() error

type DataSource

+ MasterName string

type DataSourceRef

+ func (dataSource *DataSourceRef) ParseWeight() (readWeight int, writeWeight int, err error)

type DistributedTransaction

+ AppID string

type Executor

+ AppID string

type Filter

+ AppID string

type Listener

+ AppID string

+ type LoadBalanceAlgorithm int32

+ const Random

+ const RandomWeight

+ const RoundRobin

+ func (l *LoadBalanceAlgorithm) UnmarshalText(text []byte) error

type SocketAddress

+ func (sa SocketAddress) String() string

+ type TracerConfig struct

+ JaegerEndpoint string

v0.3.3

Aug 4, 2022

v0.3.2

Jul 29, 2022

v0.3.1

Jul 29, 2022

v0.3.0

Jul 24, 2022

Changes in this version

type Configuration

+ Trace *Trace

+ type Trace struct

+ JaegerEndpoint string

v0.2.2

Jul 14, 2022

v0.2.1

Jul 12, 2022

Changes in this version

type ShardingConfig

+ TransactionTimeout int32

v0.2.0

Jul 7, 2022

v0.1.2

Jun 13, 2022

v0.1.1

Jun 8, 2022

v0.1.0

May 24, 2022

Changes in this version

+ type ClientParameters struct

+ PermitWithoutStream bool

+ Time time.Duration

+ Timeout time.Duration

+ type Configuration struct

+ DataSources []*DataSource

+ DistributedTransaction *DistributedTransaction

+ Executors []*Executor

+ Filters []*Filter

+ HTTPListenPort *int

+ Listeners []*Listener

+ TerminationDrainDuration time.Duration

+ func Load(path string) *Configuration

+ type DataSource struct

+ Capacity int

+ DSN string

+ Filters []string

+ IdleTimeout time.Duration

+ MaxCapacity int

+ Name string

+ PingInterval time.Duration

+ PingTimesForChangeStatus int

+ type DataSourceRef struct

+ Name string

+ Weight string

+ type DataSourceRefGroup struct

+ DataSources []*DataSourceRef

+ LBAlgorithm lb.LoadBalanceAlgorithm

+ Name string

+ type DataSourceRole int

+ const Master

+ const Meta

+ const Slave

+ func (r *DataSourceRole) UnmarshalText(text []byte) error

+ type DataSourceType int

+ const DBMysql

+ const DBPostgresSql

+ func (t *DataSourceType) UnmarshalText(text []byte) error

+ type DistributedTransaction struct

+ ApplicationID string

+ EtcdConfig clientv3.Config

+ RetryDeadThreshold int64

+ RollbackRetryTimeoutUnlockEnable bool

+ type EnforcementPolicy struct

+ MinTime time.Duration

+ PermitWithoutStream bool

+ type ExecuteMode byte

+ const RWS

+ const SDB

+ const SHD

+ func (m *ExecuteMode) UnmarshalText(text []byte) error

+ func (m ExecuteMode) String() string

+ type Executor struct

+ Config Parameters

+ Filters []string

+ Mode ExecuteMode

+ Name string

+ type Filter struct

+ Config Parameters

+ Kind string

+ Name string

+ type Listener struct

+ Config Parameters

+ Executor string

+ Filters []string

+ ProtocolType ProtocolType

+ SocketAddress SocketAddress

+ type LogicTable struct

+ AllowFullScan bool

+ DBName string

+ ShardingRule *ShardingRule

+ TableName string

+ Topology map[int]string

+ type Parameters map[string]interface

+ type ProtocolType int32

+ const Http

+ const Mysql

+ func (t *ProtocolType) UnmarshalText(text []byte) error

+ type ReadWriteSplittingConfig struct

+ DataSources []*DataSourceRef

+ LoadBalanceAlgorithm lb.LoadBalanceAlgorithm

+ type ServerParameters struct

+ MaxConnectionAge time.Duration

+ MaxConnectionAgeGrace time.Duration

+ MaxConnectionIdle time.Duration

+ Time time.Duration

+ Timeout time.Duration

+ type ShardingConfig struct

+ DBGroups []*DataSourceRefGroup

+ LogicTables []*LogicTable

+ type ShardingRule struct

+ Column string

+ Config Parameters

+ ShardingAlgorithm string

+ type SocketAddress struct

+ Address string

+ Port int

+ type Storage map[string]Parameters

+ func (storage Storage) Parameters() Parameters

+ func (storage Storage) Type() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL