Documentation ¶
Index ¶
- func RegisterDataCenterServer(s *grpc.Server, srv DataCenterServer)
- type DataCenterClient
- type DataCenterServer
- type DataCenter_DownloadClient
- type DataCenter_DownloadServer
- type DataCenter_UploadClient
- type DataCenter_UploadServer
- type HelloRequest
- func (*HelloRequest) Descriptor() ([]byte, []int)
- func (m *HelloRequest) GetName() string
- func (*HelloRequest) ProtoMessage()
- func (m *HelloRequest) Reset()
- func (m *HelloRequest) String() string
- func (m *HelloRequest) XXX_DiscardUnknown()
- func (m *HelloRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HelloRequest) XXX_Merge(src proto.Message)
- func (m *HelloRequest) XXX_Size() int
- func (m *HelloRequest) XXX_Unmarshal(b []byte) error
- type HelloResponse
- func (*HelloResponse) Descriptor() ([]byte, []int)
- func (m *HelloResponse) GetMessage() string
- func (*HelloResponse) ProtoMessage()
- func (m *HelloResponse) Reset()
- func (m *HelloResponse) String() string
- func (m *HelloResponse) XXX_DiscardUnknown()
- func (m *HelloResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HelloResponse) XXX_Merge(src proto.Message)
- func (m *HelloResponse) XXX_Size() int
- func (m *HelloResponse) XXX_Unmarshal(b []byte) error
- type Packet
- func (*Packet) Descriptor() ([]byte, []int)
- func (m *Packet) GetData() []byte
- func (*Packet) ProtoMessage()
- func (m *Packet) Reset()
- func (m *Packet) String() string
- func (m *Packet) XXX_DiscardUnknown()
- func (m *Packet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Packet) XXX_Merge(src proto.Message)
- func (m *Packet) XXX_Size() int
- func (m *Packet) XXX_Unmarshal(b []byte) error
- type UnimplementedDataCenterServer
- type UploadResult
- func (*UploadResult) Descriptor() ([]byte, []int)
- func (m *UploadResult) GetChecksum() []byte
- func (m *UploadResult) GetSize() uint64
- func (*UploadResult) ProtoMessage()
- func (m *UploadResult) Reset()
- func (m *UploadResult) String() string
- func (m *UploadResult) XXX_DiscardUnknown()
- func (m *UploadResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UploadResult) XXX_Merge(src proto.Message)
- func (m *UploadResult) XXX_Size() int
- func (m *UploadResult) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterDataCenterServer ¶
func RegisterDataCenterServer(s *grpc.Server, srv DataCenterServer)
Types ¶
type DataCenterClient ¶
type DataCenterClient interface { SayHello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error) Download(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (DataCenter_DownloadClient, error) Upload(ctx context.Context, opts ...grpc.CallOption) (DataCenter_UploadClient, error) }
DataCenterClient is the client API for DataCenter service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDataCenterClient ¶
func NewDataCenterClient(cc grpc.ClientConnInterface) DataCenterClient
type DataCenterServer ¶
type DataCenterServer interface { SayHello(context.Context, *HelloRequest) (*HelloResponse, error) Download(*empty.Empty, DataCenter_DownloadServer) error Upload(DataCenter_UploadServer) error }
DataCenterServer is the server API for DataCenter service.
type DataCenter_DownloadClient ¶
type DataCenter_DownloadClient interface { Recv() (*Packet, error) grpc.ClientStream }
type DataCenter_DownloadServer ¶
type DataCenter_DownloadServer interface { Send(*Packet) error grpc.ServerStream }
type DataCenter_UploadClient ¶
type DataCenter_UploadClient interface { Send(*Packet) error CloseAndRecv() (*UploadResult, error) grpc.ClientStream }
type DataCenter_UploadServer ¶
type DataCenter_UploadServer interface { SendAndClose(*UploadResult) error Recv() (*Packet, error) grpc.ServerStream }
type HelloRequest ¶
type HelloRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HelloRequest) Descriptor ¶
func (*HelloRequest) Descriptor() ([]byte, []int)
func (*HelloRequest) GetName ¶
func (m *HelloRequest) GetName() string
func (*HelloRequest) ProtoMessage ¶
func (*HelloRequest) ProtoMessage()
func (*HelloRequest) Reset ¶
func (m *HelloRequest) Reset()
func (*HelloRequest) String ¶
func (m *HelloRequest) String() string
func (*HelloRequest) XXX_DiscardUnknown ¶
func (m *HelloRequest) XXX_DiscardUnknown()
func (*HelloRequest) XXX_Marshal ¶
func (m *HelloRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HelloRequest) XXX_Merge ¶
func (m *HelloRequest) XXX_Merge(src proto.Message)
func (*HelloRequest) XXX_Size ¶
func (m *HelloRequest) XXX_Size() int
func (*HelloRequest) XXX_Unmarshal ¶
func (m *HelloRequest) XXX_Unmarshal(b []byte) error
type HelloResponse ¶
type HelloResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HelloResponse) Descriptor ¶
func (*HelloResponse) Descriptor() ([]byte, []int)
func (*HelloResponse) GetMessage ¶
func (m *HelloResponse) GetMessage() string
func (*HelloResponse) ProtoMessage ¶
func (*HelloResponse) ProtoMessage()
func (*HelloResponse) Reset ¶
func (m *HelloResponse) Reset()
func (*HelloResponse) String ¶
func (m *HelloResponse) String() string
func (*HelloResponse) XXX_DiscardUnknown ¶
func (m *HelloResponse) XXX_DiscardUnknown()
func (*HelloResponse) XXX_Marshal ¶
func (m *HelloResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HelloResponse) XXX_Merge ¶
func (m *HelloResponse) XXX_Merge(src proto.Message)
func (*HelloResponse) XXX_Size ¶
func (m *HelloResponse) XXX_Size() int
func (*HelloResponse) XXX_Unmarshal ¶
func (m *HelloResponse) XXX_Unmarshal(b []byte) error
type Packet ¶
type Packet struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Packet) Descriptor ¶
func (*Packet) ProtoMessage ¶
func (*Packet) ProtoMessage()
func (*Packet) XXX_DiscardUnknown ¶
func (m *Packet) XXX_DiscardUnknown()
func (*Packet) XXX_Marshal ¶
func (*Packet) XXX_Unmarshal ¶
type UnimplementedDataCenterServer ¶
type UnimplementedDataCenterServer struct { }
UnimplementedDataCenterServer can be embedded to have forward compatible implementations.
func (*UnimplementedDataCenterServer) Download ¶
func (*UnimplementedDataCenterServer) Download(req *empty.Empty, srv DataCenter_DownloadServer) error
func (*UnimplementedDataCenterServer) SayHello ¶
func (*UnimplementedDataCenterServer) SayHello(ctx context.Context, req *HelloRequest) (*HelloResponse, error)
func (*UnimplementedDataCenterServer) Upload ¶
func (*UnimplementedDataCenterServer) Upload(srv DataCenter_UploadServer) error
type UploadResult ¶
type UploadResult struct { Size uint64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"` Checksum []byte `protobuf:"bytes,2,opt,name=checksum,proto3" json:"checksum,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UploadResult) Descriptor ¶
func (*UploadResult) Descriptor() ([]byte, []int)
func (*UploadResult) GetChecksum ¶
func (m *UploadResult) GetChecksum() []byte
func (*UploadResult) GetSize ¶
func (m *UploadResult) GetSize() uint64
func (*UploadResult) ProtoMessage ¶
func (*UploadResult) ProtoMessage()
func (*UploadResult) Reset ¶
func (m *UploadResult) Reset()
func (*UploadResult) String ¶
func (m *UploadResult) String() string
func (*UploadResult) XXX_DiscardUnknown ¶
func (m *UploadResult) XXX_DiscardUnknown()
func (*UploadResult) XXX_Marshal ¶
func (m *UploadResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UploadResult) XXX_Merge ¶
func (m *UploadResult) XXX_Merge(src proto.Message)
func (*UploadResult) XXX_Size ¶
func (m *UploadResult) XXX_Size() int
func (*UploadResult) XXX_Unmarshal ¶
func (m *UploadResult) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.