file

Documentation

Index

• Constants
• type Discovery
  • func (f *Discovery) AutoSync()
  • func (f *Discovery) Close() error
  • func (f *Discovery) FindMicroServiceInstances(consumerID, microServiceName string, tags utiltags.Tags) ([]*registry.MicroServiceInstance, error)
  • func (f *Discovery) GetAllApplications() ([]string, error)
  • func (f *Discovery) GetAllMicroServices() ([]*registry.MicroService, error)
  • func (f *Discovery) GetMicroService(microServiceID string) (*registry.MicroService, error)
  • func (f *Discovery) GetMicroServiceID(appID, microServiceName, version, env string) (string, error)
  • func (f *Discovery) GetMicroServiceInstances(consumerID, providerID string) ([]*registry.MicroServiceInstance, error)
  • func (f *Discovery) WatchMicroService(selfMicroServiceID string, ...)
• type Options
• type Registrator
  • func (f *Registrator) AddDependencies(request *registry.MicroServiceDependency) error
  • func (f *Registrator) AddSchemas(microServiceID, schemaName, schemaInfo string) error
  • func (f *Registrator) Close() error
  • func (f *Registrator) Heartbeat(microServiceID, microServiceInstanceID string) (bool, error)
  • func (f *Registrator) RegisterService(microservice *registry.MicroService) (string, error)
  • func (f *Registrator) RegisterServiceAndInstance(microService *registry.MicroService, instance *registry.MicroServiceInstance) (string, string, error)
  • func (f *Registrator) RegisterServiceInstance(sid string, instance *registry.MicroServiceInstance) (string, error)
  • func (f *Registrator) UnRegisterMicroServiceInstance(microServiceID, microServiceInstanceID string) error
  • func (f *Registrator) UpdateMicroServiceInstanceProperties(microServiceID, microServiceInstanceID string, properties map[string]string) error
  • func (f *Registrator) UpdateMicroServiceInstanceStatus(microServiceID, microServiceInstanceID, status string) error
  • func (f *Registrator) UpdateMicroServiceProperties(microServiceID string, properties map[string]string) error

Constants

const (
	Name = "file"
)

constant string for file

const (
	// ServiceJSON service json
	ServiceJSON = "service.json"
)

Types

type Discovery

type Discovery struct {
	Name string
	// contains filtered or unexported fields
}

Discovery struct represents file service

func (*Discovery) AutoSync

func (f *Discovery) AutoSync()

AutoSync auto sync

func (*Discovery) Close

func (f *Discovery) Close() error

Close close the file

func (*Discovery) FindMicroServiceInstances

func (f *Discovery) FindMicroServiceInstances(consumerID, microServiceName string, tags utiltags.Tags) ([]*registry.MicroServiceInstance, error)

FindMicroServiceInstances find micro-service instances

func (*Discovery) GetAllApplications

func (f *Discovery) GetAllApplications() ([]string, error)

GetAllApplications get all applications

func (*Discovery) GetAllMicroServices

func (f *Discovery) GetAllMicroServices() ([]*registry.MicroService, error)

GetAllMicroServices get all microservices

func (*Discovery) GetMicroService

func (f *Discovery) GetMicroService(microServiceID string) (*registry.MicroService, error)

GetMicroService get micro-service

func (*Discovery) GetMicroServiceID

func (f *Discovery) GetMicroServiceID(appID, microServiceName, version, env string) (string, error)

GetMicroServiceID get micro-service id

func (*Discovery) GetMicroServiceInstances

func (f *Discovery) GetMicroServiceInstances(consumerID, providerID string) ([]*registry.MicroServiceInstance, error)

GetMicroServiceInstances get micro-service instances

func (*Discovery) WatchMicroService

func (f *Discovery) WatchMicroService(selfMicroServiceID string, callback func(*model.MicroServiceInstanceChangedEvent))

WatchMicroService watch micro-service

type Options

type Options struct {
	Addrs []string
}

Options struct having addresses

type Registrator

type Registrator struct {
	Name string
	// contains filtered or unexported fields
}

Registrator struct represents file parameters

func (*Registrator) AddDependencies

func (f *Registrator) AddDependencies(request *registry.MicroServiceDependency) error

AddDependencies add dependencies

func (*Registrator) AddSchemas

func (f *Registrator) AddSchemas(microServiceID, schemaName, schemaInfo string) error

AddSchemas add schema

func (*Registrator) Close

func (f *Registrator) Close() error

Close close the file

func (*Registrator) Heartbeat

func (f *Registrator) Heartbeat(microServiceID, microServiceInstanceID string) (bool, error)

Heartbeat check heartbeat of micro-service instance

func (*Registrator) RegisterService

func (f *Registrator) RegisterService(microservice *registry.MicroService) (string, error)

RegisterService register service

func (*Registrator) RegisterServiceAndInstance

func (f *Registrator) RegisterServiceAndInstance(microService *registry.MicroService, instance *registry.MicroServiceInstance) (string, string, error)

RegisterServiceAndInstance register service and instance

func (*Registrator) RegisterServiceInstance

func (f *Registrator) RegisterServiceInstance(sid string, instance *registry.MicroServiceInstance) (string, error)

RegisterServiceInstance register service instance

func (*Registrator) UnRegisterMicroServiceInstance

func (f *Registrator) UnRegisterMicroServiceInstance(microServiceID, microServiceInstanceID string) error

UnRegisterMicroServiceInstance unregister micro-service instances

func (*Registrator) UpdateMicroServiceInstanceProperties

func (f *Registrator) UpdateMicroServiceInstanceProperties(microServiceID, microServiceInstanceID string, properties map[string]string) error

UpdateMicroServiceInstanceProperties update micro-service instance properities

func (*Registrator) UpdateMicroServiceInstanceStatus

func (f *Registrator) UpdateMicroServiceInstanceStatus(microServiceID, microServiceInstanceID, status string) error

UpdateMicroServiceInstanceStatus update micro-service instance status

func (*Registrator) UpdateMicroServiceProperties

func (f *Registrator) UpdateMicroServiceProperties(microServiceID string, properties map[string]string) error

UpdateMicroServiceProperties update micro-service properities