watch

type AssociatedEventStream ¶

type AssociatedEventStream chan update.AssociatedUpdate

type GenericWatchStorage ¶

type GenericWatchStorage struct {
	storage.Storage
	// contains filtered or unexported fields
}

GenericWatchStorage implements the WatchStorage interface

func (s *GenericWatchStorage) Close() error

func (s *GenericWatchStorage) Delete(gvk schema.GroupVersionKind, uid runtime.UID) error

func (s *GenericWatchStorage) Patch(gvk schema.GroupVersionKind, uid runtime.UID, patch []byte) error

func (s *GenericWatchStorage) Set(gvk schema.GroupVersionKind, obj runtime.Object) error

func (s *GenericWatchStorage) SetEventStream(eventStream AssociatedEventStream)

type WatchStorage ¶

type WatchStorage interface {
	// WatchStorage extends the Storage interface
	storage.Storage
	// GetTrigger returns a hook that can be used to detect a watch event
	SetEventStream(AssociatedEventStream)
}

WatchStorage is an extended Storage implementation, which provides a watcher for watching changes in the directory managed by the embedded Storage's RawStorage. If the RawStorage is a MappedRawStorage instance, it's mappings will automatically be updated by the WatchStorage. Update events are sent to the given event stream.

func NewGenericWatchStorage(s storage.Storage) (WatchStorage, error)