sync

Documentation

Index

• type BucketSynchronizer
  • func New(folderWatcher watcher.FolderWatcher, textileClient tc.Client, ...) *BucketSynchronizer
  • func (bs *BucketSynchronizer) Start(ctx context.Context) error
  • func (bs *BucketSynchronizer) Stop()
• type GrpcNotifier

Types

type BucketSynchronizer

type BucketSynchronizer struct {
	// contains filtered or unexported fields
}

func New

func New(
	folderWatcher watcher.FolderWatcher,
	textileClient tc.Client,
	notifier GrpcNotifier,
) *BucketSynchronizer

Creates a new BucketSynchronizer instancelistenerEventHandler

func (*BucketSynchronizer) Start

func (bs *BucketSynchronizer) Start(ctx context.Context) error

Starts the folder watcher and the textile watcher.

func (*BucketSynchronizer) Stop

func (bs *BucketSynchronizer) Stop()

type GrpcNotifier

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