Versions in this module Expand all Collapse all v0 v0.1.2 Mar 24, 2019 Changes in this version type ServiceURL + Timeout time.Duration v0.1.1 Mar 9, 2019 Changes in this version + const CONFIGURATOR + const CONSUMER + const ConsumerRegistryZkClient + const DEFAULT_REGISTRY_TIMEOUT + const MAX_TIMES + const PROVIDER + const ProviderRegistryZkClient + const REGISTRY_CONN_DELAY + const ROUTER + const ServiceURLAdd + const ServiceURLDel + const ZKCLIENT_EVENT_CHANNEL_SIZE + const ZkEvent_Channel_Size + var DubboNodes = [...]string + var DubboRole = [...]string + var ErrServiceArrayEmpty = jerrors.New("serviceArray empty") + var ErrServiceArrayTimeout = jerrors.New("serviceArray timeout") + var ErrorRegistryNotFound = jerrors.New("registry not found") + var RegistryZkClient = "zk registry" + type ApplicationConfig struct + Environment string + Module string + Name string + Organization string + Owner string + Version string + func (c *ApplicationConfig) ToString() string + type DubboType int + func (t DubboType) Role() string + func (t DubboType) String() string + type Mode int + const SM_BEGIN + const SM_END + const SM_Random + const SM_RoundRobin + func (s Mode) String() string + type Option func(*Options) + func ApplicationConf(conf ApplicationConfig) Option + func BalanceMode(mode Mode) Option + func RegistryConf(conf RegistryConfig) Option + func ServiceTTL(ttl time.Duration) Option + type Options struct + type ProviderServiceConfig struct + Methods string + Path string + func (c ProviderServiceConfig) ServiceEqual(url *ServiceURL) bool + func (c ProviderServiceConfig) String() string + type Registry interface + Close func() + Register func(conf interface{}) error + type RegistryConfig struct + Address []string + Password string + Timeout time.Duration + TimeoutStr string + UserName string + type ServerConfig struct + IP string + Port int + Protocol string + func (c *ServerConfig) Address() string + type ServiceConfig struct + Group string + Protocol string + Service string + Version string + func (c ServiceConfig) Key() string + func (c ServiceConfig) ServiceEqual(url *ServiceURL) bool + func (c ServiceConfig) String() string + type ServiceConfigIf interface + ServiceEqual func(url *ServiceURL) bool + String func() string + type ServiceURL struct + Group string + Ip string + Location string + Path string + Port string + PrimitiveURL string + Protocol string + Query url.Values + Version string + Weight int32 + func NewServiceURL(urlString string) (*ServiceURL, error) + func (s *ServiceURL) CheckMethod(method string) bool + func (s *ServiceURL) ServiceConfig() ServiceConfig + func (s ServiceURL) String() string + type ServiceURLEvent struct + Action ServiceURLEventType + Service *ServiceURL + func (e ServiceURLEvent) String() string + type ServiceURLEventType int + func (t ServiceURLEventType) String() string + type ZkConsumerRegistry struct + func NewZkConsumerRegistry(opts ...Option) (*ZkConsumerRegistry, error) + func (r *ZkConsumerRegistry) Close() + func (r *ZkConsumerRegistry) Filter(s ServiceConfigIf, reqID int64) (*ServiceURL, error) + func (r *ZkConsumerRegistry) Register(conf ServiceConfig) error + type ZkProviderRegistry struct + func NewZkProviderRegistry(opts ...Option) (*ZkProviderRegistry, error) + func (r *ZkProviderRegistry) Close() + func (r *ZkProviderRegistry) Register(c interface{}) error
Go to main page