Versions in this module Expand all Collapse all v0 v0.7.1 Aug 16, 2018 v0.5.1 May 31, 2018 Changes in this version + const DefaultExpireTime + const DefaultRefreshInterval + const InstanceIDIsExist + const InstanceIDIsNotExist + const ServiceCenter + func ToMicroService(scs *model.MicroService) *registry.MicroService + func ToMicroServiceInstance(ins *model.MicroServiceInstance) *registry.MicroServiceInstance + func ToSCDependency(dep *registry.MicroServiceDependency) *model.MircroServiceDependencyRequest + func ToSCInstance(msi *registry.MicroServiceInstance) *model.MicroServiceInstance + func ToSCOptions(options registry.Options) client.Options + func ToSCService(cs *registry.MicroService) *model.MicroService + type CacheManager struct + func (c *CacheManager) AutoSync() + func (c *CacheManager) MakeIPIndex() error + func (c *CacheManager) MakeSchemaIndex() error + type ContractDiscovery struct + Name string + func (r *ContractDiscovery) Close() error + func (r *ContractDiscovery) GetMicroServicesByInterface(interfaceName string) (microService []*registry.MicroService) + func (r *ContractDiscovery) GetSchema(microServiceID, schemaName string) ([]byte, error) + func (r *ContractDiscovery) GetSchemaContentByInterface(interfaceName string) (schemas registry.SchemaContent) + func (r *ContractDiscovery) GetSchemaContentByServiceName(svcName, version, appID, env string) (schemas []*registry.SchemaContent) + type Registrator struct + Name string + func (r *Registrator) AddDependencies(cDep *registry.MicroServiceDependency) error + func (r *Registrator) AddSchemas(microServiceID, schemaName, schemaInfo string) error + func (r *Registrator) Close() error + func (r *Registrator) Heartbeat(microServiceID, microServiceInstanceID string) (bool, error) + func (r *Registrator) RegisterService(ms *registry.MicroService) (string, error) + func (r *Registrator) RegisterServiceAndInstance(cMicroService *registry.MicroService, cInstance *registry.MicroServiceInstance) (string, string, error) + func (r *Registrator) RegisterServiceInstance(sid string, cIns *registry.MicroServiceInstance) (string, error) + func (r *Registrator) UnRegisterMicroServiceInstance(microServiceID, microServiceInstanceID string) error + func (r *Registrator) UpdateMicroServiceInstanceProperties(microServiceID, microServiceInstanceID string, properties map[string]string) error + func (r *Registrator) UpdateMicroServiceInstanceStatus(microServiceID, microServiceInstanceID, status string) error + func (r *Registrator) UpdateMicroServiceProperties(microServiceID string, properties map[string]string) error + type ServiceDiscovery struct + Name string + func (r *ServiceDiscovery) AutoSync() + func (r *ServiceDiscovery) Close() error + func (r *ServiceDiscovery) FindMicroServiceInstances(consumerID, appID, microServiceName, version, env string) ([]*registry.MicroServiceInstance, error) + func (r *ServiceDiscovery) GetAllApplications() ([]string, error) + func (r *ServiceDiscovery) GetAllMicroServices() ([]*registry.MicroService, error) + func (r *ServiceDiscovery) GetDependentMicroServiceInstances(appID, consumerMicroServiceName, version, env string) ([]*model.MicroServiceInstance, error) + func (r *ServiceDiscovery) GetMicroService(microServiceID string) (*registry.MicroService, error) + func (r *ServiceDiscovery) GetMicroServiceID(appID, microServiceName, version, env string) (string, error) + func (r *ServiceDiscovery) GetMicroServiceInstances(consumerID, providerID string) ([]*registry.MicroServiceInstance, error) + func (r *ServiceDiscovery) WatchMicroService(selfMicroServiceID string, ...)
Go to main page