Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventContentChangeFilter ¶
type EventContentChangeFilter struct {
// contains filtered or unexported fields
}
func NewEventContentChangeFilter ¶
func NewEventContentChangeFilter(newHash func() hash.Hash) *EventContentChangeFilter
func (*EventContentChangeFilter) FilterContentChanges ¶
func (e *EventContentChangeFilter) FilterContentChanges(incomingEvents chan *Event) chan *Event
func (*EventContentChangeFilter) SetDigest ¶
func (e *EventContentChangeFilter) SetDigest(path string, digest tapjio.FileDigest)
type SubscribeConfirmEvent ¶
type SubscribeRequestEvent ¶
type Subscription ¶
type Subscription struct {
Events chan *Event
// contains filtered or unexported fields
}
func (*Subscription) Close ¶
func (s *Subscription) Close() error
func (*Subscription) Update ¶
func (s *Subscription) Update(expr interface{}) error
type Watcher ¶
type Watcher interface {
Subscribe(root string, name string, expr interface{}) (*Subscription, error)
Close() error
}
func StartWatchman ¶
type WatchmanConn ¶
type WatchmanConn struct {
EventInbox chan *Event
SubscribeConfirmInbox chan *SubscribeConfirmEvent
SubscribeRequestOutbox chan *SubscribeRequestEvent
Closer io.Closer
}
type WatchmanService ¶
type WatchmanService struct {
// contains filtered or unexported fields
}
func (*WatchmanService) Close ¶
func (w *WatchmanService) Close() error
func (*WatchmanService) Connect ¶
func (w *WatchmanService) Connect() (*WatchmanConn, error)
func (*WatchmanService) Subscribe ¶
func (w *WatchmanService) Subscribe(root string, name string, expr interface{}) (*Subscription, error)
Click to show internal directories.
Click to hide internal directories.