common

Documentation

Index

• func Filter(target *nspAPI.Target, targets []*nspAPI.Target) []*nspAPI.Target
• type RegistryWatcher
  • func NewRegistryWatcher(target *nspAPI.Target) *RegistryWatcher
  • func (rw *RegistryWatcher) IsStopped() bool
  • func (rw *RegistryWatcher) Notify(targets []*nspAPI.Target)
  • func (rw *RegistryWatcher) ResultChan() <-chan []*nspAPI.Target
  • func (rw *RegistryWatcher) Stop()

Functions

func Filter

func Filter(target *nspAPI.Target, targets []*nspAPI.Target) []*nspAPI.Target

Types

type RegistryWatcher

type RegistryWatcher struct {
	// contains filtered or unexported fields
}

func NewRegistryWatcher

func NewRegistryWatcher(target *nspAPI.Target) *RegistryWatcher

func (*RegistryWatcher) IsStopped

func (rw *RegistryWatcher) IsStopped() bool

func (*RegistryWatcher) Notify

func (rw *RegistryWatcher) Notify(targets []*nspAPI.Target)

func (*RegistryWatcher) ResultChan

func (rw *RegistryWatcher) ResultChan() <-chan []*nspAPI.Target

func (*RegistryWatcher) Stop

func (rw *RegistryWatcher) Stop()