migration

Documentation

Index

• Constants
• Variables
• func HandleMsg(msgData []byte) error
• func Init()
• func MoveObj(obj *osdss3.Object, srcLoca *LocationInfo, destLoca *LocationInfo, ...) error
• func MultipartMoveObj(obj *osdss3.Object, srcLoca *LocationInfo, destLoca *LocationInfo, ...) error
• type Migration

Constants

const WT_DELETE = 4

const WT_DOWLOAD = 48

const WT_UPLOAD = 48

Variables

var JOB_RUN_TIME_MAX = 86400 //seconds, equals 1 day

var PART_SIZE int64 = 16 * 1024 * 1024 //The max object size that can be moved directly, default is 16M.

Functions

func HandleMsg

func HandleMsg(msgData []byte) error

func Init

func Init()

func MoveObj

func MoveObj(obj *osdss3.Object, srcLoca *LocationInfo, destLoca *LocationInfo, job *flowtype.Job) error

func MultipartMoveObj

func MultipartMoveObj(obj *osdss3.Object, srcLoca *LocationInfo, destLoca *LocationInfo, job *flowtype.Job) error

Types

type Migration

type Migration interface {
	Init()
	HandleMsg(msg string)
}