datamover

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Sep 30, 2020 License: Apache-2.0 Imports: 7 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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,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) Descriptor() ([]byte, []int)

func (*Connector) GetBackendName added in v1.0.0 

func (m *Connector) GetBackendName() string

func (*Connector) GetBucketName 

func (m *Connector) GetBucketName() string

func (*Connector) GetConnConfig 

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

func (*Connector) GetType 

func (m *Connector) GetType() string

func (*Connector) ProtoMessage 

func (*Connector) ProtoMessage()

func (*Connector) Reset 

func (m *Connector) Reset()

func (*Connector) String 

func (m *Connector) String() string

func (*Connector) XXX_DiscardUnknown 

func (m *Connector) XXX_DiscardUnknown()

func (*Connector) XXX_Marshal 

func (m *Connector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Connector) XXX_Merge 

func (m *Connector) XXX_Merge(src proto.Message)

func (*Connector) XXX_Size 

func (m *Connector) XXX_Size() int

func (*Connector) XXX_Unmarshal 

func (m *Connector) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Filter) GetPrefix 

func (m *Filter) GetPrefix() string

func (*Filter) GetTag 

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

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) Reset 

func (m *Filter) Reset()

func (*Filter) String 

func (m *Filter) String() string

func (*Filter) XXX_DiscardUnknown 

func (m *Filter) XXX_DiscardUnknown()

func (*Filter) XXX_Marshal 

func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Filter) XXX_Merge 

func (m *Filter) XXX_Merge(src proto.Message)

func (*Filter) XXX_Size 

func (m *Filter) XXX_Size() int

func (*Filter) XXX_Unmarshal 

func (m *Filter) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*KV) GetKey 

func (m *KV) GetKey() string

func (*KV) GetValue 

func (m *KV) GetValue() string

func (*KV) ProtoMessage 

func (*KV) ProtoMessage()

func (*KV) Reset 

func (m *KV) Reset()

func (*KV) String 

func (m *KV) String() string

func (*KV) XXX_DiscardUnknown 

func (m *KV) XXX_DiscardUnknown()

func (*KV) XXX_Marshal 

func (m *KV) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KV) XXX_Merge 

func (m *KV) XXX_Merge(src proto.Message)

func (*KV) XXX_Size 

func (m *KV) XXX_Size() int

func (*KV) XXX_Unmarshal 

func (m *KV) XXX_Unmarshal(b []byte) error

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

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.