sync

Documentation

Index

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

Constants

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

Variables

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

Functions

func New

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

Creates a new bucketSynchronizer instancelistenerEventHandler

Types

type BucketSynchronizer

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

type GrpcNotifier

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

type TextileNotifier

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