Documentation ¶
Index ¶
- func RegisterDataSyncerServer(s *grpc.Server, srv DataSyncerServer)
- type DataSyncerClient
- type DataSyncerServer
- type InitRequest
- func (*InitRequest) Descriptor() ([]byte, []int)
- func (m *InitRequest) GetParams() map[string]string
- func (*InitRequest) ProtoMessage()
- func (m *InitRequest) Reset()
- func (m *InitRequest) String() string
- func (m *InitRequest) XXX_DiscardUnknown()
- func (m *InitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InitRequest) XXX_Merge(src proto.Message)
- func (m *InitRequest) XXX_Size() int
- func (m *InitRequest) XXX_Unmarshal(b []byte) error
- type InitResponse
- func (*InitResponse) Descriptor() ([]byte, []int)
- func (*InitResponse) ProtoMessage()
- func (m *InitResponse) Reset()
- func (m *InitResponse) String() string
- func (m *InitResponse) XXX_DiscardUnknown()
- func (m *InitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InitResponse) XXX_Merge(src proto.Message)
- func (m *InitResponse) XXX_Size() int
- func (m *InitResponse) XXX_Unmarshal(b []byte) error
- type SyncRequest
- func (*SyncRequest) Descriptor() ([]byte, []int)
- func (m *SyncRequest) GetParams() map[string]string
- func (*SyncRequest) ProtoMessage()
- func (m *SyncRequest) Reset()
- func (m *SyncRequest) String() string
- func (m *SyncRequest) XXX_DiscardUnknown()
- func (m *SyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncRequest) XXX_Merge(src proto.Message)
- func (m *SyncRequest) XXX_Size() int
- func (m *SyncRequest) XXX_Unmarshal(b []byte) error
- type SyncResponse
- func (*SyncResponse) Descriptor() ([]byte, []int)
- func (m *SyncResponse) GetSyncID() string
- func (*SyncResponse) ProtoMessage()
- func (m *SyncResponse) Reset()
- func (m *SyncResponse) String() string
- func (m *SyncResponse) XXX_DiscardUnknown()
- func (m *SyncResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncResponse) XXX_Merge(src proto.Message)
- func (m *SyncResponse) XXX_Size() int
- func (m *SyncResponse) XXX_Unmarshal(b []byte) error
- type SyncStatusRequest
- func (*SyncStatusRequest) Descriptor() ([]byte, []int)
- func (m *SyncStatusRequest) GetParams() map[string]string
- func (*SyncStatusRequest) ProtoMessage()
- func (m *SyncStatusRequest) Reset()
- func (m *SyncStatusRequest) String() string
- func (m *SyncStatusRequest) XXX_DiscardUnknown()
- func (m *SyncStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncStatusRequest) XXX_Merge(src proto.Message)
- func (m *SyncStatusRequest) XXX_Size() int
- func (m *SyncStatusRequest) XXX_Unmarshal(b []byte) error
- type SyncStatusResponse
- func (*SyncStatusResponse) Descriptor() ([]byte, []int)
- func (m *SyncStatusResponse) GetStatus() int32
- func (*SyncStatusResponse) ProtoMessage()
- func (m *SyncStatusResponse) Reset()
- func (m *SyncStatusResponse) String() string
- func (m *SyncStatusResponse) XXX_DiscardUnknown()
- func (m *SyncStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncStatusResponse) XXX_Merge(src proto.Message)
- func (m *SyncStatusResponse) XXX_Size() int
- func (m *SyncStatusResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedDataSyncerServer
- func (*UnimplementedDataSyncerServer) Init(ctx context.Context, req *InitRequest) (*InitResponse, error)
- func (*UnimplementedDataSyncerServer) SyncData(ctx context.Context, req *SyncRequest) (*SyncResponse, error)
- func (*UnimplementedDataSyncerServer) SyncStatus(ctx context.Context, req *SyncStatusRequest) (*SyncStatusResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterDataSyncerServer ¶
func RegisterDataSyncerServer(s *grpc.Server, srv DataSyncerServer)
Types ¶
type DataSyncerClient ¶
type DataSyncerClient interface { Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error) SyncData(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncResponse, error) SyncStatus(ctx context.Context, in *SyncStatusRequest, opts ...grpc.CallOption) (*SyncStatusResponse, error) }
DataSyncerClient is the client API for DataSyncer service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDataSyncerClient ¶
func NewDataSyncerClient(cc grpc.ClientConnInterface) DataSyncerClient
type DataSyncerServer ¶
type DataSyncerServer interface { Init(context.Context, *InitRequest) (*InitResponse, error) SyncData(context.Context, *SyncRequest) (*SyncResponse, error) SyncStatus(context.Context, *SyncStatusRequest) (*SyncStatusResponse, error) }
DataSyncerServer is the server API for DataSyncer service.
type InitRequest ¶
type InitRequest struct { Params map[string]string `` /* 153-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InitRequest) Descriptor ¶
func (*InitRequest) Descriptor() ([]byte, []int)
func (*InitRequest) GetParams ¶
func (m *InitRequest) GetParams() map[string]string
func (*InitRequest) ProtoMessage ¶
func (*InitRequest) ProtoMessage()
func (*InitRequest) Reset ¶
func (m *InitRequest) Reset()
func (*InitRequest) String ¶
func (m *InitRequest) String() string
func (*InitRequest) XXX_DiscardUnknown ¶
func (m *InitRequest) XXX_DiscardUnknown()
func (*InitRequest) XXX_Marshal ¶
func (m *InitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InitRequest) XXX_Merge ¶
func (m *InitRequest) XXX_Merge(src proto.Message)
func (*InitRequest) XXX_Size ¶
func (m *InitRequest) XXX_Size() int
func (*InitRequest) XXX_Unmarshal ¶
func (m *InitRequest) XXX_Unmarshal(b []byte) error
type InitResponse ¶
type InitResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InitResponse) Descriptor ¶
func (*InitResponse) Descriptor() ([]byte, []int)
func (*InitResponse) ProtoMessage ¶
func (*InitResponse) ProtoMessage()
func (*InitResponse) Reset ¶
func (m *InitResponse) Reset()
func (*InitResponse) String ¶
func (m *InitResponse) String() string
func (*InitResponse) XXX_DiscardUnknown ¶
func (m *InitResponse) XXX_DiscardUnknown()
func (*InitResponse) XXX_Marshal ¶
func (m *InitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InitResponse) XXX_Merge ¶
func (m *InitResponse) XXX_Merge(src proto.Message)
func (*InitResponse) XXX_Size ¶
func (m *InitResponse) XXX_Size() int
func (*InitResponse) XXX_Unmarshal ¶
func (m *InitResponse) XXX_Unmarshal(b []byte) error
type SyncRequest ¶
type SyncRequest struct { Params map[string]string `` /* 153-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SyncRequest) Descriptor ¶
func (*SyncRequest) Descriptor() ([]byte, []int)
func (*SyncRequest) GetParams ¶
func (m *SyncRequest) GetParams() map[string]string
func (*SyncRequest) ProtoMessage ¶
func (*SyncRequest) ProtoMessage()
func (*SyncRequest) Reset ¶
func (m *SyncRequest) Reset()
func (*SyncRequest) String ¶
func (m *SyncRequest) String() string
func (*SyncRequest) XXX_DiscardUnknown ¶
func (m *SyncRequest) XXX_DiscardUnknown()
func (*SyncRequest) XXX_Marshal ¶
func (m *SyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncRequest) XXX_Merge ¶
func (m *SyncRequest) XXX_Merge(src proto.Message)
func (*SyncRequest) XXX_Size ¶
func (m *SyncRequest) XXX_Size() int
func (*SyncRequest) XXX_Unmarshal ¶
func (m *SyncRequest) XXX_Unmarshal(b []byte) error
type SyncResponse ¶
type SyncResponse struct { SyncID string `protobuf:"bytes,1,opt,name=syncID,proto3" json:"syncID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SyncResponse) Descriptor ¶
func (*SyncResponse) Descriptor() ([]byte, []int)
func (*SyncResponse) GetSyncID ¶
func (m *SyncResponse) GetSyncID() string
func (*SyncResponse) ProtoMessage ¶
func (*SyncResponse) ProtoMessage()
func (*SyncResponse) Reset ¶
func (m *SyncResponse) Reset()
func (*SyncResponse) String ¶
func (m *SyncResponse) String() string
func (*SyncResponse) XXX_DiscardUnknown ¶
func (m *SyncResponse) XXX_DiscardUnknown()
func (*SyncResponse) XXX_Marshal ¶
func (m *SyncResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncResponse) XXX_Merge ¶
func (m *SyncResponse) XXX_Merge(src proto.Message)
func (*SyncResponse) XXX_Size ¶
func (m *SyncResponse) XXX_Size() int
func (*SyncResponse) XXX_Unmarshal ¶
func (m *SyncResponse) XXX_Unmarshal(b []byte) error
type SyncStatusRequest ¶
type SyncStatusRequest struct { Params map[string]string `` /* 153-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SyncStatusRequest) Descriptor ¶
func (*SyncStatusRequest) Descriptor() ([]byte, []int)
func (*SyncStatusRequest) GetParams ¶
func (m *SyncStatusRequest) GetParams() map[string]string
func (*SyncStatusRequest) ProtoMessage ¶
func (*SyncStatusRequest) ProtoMessage()
func (*SyncStatusRequest) Reset ¶
func (m *SyncStatusRequest) Reset()
func (*SyncStatusRequest) String ¶
func (m *SyncStatusRequest) String() string
func (*SyncStatusRequest) XXX_DiscardUnknown ¶
func (m *SyncStatusRequest) XXX_DiscardUnknown()
func (*SyncStatusRequest) XXX_Marshal ¶
func (m *SyncStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncStatusRequest) XXX_Merge ¶
func (m *SyncStatusRequest) XXX_Merge(src proto.Message)
func (*SyncStatusRequest) XXX_Size ¶
func (m *SyncStatusRequest) XXX_Size() int
func (*SyncStatusRequest) XXX_Unmarshal ¶
func (m *SyncStatusRequest) XXX_Unmarshal(b []byte) error
type SyncStatusResponse ¶
type SyncStatusResponse struct { Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SyncStatusResponse) Descriptor ¶
func (*SyncStatusResponse) Descriptor() ([]byte, []int)
func (*SyncStatusResponse) GetStatus ¶
func (m *SyncStatusResponse) GetStatus() int32
func (*SyncStatusResponse) ProtoMessage ¶
func (*SyncStatusResponse) ProtoMessage()
func (*SyncStatusResponse) Reset ¶
func (m *SyncStatusResponse) Reset()
func (*SyncStatusResponse) String ¶
func (m *SyncStatusResponse) String() string
func (*SyncStatusResponse) XXX_DiscardUnknown ¶
func (m *SyncStatusResponse) XXX_DiscardUnknown()
func (*SyncStatusResponse) XXX_Marshal ¶
func (m *SyncStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncStatusResponse) XXX_Merge ¶
func (m *SyncStatusResponse) XXX_Merge(src proto.Message)
func (*SyncStatusResponse) XXX_Size ¶
func (m *SyncStatusResponse) XXX_Size() int
func (*SyncStatusResponse) XXX_Unmarshal ¶
func (m *SyncStatusResponse) XXX_Unmarshal(b []byte) error
type UnimplementedDataSyncerServer ¶
type UnimplementedDataSyncerServer struct { }
UnimplementedDataSyncerServer can be embedded to have forward compatible implementations.
func (*UnimplementedDataSyncerServer) Init ¶
func (*UnimplementedDataSyncerServer) Init(ctx context.Context, req *InitRequest) (*InitResponse, error)
func (*UnimplementedDataSyncerServer) SyncData ¶
func (*UnimplementedDataSyncerServer) SyncData(ctx context.Context, req *SyncRequest) (*SyncResponse, error)
func (*UnimplementedDataSyncerServer) SyncStatus ¶
func (*UnimplementedDataSyncerServer) SyncStatus(ctx context.Context, req *SyncStatusRequest) (*SyncStatusResponse, error)
Click to show internal directories.
Click to hide internal directories.