file

Documentation

Index

• Constants
• type Sync
  • func NewFileSync(uri string, watchType string, logger *logger.Logger) *Sync
  • func (fs *Sync) Init(ctx context.Context) error
  • func (fs *Sync) IsReady() bool
  • func (fs *Sync) ReSync(ctx context.Context, dataSync chan<- sync.DataSync) error
  • func (fs *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error
• type Watcher
  • func NewFSNotifyWatcher() (Watcher, error)
  • func NewFileInfoWatcher(ctx context.Context, logger *logger.Logger) Watcher

Constants

const (
	FSNOTIFY = "fsnotify"
	FILEINFO = "fileinfo"
)

Types

type Sync

type Sync struct {
	URI    string
	Logger *logger.Logger

	Mux *msync.RWMutex
	// contains filtered or unexported fields
}

func NewFileSync

func NewFileSync(uri string, watchType string, logger *logger.Logger) *Sync

func (*Sync) Init

func (fs *Sync) Init(ctx context.Context) error

func (*Sync) IsReady

func (fs *Sync) IsReady() bool

func (*Sync) ReSync

func (fs *Sync) ReSync(ctx context.Context, dataSync chan<- sync.DataSync) error

func (*Sync) Sync

func (fs *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error

type Watcher

type Watcher interface {
	Close() error
	Add(name string) error
	Remove(name string) error
	WatchList() []string
	Events() chan fsnotify.Event
	Errors() chan error
}

func NewFSNotifyWatcher

func NewFSNotifyWatcher() (Watcher, error)

NewFsNotifyWatcher returns a new fsNotifyWatcher

func NewFileInfoWatcher

func NewFileInfoWatcher(ctx context.Context, logger *logger.Logger) Watcher

NewFsNotifyWatcher returns a new fsNotifyWatcher