datamover

package
v0.3.4 Latest Latest
Warning

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

 Go to latest Published: Dec 7, 2018 License: Apache-2.0 Imports: 6 Imported by: 4

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

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
}

type DatamoverService 

type DatamoverService interface {
	Runjob(ctx context.Context, in *RunJobRequest, opts ...client.CallOption) (*RunJobResponse, 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 RunJobRequest 

type RunJobRequest struct {
	Id                   string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	SourceConn           *Connector `protobuf:"bytes,2,opt,name=sourceConn,proto3" json:"sourceConn,omitempty"`
	DestConn             *Connector `protobuf:"bytes,3,opt,name=destConn,proto3" json:"destConn,omitempty"`
	Filt                 *Filter    `protobuf:"bytes,4,opt,name=filt,proto3" json:"filt,omitempty"`
	RemainSource         bool       `protobuf:"varint,5,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) 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.