registry

package

Go to main page

Versions in this module

v0

v0.7.1

Aug 16, 2018

Changes in this version

+ func SetIPIndex(ip string, si *SourceInfo)

+ func SetNoIndexCache()

+ type CacheIndex interface

+ Delete func(k string)

+ Get func(k string, tags map[string]string) (interface{}, bool)

+ GetIndexTags func() []string

+ Items func() map[string]*cache.Cache

+ Set func(k string, x interface{})

+ SetIndexTags func(tags sets.String)

+ var MicroserviceInstanceIndex CacheIndex

+ type Index interface

+ Delete func(k string)

+ Get func(k string, tags map[string]string) (interface{}, bool)

+ GetTags func() []string

+ Items func() map[string]*cache.Cache

+ Set func(k string, x interface{})

+ SetTags func(tags sets.String)

type MicroServiceInstance

+ func (m *MicroServiceInstance) Has(tags map[string]string) bool

+ func (m *MicroServiceInstance) WithAppID(v string) *MicroServiceInstance

type Options

+ ConfigPath string

type SourceInfo

+ func GetIPIndex(ip string) *SourceInfo

v0.5.1

May 31, 2018

Changes in this version

+ const Auto

+ const CDTag

+ const DefaultContractDiscoveryPlugin

+ const DefaultExpireTime

+ const DefaultRegistratorPlugin

+ const DefaultRetryTime

+ const DefaultServiceDiscoveryPlugin

+ const Manual

+ const Name

+ const RTag

+ const SDTag

+ var DefaultAddr = "http://127.0.0.1:30100"

+ var HBService = &HeartbeatService

+ var IPIndexedCache *cache.Cache

+ var InstanceEndpoints map[string]string

+ var IsEnabled bool

+ var MicroserviceInstanceCache *cache.Cache

+ var SchemaInterfaceIndexedCache *cache.Cache

+ var SchemaServiceIndexedCache *cache.Cache

+ var SelfInstancesCache *cache.Cache

+ func DoRegister() error

+ func Enable() (err error)

+ func GetProtocolList(m map[string]string) []string

+ func GetProtocolMap(eps []string) (map[string]string, string)

+ func HealthCheck(serviceKey string, instance *MicroServiceInstance) error

+ func InstallContractDiscovery(name string, f func(opts Options) ContractDiscovery)

+ func InstallRegistrator(name string, f func(opts Options) Registrator)

+ func InstallServiceDiscovery(name string, f func(opts Options) ServiceDiscovery)

+ func MakeEndpointMap(m map[string]model.Protocol) map[string]string

+ func MakeEndpoints(m map[string]model.Protocol) []string

+ func Microservice2ServiceKeyStr(m *MicroService) string

+ func RefreshCache(store map[string][]*MicroServiceInstance)

+ func RegisterMicroservice() error

+ func RegisterMicroserviceInstances() error

+ func URIs2Hosts(uris []string) ([]string, string, error)

+ type ContractDiscovery interface

+ Close func() error

+ GetMicroServicesByInterface func(interfaceName string) (microservices []*MicroService)

+ GetSchemaContentByInterface func(interfaceName string) SchemaContent

+ GetSchemaContentByServiceName func(svcName, version, appID, env string) []*SchemaContent

+ var DefaultContractDiscoveryService ContractDiscovery

+ type DataCenterInfo struct

+ AvailableZone string

+ Name string

+ Region string

+ type Definition struct

+ Properties map[string]interface{}

+ Types string

+ XJavaClass string

+ type Framework struct

+ Name string

+ Version string

+ type HealthChecker struct

+ func (hc *HealthChecker) Add(i *WrapInstance) error

+ func (hc *HealthChecker) Run()

+ type HeartbeatService struct

+ func (s *HeartbeatService) AddTask(microServiceID, microServiceInstanceID string)

+ func (s *HeartbeatService) DoHeartBeat(microServiceID, microServiceInstanceID string)

+ func (s *HeartbeatService) ReRegisterSelfMSandMSI() error

+ func (s *HeartbeatService) RefreshTask(microServiceID, microServiceInstanceID string)

+ func (s *HeartbeatService) RemoveTask(microServiceID, microServiceInstanceID string)

+ func (s *HeartbeatService) RetryRegister(sid string) error

+ func (s *HeartbeatService) Start()

+ func (s *HeartbeatService) Stop()

+ type HeartbeatTask struct

+ InstanceID string

+ Running bool

+ ServiceID string

+ Time time.Time

+ type Item struct

+ Type string

+ XML map[string]interface{}

+ type MethodInfo struct

+ OperationID string

+ Parameters []Parameter

+ Response map[string]Response

+ type MicroService struct

+ AppID string

+ Environment string

+ Framework *Framework

+ Level string

+ Metadata map[string]string

+ RegisterBy string

+ Schemas []string

+ ServiceID string

+ ServiceName string

+ Status string

+ Version string

+ type MicroServiceDependency struct

+ Consumer *MicroService

+ Providers []*MicroService

+ type MicroServiceInstance struct

+ DataCenterInfo *DataCenterInfo

+ DefaultEndpoint string

+ DefaultProtocol string

+ EndpointsMap map[string]string

+ HostName string

+ InstanceID string

+ Metadata map[string]string

+ ServiceID string

+ Status string

+ type Options struct

+ Addrs []string

+ Compressed bool

+ EnableSSL bool

+ TLSConfig *tls.Config

+ Tenant string

+ Timeout time.Duration

+ Verbose bool

+ Version string

+ type Parameter struct

+ ColFormat string

+ Format string

+ In string

+ Items Item

+ Name string

+ Required bool

+ Schema SchemaValue

+ Type string

+ type Registrator interface

+ AddDependencies func(dep *MicroServiceDependency) error

+ AddSchemas func(microServiceID, schemaName, schemaInfo string) error

+ Close func() error

+ Heartbeat func(microServiceID, microServiceInstanceID string) (bool, error)

+ RegisterService func(microService *MicroService) (string, error)

+ RegisterServiceAndInstance func(microService *MicroService, instance *MicroServiceInstance) (string, string, error)

+ RegisterServiceInstance func(sid string, instance *MicroServiceInstance) (string, error)

+ UnRegisterMicroServiceInstance func(microServiceID, microServiceInstanceID string) error

+ UpdateMicroServiceInstanceProperties func(microServiceID, microServiceInstanceID string, properties map[string]string) error

+ UpdateMicroServiceInstanceStatus func(microServiceID, microServiceInstanceID, status string) error

+ UpdateMicroServiceProperties func(microServiceID string, properties map[string]string) error

+ var DefaultRegistrator Registrator

+ type Response struct

+ Description string

+ Schema map[string]string

+ type Schema struct

+ Schema string

+ type SchemaContent struct

+ BasePath string

+ Definition map[string]Definition

+ Info map[string]string

+ Paths map[string]map[string]MethodInfo

+ Produces []string

+ Swagger string

+ type SchemaContents struct

+ Schemas []*SchemaContent

+ type SchemaValue struct

+ AdditionalProperties map[string]string

+ Default string

+ Description string

+ Enum []interface{}

+ ExclusiveMaximum int

+ ExclusiveMinimum int

+ Format string

+ Items Item

+ MaxItems int

+ MaxLength int

+ MaxProperties int

+ MinItems int

+ MinLength int

+ MinProperties int

+ Minimum int

+ MultipleOf int

+ Pattern int

+ Properties map[string]interface{}

+ Reference string

+ Required bool

+ Title string

+ Type string

+ UniqueItems bool

+ type ServiceDiscovery interface

+ AutoSync func()

+ Close func() error

+ FindMicroServiceInstances func(consumerID, appID, microServiceName, version, env string) ([]*MicroServiceInstance, error)

+ GetAllMicroServices func() ([]*MicroService, error)

+ GetMicroService func(microServiceID string) (*MicroService, error)

+ GetMicroServiceID func(appID, microServiceName, version, env string) (string, error)

+ GetMicroServiceInstances func(consumerID, providerID string) ([]*MicroServiceInstance, error)

+ var DefaultServiceDiscoveryService ServiceDiscovery

+ type SourceInfo struct

+ Name string

+ Tags map[string]string

+ type WrapInstance struct

+ AppID string

+ Instance *MicroServiceInstance

+ ServiceName string

+ Version string

+ func (i *WrapInstance) ServiceKey() string

+ func (i *WrapInstance) String() string

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