updates

Documentation

Index

• type FileWatcher
  • func (w *FileWatcher) Context() context.Context
• type Notifier
  • func NewNotifier(wsURL string, handshakeTimeout, writeTimeout time.Duration) *Notifier
  • func (s *Notifier) Close()
  • func (s *Notifier) Connected() bool
  • func (s *Notifier) SetToken(token string)
  • func (s *Notifier) Start()
  • func (s *Notifier) WatchFile(ctx context.Context, id int64) *FileWatcher

Types

type FileWatcher

type FileWatcher struct {
	Stop func() bool
	// contains filtered or unexported fields
}

func (*FileWatcher) Context

func (w *FileWatcher) Context() context.Context

type Notifier

type Notifier struct {
	HasUpdates chan string
	// contains filtered or unexported fields
}

func NewNotifier

func NewNotifier(wsURL string, handshakeTimeout, writeTimeout time.Duration) *Notifier

func (*Notifier) Close

func (s *Notifier) Close()

func (*Notifier) Connected

func (s *Notifier) Connected() bool

func (*Notifier) SetToken

func (s *Notifier) SetToken(token string)

func (*Notifier) Start

func (s *Notifier) Start()

func (*Notifier) WatchFile

func (s *Notifier) WatchFile(ctx context.Context, id int64) *FileWatcher