fs

Documentation

Index

• type FSClient
  • func CreateFSClient(coloniesClient *client.ColoniesClient, colonyID string, executorPrvKey string) (*FSClient, error)
  • func (fsClient *FSClient) ApplySyncPlan(colonyID string, syncPlan *SyncPlan) error
  • func (fsClient *FSClient) CalcSyncPlan(dir string, label string, keepLocal bool) (*SyncPlan, error)
  • func (fsClient *FSClient) Download(colonyID string, fileID string, downloadDir string) error
  • func (fsClient *FSClient) DownloadSnapshot(snapshotID string, downloadDir string) error
  • func (fsClient *FSClient) RemoveAllFilesWithLabel(label string) error
  • func (fsClient *FSClient) RemoveFileByID(colonyID string, fileID string) error
  • func (fsClient *FSClient) RemoveFileByName(colonyID string, label string, name string) error
• type FileInfo
• type S3Client
  • func CreateS3Client() (*S3Client, error)
  • func (s3Client *S3Client) Download(filename string, s3Filename string, downloadDir string) error
  • func (s3Client *S3Client) Exists(filename string) bool
  • func (s3Client *S3Client) Remove(filename string) error
  • func (s3Client *S3Client) Upload(dir string, filename string, s3Filename string, filelength int64) error
• type SyncPlan

Types

type FSClient

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

func CreateFSClient

func CreateFSClient(coloniesClient *client.ColoniesClient, colonyID string, executorPrvKey string) (*FSClient, error)

func (*FSClient) ApplySyncPlan

func (fsClient *FSClient) ApplySyncPlan(colonyID string, syncPlan *SyncPlan) error

func (*FSClient) CalcSyncPlan

func (fsClient *FSClient) CalcSyncPlan(dir string, label string, keepLocal bool) (*SyncPlan, error)

func (*FSClient) Download

func (fsClient *FSClient) Download(colonyID string, fileID string, downloadDir string) error

func (*FSClient) DownloadSnapshot

func (fsClient *FSClient) DownloadSnapshot(snapshotID string, downloadDir string) error

func (*FSClient) RemoveAllFilesWithLabel

func (fsClient *FSClient) RemoveAllFilesWithLabel(label string) error

func (*FSClient) RemoveFileByID

func (fsClient *FSClient) RemoveFileByID(colonyID string, fileID string) error

func (*FSClient) RemoveFileByName

func (fsClient *FSClient) RemoveFileByName(colonyID string, label string, name string) error

type FileInfo

type FileInfo struct {
	Name       string
	Checksum   string
	Size       int64
	S3Filename string
}

type S3Client

type S3Client struct {
	BucketName string
	Endpoint   string
	AccessKey  string
	SecretKey  string
	Region     string
	TLS        bool
	// contains filtered or unexported fields
}

func CreateS3Client

func CreateS3Client() (*S3Client, error)

func (*S3Client) Download

func (s3Client *S3Client) Download(filename string, s3Filename string, downloadDir string) error

func (*S3Client) Exists

func (s3Client *S3Client) Exists(filename string) bool

func (*S3Client) Remove

func (s3Client *S3Client) Remove(filename string) error

func (*S3Client) Upload

func (s3Client *S3Client) Upload(dir string, filename string, s3Filename string, filelength int64) error

type SyncPlan

type SyncPlan struct {
	Dir           string
	LocalMissing  []*FileInfo
	RemoteMissing []*FileInfo
	Conflicts     []*FileInfo
	KeepLocal     bool
	Label         string
}