Versions in this module Expand all Collapse all v1 v1.0.0 Dec 28, 2024 Changes in this version + const MaxWheelTimeSpan + var DumpHeapShutdownSignals = []os.Signal — darwin/amd64, linux/amd64, windows/amd64 + var NewInfoInvoker func(url *common.URL, info interface{}, svc common.RPCService) protocol.Invoker + var ShutdownSignals = []os.Signal — darwin/amd64, linux/amd64, windows/amd64 + func BeforeShutdown() + func GetCallback(name string) func(response common.CallbackResponse) + func GetClientTlsConfig(opt *TLSConfig) (*tls.Config, error) + func GetClientTlsConfigBuilder() getty.TlsConfigBuilder + func GetConfigResolver(conf *loaderConf) *koanf.Koanf + func GetConsumerService(name string) common.RPCService + func GetConsumerServiceByInterfaceName(interfaceName string) common.RPCService + func GetConsumerServiceMap() map[string]common.RPCService + func GetDefineValue(key string, default_value interface{}) interface + func GetProtocolsInstance() map[string]*ProtocolConfig + func GetProviderService(name string) common.RPCService + func GetProviderServiceInfo(name string) interface + func GetProviderServiceMap() map[string]common.RPCService + func GetRPCService(name string) common.RPCService + func GetServerTlsConfig(opt *TLSConfig) (*tls.Config, error) + func GetServerTlsConfigBuilder() getty.TlsConfigBuilder + func IsProvider() bool + func Load(opts ...LoaderConfOption) error + func LoadRegistries(registryIds []string, registries map[string]*RegistryConfig, ...) []*common.URL + func NewLoaderConf(opts ...LoaderConfOption) *loaderConf + func RPCService(service common.RPCService) + func SetClientInfoService(info interface{}, 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 SetProviderServiceWithInfo(service common.RPCService, info interface{}) + func SetRootConfig(r RootConfig) + func SetServerTlsConfigBuilder(configBuilder getty.TlsConfigBuilder) + type AggregateConfig struct + BucketNum int + Enabled *bool + TimeWindowSeconds int + type ApplicationConfig struct + Environment string + Group string + MetadataServicePort string + MetadataType string + Module string + Name string + Organization string + Owner string + Tag string + Version string + func GetApplicationConfig() *ApplicationConfig + func (ac *ApplicationConfig) Init() error + func (ac *ApplicationConfig) Prefix() string + 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 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 ConditionRouter struct + Conditions []ConditionRule + Enabled bool + Force bool + Key string + Runtime bool + Scope string + type ConditionRule struct + Disable bool + Force bool + From ConditionRuleFrom + Priority int + Ratio int + To []ConditionRuleTo + type ConditionRuleFrom struct + Match string + type ConditionRuleTo struct + Match string + Weight int + 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 + MeshEnabled bool + Protocol string + ProxyFactory string + References map[string]*ReferenceConfig + RegistryIDs []string + RequestTimeout string + TracingKey string + func GetConsumerConfig() *ConsumerConfig + func (ConsumerConfig) Prefix() string + func (cc *ConsumerConfig) DynamicUpdateProperties(newConsumerConfig *ConsumerConfig) + 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) SetMeshEnabled(meshEnabled bool) *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 Exporter struct + Enabled *bool + type File struct + Compress *bool + MaxAge int + MaxBackups int + MaxSize int + Name string + 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 + Appender string + Driver string + File *File + Format string + Level string + func (l *LoggerConfig) DynamicUpdateProperties(new *LoggerConfig) + func (l *LoggerConfig) Init() error + func (l *LoggerConfig) Prefix() string + type LoggerConfigBuilder struct + func NewLoggerConfigBuilder() *LoggerConfigBuilder + func (lcb *LoggerConfigBuilder) Build() *LoggerConfig + func (lcb *LoggerConfigBuilder) SetAppender(appender string) *LoggerConfigBuilder + func (lcb *LoggerConfigBuilder) SetDriver(driver string) *LoggerConfigBuilder + func (lcb *LoggerConfigBuilder) SetFileCompress(compress bool) *LoggerConfigBuilder + func (lcb *LoggerConfigBuilder) SetFileMaxAge(maxAge int) *LoggerConfigBuilder + func (lcb *LoggerConfigBuilder) SetFileMaxBackups(maxBackups int) *LoggerConfigBuilder + func (lcb *LoggerConfigBuilder) SetFileMaxSize(maxSize int) *LoggerConfigBuilder + func (lcb *LoggerConfigBuilder) SetFileName(name string) *LoggerConfigBuilder + func (lcb *LoggerConfigBuilder) SetFormat(format string) *LoggerConfigBuilder + func (lcb *LoggerConfigBuilder) SetLevel(level string) *LoggerConfigBuilder + type MetadataReportConfig struct + Address string + Group string + Namespace string + Params map[string]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 MethodOption func(*MethodOptions) + func WithExecuteLimit(limit int) MethodOption + func WithExecuteLimitRejectedHandler(handler string) MethodOption + func WithInterfaceId(id string) MethodOption + func WithInterfaceName(name string) MethodOption + func WithLoadBalance(lb string) MethodOption + func WithName(name string) MethodOption + func WithRequestTimeout(millSeconds time.Duration) MethodOption + func WithRetries(retries int) MethodOption + func WithSticky() MethodOption + func WithTpsLimitInterval(interval int) MethodOption + func WithTpsLimitRate(rate int) MethodOption + func WithTpsLimitStrategy(strategy string) MethodOption + func WithWeight(weight int64) MethodOption + type MethodOptions struct + Method *global.MethodConfig + func NewMethodOptions(opts ...MethodOption) *MethodOptions + type MetricConfigBuilder struct + func NewMetricConfigBuilder() *MetricConfigBuilder + func (mcb *MetricConfigBuilder) Build() *MetricsConfig + func (mcb *MetricConfigBuilder) SetConfigCenterEnabled(enabled bool) *MetricConfigBuilder + func (mcb *MetricConfigBuilder) SetMetadataEnabled(enabled bool) *MetricConfigBuilder + func (mcb *MetricConfigBuilder) SetRegistryEnabled(enabled bool) *MetricConfigBuilder + type MetricsConfig struct + Aggregation *AggregateConfig + Enable *bool + EnableConfigCenter *bool + EnableMetadata *bool + EnableRegistry *bool + Path string + Port string + Prometheus *PrometheusConfig + Protocol string + func GetMetricConfig() *MetricsConfig + func (mc *MetricsConfig) DynamicUpdateProperties(newMetricConfig *MetricsConfig) + func (mc *MetricsConfig) Init(rc *RootConfig) error + func (mc *MetricsConfig) ToReporterConfig() *metrics.ReporterConfig + 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 OtelConfig struct + TraceConfig *OtelTraceConfig + func (oc *OtelConfig) Init(appConfig *ApplicationConfig) error + type OtelConfigBuilder struct + func NewOtelConfigBuilder() *OtelConfigBuilder + func (ocb *OtelConfigBuilder) Build() *OtelConfig + type OtelTraceConfig struct + Enable *bool + Endpoint string + Exporter string + Propagator string + SampleMode string + SampleRatio float64 + type ProfilesConfig struct + Active string + func (ProfilesConfig) Prefix() string + type PrometheusConfig struct + Exporter *Exporter + Pushgateway *PushgatewayConfig + type ProtocolConfig struct + Ip string + MaxServerRecvMsgSize string + MaxServerSendMsgSize 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) SetMaxServerRecvMsgSize(maxServerRecvMsgSize string) *ProtocolConfigBuilder + func (pcb *ProtocolConfigBuilder) SetMaxServerSendMsgSize(maxServerSendMsgSize 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{} + ProtocolIDs []string + 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 PushgatewayConfig struct + BaseUrl string + Enabled *bool + Job string + Password string + PushInterval int + Username string + type ReferenceConfig struct + Async bool + Check *bool + Cluster string + Filter string + ForceTag bool + Generic string + Group string + InterfaceName string + Loadbalance string + MeshProviderPort int + 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) AddMethodConfig(methodConfig *MethodConfig) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) Build() *ReferenceConfig + func (pcb *ReferenceConfigBuilder) SetAsync(async bool) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetCluster(cluster string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetFilter(filter string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetForceTag(forceTag bool) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetGeneric(generic bool) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetGroup(group string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetInterface(interfaceName string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetLoadbalance(loadbalance string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetMethodConfig(methodConfigs []*MethodConfig) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetParams(params map[string]string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetProtocol(protocol string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetProvidedBy(providedBy string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetRegistryIDs(registryIDs ...string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetRequestTimeout(requestTimeout string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetRetries(retries string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetSerialization(serialization string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetSticky(sticky bool) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetTracingKey(tracingKey string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetURL(url string) *ReferenceConfigBuilder + func (pcb *ReferenceConfigBuilder) SetVersion(version 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 + UseAsConfigCenter string + UseAsMetaReport string + Username string + Weight int64 + Zone string + func NewRegistryConfig(opts ...RegistryConfigOpt) *RegistryConfig + func NewRegistryConfigWithProtocolDefaultPort(protocol string) *RegistryConfig + func (RegistryConfig) Prefix() string + func (c *RegistryConfig) DynamicUpdateProperties(updateRegistryConfig *RegistryConfig) + func (c *RegistryConfig) GetInstance(roleType common.RoleType) (registry.Registry, error) + func (c *RegistryConfig) Init() error + type RegistryConfigBuilder struct + func NewRegistryConfigBuilder() *RegistryConfigBuilder + func (rcb *RegistryConfigBuilder) AddParam(key, value string) *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 + Metrics *MetricsConfig + Otel *OtelConfig + Profiles *ProfilesConfig + Protocols map[string]*ProtocolConfig + Provider *ProviderConfig + Registries map[string]*RegistryConfig + Router []*RouterConfig + Shutdown *ShutdownConfig + TLSConfig *TLSConfig + Tracing map[string]*TracingConfig + func GetRootConfig() *RootConfig + func (rc *RootConfig) Init() error + func (rc *RootConfig) Prefix() string + 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 *MetricsConfig) *RootConfigBuilder + func (rb *RootConfigBuilder) SetOtel(otel *OtelConfig) *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 + func (rb *RootConfigBuilder) SetTLSConfig(tlsConfig *TLSConfig) *RootConfigBuilder + type RouterConfig struct + Conditions []string + Enabled *bool + Force *bool + Key string + Priority int + Runtime *bool + Scope string + Script string + ScriptType 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) SetEnabled(enabled 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 ServiceConfig struct + AccessLog string + Auth string + Cluster string + ExecuteLimit string + ExecuteLimitRejectedHandler string + Filter string + Group string + Interface string + Loadbalance string + Methods []*MethodConfig + NotRegister bool + 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) SetNotRegister(notRegister bool) *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 + OfflineRequestWindowTimeout string + ProviderActiveCount atomic.Int32 + ProviderLastReceivedRequestTime atomic.Time + RejectRequest atomic.Bool + RejectRequestHandler string + StepTimeout string + Timeout string + func GetShutDown() *ShutdownConfig + func (config *ShutdownConfig) GetConsumerUpdateWaitTime() time.Duration + func (config *ShutdownConfig) GetInternalSignal() bool + func (config *ShutdownConfig) GetOfflineRequestWindowTimeout() 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) SetOfflineRequestWindowTimeout(offlineRequestWindowTimeout string) *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 TLSConfig struct + CACertFile string + TLSCertFile string + TLSKeyFile string + TLSServerName string + func GetTLSConfig() *TLSConfig + func (t *TLSConfig) Prefix() string + type TLSConfigBuilder struct + func NewTLSConfigBuilder() *TLSConfigBuilder + func (tcb *TLSConfigBuilder) Build() *TLSConfig + func (tcb *TLSConfigBuilder) SetCACertFile(caCertFile string) *TLSConfigBuilder + func (tcb *TLSConfigBuilder) SetTLSCertFile(tlsCertFile string) *TLSConfigBuilder + func (tcb *TLSConfigBuilder) SetTLSKeyFile(tlsKeyFile string) *TLSConfigBuilder + func (tcb *TLSConfigBuilder) SetTLSServerName(tlsServerName string) *TLSConfigBuilder + type Tag struct + Addresses []string + Match []*common.ParamMatch + 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
Go to main page