watcher

Documentation

Index

• type Event
• type EventType
• type IWatcher
• type Watcher
  • func NewStreamWatcher(reqder io.ReadCloser) *Watcher
  • func (w *Watcher) ResultChan() <-chan Event
  • func (w *Watcher) Stop()

Types

type Event

type Event struct {
	Type EventType
	Data interface{}
}

type EventType

type EventType string

EventType defines the possible types of events.

const (
	Added    EventType = "ADDED"
	Modified EventType = "MODIFIED"
	Deleted  EventType = "DELETED"
	Error    EventType = "ERROR"
)

type IWatcher

type IWatcher interface {
	Stop()
	ResultChan() <-chan Event
}

type Watcher

type Watcher struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewStreamWatcher

func NewStreamWatcher(reqder io.ReadCloser) *Watcher

func (*Watcher) ResultChan

func (w *Watcher) ResultChan() <-chan Event

func (*Watcher) Stop

func (w *Watcher) Stop()