config

package

Go to main page

Versions in this module

v3

v3.2.0-rc2

Jul 19, 2024

v3.2.0-rc1

Mar 10, 2024

v3.1.1

Feb 20, 2024

Changes in this version

+ type AggregateConfig struct

+ BucketNum int

+ Enabled *bool

+ TimeWindowSeconds int

type ApplicationConfig

+ MetadataServicePort string

+ type Exporter struct

+ Enabled *bool

type MetricConfig

+ Aggregation *AggregateConfig

+ EnableConfigCenter *bool

+ EnableMetadata *bool

+ EnableRegistry *bool

+ Prometheus *PrometheusConfig

+ Protocol string

type MetricConfigBuilder

+ func (mcb *MetricConfigBuilder) SetConfigCenterEnabled(enabled bool) *MetricConfigBuilder

+ func (mcb *MetricConfigBuilder) SetMetadataEnabled(enabled bool) *MetricConfigBuilder

+ func (mcb *MetricConfigBuilder) SetRegistryEnabled(enabled bool) *MetricConfigBuilder

+ 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 PrometheusConfig struct

+ Exporter *Exporter

+ Pushgateway *PushgatewayConfig

+ type PushgatewayConfig struct

+ BaseUrl string

+ Enabled *bool

+ Job string

+ Password string

+ PushInterval int

+ Username string

type RootConfig

+ Otel *OtelConfig

type RootConfigBuilder

+ func (rb *RootConfigBuilder) SetOtel(otel *OtelConfig) *RootConfigBuilder

type Tag

+ Match []*common.ParamMatch

v3.1.1-rc1

Dec 2, 2023

v3.1.0

Jul 17, 2023

Changes in this version

type ApplicationConfig

+ Tag string

type ConsumerConfig

+ MeshEnabled bool

type ConsumerConfigBuilder

+ func (ccb *ConsumerConfigBuilder) SetMeshEnabled(meshEnabled bool) *ConsumerConfigBuilder

+ type File struct

+ Compress *bool

+ MaxAge int

+ MaxBackups int

+ MaxSize int

+ Name string

type LoggerConfig

+ Appender string

+ Driver string

+ File *File

+ Format string

+ Level string

type LoggerConfigBuilder

+ 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 ProtocolConfig

+ MaxServerRecvMsgSize string

+ MaxServerSendMsgSize string

type ProtocolConfigBuilder

+ func (pcb *ProtocolConfigBuilder) SetMaxServerRecvMsgSize(maxServerRecvMsgSize string) *ProtocolConfigBuilder

+ func (pcb *ProtocolConfigBuilder) SetMaxServerSendMsgSize(maxServerSendMsgSize string) *ProtocolConfigBuilder

type ReferenceConfig

+ MeshProviderPort int

type RegistryConfig

+ UseAsConfigCenter bool

+ UseAsMetaReport bool

type RootConfigBuilder

+ func (rb *RootConfigBuilder) SetTLSConfig(tlsConfig *TLSConfig) *RootConfigBuilder

type TLSConfig

+ 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

v3.1.0-rc1

Jul 17, 2023

v3.0.5

Feb 2, 2023

Changes in this version

type LoggerConfig

+ func (lc *LoggerConfig) DynamicUpdateProperties(newLoggerConfig *LoggerConfig)

type MetricConfig

+ func (mc *MetricConfig) DynamicUpdateProperties(newMetricConfig *MetricConfig)

v3.0.5-rc1

Feb 2, 2023

v3.0.4

Dec 2, 2022

Changes in this version

+ func GetClientTlsConfig(opt *TLSConfig) (*tls.Config, error)

+ func GetServerTlsConfig(opt *TLSConfig) (*tls.Config, error)

type ReferenceConfigBuilder

+ func (pcb *ReferenceConfigBuilder) AddMethodConfig(methodConfig *MethodConfig) *ReferenceConfigBuilder

+ func (pcb *ReferenceConfigBuilder) SetAsync(async bool) *ReferenceConfigBuilder

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

+ func (pcb *ReferenceConfigBuilder) SetForceTag(forceTag bool) *ReferenceConfigBuilder

+ func (pcb *ReferenceConfigBuilder) SetGroup(group 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) SetProvidedBy(providedBy string) *ReferenceConfigBuilder

+ func (pcb *ReferenceConfigBuilder) SetRequestTimeout(requestTimeout string) *ReferenceConfigBuilder

+ func (pcb *ReferenceConfigBuilder) SetRetries(retries string) *ReferenceConfigBuilder

+ func (pcb *ReferenceConfigBuilder) SetSticky(sticky bool) *ReferenceConfigBuilder

+ func (pcb *ReferenceConfigBuilder) SetTracingKey(tracingKey string) *ReferenceConfigBuilder

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

type RootConfig

+ TLSConfig *TLSConfig

type ShutdownConfig

+ OfflineRequestWindowTimeout string

+ ProviderLastReceivedRequestTime atomic.Time

+ func (config *ShutdownConfig) GetInternalSignal() bool

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

type ShutdownConfigBuilder

+ func (scb *ShutdownConfigBuilder) SetOfflineRequestWindowTimeout(offlineRequestWindowTimeout string) *ShutdownConfigBuilder

+ type TLSConfig struct

+ CACertFile string

+ TLSCertFile string

+ TLSKeyFile string

+ TLSServerName string

v3.0.4-rc1

Dec 2, 2022

v3.0.3-rc2

Oct 6, 2022

v3.0.3-rc1

Sep 30, 2022

v3.0.2

Jun 5, 2022

Changes in this version

+ func GetConsumerServiceMap() map[string]common.RPCService

+ func GetProviderServiceMap() map[string]common.RPCService

type ApplicationConfig

+ Group string

type ConsumerConfig

+ Protocol string

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

type MetricConfig

+ SummaryMaxAge int64

+ type ProfilesConfig struct

+ Active string

+ func (ProfilesConfig) Prefix() string

type ProviderConfig

+ ProtocolIDs []string

type ReferenceConfigBuilder

+ func (pcb *ReferenceConfigBuilder) SetURL(url string) *ReferenceConfigBuilder

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

type ServiceConfig

+ NotRegister bool

type ServiceConfigBuilder

+ func (pcb *ServiceConfigBuilder) SetNotRegister(notRegister bool) *ServiceConfigBuilder

v3.0.1

Feb 17, 2022

Changes in this version

type ProviderConfig

+ AdaptiveService bool

type RegistryConfig

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

type RootConfig

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

type RootConfigBuilder

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

type ShutdownConfig

+ ConsumerActiveCount atomic.Int32

+ ConsumerUpdateWaitTime string

+ InternalSignal bool

+ ProviderActiveCount atomic.Int32

+ func GetShutDown() *ShutdownConfig

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

+ func (config *ShutdownConfig) Init() error

type ShutdownConfigBuilder

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

v3.0.0

Dec 7, 2021

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 GracefulShutdownInit()

+ 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 (mc *MethodConfig) Init() error

+ func (mc *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

+ 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

+ 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) 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(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 (svc *ServiceConfig) Export() error

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

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

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

+ func (svc *ServiceConfig) InitExported()

+ func (svc *ServiceConfig) IsExport() bool

+ func (svc *ServiceConfig) Prefix() string

+ func (svc *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

+ RejectRequest bool

+ RejectRequestHandler string

+ RequestsFinished bool

+ StepTimeout string

+ Timeout string

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

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

+ func (config *ShutdownConfig) Prefix() string

+ type ShutdownConfigBuilder struct

+ func NewShutDownConfigBuilder() *ShutdownConfigBuilder

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

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

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

+ func (scb *ShutdownConfigBuilder) SetRequestsFinished(requestsFinished bool) *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

v3.0.0-rc4-1

Nov 12, 2021

v3.0.0-rc4

Nov 10, 2021

v3.0.0-rc3

Oct 30, 2021

v3.0.0-rc2

Jun 20, 2021

v3.0.0-rc1

May 15, 2021

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