sync

type AddBucketListenerFn func(ctx context.Context, bucketSlug string) error

type EventNotifier interface {
	SendFileEvent(event events.FileEvent)
}

type GetBucketCtxFn func(ctx context.Context, sDbID string, bucketSlug string, ishub bool, enckey []byte) (context.Context, *thread.ID, error)

type GetBucketFn func(ctx context.Context, slug string) (bucket.BucketInterface, error)

type GetMirrorBucketFn func(ctx context.Context, slug string) (bucket.BucketInterface, error)

type Synchronizer interface {
	NotifyItemAdded(bucket, path string)
	NotifyItemRemoved(bucket, path string)
	NotifyBucketCreated(bucket string, enckey []byte)
	NotifyBucketBackupOn(bucket string)
	NotifyBucketBackupOff(bucket string)
	NotifyBucketRestore(bucket string)
	NotifyFileRestore(bucket, path string)
	NotifyBucketStartup(bucket string)
	NotifyIndexItemAdded(bucket, path, dbId string)
	Start(ctx context.Context)
	RestoreQueue() error
	Shutdown()
	String() string
	AttachNotifier(EventNotifier)
}

type Task struct {
	ID             string    `json:"id"`
	State          taskState `json:"state"`
	Type           taskType  `json:"type"`
	Args           []string  `json:"args"`
	Parallelizable bool      `json:"parallelizable"`

	// Set to -1 for infinite retries
	MaxRetries int `json:"maxRetries"`
	Retries    int `json:"retries"`
}