directory

Documentation

Overview

Package directory implements registry around file system.

Index

• func NewRegistryDirectory(url *common.URL, registry registry.Registry) (directory.Directory, error)
• func NewServiceDiscoveryRegistryDirectory(url *common.URL, registry registry.Registry) (directory.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) Subscribe(url *common.URL) error
• type ServiceDiscoveryRegistryDirectory
  • func (dir *ServiceDiscoveryRegistryDirectory) List(invocation protocol.Invocation) []protocol.Invoker
  • func (dir *ServiceDiscoveryRegistryDirectory) Subscribe(url *common.URL) error

Functions

func NewRegistryDirectory

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

NewRegistryDirectory will create a new RegistryDirectory

func NewServiceDiscoveryRegistryDirectory

func NewServiceDiscoveryRegistryDirectory(url *common.URL, registry registry.Registry) (directory.Directory, error)

NewServiceDiscoveryRegistryDirectory will create a new ServiceDiscoveryRegistryDirectory

Types

type RegistryDirectory

type RegistryDirectory struct {
	*base.Directory

	SubscribedUrl *common.URL
	RegisteredUrl *common.URL
	// 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) Subscribe

func (dir *RegistryDirectory) Subscribe(url *common.URL) error

subscribe from registry

type ServiceDiscoveryRegistryDirectory

type ServiceDiscoveryRegistryDirectory struct {
	*base.Directory
	*RegistryDirectory
}

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

func (*ServiceDiscoveryRegistryDirectory) List

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

List selected protocol invokers from the directory

func (*ServiceDiscoveryRegistryDirectory) Subscribe

func (dir *ServiceDiscoveryRegistryDirectory) Subscribe(url *common.URL) error

Subscribe do subscribe from registry