task

package
v2.0.0-beta.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 7, 2019 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

Code generated by go generate; DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewCopyDirTask 

func NewCopyDirTask(task navvy.Task) navvy.Task

NewCopyDirTask will create a CopyDirTask which meets navvy.Task.

func NewCopyFileTask 

func NewCopyFileTask(task navvy.Task) navvy.Task

NewCopyFileTask will create a CopyFileTask which meets navvy.Task.

func NewCopyLargeFileTask 

func NewCopyLargeFileTask(task navvy.Task) navvy.Task

NewCopyLargeFileTask will create a CopyLargeFileTask which meets navvy.Task.

func NewCopyPartialFileTask 

func NewCopyPartialFileTask(task navvy.Task) navvy.Task

NewCopyPartialFileTask will create a CopyPartialFileTask which meets navvy.Task.

func NewCopyPartialStreamTask 

func NewCopyPartialStreamTask(task navvy.Task) navvy.Task

NewCopyPartialStreamTask will create a CopyPartialStreamTask which meets navvy.Task.

func NewCopySingleFileTask 

func NewCopySingleFileTask(task navvy.Task) navvy.Task

NewCopySingleFileTask will create a CopySingleFileTask which meets navvy.Task.

func NewCopySmallFileTask 

func NewCopySmallFileTask(task navvy.Task) navvy.Task

NewCopySmallFileTask will create a CopySmallFileTask which meets navvy.Task.

func NewCopyStreamTask 

func NewCopyStreamTask(task navvy.Task) navvy.Task

NewCopyStreamTask will create a CopyStreamTask which meets navvy.Task.

func NewCreateStorageTask 

func NewCreateStorageTask(task navvy.Task) navvy.Task

NewCreateStorageTask will create a CreateStorageTask which meets navvy.Task.

func NewDeleteDirTask 

func NewDeleteDirTask(task navvy.Task) navvy.Task

NewDeleteDirTask will create a DeleteDirTask which meets navvy.Task.

func NewDeleteFileTask 

func NewDeleteFileTask(task navvy.Task) navvy.Task

NewDeleteFileTask will create a DeleteFileTask which meets navvy.Task.

func NewDeleteSegmentDirTask 

func NewDeleteSegmentDirTask(task navvy.Task) navvy.Task

NewDeleteSegmentDirTask will create a DeleteSegmentDirTask which meets navvy.Task.

func NewDeleteSegmentTask 

func NewDeleteSegmentTask(task navvy.Task) navvy.Task

NewDeleteSegmentTask will create a DeleteSegmentTask which meets navvy.Task.

func NewDeleteStorageTask 

func NewDeleteStorageTask(task navvy.Task) navvy.Task

NewDeleteStorageTask will create a DeleteStorageTask which meets navvy.Task.

func NewIterateFileTask 

func NewIterateFileTask(task navvy.Task) navvy.Task

NewIterateFileTask will create a IterateFileTask which meets navvy.Task.

func NewIterateSegmentTask 

func NewIterateSegmentTask(task navvy.Task) navvy.Task

NewIterateSegmentTask will create a IterateSegmentTask which meets navvy.Task.

func NewListFileTask 

func NewListFileTask(task navvy.Task) navvy.Task

NewListFileTask will create a ListFileTask which meets navvy.Task.

func NewListSegmentTask 

func NewListSegmentTask(task navvy.Task) navvy.Task

NewListSegmentTask will create a ListSegmentTask which meets navvy.Task.

func NewListStorageTask 

func NewListStorageTask(task navvy.Task) navvy.Task

NewListStorageTask will create a ListStorageTask which meets navvy.Task.

func NewMD5SumFileTask 

func NewMD5SumFileTask(task navvy.Task) navvy.Task

NewMD5SumFileTask will create a MD5SumFileTask which meets navvy.Task.

func NewMD5SumStreamTask 

func NewMD5SumStreamTask(task navvy.Task) navvy.Task

NewMD5SumStreamTask will create a MD5SumStreamTask which meets navvy.Task.

func NewReachFileTask 

func NewReachFileTask(task navvy.Task) navvy.Task

NewReachFileTask will create a ReachFileTask which meets navvy.Task.

func NewSegmentAbortAllTask 

func NewSegmentAbortAllTask(task navvy.Task) navvy.Task

NewSegmentAbortAllTask will create a SegmentAbortAllTask which meets navvy.Task.

func NewSegmentCompleteTask 

func NewSegmentCompleteTask(task navvy.Task) navvy.Task

NewSegmentCompleteTask will create a SegmentCompleteTask which meets navvy.Task.

func NewSegmentFileCopyTask 

func NewSegmentFileCopyTask(task navvy.Task) navvy.Task

NewSegmentFileCopyTask will create a SegmentFileCopyTask which meets navvy.Task.

func NewSegmentInitTask 

func NewSegmentInitTask(task navvy.Task) navvy.Task

NewSegmentInitTask will create a SegmentInitTask which meets navvy.Task.

func NewSegmentStreamCopyTask 

func NewSegmentStreamCopyTask(task navvy.Task) navvy.Task

NewSegmentStreamCopyTask will create a SegmentStreamCopyTask which meets navvy.Task.

func NewStatFileTask 

func NewStatFileTask(task navvy.Task) navvy.Task

NewStatFileTask will create a StatFileTask which meets navvy.Task.

func NewSyncTask 

func NewSyncTask(task navvy.Task) navvy.Task

NewSyncTask will create a SyncTask which meets navvy.Task.

Types

type CopyDirTask 

type CopyDirTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.DestinationPath
	types.DestinationStorage
	types.SourcePath
	types.SourceStorage
}

CopyDirTask will copy a directory recursively between two storager.

func NewCopyDir 

func NewCopyDir(task navvy.Task) *CopyDirTask

NewCopyDir will create a CopyDirTask struct and fetch inherited data from parent task.

func (*CopyDirTask) Run 

func (t *CopyDirTask) Run()

Run implement navvy.Task

func (*CopyDirTask) String 

func (t *CopyDirTask) String() string

String will implement Stringer interface.

func (*CopyDirTask) TriggerFault 

func (t *CopyDirTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*CopyDirTask) VoidWorkload 

func (t *CopyDirTask) VoidWorkload()

type CopyFileTask 

type CopyFileTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.DestinationPath
	types.DestinationStorage
	types.SourcePath
	types.SourceStorage
}

CopyFileTask will copy a file between two storager.

func NewCopyFile 

func NewCopyFile(task navvy.Task) *CopyFileTask

NewCopyFile will create a CopyFileTask struct and fetch inherited data from parent task.

func (*CopyFileTask) Run 

func (t *CopyFileTask) Run()

Run implement navvy.Task

func (*CopyFileTask) String 

func (t *CopyFileTask) String() string

String will implement Stringer interface.

func (*CopyFileTask) TriggerFault 

func (t *CopyFileTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*CopyFileTask) VoidWorkload 

func (t *CopyFileTask) VoidWorkload()

type CopyLargeFileTask 

type CopyLargeFileTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.DestinationPath
	types.DestinationStorage
	types.SourcePath
	types.SourceStorage
	types.TotalSize

	// Output value
	types.Offset
	types.PartSize
	types.SegmentID
}

CopyLargeFileTask will copy a large file between two storager.

func NewCopyLargeFile 

func NewCopyLargeFile(task navvy.Task) *CopyLargeFileTask

NewCopyLargeFile will create a CopyLargeFileTask struct and fetch inherited data from parent task.

func (*CopyLargeFileTask) Run 

func (t *CopyLargeFileTask) Run()

Run implement navvy.Task

func (*CopyLargeFileTask) String 

func (t *CopyLargeFileTask) String() string

String will implement Stringer interface.

func (*CopyLargeFileTask) TriggerFault 

func (t *CopyLargeFileTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*CopyLargeFileTask) VoidWorkload 

func (t *CopyLargeFileTask) VoidWorkload()

type CopyPartialFileTask 

type CopyPartialFileTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.DestinationPath
	types.DestinationStorage
	types.Offset
	types.PartSize
	types.SegmentID
	types.SourcePath
	types.SourceStorage
	types.TotalSize

	// Output value
	types.Done
	types.Size
}

CopyPartialFileTask will copy a partial file to between two storager.

func NewCopyPartialFile 

func NewCopyPartialFile(task navvy.Task) *CopyPartialFileTask

NewCopyPartialFile will create a CopyPartialFileTask struct and fetch inherited data from parent task.

func (*CopyPartialFileTask) Run 

func (t *CopyPartialFileTask) Run()

Run implement navvy.Task

func (*CopyPartialFileTask) String 

func (t *CopyPartialFileTask) String() string

String will implement Stringer interface.

func (*CopyPartialFileTask) TriggerFault 

func (t *CopyPartialFileTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*CopyPartialFileTask) VoidWorkload 

func (t *CopyPartialFileTask) VoidWorkload()

type CopyPartialStreamTask 

type CopyPartialStreamTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.BytesPool
	types.DestinationPath
	types.DestinationStorage
	types.PartSize
	types.SegmentID
	types.SourcePath
	types.SourceStorage

	// Output value
	types.Content
	types.Done
	types.Size
}

CopyPartialStreamTask will copy a partial stream between two storager.

func NewCopyPartialStream 

func NewCopyPartialStream(task navvy.Task) *CopyPartialStreamTask

NewCopyPartialStream will create a CopyPartialStreamTask struct and fetch inherited data from parent task.

func (*CopyPartialStreamTask) Run 

func (t *CopyPartialStreamTask) Run()

Run implement navvy.Task

func (*CopyPartialStreamTask) String 

func (t *CopyPartialStreamTask) String() string

String will implement Stringer interface.

func (*CopyPartialStreamTask) TriggerFault 

func (t *CopyPartialStreamTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*CopyPartialStreamTask) VoidWorkload 

func (t *CopyPartialStreamTask) VoidWorkload()

type CopySingleFileTask 

type CopySingleFileTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.DestinationPath
	types.DestinationStorage
	types.MD5Sum
	types.Size
	types.SourcePath
	types.SourceStorage
}

CopySingleFileTask will execute a file copy operation between towo storager.

func NewCopySingleFile 

func NewCopySingleFile(task navvy.Task) *CopySingleFileTask

NewCopySingleFile will create a CopySingleFileTask struct and fetch inherited data from parent task.

func (*CopySingleFileTask) Run 

func (t *CopySingleFileTask) Run()

Run implement navvy.Task

func (*CopySingleFileTask) String 

func (t *CopySingleFileTask) String() string

String will implement Stringer interface.

func (*CopySingleFileTask) TriggerFault 

func (t *CopySingleFileTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*CopySingleFileTask) VoidWorkload 

func (t *CopySingleFileTask) VoidWorkload()

type CopySmallFileTask 

type CopySmallFileTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.DestinationPath
	types.DestinationStorage
	types.Size
	types.SourcePath
	types.SourceStorage

	// Output value
	types.MD5Sum
}

CopySmallFileTask will copy a small file between two storager.

func NewCopySmallFile 

func NewCopySmallFile(task navvy.Task) *CopySmallFileTask

NewCopySmallFile will create a CopySmallFileTask struct and fetch inherited data from parent task.

func (*CopySmallFileTask) Run 

func (t *CopySmallFileTask) Run()

Run implement navvy.Task

func (*CopySmallFileTask) String 

func (t *CopySmallFileTask) String() string

String will implement Stringer interface.

func (*CopySmallFileTask) TriggerFault 

func (t *CopySmallFileTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*CopySmallFileTask) VoidWorkload 

func (t *CopySmallFileTask) VoidWorkload()

type CopyStreamTask 

type CopyStreamTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.DestinationPath
	types.DestinationStorage
	types.SourcePath
	types.SourceStorage

	// Output value
	types.BytesPool
	types.PartSize
	types.SegmentID
}

CopyStreamTask will copy a stream between two storager.

func NewCopyStream 

func NewCopyStream(task navvy.Task) *CopyStreamTask

NewCopyStream will create a CopyStreamTask struct and fetch inherited data from parent task.

func (*CopyStreamTask) Run 

func (t *CopyStreamTask) Run()

Run implement navvy.Task

func (*CopyStreamTask) String 

func (t *CopyStreamTask) String() string

String will implement Stringer interface.

func (*CopyStreamTask) TriggerFault 

func (t *CopyStreamTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*CopyStreamTask) VoidWorkload 

func (t *CopyStreamTask) VoidWorkload()

type CreateStorageTask 

type CreateStorageTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Service

	// Output value
	types.StorageName
	types.Zone
}

CreateStorageTask will create a storage.

func NewCreateStorage 

func NewCreateStorage(task navvy.Task) *CreateStorageTask

NewCreateStorage will create a CreateStorageTask struct and fetch inherited data from parent task.

func (*CreateStorageTask) IOWorkload 

func (t *CreateStorageTask) IOWorkload()

func (*CreateStorageTask) Run 

func (t *CreateStorageTask) Run()

Run implement navvy.Task

func (*CreateStorageTask) String 

func (t *CreateStorageTask) String() string

String will implement Stringer interface.

func (*CreateStorageTask) TriggerFault 

func (t *CreateStorageTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

type DeleteDirTask 

type DeleteDirTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Path
	types.Storage
}

DeleteDirTask will will delete a dir recursively.

func NewDeleteDir 

func NewDeleteDir(task navvy.Task) *DeleteDirTask

NewDeleteDir will create a DeleteDirTask struct and fetch inherited data from parent task.

func (*DeleteDirTask) Run 

func (t *DeleteDirTask) Run()

Run implement navvy.Task

func (*DeleteDirTask) String 

func (t *DeleteDirTask) String() string

String will implement Stringer interface.

func (*DeleteDirTask) TriggerFault 

func (t *DeleteDirTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*DeleteDirTask) VoidWorkload 

func (t *DeleteDirTask) VoidWorkload()

type DeleteFileTask 

type DeleteFileTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Path
	types.Storage
}

DeleteFileTask will will delete a file from storage.

func NewDeleteFile 

func NewDeleteFile(task navvy.Task) *DeleteFileTask

NewDeleteFile will create a DeleteFileTask struct and fetch inherited data from parent task.

func (*DeleteFileTask) IOWorkload 

func (t *DeleteFileTask) IOWorkload()

func (*DeleteFileTask) Run 

func (t *DeleteFileTask) Run()

Run implement navvy.Task

func (*DeleteFileTask) String 

func (t *DeleteFileTask) String() string

String will implement Stringer interface.

func (*DeleteFileTask) TriggerFault 

func (t *DeleteFileTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

type DeleteSegmentDirTask 

type DeleteSegmentDirTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Path
	types.Storage
}

DeleteSegmentDirTask will delete all segments under a path.

func NewDeleteSegmentDir 

func NewDeleteSegmentDir(task navvy.Task) *DeleteSegmentDirTask

NewDeleteSegmentDir will create a DeleteSegmentDirTask struct and fetch inherited data from parent task.

func (*DeleteSegmentDirTask) Run 

func (t *DeleteSegmentDirTask) Run()

Run implement navvy.Task

func (*DeleteSegmentDirTask) String 

func (t *DeleteSegmentDirTask) String() string

String will implement Stringer interface.

func (*DeleteSegmentDirTask) TriggerFault 

func (t *DeleteSegmentDirTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*DeleteSegmentDirTask) VoidWorkload 

func (t *DeleteSegmentDirTask) VoidWorkload()

type DeleteSegmentTask 

type DeleteSegmentTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.SegmentID
	types.Storage
}

DeleteSegmentTask will delete all segments with a given path.

func NewDeleteSegment 

func NewDeleteSegment(task navvy.Task) *DeleteSegmentTask

NewDeleteSegment will create a DeleteSegmentTask struct and fetch inherited data from parent task.

func (*DeleteSegmentTask) IOWorkload 

func (t *DeleteSegmentTask) IOWorkload()

func (*DeleteSegmentTask) Run 

func (t *DeleteSegmentTask) Run()

Run implement navvy.Task

func (*DeleteSegmentTask) String 

func (t *DeleteSegmentTask) String() string

String will implement Stringer interface.

func (*DeleteSegmentTask) TriggerFault 

func (t *DeleteSegmentTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

type DeleteStorageTask 

type DeleteStorageTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Force
	types.Service
	types.StorageName
}

DeleteStorageTask will delete a storage.

func NewDeleteStorage 

func NewDeleteStorage(task navvy.Task) *DeleteStorageTask

NewDeleteStorage will create a DeleteStorageTask struct and fetch inherited data from parent task.

func (*DeleteStorageTask) IOWorkload 

func (t *DeleteStorageTask) IOWorkload()

func (*DeleteStorageTask) Run 

func (t *DeleteStorageTask) Run()

Run implement navvy.Task

func (*DeleteStorageTask) String 

func (t *DeleteStorageTask) String() string

String will implement Stringer interface.

func (*DeleteStorageTask) TriggerFault 

func (t *DeleteStorageTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

type IterateFileTask 

type IterateFileTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Path
	types.PathFunc
	types.Recursive
	types.Storage
}

IterateFileTask will iterate file and execute operations on it.

func NewIterateFile 

func NewIterateFile(task navvy.Task) *IterateFileTask

NewIterateFile will create a IterateFileTask struct and fetch inherited data from parent task.

func (*IterateFileTask) Run 

func (t *IterateFileTask) Run()

Run implement navvy.Task

func (*IterateFileTask) String 

func (t *IterateFileTask) String() string

String will implement Stringer interface.

func (*IterateFileTask) TriggerFault 

func (t *IterateFileTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*IterateFileTask) VoidWorkload 

func (t *IterateFileTask) VoidWorkload()

type IterateSegmentTask 

type IterateSegmentTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Path
	types.SegmentIDFunc
	types.Storage
}

IterateSegmentTask will iterate segment and execute operations on it.

func NewIterateSegment 

func NewIterateSegment(task navvy.Task) *IterateSegmentTask

NewIterateSegment will create a IterateSegmentTask struct and fetch inherited data from parent task.

func (*IterateSegmentTask) Run 

func (t *IterateSegmentTask) Run()

Run implement navvy.Task

func (*IterateSegmentTask) String 

func (t *IterateSegmentTask) String() string

String will implement Stringer interface.

func (*IterateSegmentTask) TriggerFault 

func (t *IterateSegmentTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*IterateSegmentTask) VoidWorkload 

func (t *IterateSegmentTask) VoidWorkload()

type ListFileTask 

type ListFileTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Path
	types.Recursive
	types.Storage

	// Output value
	types.ObjectChannel
}

ListFileTask will list files.

func NewListFile 

func NewListFile(task navvy.Task) *ListFileTask

NewListFile will create a ListFileTask struct and fetch inherited data from parent task.

func (*ListFileTask) Run 

func (t *ListFileTask) Run()

Run implement navvy.Task

func (*ListFileTask) String 

func (t *ListFileTask) String() string

String will implement Stringer interface.

func (*ListFileTask) TriggerFault 

func (t *ListFileTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*ListFileTask) VoidWorkload 

func (t *ListFileTask) VoidWorkload()

type ListSegmentTask 

type ListSegmentTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Path
	types.Storage

	// Output value
	types.SegmentChannel
}

ListSegmentTask will list segments.

func NewListSegment 

func NewListSegment(task navvy.Task) *ListSegmentTask

NewListSegment will create a ListSegmentTask struct and fetch inherited data from parent task.

func (*ListSegmentTask) Run 

func (t *ListSegmentTask) Run()

Run implement navvy.Task

func (*ListSegmentTask) String 

func (t *ListSegmentTask) String() string

String will implement Stringer interface.

func (*ListSegmentTask) TriggerFault 

func (t *ListSegmentTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*ListSegmentTask) VoidWorkload 

func (t *ListSegmentTask) VoidWorkload()

type ListStorageTask 

type ListStorageTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Service

	// Output value
	types.BucketList
	types.Zone
}

ListStorageTask will send get request to get bucket list.

func NewListStorage 

func NewListStorage(task navvy.Task) *ListStorageTask

NewListStorage will create a ListStorageTask struct and fetch inherited data from parent task.

func (*ListStorageTask) Run 

func (t *ListStorageTask) Run()

Run implement navvy.Task

func (*ListStorageTask) String 

func (t *ListStorageTask) String() string

String will implement Stringer interface.

func (*ListStorageTask) TriggerFault 

func (t *ListStorageTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*ListStorageTask) VoidWorkload 

func (t *ListStorageTask) VoidWorkload()

type MD5SumFileTask 

type MD5SumFileTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Offset
	types.Path
	types.Size
	types.Storage

	// Output value
	types.MD5Sum
}

MD5SumFileTask will get file's md5 sum.

func NewMD5SumFile 

func NewMD5SumFile(task navvy.Task) *MD5SumFileTask

NewMD5SumFile will create a MD5SumFileTask struct and fetch inherited data from parent task.

func (*MD5SumFileTask) IOWorkload 

func (t *MD5SumFileTask) IOWorkload()

func (*MD5SumFileTask) Run 

func (t *MD5SumFileTask) Run()

Run implement navvy.Task

func (*MD5SumFileTask) String 

func (t *MD5SumFileTask) String() string

String will implement Stringer interface.

func (*MD5SumFileTask) TriggerFault 

func (t *MD5SumFileTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

type MD5SumStreamTask 

type MD5SumStreamTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Content

	// Output value
	types.MD5Sum
}

MD5SumStreamTask will get stream's md5 sum.

func NewMD5SumStream 

func NewMD5SumStream(task navvy.Task) *MD5SumStreamTask

NewMD5SumStream will create a MD5SumStreamTask struct and fetch inherited data from parent task.

func (*MD5SumStreamTask) IOWorkload 

func (t *MD5SumStreamTask) IOWorkload()

func (*MD5SumStreamTask) Run 

func (t *MD5SumStreamTask) Run()

Run implement navvy.Task

func (*MD5SumStreamTask) String 

func (t *MD5SumStreamTask) String() string

String will implement Stringer interface.

func (*MD5SumStreamTask) TriggerFault 

func (t *MD5SumStreamTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

type ReachFileTask 

type ReachFileTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Expire
	types.Path
	types.Storage

	// Output value
	types.URL
}

ReachFileTask will will reach a remote object and return the signed url.

func NewReachFile 

func NewReachFile(task navvy.Task) *ReachFileTask

NewReachFile will create a ReachFileTask struct and fetch inherited data from parent task.

func (*ReachFileTask) IOWorkload 

func (t *ReachFileTask) IOWorkload()

func (*ReachFileTask) Run 

func (t *ReachFileTask) Run()

Run implement navvy.Task

func (*ReachFileTask) String 

func (t *ReachFileTask) String() string

String will implement Stringer interface.

func (*ReachFileTask) TriggerFault 

func (t *ReachFileTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

type SegmentAbortAllTask 

type SegmentAbortAllTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Storage
	types.StorageName
}

SegmentAbortAllTask will abort all multipart uploads in a bucket.

func NewSegmentAbortAll 

func NewSegmentAbortAll(task navvy.Task) *SegmentAbortAllTask

NewSegmentAbortAll will create a SegmentAbortAllTask struct and fetch inherited data from parent task.

func (*SegmentAbortAllTask) Run 

func (t *SegmentAbortAllTask) Run()

Run implement navvy.Task

func (*SegmentAbortAllTask) String 

func (t *SegmentAbortAllTask) String() string

String will implement Stringer interface.

func (*SegmentAbortAllTask) TriggerFault 

func (t *SegmentAbortAllTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*SegmentAbortAllTask) VoidWorkload 

func (t *SegmentAbortAllTask) VoidWorkload()

type SegmentCompleteTask 

type SegmentCompleteTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Path
	types.SegmentID
	types.Storage
}

SegmentCompleteTask will complete a segment.

func NewSegmentComplete 

func NewSegmentComplete(task navvy.Task) *SegmentCompleteTask

NewSegmentComplete will create a SegmentCompleteTask struct and fetch inherited data from parent task.

func (*SegmentCompleteTask) IOWorkload 

func (t *SegmentCompleteTask) IOWorkload()

func (*SegmentCompleteTask) Run 

func (t *SegmentCompleteTask) Run()

Run implement navvy.Task

func (*SegmentCompleteTask) String 

func (t *SegmentCompleteTask) String() string

String will implement Stringer interface.

func (*SegmentCompleteTask) TriggerFault 

func (t *SegmentCompleteTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

type SegmentFileCopyTask 

type SegmentFileCopyTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.DestinationPath
	types.DestinationStorage
	types.MD5Sum
	types.Offset
	types.SegmentID
	types.Size
	types.SourcePath
	types.SourceStorage
}

SegmentFileCopyTask will copy a segment file.

func NewSegmentFileCopy 

func NewSegmentFileCopy(task navvy.Task) *SegmentFileCopyTask

NewSegmentFileCopy will create a SegmentFileCopyTask struct and fetch inherited data from parent task.

func (*SegmentFileCopyTask) IOWorkload 

func (t *SegmentFileCopyTask) IOWorkload()

func (*SegmentFileCopyTask) Run 

func (t *SegmentFileCopyTask) Run()

Run implement navvy.Task

func (*SegmentFileCopyTask) String 

func (t *SegmentFileCopyTask) String() string

String will implement Stringer interface.

func (*SegmentFileCopyTask) TriggerFault 

func (t *SegmentFileCopyTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

type SegmentInitTask 

type SegmentInitTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.PartSize
	types.Path
	types.Storage

	// Output value
	types.SegmentID
}

SegmentInitTask will init a segment upload.

func NewSegmentInit 

func NewSegmentInit(task navvy.Task) *SegmentInitTask

NewSegmentInit will create a SegmentInitTask struct and fetch inherited data from parent task.

func (*SegmentInitTask) IOWorkload 

func (t *SegmentInitTask) IOWorkload()

func (*SegmentInitTask) Run 

func (t *SegmentInitTask) Run()

Run implement navvy.Task

func (*SegmentInitTask) String 

func (t *SegmentInitTask) String() string

String will implement Stringer interface.

func (*SegmentInitTask) TriggerFault 

func (t *SegmentInitTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

type SegmentStreamCopyTask 

type SegmentStreamCopyTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Content
	types.DestinationPath
	types.DestinationStorage
	types.MD5Sum
	types.Offset
	types.SegmentID
	types.Size
}

SegmentStreamCopyTask will copy a segment stream.

func NewSegmentStreamCopy 

func NewSegmentStreamCopy(task navvy.Task) *SegmentStreamCopyTask

NewSegmentStreamCopy will create a SegmentStreamCopyTask struct and fetch inherited data from parent task.

func (*SegmentStreamCopyTask) IOWorkload 

func (t *SegmentStreamCopyTask) IOWorkload()

func (*SegmentStreamCopyTask) Run 

func (t *SegmentStreamCopyTask) Run()

Run implement navvy.Task

func (*SegmentStreamCopyTask) String 

func (t *SegmentStreamCopyTask) String() string

String will implement Stringer interface.

func (*SegmentStreamCopyTask) TriggerFault 

func (t *SegmentStreamCopyTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

type StatFileTask 

type StatFileTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.Path
	types.Storage

	// Output value
	types.Object
}

StatFileTask will stat a remote object by request headObject.

func NewStatFile 

func NewStatFile(task navvy.Task) *StatFileTask

NewStatFile will create a StatFileTask struct and fetch inherited data from parent task.

func (*StatFileTask) IOWorkload 

func (t *StatFileTask) IOWorkload()

func (*StatFileTask) Run 

func (t *StatFileTask) Run()

Run implement navvy.Task

func (*StatFileTask) String 

func (t *StatFileTask) String() string

String will implement Stringer interface.

func (*StatFileTask) TriggerFault 

func (t *StatFileTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

type SyncTask 

type SyncTask struct {
	// Predefined value
	types.Fault
	types.ID
	types.Pool
	types.Scheduler

	// Input value
	types.DestinationPath
	types.DestinationStorage
	types.SourcePath
	types.SourceStorage
}

SyncTask will sync directory between two storage.

func NewSync 

func NewSync(task navvy.Task) *SyncTask

NewSync will create a SyncTask struct and fetch inherited data from parent task.

func (*SyncTask) Run 

func (t *SyncTask) Run()

Run implement navvy.Task

func (*SyncTask) String 

func (t *SyncTask) String() string

String will implement Stringer interface.

func (*SyncTask) TriggerFault 

func (t *SyncTask) TriggerFault(err error)

TriggerFault will be used to trigger a task related fault.

func (*SyncTask) VoidWorkload 

func (t *SyncTask) VoidWorkload()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.