Documentation ¶
Index ¶
- func NewDatamoverEndpoints() []*api.Endpoint
- func RegisterDatamoverHandler(s server.Server, hdlr DatamoverHandler, opts ...server.HandlerOption) error
- type Connector
- func (*Connector) Descriptor() ([]byte, []int)
- func (m *Connector) GetBackendName() string
- func (m *Connector) GetBucketName() string
- func (m *Connector) GetConnConfig() []*KV
- func (m *Connector) GetType() string
- func (*Connector) ProtoMessage()
- func (m *Connector) Reset()
- func (m *Connector) String() string
- func (m *Connector) XXX_DiscardUnknown()
- func (m *Connector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Connector) XXX_Merge(src proto.Message)
- func (m *Connector) XXX_Size() int
- func (m *Connector) XXX_Unmarshal(b []byte) error
- type DatamoverHandler
- type DatamoverService
- type Filter
- func (*Filter) Descriptor() ([]byte, []int)
- func (m *Filter) GetPrefix() string
- func (m *Filter) GetTag() []*KV
- func (*Filter) ProtoMessage()
- func (m *Filter) Reset()
- func (m *Filter) String() string
- func (m *Filter) XXX_DiscardUnknown()
- func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Filter) XXX_Merge(src proto.Message)
- func (m *Filter) XXX_Size() int
- func (m *Filter) XXX_Unmarshal(b []byte) error
- type KV
- func (*KV) Descriptor() ([]byte, []int)
- func (m *KV) GetKey() string
- func (m *KV) GetValue() string
- func (*KV) ProtoMessage()
- func (m *KV) Reset()
- func (m *KV) String() string
- func (m *KV) XXX_DiscardUnknown()
- func (m *KV) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KV) XXX_Merge(src proto.Message)
- func (m *KV) XXX_Size() int
- func (m *KV) XXX_Unmarshal(b []byte) error
- type LifecycleActionRequest
- func (*LifecycleActionRequest) Descriptor() ([]byte, []int)
- func (m *LifecycleActionRequest) GetAction() int32
- func (m *LifecycleActionRequest) GetBucketName() string
- func (m *LifecycleActionRequest) GetObjKey() string
- func (m *LifecycleActionRequest) GetObjSize() int64
- func (m *LifecycleActionRequest) GetObjectId() string
- func (m *LifecycleActionRequest) GetSourceBackend() string
- func (m *LifecycleActionRequest) GetSourceTier() int32
- func (m *LifecycleActionRequest) GetStorageMeta() string
- func (m *LifecycleActionRequest) GetTargetBackend() string
- func (m *LifecycleActionRequest) GetTargetTier() int32
- func (m *LifecycleActionRequest) GetUploadId() string
- func (m *LifecycleActionRequest) GetVersionId() string
- func (*LifecycleActionRequest) ProtoMessage()
- func (m *LifecycleActionRequest) Reset()
- func (m *LifecycleActionRequest) String() string
- func (m *LifecycleActionRequest) XXX_DiscardUnknown()
- func (m *LifecycleActionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LifecycleActionRequest) XXX_Merge(src proto.Message)
- func (m *LifecycleActionRequest) XXX_Size() int
- func (m *LifecycleActionRequest) XXX_Unmarshal(b []byte) error
- type LifecycleActionResonse
- func (*LifecycleActionResonse) Descriptor() ([]byte, []int)
- func (m *LifecycleActionResonse) GetErr() string
- func (*LifecycleActionResonse) ProtoMessage()
- func (m *LifecycleActionResonse) Reset()
- func (m *LifecycleActionResonse) String() string
- func (m *LifecycleActionResonse) XXX_DiscardUnknown()
- func (m *LifecycleActionResonse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LifecycleActionResonse) XXX_Merge(src proto.Message)
- func (m *LifecycleActionResonse) XXX_Size() int
- func (m *LifecycleActionResonse) XXX_Unmarshal(b []byte) error
- type RunJobRequest
- func (*RunJobRequest) Descriptor() ([]byte, []int)
- func (m *RunJobRequest) GetDestConn() *Connector
- func (m *RunJobRequest) GetFilt() *Filter
- func (m *RunJobRequest) GetId() string
- func (m *RunJobRequest) GetRemainSource() bool
- func (m *RunJobRequest) GetSourceConn() *Connector
- func (m *RunJobRequest) GetTenanId() string
- func (m *RunJobRequest) GetUserId() string
- func (*RunJobRequest) ProtoMessage()
- func (m *RunJobRequest) Reset()
- func (m *RunJobRequest) String() string
- func (m *RunJobRequest) XXX_DiscardUnknown()
- func (m *RunJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RunJobRequest) XXX_Merge(src proto.Message)
- func (m *RunJobRequest) XXX_Size() int
- func (m *RunJobRequest) XXX_Unmarshal(b []byte) error
- type RunJobResponse
- func (*RunJobResponse) Descriptor() ([]byte, []int)
- func (m *RunJobResponse) GetErr() string
- func (*RunJobResponse) ProtoMessage()
- func (m *RunJobResponse) Reset()
- func (m *RunJobResponse) String() string
- func (m *RunJobResponse) XXX_DiscardUnknown()
- func (m *RunJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RunJobResponse) XXX_Merge(src proto.Message)
- func (m *RunJobResponse) XXX_Size() int
- func (m *RunJobResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDatamoverEndpoints ¶ added in v1.0.0
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,proto3" json:"Type,omitempty"` BucketName string `protobuf:"bytes,2,opt,name=BucketName,proto3" json:"BucketName,omitempty"` ConnConfig []*KV `protobuf:"bytes,3,rep,name=ConnConfig,proto3" json:"ConnConfig,omitempty"` BackendName string `protobuf:"bytes,4,opt,name=BackendName,proto3" json:"BackendName,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Connector) Descriptor ¶
func (*Connector) GetBackendName ¶ added in v1.0.0
func (*Connector) GetBucketName ¶
func (*Connector) GetConnConfig ¶
func (*Connector) ProtoMessage ¶
func (*Connector) ProtoMessage()
func (*Connector) XXX_DiscardUnknown ¶
func (m *Connector) XXX_DiscardUnknown()
func (*Connector) XXX_Marshal ¶
func (*Connector) XXX_Unmarshal ¶
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Filter) Descriptor ¶
func (*Filter) ProtoMessage ¶
func (*Filter) ProtoMessage()
func (*Filter) XXX_DiscardUnknown ¶
func (m *Filter) XXX_DiscardUnknown()
func (*Filter) XXX_Marshal ¶
func (*Filter) XXX_Unmarshal ¶
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*KV) Descriptor ¶
func (*KV) ProtoMessage ¶
func (*KV) ProtoMessage()
func (*KV) XXX_DiscardUnknown ¶
func (m *KV) XXX_DiscardUnknown()
func (*KV) XXX_Unmarshal ¶
type LifecycleActionRequest ¶ added in v0.5.3
type LifecycleActionRequest struct { ObjKey string `protobuf:"bytes,1,opt,name=objKey,proto3" json:"objKey,omitempty"` BucketName string `protobuf:"bytes,2,opt,name=bucketName,proto3" json:"bucketName,omitempty"` VersionId string `protobuf:"bytes,3,opt,name=versionId,proto3" json:"versionId,omitempty"` StorageMeta string `protobuf:"bytes,4,opt,name=storageMeta,proto3" json:"storageMeta,omitempty"` ObjectId string `protobuf:"bytes,5,opt,name=objectId,proto3" json:"objectId,omitempty"` Action int32 `protobuf:"varint,6,opt,name=action,proto3" json:"action,omitempty"` SourceTier int32 `protobuf:"varint,7,opt,name=sourceTier,proto3" json:"sourceTier,omitempty"` TargetTier int32 `protobuf:"varint,8,opt,name=targetTier,proto3" json:"targetTier,omitempty"` SourceBackend string `protobuf:"bytes,9,opt,name=sourceBackend,proto3" json:"sourceBackend,omitempty"` TargetBackend string `protobuf:"bytes,10,opt,name=targetBackend,proto3" json:"targetBackend,omitempty"` ObjSize int64 `protobuf:"varint,11,opt,name=objSize,proto3" json:"objSize,omitempty"` UploadId string `protobuf:"bytes,12,opt,name=uploadId,proto3" json:"uploadId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LifecycleActionRequest) Descriptor ¶ added in v0.5.3
func (*LifecycleActionRequest) Descriptor() ([]byte, []int)
func (*LifecycleActionRequest) GetAction ¶ added in v0.5.3
func (m *LifecycleActionRequest) GetAction() int32
func (*LifecycleActionRequest) GetBucketName ¶ added in v0.5.3
func (m *LifecycleActionRequest) GetBucketName() string
func (*LifecycleActionRequest) GetObjKey ¶ added in v0.5.3
func (m *LifecycleActionRequest) GetObjKey() string
func (*LifecycleActionRequest) GetObjSize ¶ added in v0.5.3
func (m *LifecycleActionRequest) GetObjSize() int64
func (*LifecycleActionRequest) GetObjectId ¶ added in v0.6.3
func (m *LifecycleActionRequest) GetObjectId() string
func (*LifecycleActionRequest) GetSourceBackend ¶ added in v0.5.3
func (m *LifecycleActionRequest) GetSourceBackend() string
func (*LifecycleActionRequest) GetSourceTier ¶ added in v0.5.3
func (m *LifecycleActionRequest) GetSourceTier() int32
func (*LifecycleActionRequest) GetStorageMeta ¶ added in v0.6.3
func (m *LifecycleActionRequest) GetStorageMeta() string
func (*LifecycleActionRequest) GetTargetBackend ¶ added in v0.5.3
func (m *LifecycleActionRequest) GetTargetBackend() string
func (*LifecycleActionRequest) GetTargetTier ¶ added in v0.5.3
func (m *LifecycleActionRequest) GetTargetTier() int32
func (*LifecycleActionRequest) GetUploadId ¶ added in v0.5.3
func (m *LifecycleActionRequest) GetUploadId() string
func (*LifecycleActionRequest) GetVersionId ¶ added in v0.6.3
func (m *LifecycleActionRequest) GetVersionId() string
func (*LifecycleActionRequest) ProtoMessage ¶ added in v0.5.3
func (*LifecycleActionRequest) ProtoMessage()
func (*LifecycleActionRequest) Reset ¶ added in v0.5.3
func (m *LifecycleActionRequest) Reset()
func (*LifecycleActionRequest) String ¶ added in v0.5.3
func (m *LifecycleActionRequest) String() string
func (*LifecycleActionRequest) XXX_DiscardUnknown ¶ added in v0.5.3
func (m *LifecycleActionRequest) XXX_DiscardUnknown()
func (*LifecycleActionRequest) XXX_Marshal ¶ added in v0.5.3
func (m *LifecycleActionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LifecycleActionRequest) XXX_Merge ¶ added in v0.5.3
func (m *LifecycleActionRequest) XXX_Merge(src proto.Message)
func (*LifecycleActionRequest) XXX_Size ¶ added in v0.5.3
func (m *LifecycleActionRequest) XXX_Size() int
func (*LifecycleActionRequest) XXX_Unmarshal ¶ added in v0.5.3
func (m *LifecycleActionRequest) XXX_Unmarshal(b []byte) error
type LifecycleActionResonse ¶ added in v0.5.3
type LifecycleActionResonse struct { Err string `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LifecycleActionResonse) Descriptor ¶ added in v0.5.3
func (*LifecycleActionResonse) Descriptor() ([]byte, []int)
func (*LifecycleActionResonse) GetErr ¶ added in v0.5.3
func (m *LifecycleActionResonse) GetErr() string
func (*LifecycleActionResonse) ProtoMessage ¶ added in v0.5.3
func (*LifecycleActionResonse) ProtoMessage()
func (*LifecycleActionResonse) Reset ¶ added in v0.5.3
func (m *LifecycleActionResonse) Reset()
func (*LifecycleActionResonse) String ¶ added in v0.5.3
func (m *LifecycleActionResonse) String() string
func (*LifecycleActionResonse) XXX_DiscardUnknown ¶ added in v0.5.3
func (m *LifecycleActionResonse) XXX_DiscardUnknown()
func (*LifecycleActionResonse) XXX_Marshal ¶ added in v0.5.3
func (m *LifecycleActionResonse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LifecycleActionResonse) XXX_Merge ¶ added in v0.5.3
func (m *LifecycleActionResonse) XXX_Merge(src proto.Message)
func (*LifecycleActionResonse) XXX_Size ¶ added in v0.5.3
func (m *LifecycleActionResonse) XXX_Size() int
func (*LifecycleActionResonse) XXX_Unmarshal ¶ added in v0.5.3
func (m *LifecycleActionResonse) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RunJobRequest) Descriptor ¶
func (*RunJobRequest) Descriptor() ([]byte, []int)
func (*RunJobRequest) GetDestConn ¶
func (m *RunJobRequest) GetDestConn() *Connector
func (*RunJobRequest) GetFilt ¶
func (m *RunJobRequest) GetFilt() *Filter
func (*RunJobRequest) GetId ¶
func (m *RunJobRequest) GetId() string
func (*RunJobRequest) GetRemainSource ¶
func (m *RunJobRequest) GetRemainSource() bool
func (*RunJobRequest) GetSourceConn ¶
func (m *RunJobRequest) GetSourceConn() *Connector
func (*RunJobRequest) GetTenanId ¶ added in v0.6.3
func (m *RunJobRequest) GetTenanId() string
func (*RunJobRequest) GetUserId ¶ added in v0.6.3
func (m *RunJobRequest) GetUserId() string
func (*RunJobRequest) ProtoMessage ¶
func (*RunJobRequest) ProtoMessage()
func (*RunJobRequest) Reset ¶
func (m *RunJobRequest) Reset()
func (*RunJobRequest) String ¶
func (m *RunJobRequest) String() string
func (*RunJobRequest) XXX_DiscardUnknown ¶
func (m *RunJobRequest) XXX_DiscardUnknown()
func (*RunJobRequest) XXX_Marshal ¶
func (m *RunJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RunJobRequest) XXX_Merge ¶
func (m *RunJobRequest) XXX_Merge(src proto.Message)
func (*RunJobRequest) XXX_Size ¶
func (m *RunJobRequest) XXX_Size() int
func (*RunJobRequest) XXX_Unmarshal ¶
func (m *RunJobRequest) XXX_Unmarshal(b []byte) error
type RunJobResponse ¶
type RunJobResponse struct { Err string `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RunJobResponse) Descriptor ¶
func (*RunJobResponse) Descriptor() ([]byte, []int)
func (*RunJobResponse) GetErr ¶
func (m *RunJobResponse) GetErr() string
func (*RunJobResponse) ProtoMessage ¶
func (*RunJobResponse) ProtoMessage()
func (*RunJobResponse) Reset ¶
func (m *RunJobResponse) Reset()
func (*RunJobResponse) String ¶
func (m *RunJobResponse) String() string
func (*RunJobResponse) XXX_DiscardUnknown ¶
func (m *RunJobResponse) XXX_DiscardUnknown()
func (*RunJobResponse) XXX_Marshal ¶
func (m *RunJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RunJobResponse) XXX_Merge ¶
func (m *RunJobResponse) XXX_Merge(src proto.Message)
func (*RunJobResponse) XXX_Size ¶
func (m *RunJobResponse) XXX_Size() int
func (*RunJobResponse) XXX_Unmarshal ¶
func (m *RunJobResponse) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.