directory

package

v1.5.0 Latest Latest Go to latest Published: Jul 23, 2020 License: Apache-2.0 Imports: 16 Imported by: 2

Details

This section is empty.

This section is empty.

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

NewRegistryDirectory will create a new 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 (dir *RegistryDirectory) Destroy()

Destroy method

func (dir *RegistryDirectory) IsAvailable() bool

IsAvailable whether the directory is available

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

List selected protocol invokers from the directory

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

Notify monitor changes from registry,and update the cacheServices