registry

Documentation

Index

• func Filter(stream *ambassadorAPI.Stream, streams []*ambassadorAPI.StreamStatus) []*ambassadorAPI.StreamStatus
• type Registry
  • func New() *Registry
  • func (r *Registry) Remove(stream *ambassadorAPI.Stream)
  • func (r *Registry) SetStatus(stream *ambassadorAPI.Stream, status ambassadorAPI.StreamStatus_Status)
  • func (r *Registry) Watch(ctx context.Context, stream *ambassadorAPI.Stream) (types.Watcher, error)
• type RegistryWatcher
  • func NewRegistryWatcher(stream *ambassadorAPI.Stream) *RegistryWatcher
  • func (rw *RegistryWatcher) IsStopped() bool
  • func (rw *RegistryWatcher) Notify(streams []*ambassadorAPI.StreamStatus)
  • func (rw *RegistryWatcher) ResultChan() <-chan []*ambassadorAPI.StreamStatus
  • func (rw *RegistryWatcher) Stop()

Functions

func Filter

func Filter(stream *ambassadorAPI.Stream, streams []*ambassadorAPI.StreamStatus) []*ambassadorAPI.StreamStatus

Types

type Registry

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

func New

func New() *Registry

func (*Registry) Remove

func (r *Registry) Remove(stream *ambassadorAPI.Stream)

func (*Registry) SetStatus

func (r *Registry) SetStatus(stream *ambassadorAPI.Stream, status ambassadorAPI.StreamStatus_Status)

func (*Registry) Watch

func (r *Registry) Watch(ctx context.Context, stream *ambassadorAPI.Stream) (types.Watcher, error)

type RegistryWatcher

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

func NewRegistryWatcher

func NewRegistryWatcher(stream *ambassadorAPI.Stream) *RegistryWatcher

func (*RegistryWatcher) IsStopped

func (rw *RegistryWatcher) IsStopped() bool

func (*RegistryWatcher) Notify

func (rw *RegistryWatcher) Notify(streams []*ambassadorAPI.StreamStatus)

func (*RegistryWatcher) ResultChan

func (rw *RegistryWatcher) ResultChan() <-chan []*ambassadorAPI.StreamStatus

func (*RegistryWatcher) Stop

func (rw *RegistryWatcher) Stop()