datamover

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Jan 4, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package datamover is a generated protocol buffer package.

It is generated from these files: 

datamover.proto

It has these top-level messages: 

KV
Filter
Connector
RunJobRequest
RunJobResponse
LifecycleActionRequest
LifecycleActionResonse

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Connector) Descriptor 

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

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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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.