datamover

package
v1.10.0 Latest Latest
Warning

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

 Go to latest Published: Feb 14, 2024 License: Apache-2.0 Imports: 11 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_datamover_proto_datamover_proto protoreflect.FileDescriptor

Functions

func NewDatamoverEndpoints added in v1.0.0 

func NewDatamoverEndpoints() []*api.Endpoint

func RegisterDatamoverHandler 

func RegisterDatamoverHandler(s server.Server, hdlr DatamoverHandler, opts ...server.HandlerOption) error

Types

type Connector 

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
}

func (*Connector) Descriptor deprecated 

func (*Connector) Descriptor() ([]byte, []int)

Deprecated: Use Connector.ProtoReflect.Descriptor instead.

func (*Connector) GetBackendName added in v1.0.0 

func (x *Connector) GetBackendName() string

func (*Connector) GetBucketName 

func (x *Connector) GetBucketName() string

func (*Connector) GetConnConfig 

func (x *Connector) GetConnConfig() []*KV

func (*Connector) GetType 

func (x *Connector) GetType() string

func (*Connector) ProtoMessage 

func (*Connector) ProtoMessage()

func (*Connector) ProtoReflect added in v1.2.2 

func (x *Connector) ProtoReflect() protoreflect.Message

func (*Connector) Reset 

func (x *Connector) Reset()

func (*Connector) String 

func (x *Connector) String() string

type DatamoverHandler 

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

type DatamoverService 

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)
}

func NewDatamoverService 

func NewDatamoverService(name string, c client.Client) DatamoverService

type Filter 

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
}

func (*Filter) Descriptor deprecated 

func (*Filter) Descriptor() ([]byte, []int)

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetPrefix 

func (x *Filter) GetPrefix() string

func (*Filter) GetTag 

func (x *Filter) GetTag() []*KV

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect added in v1.2.2 

func (x *Filter) ProtoReflect() protoreflect.Message

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

type KV 

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
}

func (*KV) Descriptor deprecated 

func (*KV) Descriptor() ([]byte, []int)

Deprecated: Use KV.ProtoReflect.Descriptor instead.

func (*KV) GetKey 

func (x *KV) GetKey() string

func (*KV) GetValue 

func (x *KV) GetValue() string

func (*KV) ProtoMessage 

func (*KV) ProtoMessage()

func (*KV) ProtoReflect added in v1.2.2 

func (x *KV) ProtoReflect() protoreflect.Message

func (*KV) Reset 

func (x *KV) Reset()

func (*KV) String 

func (x *KV) String() string

type LifecycleActionRequest added in v0.5.3 

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
}

func (*LifecycleActionRequest) Descriptor deprecated added in v0.5.3 

func (*LifecycleActionRequest) Descriptor() ([]byte, []int)

Deprecated: Use LifecycleActionRequest.ProtoReflect.Descriptor instead.

func (*LifecycleActionRequest) GetAction added in v0.5.3 

func (x *LifecycleActionRequest) GetAction() int32

func (*LifecycleActionRequest) GetBucketName added in v0.5.3 

func (x *LifecycleActionRequest) GetBucketName() string

func (*LifecycleActionRequest) GetObjKey added in v0.5.3 

func (x *LifecycleActionRequest) GetObjKey() string

func (*LifecycleActionRequest) GetObjSize added in v0.5.3 

func (x *LifecycleActionRequest) GetObjSize() int64

func (*LifecycleActionRequest) GetObjectId added in v0.6.3 

func (x *LifecycleActionRequest) GetObjectId() string

func (*LifecycleActionRequest) GetSourceBackend added in v0.5.3 

func (x *LifecycleActionRequest) GetSourceBackend() string

func (*LifecycleActionRequest) GetSourceTier added in v0.5.3 

func (x *LifecycleActionRequest) GetSourceTier() int32

func (*LifecycleActionRequest) GetStorageMeta added in v0.6.3 

func (x *LifecycleActionRequest) GetStorageMeta() string

func (*LifecycleActionRequest) GetTargetBackend added in v0.5.3 

func (x *LifecycleActionRequest) GetTargetBackend() string

func (*LifecycleActionRequest) GetTargetBucket added in v1.2.2 

func (x *LifecycleActionRequest) GetTargetBucket() string

func (*LifecycleActionRequest) GetTargetTier added in v0.5.3 

func (x *LifecycleActionRequest) GetTargetTier() int32

func (*LifecycleActionRequest) GetUploadId added in v0.5.3 

func (x *LifecycleActionRequest) GetUploadId() string

func (*LifecycleActionRequest) GetVersionId added in v0.6.3 

func (x *LifecycleActionRequest) GetVersionId() string

func (*LifecycleActionRequest) ProtoMessage added in v0.5.3 

func (*LifecycleActionRequest) ProtoMessage()

func (*LifecycleActionRequest) ProtoReflect added in v1.2.2 

func (x *LifecycleActionRequest) ProtoReflect() protoreflect.Message

func (*LifecycleActionRequest) Reset added in v0.5.3 

func (x *LifecycleActionRequest) Reset()

func (*LifecycleActionRequest) String added in v0.5.3 

func (x *LifecycleActionRequest) String() string

type LifecycleActionResonse added in v0.5.3 

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

func (*LifecycleActionResonse) Descriptor deprecated added in v0.5.3 

func (*LifecycleActionResonse) Descriptor() ([]byte, []int)

Deprecated: Use LifecycleActionResonse.ProtoReflect.Descriptor instead.

func (*LifecycleActionResonse) GetErr added in v0.5.3 

func (x *LifecycleActionResonse) GetErr() string

func (*LifecycleActionResonse) ProtoMessage added in v0.5.3 

func (*LifecycleActionResonse) ProtoMessage()

func (*LifecycleActionResonse) ProtoReflect added in v1.2.2 

func (x *LifecycleActionResonse) ProtoReflect() protoreflect.Message

func (*LifecycleActionResonse) Reset added in v0.5.3 

func (x *LifecycleActionResonse) Reset()

func (*LifecycleActionResonse) String added in v0.5.3 

func (x *LifecycleActionResonse) String() string

type RunJobRequest 

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
}

func (*RunJobRequest) Descriptor deprecated 

func (*RunJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use RunJobRequest.ProtoReflect.Descriptor instead.

func (*RunJobRequest) GetDestConn 

func (x *RunJobRequest) GetDestConn() *Connector

func (*RunJobRequest) GetFilt 

func (x *RunJobRequest) GetFilt() *Filter

func (*RunJobRequest) GetId 

func (x *RunJobRequest) GetId() string

func (*RunJobRequest) GetRemainSource 

func (x *RunJobRequest) GetRemainSource() bool

func (*RunJobRequest) GetSourceConn 

func (x *RunJobRequest) GetSourceConn() *Connector

func (*RunJobRequest) GetTenanId added in v0.6.3 

func (x *RunJobRequest) GetTenanId() string

func (*RunJobRequest) GetUserId added in v0.6.3 

func (x *RunJobRequest) GetUserId() string

func (*RunJobRequest) ProtoMessage 

func (*RunJobRequest) ProtoMessage()

func (*RunJobRequest) ProtoReflect added in v1.2.2 

func (x *RunJobRequest) ProtoReflect() protoreflect.Message

func (*RunJobRequest) Reset 

func (x *RunJobRequest) Reset()

func (*RunJobRequest) String 

func (x *RunJobRequest) String() string

type RunJobResponse 

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

func (*RunJobResponse) Descriptor deprecated 

func (*RunJobResponse) Descriptor() ([]byte, []int)

Deprecated: Use RunJobResponse.ProtoReflect.Descriptor instead.

func (*RunJobResponse) GetErr 

func (x *RunJobResponse) GetErr() string

func (*RunJobResponse) ProtoMessage 

func (*RunJobResponse) ProtoMessage()

func (*RunJobResponse) ProtoReflect added in v1.2.2 

func (x *RunJobResponse) ProtoReflect() protoreflect.Message

func (*RunJobResponse) Reset 

func (x *RunJobResponse) Reset()

func (*RunJobResponse) String 

func (x *RunJobResponse) String() string

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.