Versions in this module Expand all Collapse all v0 v0.3.2 Nov 9, 2018 Changes in this version + func RegisterDatamoverHandler(s server.Server, hdlr DatamoverHandler, opts ...server.HandlerOption) error + type Connector struct + BucketName string + ConnConfig []*KV + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Connector) Descriptor() ([]byte, []int) + func (*Connector) ProtoMessage() + func (dst *Connector) XXX_Merge(src proto.Message) + func (m *Connector) GetBucketName() string + func (m *Connector) GetConnConfig() []*KV + func (m *Connector) GetType() string + 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_Size() int + func (m *Connector) XXX_Unmarshal(b []byte) error + type DatamoverHandler interface + Runjob func(context.Context, *RunJobRequest, *RunJobResponse) error + type DatamoverService interface + Runjob func(ctx context.Context, in *RunJobRequest, opts ...client.CallOption) (*RunJobResponse, error) + func NewDatamoverService(name string, c client.Client) DatamoverService + type Filter struct + Prefix string + Tag []*KV + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Filter) Descriptor() ([]byte, []int) + func (*Filter) ProtoMessage() + func (dst *Filter) XXX_Merge(src proto.Message) + func (m *Filter) GetPrefix() string + func (m *Filter) GetTag() []*KV + 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_Size() int + func (m *Filter) XXX_Unmarshal(b []byte) error + type KV struct + Key string + Value string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KV) Descriptor() ([]byte, []int) + func (*KV) ProtoMessage() + func (dst *KV) XXX_Merge(src proto.Message) + func (m *KV) GetKey() string + func (m *KV) GetValue() string + 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_Size() int + func (m *KV) XXX_Unmarshal(b []byte) error + type RunJobRequest struct + DestConn *Connector + Filt *Filter + Id string + RemainSource bool + SourceConn *Connector + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RunJobRequest) Descriptor() ([]byte, []int) + func (*RunJobRequest) ProtoMessage() + func (dst *RunJobRequest) XXX_Merge(src proto.Message) + 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) 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_Size() int + func (m *RunJobRequest) XXX_Unmarshal(b []byte) error + type RunJobResponse struct + Err string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RunJobResponse) Descriptor() ([]byte, []int) + func (*RunJobResponse) ProtoMessage() + func (dst *RunJobResponse) XXX_Merge(src proto.Message) + func (m *RunJobResponse) GetErr() string + 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_Size() int + func (m *RunJobResponse) XXX_Unmarshal(b []byte) error
Go to main page