Documentation
¶
Index ¶
- func DefaultMysqlConfig() *mysql.MysqlStoreConfig
- type AddressConfig
- func (c *AddressConfig) GetAddress() string
- func (c *AddressConfig) GetProtocol() string
- func (c *AddressConfig) GetUrlMap() url.Values
- func (a *AddressConfig) PostProcess() error
- func (a *AddressConfig) Sanitize()
- func (c *AddressConfig) ToURL() (*common.URL, error)
- func (a *AddressConfig) Validate() error
- type CacheStoreConfig
- type Registry
- type StoreConfig
- type StoreType
- type UpsertConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DefaultMysqlConfig ¶
func DefaultMysqlConfig() *mysql.MysqlStoreConfig
Types ¶
type AddressConfig ¶
func (*AddressConfig) GetAddress ¶
func (c *AddressConfig) GetAddress() string
func (*AddressConfig) GetProtocol ¶
func (c *AddressConfig) GetProtocol() string
func (*AddressConfig) GetUrlMap ¶
func (c *AddressConfig) GetUrlMap() url.Values
func (*AddressConfig) PostProcess ¶
func (a *AddressConfig) PostProcess() error
func (*AddressConfig) Sanitize ¶
func (a *AddressConfig) Sanitize()
func (*AddressConfig) Validate ¶
func (a *AddressConfig) Validate() error
type CacheStoreConfig ¶
type CacheStoreConfig struct {
config.BaseConfig
Enabled bool `json:"enabled" envconfig:"DUBBO_STORE_CACHE_ENABLED"`
ExpirationTime config_types.Duration `json:"expirationTime" envconfig:"DUBBO_STORE_CACHE_EXPIRATION_TIME"`
}
func DefaultCacheStoreConfig ¶
func DefaultCacheStoreConfig() CacheStoreConfig
type Registry ¶
type Registry struct {
ConfigCenter AddressConfig `json:"configCenter,omitempty"`
MetadataReport AddressConfig `json:"metadataReport,omitempty"`
Registry AddressConfig `json:"registry,omitempty"`
}
func DefaultTraditionalConfig ¶
func DefaultTraditionalConfig() Registry
func (*Registry) PostProcess ¶
type StoreConfig ¶
type StoreConfig struct {
// Type of Store used in the Control Plane. Can be either "kubernetes", "postgres" or "memory"
Type StoreType `json:"type" envconfig:"DUBBO_STORE_TYPE"`
// Kubernetes Store configuration
Kubernetes *k8s.KubernetesStoreConfig `json:"kubernetes"`
// Zookeeper Store configuration
Zookeeper *zookeeper.ZookeeperStoreConfig `json:"zookeeper"`
// Mysql Store configuration
Mysql *mysql.MysqlStoreConfig `json:"mysql"`
Traditional Registry `json:"traditional" envconfig:"DUBBO_STORE_TRADITIONAL_REGISTRY"`
// Cache configuration
Cache CacheStoreConfig `json:"cache"`
// Upsert configuration
Upsert UpsertConfig `json:"upsert"`
// UnsafeDelete skips validation of resource delete.
// For example you don't have to delete all Dataplane objects before you delete a Mesh
UnsafeDelete bool `json:"unsafeDelete" envconfig:"DUBBO_STORE_UNSAFE_DELETE"`
}
StoreConfig defines Resource Store configuration
func DefaultStoreConfig ¶
func DefaultStoreConfig() *StoreConfig
func (*StoreConfig) PostProcess ¶
func (s *StoreConfig) PostProcess() error
func (*StoreConfig) Sanitize ¶
func (s *StoreConfig) Sanitize()
func (*StoreConfig) Validate ¶
func (s *StoreConfig) Validate() error
type UpsertConfig ¶
type UpsertConfig struct {
config.BaseConfig
// Base time for exponential backoff on upsert (get and update) operations when retry is enabled
ConflictRetryBaseBackoff config_types.Duration `json:"conflictRetryBaseBackoff" envconfig:"DUBBO_STORE_UPSERT_CONFLICT_RETRY_BASE_BACKOFF"`
// Max retries on upsert (get and update) operation when retry is enabled
ConflictRetryMaxTimes uint `json:"conflictRetryMaxTimes" envconfig:"DUBBO_STORE_UPSERT_CONFLICT_RETRY_MAX_TIMES"`
// Percentage of jitter. For example: if backoff is 20s, and this value 10, the backoff will be between 18s and 22s.
ConflictRetryJitterPercent uint `json:"conflictRetryJitterPercent" envconfig:"DUBBO_STORE_UPSERT_CONFLICT_RETRY_JITTER_PERCENT"`
}
func DefaultUpsertConfig ¶
func DefaultUpsertConfig() UpsertConfig
func (*UpsertConfig) Validate ¶
func (u *UpsertConfig) Validate() error
Click to show internal directories.
Click to hide internal directories.