datamover

type Connector struct {
	Type        string `protobuf:"bytes,1,opt,name=Type,json=type,proto3" json:"Type,omitempty"` //opensds,aws,azure,hwcloud,etc.
	BucketName  string `protobuf:"bytes,2,opt,name=BucketName,json=bucketName,proto3" json:"BucketName,omitempty"`
	ConnConfig  []*KV  `protobuf:"bytes,3,rep,name=ConnConfig,json=connConfig,proto3" json:"ConnConfig,omitempty"`
	BackendName string `protobuf:"bytes,4,opt,name=BackendName,json=backendName,proto3" json:"BackendName,omitempty"`
	// contains filtered or unexported fields
}

type DatamoverHandler interface {
	Runjob(context.Context, *RunJobRequest, *RunJobResponse) error
	DoLifecycleAction(context.Context, *LifecycleActionRequest, *LifecycleActionResonse) error
}

type DatamoverService interface {
	Runjob(ctx context.Context, in *RunJobRequest, opts ...client.CallOption) (*RunJobResponse, error)
	DoLifecycleAction(ctx context.Context, in *LifecycleActionRequest, opts ...client.CallOption) (*LifecycleActionResonse, error)
}

type Filter struct {
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Tag    []*KV  `protobuf:"bytes,2,rep,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

type KV struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type LifecycleActionRequest struct {
	ObjKey        string `protobuf:"bytes,1,opt,name=objKey,proto3" json:"objKey,omitempty"`                // for transition and expiration
	BucketName    string `protobuf:"bytes,2,opt,name=bucketName,proto3" json:"bucketName,omitempty"`        // for transition and expiration
	VersionId     string `protobuf:"bytes,3,opt,name=versionId,proto3" json:"versionId,omitempty"`          // for transition and expiration
	StorageMeta   string `protobuf:"bytes,4,opt,name=storageMeta,proto3" json:"storageMeta,omitempty"`      // for transition and expiration
	ObjectId      string `protobuf:"bytes,5,opt,name=objectId,proto3" json:"objectId,omitempty"`            // for transition and expiration
	Action        int32  `protobuf:"varint,6,opt,name=action,proto3" json:"action,omitempty"`               // 0-Expiration, 1-IncloudTransition, 2-CrossCloudTransition, 3-AbortMultipartUpload
	SourceTier    int32  `protobuf:"varint,7,opt,name=sourceTier,proto3" json:"sourceTier,omitempty"`       // only for transition
	TargetTier    int32  `protobuf:"varint,8,opt,name=targetTier,proto3" json:"targetTier,omitempty"`       // only for transtion
	SourceBackend string `protobuf:"bytes,9,opt,name=sourceBackend,proto3" json:"sourceBackend,omitempty"`  //for transition and expiration
	TargetBackend string `protobuf:"bytes,10,opt,name=targetBackend,proto3" json:"targetBackend,omitempty"` //for transition and abort incomplete multipart upload
	TargetBucket  string `protobuf:"bytes,11,opt,name=targetBucket,proto3" json:"targetBucket,omitempty"`   // for transition to specific backend
	ObjSize       int64  `protobuf:"varint,12,opt,name=objSize,proto3" json:"objSize,omitempty"`            // for transition
	UploadId      string `protobuf:"bytes,13,opt,name=uploadId,proto3" json:"uploadId,omitempty"`           // only for abort incomplete multipart upload
	// contains filtered or unexported fields
}

type LifecycleActionResonse struct {
	Err string `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

type RunJobRequest struct {
	Id           string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TenanId      string     `protobuf:"bytes,2,opt,name=tenanId,proto3" json:"tenanId,omitempty"`
	UserId       string     `protobuf:"bytes,3,opt,name=userId,proto3" json:"userId,omitempty"`
	SourceConn   *Connector `protobuf:"bytes,4,opt,name=sourceConn,proto3" json:"sourceConn,omitempty"`
	DestConn     *Connector `protobuf:"bytes,5,opt,name=destConn,proto3" json:"destConn,omitempty"`
	Filt         *Filter    `protobuf:"bytes,6,opt,name=filt,proto3" json:"filt,omitempty"`
	RemainSource bool       `protobuf:"varint,7,opt,name=remainSource,proto3" json:"remainSource,omitempty"`
	// contains filtered or unexported fields
}

type RunJobResponse struct {
	Err string `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}