sync

Documentation

Index

• Constants
• func New(st store.Store, model model.Model, kc keychain.Keychain, hubAuth hub.HubAuth, ...) *synchronizer
• type EventNotifier
• type GetBucketCtxFn
• type GetBucketFn
• type GetMirrorBucketFn
• type Synchronizer
• type Task

Constants

const QueueStoreKey = "TextileSyncTaskQueue"

Functions

func New

func New(
	st store.Store,
	model model.Model,
	kc keychain.Keychain,
	hubAuth hub.HubAuth,
	hb *bucketsClient.Client,
	ht *threadsClient.Client,
	netc *nc.Client,
	cfg config.Config,
	getMirrorBucket GetMirrorBucketFn,
	getBucket GetBucketFn,
	getBucketCtx GetBucketCtxFn,
) *synchronizer

Creates a new Synchronizer

Types

type EventNotifier

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

type GetBucketCtxFn

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

type GetBucketFn

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

type GetMirrorBucketFn

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

type Synchronizer

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

type Task

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"`
}