directory

Documentation

Index

• func NewRegistryDirectory(url *common.URL, registry registry.Registry) (cluster.Directory, error)
• type RegistryDirectory
  • func (dir *RegistryDirectory) Destroy()
  • func (dir *RegistryDirectory) IsAvailable() bool
  • func (dir *RegistryDirectory) List(invocation protocol.Invocation) []protocol.Invoker
  • func (dir *RegistryDirectory) Notify(event *registry.ServiceEvent)
  • func (dir *RegistryDirectory) NotifyAll(events []*registry.ServiceEvent, callback func())
  • func (dir *RegistryDirectory) ServiceHealthState() *protocol.ServiceHealthState

Functions

func NewRegistryDirectory

func NewRegistryDirectory(url *common.URL, registry registry.Registry) (cluster.Directory, error)

NewRegistryDirectory will create a new RegistryDirectory

Types

type RegistryDirectory

type RegistryDirectory struct {
	directory.BaseDirectory
	// contains filtered or unexported fields
}

RegistryDirectory implementation of Directory: Invoker list returned from this Directory's list method have been filtered by Routers

func (*RegistryDirectory) Destroy

func (dir *RegistryDirectory) Destroy()

Destroy method

func (*RegistryDirectory) IsAvailable

func (dir *RegistryDirectory) IsAvailable() bool

IsAvailable whether the directory is available

func (*RegistryDirectory) List

func (dir *RegistryDirectory) List(invocation protocol.Invocation) []protocol.Invoker

List selected protocol invokers from the directory

func (*RegistryDirectory) Notify

func (dir *RegistryDirectory) Notify(event *registry.ServiceEvent)

Notify monitor changes from registry,and update the cacheServices

func (*RegistryDirectory) NotifyAll

func (dir *RegistryDirectory) NotifyAll(events []*registry.ServiceEvent, callback func())

NotifyAll notify the events that are complete Service Event List. After notify the address, the callback func will be invoked.

func (*RegistryDirectory) ServiceHealthState

func (dir *RegistryDirectory) ServiceHealthState() *protocol.ServiceHealthState

Fetch ServiceHealthState