sync

Documentation

Index

• Constants
• Variables
• type BucketSynchronizer
  • func New(folderWatcher watcher.FolderWatcher, textileClient textile.Client, ...) BucketSynchronizer
• type GrpcNotifier
• type TextileNotifier

Constants

const (
	OpenFilesKeyPrefix        = "openFiles#"
	ReverseOpenFilesKeyPrefix = "reverseOpenFiles#"
)

Variables

var (
	ErrAddFileWatch = errors.New("error adding file to watch")
)

Types

type BucketSynchronizer

type BucketSynchronizer interface {
	WaitForReady() chan bool
	Start(ctx context.Context) error
	Stop()
	RegisterNotifier(notifier GrpcNotifier)
	AddFileWatch(addFileInfo domain.AddWatchFile) error
	GetOpenFilePath(bucketSlug string, bucketPath string) (string, bool)
}

func New

func New(
	folderWatcher watcher.FolderWatcher,
	textileClient textile.Client,
	store store.Store,
	notifier GrpcNotifier,
) BucketSynchronizer

Creates a new bucketSynchronizer instancelistenerEventHandler

type GrpcNotifier

type GrpcNotifier interface {
	SendFileEvent(event events.FileEvent)
	SendTextileEvent(event events.TextileEvent)
}

type TextileNotifier

type TextileNotifier interface {
	SendTextileEvent(event events.TextileEvent)
}