migration

Documentation

Index

• Constants
• Variables
• func CopyObj(ctx context.Context, obj *osdss3.Object, destLoca *LocationInfo, ...) error
• func GetCtxTimeout(key string, min, max, def int64) time.Duration
• func GetMultipartSize() int64
• func HandleMsg(msgData []byte) error
• func Init()
• func MultipartCopyObj(ctx context.Context, obj *osdss3.Object, destLoca *LocationInfo, ...) error
• type Migration

Constants

const (
	MICRO_ENVIRONMENT = "MICRO_ENVIRONMENT"
	K8S               = "k8s"
)

const JobType = "migration"

const WT_DELETE = 4

const WT_MOVE = 96

Variables

var JOB_RUN_TIME_MAX = 86400 //seconds, equals 1 day

var MiniSpeed int64 = 5 // 5KByte/Sec

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

Functions

func CopyObj

func CopyObj(ctx context.Context, obj *osdss3.Object, destLoca *LocationInfo, job *flowtype.Job) error

func GetCtxTimeout

func GetCtxTimeout(key string, min, max, def int64) time.Duration

func GetMultipartSize

func GetMultipartSize() int64

func HandleMsg

func HandleMsg(msgData []byte) error

func Init

func Init()

func MultipartCopyObj

func MultipartCopyObj(ctx context.Context, obj *osdss3.Object, destLoca *LocationInfo, job *flowtype.Job) error

Types

type Migration

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