Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 (*Registry) Remove ¶
func (r *Registry) Remove(stream *ambassadorAPI.Stream)
func (*Registry) SetStatus ¶
func (r *Registry) SetStatus(stream *ambassadorAPI.Stream, status ambassadorAPI.StreamStatus_Status)
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()
Click to show internal directories.
Click to hide internal directories.