config

package

Go to main page

Versions in this module

v1

v1.0.7

Apr 28, 2022

v1.0.6

Apr 11, 2022

v1.0.5

Mar 31, 2022

Changes in this version

type ConsumerConfig

+ func (cc *ConsumerConfig) DynamicUpdateProperties(newConsumerConfig *ConsumerConfig)

+ type ProfilesConfig struct

+ Active string

+ func (ProfilesConfig) Prefix() string

type RegistryConfig

+ func (c *RegistryConfig) DynamicUpdateProperties(updateRegistryConfig *RegistryConfig)

type RegistryConfigBuilder

+ func (rcb *RegistryConfigBuilder) AddParam(key, value string) *RegistryConfigBuilder

type RootConfig

+ Profiles *ProfilesConfig

type RouterConfig

+ Enabled bool

type RouterConfigBuilder

+ func (rcb *RouterConfigBuilder) SetEnabled(enabled bool) *RouterConfigBuilder

v1.0.4

Mar 29, 2022

Changes in this version

+ const MaxWheelTimeSpan

+ var DumpHeapShutdownSignals = []os.Signal — darwin/amd64, linux/amd64, windows/amd64

+ var ShutdownSignals = []os.Signal — darwin/amd64, linux/amd64, windows/amd64

+ func BeforeShutdown()

+ func GetCallback(name string) func(response common.CallbackResponse)

+ func GetClientTlsConfigBuilder() getty.TlsConfigBuilder

+ func GetConfigResolver(conf *loaderConf) *koanf.Koanf

+ func GetConsumerService(name string) common.RPCService

+ func GetConsumerServiceByInterfaceName(interfaceName string) common.RPCService

+ func GetDefineValue(key string, default_value interface{}) interface

+ func GetProtocolsInstance() map[string]*ProtocolConfig

+ func GetProviderService(name string) common.RPCService

+ func GetRPCService(name string) common.RPCService

+ func GetServerTlsConfigBuilder() getty.TlsConfigBuilder

+ func IsProvider() bool

+ func Load(opts ...LoaderConfOption) error

+ func NewLoaderConf(opts ...LoaderConfOption) *loaderConf

+ func RPCService(service common.RPCService)

+ func SetClientTlsConfigBuilder(configBuilder getty.TlsConfigBuilder)

+ func SetConsumerConfig(c ConsumerConfig)

+ func SetConsumerService(service common.RPCService)

+ func SetConsumerServiceByInterfaceName(interfaceName string, srv common.RPCService)

+ func SetProviderService(service common.RPCService)

+ func SetRootConfig(r RootConfig)

+ func SetServerTlsConfigBuilder(configBuilder getty.TlsConfigBuilder)

+ type ApplicationConfig struct

+ Environment string

+ MetadataType string

+ Module string

+ Name string

+ Organization string

+ Owner string

+ Version string

+ func GetApplicationConfig() *ApplicationConfig

+ func (ApplicationConfig) Prefix() string

+ func (ac *ApplicationConfig) Init() error

+ type ApplicationConfigBuilder struct

+ func NewApplicationConfigBuilder() *ApplicationConfigBuilder

+ func (acb *ApplicationConfigBuilder) Build() *ApplicationConfig

+ func (acb *ApplicationConfigBuilder) SetEnvironment(environment string) *ApplicationConfigBuilder

+ func (acb *ApplicationConfigBuilder) SetMetadataType(metadataType string) *ApplicationConfigBuilder

+ func (acb *ApplicationConfigBuilder) SetModule(module string) *ApplicationConfigBuilder

+ func (acb *ApplicationConfigBuilder) SetName(name string) *ApplicationConfigBuilder

+ func (acb *ApplicationConfigBuilder) SetOrganization(organization string) *ApplicationConfigBuilder

+ func (acb *ApplicationConfigBuilder) SetOwner(owner string) *ApplicationConfigBuilder

+ func (acb *ApplicationConfigBuilder) SetVersion(version string) *ApplicationConfigBuilder

+ type BoolMatch struct

+ Exact bool

+ type CenterConfig struct

+ Address string

+ AppID string

+ Cluster string

+ DataId string

+ FileExtension string

+ Group string

+ Namespace string

+ Params map[string]string

+ Password string

+ Protocol string

+ Timeout string

+ Username string

+ func (CenterConfig) Prefix() string

+ func (c *CenterConfig) CreateDynamicConfiguration() (config_center.DynamicConfiguration, error)

+ func (c *CenterConfig) GetDynamicConfiguration() (config_center.DynamicConfiguration, error)

+ func (c *CenterConfig) GetUrlMap() url.Values

+ func (c *CenterConfig) Init(rc *RootConfig) error

+ type ConfigCenterConfigBuilder struct

+ func NewConfigCenterConfigBuilder() *ConfigCenterConfigBuilder

+ func (ccb *ConfigCenterConfigBuilder) Build() *CenterConfig

+ func (ccb *ConfigCenterConfigBuilder) SetAddress(address string) *ConfigCenterConfigBuilder

+ func (ccb *ConfigCenterConfigBuilder) SetDataID(dataID string) *ConfigCenterConfigBuilder

+ func (ccb *ConfigCenterConfigBuilder) SetGroup(group string) *ConfigCenterConfigBuilder

+ func (ccb *ConfigCenterConfigBuilder) SetNamespace(namespace string) *ConfigCenterConfigBuilder

+ func (ccb *ConfigCenterConfigBuilder) SetPassword(password string) *ConfigCenterConfigBuilder

+ func (ccb *ConfigCenterConfigBuilder) SetProtocol(protocol string) *ConfigCenterConfigBuilder

+ func (ccb *ConfigCenterConfigBuilder) SetUserName(userName string) *ConfigCenterConfigBuilder

+ type ConsumerConfig struct

+ AdaptiveService bool

+ Check bool

+ Filter string

+ FilterConf interface{}

+ MaxWaitTimeForServiceDiscovery string

+ ProxyFactory string

+ References map[string]*ReferenceConfig

+ RegistryIDs []string

+ RequestTimeout string

+ TracingKey string

+ func GetConsumerConfig() *ConsumerConfig

+ func (ConsumerConfig) Prefix() string

+ func (cc *ConsumerConfig) Init(rc *RootConfig) error

+ func (cc *ConsumerConfig) Load()

+ type ConsumerConfigBuilder struct

+ func NewConsumerConfigBuilder() *ConsumerConfigBuilder

+ func (ccb *ConsumerConfigBuilder) AddReference(referenceKey string, referenceConfig *ReferenceConfig) *ConsumerConfigBuilder

+ func (ccb *ConsumerConfigBuilder) Build() *ConsumerConfig

+ func (ccb *ConsumerConfigBuilder) SetCheck(check bool) *ConsumerConfigBuilder

+ func (ccb *ConsumerConfigBuilder) SetFilter(filter string) *ConsumerConfigBuilder

+ func (ccb *ConsumerConfigBuilder) SetFilterConf(filterConf interface{}) *ConsumerConfigBuilder

+ func (ccb *ConsumerConfigBuilder) SetMaxWaitTimeForServiceDiscovery(maxWaitTimeForServiceDiscovery string) *ConsumerConfigBuilder

+ func (ccb *ConsumerConfigBuilder) SetProxyFactory(proxyFactory string) *ConsumerConfigBuilder

+ func (ccb *ConsumerConfigBuilder) SetReferences(references map[string]*ReferenceConfig) *ConsumerConfigBuilder

+ func (ccb *ConsumerConfigBuilder) SetRegistryIDs(RegistryIDs ...string) *ConsumerConfigBuilder

+ func (ccb *ConsumerConfigBuilder) SetRequestTimeout(requestTimeout string) *ConsumerConfigBuilder

+ func (ccb *ConsumerConfigBuilder) SetRootConfig(rootConfig *RootConfig) *ConsumerConfigBuilder

+ type CustomConfig struct

+ ConfigMap map[string]interface{}

+ func (*CustomConfig) Prefix() string

+ func (c *CustomConfig) GetDefineValue(key string, default_value interface{}) interface{}

+ func (c *CustomConfig) Init() error

+ type CustomConfigBuilder struct

+ func NewCustomConfigBuilder() *CustomConfigBuilder

+ func (ccb *CustomConfigBuilder) Build() *CustomConfig

+ func (ccb *CustomConfigBuilder) SetDefineConfig(key string, val interface{}) *CustomConfigBuilder

+ type DestinationRuleConfig struct

+ MetaData MetaDataStruct

+ Spec DestinationRuleSpec

+ YamlAPIVersion string

+ YamlKind string

+ func (drc *DestinationRuleConfig) DeepCopyObject() runtime.Object

+ type DestinationRuleConfigList struct

+ Items []DestinationRuleConfig

+ func (drc *DestinationRuleConfigList) DeepCopyObject() runtime.Object

+ type DestinationRuleSpec struct

+ Host string

+ SubSets []DestinationRuleSubSet

+ type DestinationRuleSpecList struct

+ Items []DestinationRuleSpec

+ type DestinationRuleSubSet struct

+ Labels map[string]string

+ Name string

+ type DoubleMatch struct

+ Exact float64

+ Mode float64

+ Range *DoubleRangeMatch

+ type DoubleRangeMatch struct

+ End float64

+ Start float64

+ type DubboAttachmentMatch struct

+ DubboContext map[string]*StringMatch

+ EagleeyeContext map[string]*StringMatch

+ type DubboDestination struct

+ Destination RouterDest

+ type DubboMatchRequest struct

+ Attachment *DubboAttachmentMatch

+ Header map[string]*StringMatch

+ Method *DubboMethodMatch

+ Name string

+ SourceLabels map[string]string

+ Threshold *DoubleMatch

+ type DubboMethodArg struct

+ BoolValue *BoolMatch

+ Index uint32

+ NumValue *ListDoubleMatch

+ StrValue *ListStringMatch

+ Type string

+ type DubboMethodMatch struct

+ Argc int

+ Argp []*StringMatch

+ Args []*DubboMethodArg

+ Headers map[string]*StringMatch

+ NameMatch *StringMatch

+ type DubboRoute struct

+ Name string

+ RouterDetail []*DubboRouteDetail

+ Services []*StringMatch

+ type DubboRouteDetail struct

+ Match []*DubboMatchRequest

+ Name string

+ Router []*DubboDestination

+ type EncoderConfig struct

+ CallerKey string

+ EncodeCaller string

+ EncodeDuration string

+ EncodeLevel string

+ EncodeTime string

+ LevelKey string

+ MessageKey string

+ NameKey string

+ Params map[string]string

+ StacktraceKey string

+ TimeKey string

+ type ListDoubleMatch struct

+ Oneof []*DoubleMatch

+ type ListStringMatch struct

+ Oneof []*StringMatch

+ type LoaderConfOption interface

+ func WithBytes(bytes []byte) LoaderConfOption

+ func WithDelim(delim string) LoaderConfOption

+ func WithGenre(suffix string) LoaderConfOption

+ func WithPath(path string) LoaderConfOption

+ func WithRootConfig(rc *RootConfig) LoaderConfOption

+ func WithSuffix(suffix file.Suffix) LoaderConfOption

+ type LoggerConfig struct

+ LumberjackConfig *lumberjack.Logger

+ ZapConfig ZapConfig

+ func (LoggerConfig) Prefix() string

+ func (lc *LoggerConfig) Init() error

+ type LoggerConfigBuilder struct

+ func NewLoggerConfigBuilder() *LoggerConfigBuilder

+ func (lcb *LoggerConfigBuilder) Build() *LoggerConfig

+ func (lcb *LoggerConfigBuilder) SetLumberjackConfig(lumberjackConfig *lumberjack.Logger) *LoggerConfigBuilder

+ func (lcb *LoggerConfigBuilder) SetZapConfig(zapConfig ZapConfig) *LoggerConfigBuilder

+ type MeshRouteMetadata struct

+ MetaData MetaDataStruct

+ Spec interface{}

+ YamlAPIVersion string

+ YamlKind string

+ type MetaDataStruct struct

+ Name string

+ type MetadataReportConfig struct

+ Address string

+ Group string

+ Namespace string

+ Password string

+ Protocol string

+ Timeout string

+ Username string

+ func GetMetadataReportConfg() *MetadataReportConfig

+ func (MetadataReportConfig) Prefix() string

+ func (mc *MetadataReportConfig) Init(rc *RootConfig) error

+ func (mc *MetadataReportConfig) IsValid() bool

+ func (mc *MetadataReportConfig) StartMetadataReport() error

+ func (mc *MetadataReportConfig) ToUrl() (*common.URL, error)

+ type MetadataReportConfigBuilder struct

+ func NewMetadataReportConfigBuilder() *MetadataReportConfigBuilder

+ func (mrcb *MetadataReportConfigBuilder) Build() *MetadataReportConfig

+ func (mrcb *MetadataReportConfigBuilder) SetAddress(address string) *MetadataReportConfigBuilder

+ func (mrcb *MetadataReportConfigBuilder) SetGroup(group string) *MetadataReportConfigBuilder

+ func (mrcb *MetadataReportConfigBuilder) SetPassword(password string) *MetadataReportConfigBuilder

+ func (mrcb *MetadataReportConfigBuilder) SetProtocol(protocol string) *MetadataReportConfigBuilder

+ func (mrcb *MetadataReportConfigBuilder) SetTimeout(timeout string) *MetadataReportConfigBuilder

+ func (mrcb *MetadataReportConfigBuilder) SetUsername(username string) *MetadataReportConfigBuilder

+ type MethodConfig struct

+ ExecuteLimit string

+ ExecuteLimitRejectedHandler string

+ InterfaceId string

+ InterfaceName string

+ LoadBalance string

+ Name string

+ RequestTimeout string

+ Retries string

+ Sticky bool

+ TpsLimitInterval string

+ TpsLimitRate string

+ TpsLimitStrategy string

+ Weight int64

+ func (m *MethodConfig) Init() error

+ func (m *MethodConfig) Prefix() string

+ type MetricConfig struct

+ Enable string

+ Mode string

+ Namespace string

+ Path string

+ Port string

+ PushGatewayAddress string

+ func GetMetricConfig() *MetricConfig

+ func (m *MetricConfig) ToReporterConfig() *metrics.ReporterConfig

+ func (mc *MetricConfig) Init() error

+ type MetricConfigBuilder struct

+ func NewMetricConfigBuilder() *MetricConfigBuilder

+ func (mcb *MetricConfigBuilder) Build() *MetricConfig

+ type MockService struct

+ func (*MockService) GetUser(ctx context.Context, itf []interface{}, str *struct{}) error

+ func (*MockService) GetUser1(ctx context.Context, itf []interface{}, str *struct{}) error

+ func (*MockService) Reference() string

+ type ProtocolConfig struct

+ Ip string

+ Name string

+ Params interface{}

+ Port string

+ func (ProtocolConfig) Prefix() string

+ func (p *ProtocolConfig) Init() error

+ type ProtocolConfigBuilder struct

+ func NewProtocolConfigBuilder() *ProtocolConfigBuilder

+ func (pcb *ProtocolConfigBuilder) Build() *ProtocolConfig

+ func (pcb *ProtocolConfigBuilder) SetIp(ip string) *ProtocolConfigBuilder

+ func (pcb *ProtocolConfigBuilder) SetName(name string) *ProtocolConfigBuilder

+ func (pcb *ProtocolConfigBuilder) SetParams(params interface{}) *ProtocolConfigBuilder

+ func (pcb *ProtocolConfigBuilder) SetPort(port string) *ProtocolConfigBuilder

+ type ProviderConfig struct

+ AdaptiveService bool

+ AdaptiveServiceVerbose bool

+ ConfigType map[string]string

+ Filter string

+ FilterConf interface{}

+ ProxyFactory string

+ Register bool

+ RegistryIDs []string

+ Services map[string]*ServiceConfig

+ TracingKey string

+ func GetProviderConfig() *ProviderConfig

+ func (ProviderConfig) Prefix() string

+ func (c *ProviderConfig) Init(rc *RootConfig) error

+ func (c *ProviderConfig) Load()

+ type ProviderConfigBuilder struct

+ func NewProviderConfigBuilder() *ProviderConfigBuilder

+ func (pcb *ProviderConfigBuilder) AddConfigType(key, value string) *ProviderConfigBuilder

+ func (pcb *ProviderConfigBuilder) AddService(serviceID string, serviceConfig *ServiceConfig) *ProviderConfigBuilder

+ func (pcb *ProviderConfigBuilder) Build() *ProviderConfig

+ func (pcb *ProviderConfigBuilder) SetConfigType(configType map[string]string) *ProviderConfigBuilder

+ func (pcb *ProviderConfigBuilder) SetFilter(filter string) *ProviderConfigBuilder

+ func (pcb *ProviderConfigBuilder) SetFilterConf(filterConf interface{}) *ProviderConfigBuilder

+ func (pcb *ProviderConfigBuilder) SetProxyFactory(proxyFactory string) *ProviderConfigBuilder

+ func (pcb *ProviderConfigBuilder) SetRegister(register bool) *ProviderConfigBuilder

+ func (pcb *ProviderConfigBuilder) SetRegistryIDs(RegistryIDs ...string) *ProviderConfigBuilder

+ func (pcb *ProviderConfigBuilder) SetRootConfig(rootConfig *RootConfig) *ProviderConfigBuilder

+ func (pcb *ProviderConfigBuilder) SetServices(services map[string]*ServiceConfig) *ProviderConfigBuilder

+ type ReferenceConfig struct

+ Async bool

+ Check *bool

+ Cluster string

+ Filter string

+ ForceTag bool

+ Generic string

+ Group string

+ InterfaceName string

+ Loadbalance string

+ Methods []*MethodConfig

+ Params map[string]string

+ Protocol string

+ ProvidedBy string

+ RegistryIDs []string

+ RequestTimeout string

+ Retries string

+ Serialization string

+ Sticky bool

+ TracingKey string

+ URL string

+ Version string

+ func (rc *ReferenceConfig) GenericLoad(id string)

+ func (rc *ReferenceConfig) GetInvoker() protocol.Invoker

+ func (rc *ReferenceConfig) GetProxy() *proxy.Proxy

+ func (rc *ReferenceConfig) GetRPCService() common.RPCService

+ func (rc *ReferenceConfig) Implement(v common.RPCService)

+ func (rc *ReferenceConfig) Init(root *RootConfig) error

+ func (rc *ReferenceConfig) Prefix() string

+ func (rc *ReferenceConfig) Refer(srv interface{})

+ type ReferenceConfigBuilder struct

+ func NewReferenceConfigBuilder() *ReferenceConfigBuilder

+ func (pcb *ReferenceConfigBuilder) Build() *ReferenceConfig

+ func (pcb *ReferenceConfigBuilder) SetCluster(cluster string) *ReferenceConfigBuilder

+ func (pcb *ReferenceConfigBuilder) SetGeneric(generic bool) *ReferenceConfigBuilder

+ func (pcb *ReferenceConfigBuilder) SetInterface(interfaceName string) *ReferenceConfigBuilder

+ func (pcb *ReferenceConfigBuilder) SetProtocol(protocol string) *ReferenceConfigBuilder

+ func (pcb *ReferenceConfigBuilder) SetRegistryIDs(registryIDs ...string) *ReferenceConfigBuilder

+ func (pcb *ReferenceConfigBuilder) SetSerialization(serialization string) *ReferenceConfigBuilder

+ type RegistryConfig struct

+ Address string

+ Group string

+ Namespace string

+ Params map[string]string

+ Password string

+ Preferred bool

+ Protocol string

+ RegistryType string

+ Simplified bool

+ TTL string

+ Timeout string

+ Username string

+ Weight int64

+ Zone string

+ func NewRegistryConfig(opts ...RegistryConfigOpt) *RegistryConfig

+ func NewRegistryConfigWithProtocolDefaultPort(protocol string) *RegistryConfig

+ func (RegistryConfig) Prefix() string

+ func (c *RegistryConfig) GetInstance(roleType common.RoleType) (registry.Registry, error)

+ func (c *RegistryConfig) Init() error

+ func (c *RegistryConfig) UpdateProperties(updateRegistryConfig *RegistryConfig)

+ type RegistryConfigBuilder struct

+ func NewRegistryConfigBuilder() *RegistryConfigBuilder

+ func (rcb *RegistryConfigBuilder) Build() *RegistryConfig

+ func (rcb *RegistryConfigBuilder) SetAddress(address string) *RegistryConfigBuilder

+ func (rcb *RegistryConfigBuilder) SetGroup(group string) *RegistryConfigBuilder

+ func (rcb *RegistryConfigBuilder) SetNamespace(namespace string) *RegistryConfigBuilder

+ func (rcb *RegistryConfigBuilder) SetParams(params map[string]string) *RegistryConfigBuilder

+ func (rcb *RegistryConfigBuilder) SetPassword(password string) *RegistryConfigBuilder

+ func (rcb *RegistryConfigBuilder) SetPreferred(preferred bool) *RegistryConfigBuilder

+ func (rcb *RegistryConfigBuilder) SetProtocol(protocol string) *RegistryConfigBuilder

+ func (rcb *RegistryConfigBuilder) SetRegistryType(registryType string) *RegistryConfigBuilder

+ func (rcb *RegistryConfigBuilder) SetSimplified(simplified bool) *RegistryConfigBuilder

+ func (rcb *RegistryConfigBuilder) SetTTL(ttl string) *RegistryConfigBuilder

+ func (rcb *RegistryConfigBuilder) SetTimeout(timeout string) *RegistryConfigBuilder

+ func (rcb *RegistryConfigBuilder) SetUsername(username string) *RegistryConfigBuilder

+ func (rcb *RegistryConfigBuilder) SetWeight(weight int64) *RegistryConfigBuilder

+ func (rcb *RegistryConfigBuilder) SetZone(zone string) *RegistryConfigBuilder

+ type RegistryConfigOpt func(config *RegistryConfig) *RegistryConfig

+ func WithRegistryAddress(addr string) RegistryConfigOpt

+ func WithRegistryGroup(group string) RegistryConfigOpt

+ func WithRegistryParams(params map[string]string) RegistryConfigOpt

+ func WithRegistryPassword(psw string) RegistryConfigOpt

+ func WithRegistryPreferred(preferred bool) RegistryConfigOpt

+ func WithRegistryProtocol(regProtocol string) RegistryConfigOpt

+ func WithRegistrySimplified(simplified bool) RegistryConfigOpt

+ func WithRegistryTTL(ttl string) RegistryConfigOpt

+ func WithRegistryTimeOut(timeout string) RegistryConfigOpt

+ func WithRegistryUserName(userName string) RegistryConfigOpt

+ func WithRegistryWeight(weight int64) RegistryConfigOpt

+ type RemoteConfig struct

+ Address string

+ Params map[string]string

+ Password string

+ Protocol string

+ Timeout string

+ Username string

+ func (rc *RemoteConfig) GetParam(key string, def string) string

+ func (rc *RemoteConfig) GetTimeout() time.Duration

+ func (rc *RemoteConfig) Init() error

+ func (rc *RemoteConfig) Prefix() string

+ func (rc *RemoteConfig) ToURL() (*common.URL, error)

+ type RemoteConfigBuilder struct

+ func NewRemoteConfigBuilder() *RemoteConfigBuilder

+ func (rcb *RemoteConfigBuilder) AddParam(key, value string) *RemoteConfigBuilder

+ func (rcb *RemoteConfigBuilder) Build() *RemoteConfig

+ func (rcb *RemoteConfigBuilder) SetAddress(address string) *RemoteConfigBuilder

+ func (rcb *RemoteConfigBuilder) SetParams(params map[string]string) *RemoteConfigBuilder

+ func (rcb *RemoteConfigBuilder) SetPassword(password string) *RemoteConfigBuilder

+ func (rcb *RemoteConfigBuilder) SetProtocol(protocol string) *RemoteConfigBuilder

+ func (rcb *RemoteConfigBuilder) SetTimeout(timeout string) *RemoteConfigBuilder

+ func (rcb *RemoteConfigBuilder) SetUsername(username string) *RemoteConfigBuilder

+ type RootConfig struct

+ Application *ApplicationConfig

+ CacheFile string

+ ConfigCenter *CenterConfig

+ Consumer *ConsumerConfig

+ Custom *CustomConfig

+ EventDispatcherType string

+ Logger *LoggerConfig

+ MetadataReport *MetadataReportConfig

+ Metric *MetricConfig

+ Protocols map[string]*ProtocolConfig

+ Provider *ProviderConfig

+ Registries map[string]*RegistryConfig

+ Router []*RouterConfig

+ Shutdown *ShutdownConfig

+ Tracing map[string]*TracingConfig

+ func GetRootConfig() *RootConfig

+ func (RootConfig) Prefix() string

+ func (rc *RootConfig) Init() error

+ func (rc *RootConfig) Process(event *config_center.ConfigChangeEvent)

+ func (rc *RootConfig) Start()

+ type RootConfigBuilder struct

+ func NewRootConfigBuilder() *RootConfigBuilder

+ func (rb *RootConfigBuilder) AddProtocol(protocolID string, protocolConfig *ProtocolConfig) *RootConfigBuilder

+ func (rb *RootConfigBuilder) AddRegistry(registryID string, registryConfig *RegistryConfig) *RootConfigBuilder

+ func (rb *RootConfigBuilder) Build() *RootConfig

+ func (rb *RootConfigBuilder) SetApplication(application *ApplicationConfig) *RootConfigBuilder

+ func (rb *RootConfigBuilder) SetCacheFile(cacheFile string) *RootConfigBuilder

+ func (rb *RootConfigBuilder) SetConfigCenter(configCenterConfig *CenterConfig) *RootConfigBuilder

+ func (rb *RootConfigBuilder) SetConsumer(consumer *ConsumerConfig) *RootConfigBuilder

+ func (rb *RootConfigBuilder) SetCustom(customConfig *CustomConfig) *RootConfigBuilder

+ func (rb *RootConfigBuilder) SetEventDispatcherType(eventDispatcherType string) *RootConfigBuilder

+ func (rb *RootConfigBuilder) SetLogger(logger *LoggerConfig) *RootConfigBuilder

+ func (rb *RootConfigBuilder) SetMetadataReport(metadataReport *MetadataReportConfig) *RootConfigBuilder

+ func (rb *RootConfigBuilder) SetMetric(metric *MetricConfig) *RootConfigBuilder

+ func (rb *RootConfigBuilder) SetProtocols(protocols map[string]*ProtocolConfig) *RootConfigBuilder

+ func (rb *RootConfigBuilder) SetProvider(provider *ProviderConfig) *RootConfigBuilder

+ func (rb *RootConfigBuilder) SetRegistries(registries map[string]*RegistryConfig) *RootConfigBuilder

+ func (rb *RootConfigBuilder) SetRouter(router []*RouterConfig) *RootConfigBuilder

+ func (rb *RootConfigBuilder) SetShutDown(shutDownConfig *ShutdownConfig) *RootConfigBuilder

+ func (rb *RootConfigBuilder) SetShutdown(shutdown *ShutdownConfig) *RootConfigBuilder

+ type RouterConfig struct

+ Conditions []string

+ Enable bool

+ Force bool

+ Key string

+ Priority int

+ Runtime bool

+ Scope string

+ Tags []Tag

+ Valid bool

+ func (RouterConfig) Prefix() string

+ func (c *RouterConfig) Init() error

+ type RouterConfigBuilder struct

+ func NewRouterConfigBuilder() *RouterConfigBuilder

+ func (rcb *RouterConfigBuilder) AddCondition(condition string) *RouterConfigBuilder

+ func (rcb *RouterConfigBuilder) AddTag(tag Tag) *RouterConfigBuilder

+ func (rcb *RouterConfigBuilder) Build() *RouterConfig

+ func (rcb *RouterConfigBuilder) SetConditions(conditions []string) *RouterConfigBuilder

+ func (rcb *RouterConfigBuilder) SetEnable(enable bool) *RouterConfigBuilder

+ func (rcb *RouterConfigBuilder) SetForce(force bool) *RouterConfigBuilder

+ func (rcb *RouterConfigBuilder) SetKey(key string) *RouterConfigBuilder

+ func (rcb *RouterConfigBuilder) SetPriority(priority int) *RouterConfigBuilder

+ func (rcb *RouterConfigBuilder) SetRuntime(runtime bool) *RouterConfigBuilder

+ func (rcb *RouterConfigBuilder) SetScope(scope string) *RouterConfigBuilder

+ func (rcb *RouterConfigBuilder) SetTags(tags []Tag) *RouterConfigBuilder

+ func (rcb *RouterConfigBuilder) SetValid(valid bool) *RouterConfigBuilder

+ type RouterDest struct

+ Fallback *DubboDestination

+ Host string

+ Subset string

+ Weight int

+ type ServiceConfig struct

+ AccessLog string

+ Auth string

+ Cluster string

+ ExecuteLimit string

+ ExecuteLimitRejectedHandler string

+ Filter string

+ Group string

+ GrpcMaxMessageSize int

+ Interface string

+ Loadbalance string

+ Methods []*MethodConfig

+ ParamSign string

+ Params map[string]string

+ ProtocolIDs []string

+ ProxyFactoryKey string

+ RCProtocolsMap map[string]*ProtocolConfig

+ RCRegistriesMap map[string]*RegistryConfig

+ RegistryIDs []string

+ Retries string

+ Serialization string

+ Tag string

+ Token string

+ TpsLimitInterval string

+ TpsLimitRate string

+ TpsLimitRejectedHandler string

+ TpsLimitStrategy string

+ TpsLimiter string

+ TracingKey string

+ Version string

+ Warmup string

+ func (s *ServiceConfig) Export() error

+ func (s *ServiceConfig) GetExportedUrls() []*common.URL

+ func (s *ServiceConfig) Implement(rpcService common.RPCService)

+ func (s *ServiceConfig) Init(rc *RootConfig) error

+ func (s *ServiceConfig) InitExported()

+ func (s *ServiceConfig) IsExport() bool

+ func (s *ServiceConfig) Prefix() string

+ func (s *ServiceConfig) Unexport()

+ type ServiceConfigBuilder struct

+ func NewServiceConfigBuilder() *ServiceConfigBuilder

+ func (pcb *ServiceConfigBuilder) AddRCProtocol(protocolName string, protocolConfig *ProtocolConfig) *ServiceConfigBuilder

+ func (pcb *ServiceConfigBuilder) AddRCRegistry(registryName string, registryConfig *RegistryConfig) *ServiceConfigBuilder

+ func (pcb *ServiceConfigBuilder) Build() *ServiceConfig

+ func (pcb *ServiceConfigBuilder) SetCluster(cluster string) *ServiceConfigBuilder

+ func (pcb *ServiceConfigBuilder) SetGroup(group string) *ServiceConfigBuilder

+ func (pcb *ServiceConfigBuilder) SetInterface(interfaceName string) *ServiceConfigBuilder

+ func (pcb *ServiceConfigBuilder) SetLoadBalancce(lb string) *ServiceConfigBuilder

+ func (pcb *ServiceConfigBuilder) SetMetadataType(setMetadataType string) *ServiceConfigBuilder

+ func (pcb *ServiceConfigBuilder) SetProtocolIDs(protocolIDs ...string) *ServiceConfigBuilder

+ func (pcb *ServiceConfigBuilder) SetProxyFactoryKey(proxyFactoryKey string) *ServiceConfigBuilder

+ func (pcb *ServiceConfigBuilder) SetRPCService(service common.RPCService) *ServiceConfigBuilder

+ func (pcb *ServiceConfigBuilder) SetRegistryIDs(registryIDs ...string) *ServiceConfigBuilder

+ func (pcb *ServiceConfigBuilder) SetSerialization(serialization string) *ServiceConfigBuilder

+ func (pcb *ServiceConfigBuilder) SetServiceID(id string) *ServiceConfigBuilder

+ func (pcb *ServiceConfigBuilder) SetVersion(version string) *ServiceConfigBuilder

+ func (pcb *ServiceConfigBuilder) SetWarmUpTie(warmUp string) *ServiceConfigBuilder

+ type ServiceDiscoveryConfig struct

+ Group string

+ Protocol string

+ RemoteRef string

+ func (ServiceDiscoveryConfig) Init() error

+ func (ServiceDiscoveryConfig) Prefix() string

+ type ServiceDiscoveryConfigBuilder struct

+ func NewServiceDiscoveryConfigBuilder() *ServiceDiscoveryConfigBuilder

+ func (sdcb *ServiceDiscoveryConfigBuilder) Build() *ServiceDiscoveryConfig

+ func (sdcb *ServiceDiscoveryConfigBuilder) SetGroup(group string) *ServiceDiscoveryConfigBuilder

+ func (sdcb *ServiceDiscoveryConfigBuilder) SetProtocol(protocol string) *ServiceDiscoveryConfigBuilder

+ func (sdcb *ServiceDiscoveryConfigBuilder) SetRemoteRef(remoteRef string) *ServiceDiscoveryConfigBuilder

+ type Setter interface

+ Set func(name string, config interface{})

+ type ShutdownConfig struct

+ ConsumerActiveCount atomic.Int32

+ ConsumerUpdateWaitTime string

+ InternalSignal bool

+ ProviderActiveCount atomic.Int32

+ RejectRequest atomic.Bool

+ RejectRequestHandler string

+ StepTimeout string

+ Timeout string

+ func GetShutDown() *ShutdownConfig

+ func (config *ShutdownConfig) GetConsumerUpdateWaitTime() time.Duration

+ func (config *ShutdownConfig) GetStepTimeout() time.Duration

+ func (config *ShutdownConfig) GetTimeout() time.Duration

+ func (config *ShutdownConfig) Init() error

+ func (config *ShutdownConfig) Prefix() string

+ type ShutdownConfigBuilder struct

+ func NewShutDownConfigBuilder() *ShutdownConfigBuilder

+ func (scb *ShutdownConfigBuilder) Build() *ShutdownConfig

+ func (scb *ShutdownConfigBuilder) SetInternalSignal(internalSignal bool) *ShutdownConfigBuilder

+ func (scb *ShutdownConfigBuilder) SetRejectRequest(rejectRequest bool) *ShutdownConfigBuilder

+ func (scb *ShutdownConfigBuilder) SetRejectRequestHandler(rejectRequestHandler string) *ShutdownConfigBuilder

+ func (scb *ShutdownConfigBuilder) SetStepTimeout(stepTimeout string) *ShutdownConfigBuilder

+ func (scb *ShutdownConfigBuilder) SetTimeout(timeout string) *ShutdownConfigBuilder

+ type StringMatch struct

+ Empty string

+ Exact string

+ NoEmpty string

+ Prefix string

+ Regex string

+ type Tag struct

+ Addresses []string

+ Name string

+ type TracingConfig struct

+ Address string

+ Name string

+ ServiceName string

+ UseAgent bool

+ func GetTracingConfig(tracingKey string) *TracingConfig

+ func (TracingConfig) Prefix() string

+ func (c *TracingConfig) Init() error

+ type UniformRouterConfigSpec struct

+ Dubbo []*DubboRoute

+ Hosts []string

+ type VirtualServiceConfig struct

+ MetaData MetaDataStruct

+ Spec UniformRouterConfigSpec

+ YamlAPIVersion string

+ YamlKind string

+ func (urc *VirtualServiceConfig) DeepCopyObject() runtime.Object

+ type VirtualServiceConfigList struct

+ Items []VirtualServiceConfig

+ func (drc *VirtualServiceConfigList) DeepCopyObject() runtime.Object

+ type ZapConfig struct

+ Development bool

+ DisableCaller bool

+ DisableStacktrace bool

+ EncoderConfig EncoderConfig

+ Encoding string

+ ErrorOutputPaths []string

+ InitialFields map[string]interface{}

+ Level string

+ OutputPaths []string

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