Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterFileTransferServiceServer(s grpc.ServiceRegistrar, srv FileTransferServiceServer)
- type FileRequest
- func (*FileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FileRequest) GetChunkNumber() int32
- func (x *FileRequest) GetFileName() string
- func (*FileRequest) ProtoMessage()
- func (x *FileRequest) ProtoReflect() protoreflect.Message
- func (x *FileRequest) Reset()
- func (x *FileRequest) String() string
- type FileResponse
- func (*FileResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FileResponse) GetChunk() *FileResponse_Chunk
- func (x *FileResponse) GetName() string
- func (x *FileResponse) GetStat() *FileResponse_Stat
- func (*FileResponse) ProtoMessage()
- func (x *FileResponse) ProtoReflect() protoreflect.Message
- func (x *FileResponse) Reset()
- func (x *FileResponse) String() string
- type FileResponse_Chunk
- func (*FileResponse_Chunk) Descriptor() ([]byte, []int)deprecated
- func (x *FileResponse_Chunk) GetChunkNumber() int32
- func (x *FileResponse_Chunk) GetChunkSize() int32
- func (x *FileResponse_Chunk) GetData() []byte
- func (x *FileResponse_Chunk) GetEnd() bool
- func (x *FileResponse_Chunk) GetTotalChunks() int32
- func (*FileResponse_Chunk) ProtoMessage()
- func (x *FileResponse_Chunk) ProtoReflect() protoreflect.Message
- func (x *FileResponse_Chunk) Reset()
- func (x *FileResponse_Chunk) String() string
- type FileResponse_Stat
- func (*FileResponse_Stat) Descriptor() ([]byte, []int)deprecated
- func (x *FileResponse_Stat) GetLastModified() *timestamppb.Timestamp
- func (x *FileResponse_Stat) GetTotalSize() int32
- func (*FileResponse_Stat) ProtoMessage()
- func (x *FileResponse_Stat) ProtoReflect() protoreflect.Message
- func (x *FileResponse_Stat) Reset()
- func (x *FileResponse_Stat) String() string
- type FileTransferServiceClient
- type FileTransferServiceServer
- type FileTransferService_GetFileClient
- type FileTransferService_GetFileServer
- type UnimplementedFileTransferServiceServer
- type UnsafeFileTransferServiceServer
Constants ¶
const (
FileTransferService_GetFile_FullMethodName = "/bigfile.v1.FileTransferService/GetFile"
)
Variables ¶
var FileTransferService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "bigfile.v1.FileTransferService", HandlerType: (*FileTransferServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "GetFile", Handler: _FileTransferService_GetFile_Handler, ServerStreams: true, }, }, Metadata: "proto/v1/bigfile.proto", }
FileTransferService_ServiceDesc is the grpc.ServiceDesc for FileTransferService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_proto_v1_bigfile_proto protoreflect.FileDescriptor
Functions ¶
func RegisterFileTransferServiceServer ¶
func RegisterFileTransferServiceServer(s grpc.ServiceRegistrar, srv FileTransferServiceServer)
Types ¶
type FileRequest ¶
type FileRequest struct { FileName string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"` ChunkNumber int32 `protobuf:"varint,2,opt,name=chunk_number,json=chunkNumber,proto3" json:"chunk_number,omitempty"` // contains filtered or unexported fields }
func (*FileRequest) Descriptor
deprecated
func (*FileRequest) Descriptor() ([]byte, []int)
Deprecated: Use FileRequest.ProtoReflect.Descriptor instead.
func (*FileRequest) GetChunkNumber ¶
func (x *FileRequest) GetChunkNumber() int32
func (*FileRequest) GetFileName ¶
func (x *FileRequest) GetFileName() string
func (*FileRequest) ProtoMessage ¶
func (*FileRequest) ProtoMessage()
func (*FileRequest) ProtoReflect ¶
func (x *FileRequest) ProtoReflect() protoreflect.Message
func (*FileRequest) Reset ¶
func (x *FileRequest) Reset()
func (*FileRequest) String ¶
func (x *FileRequest) String() string
type FileResponse ¶
type FileResponse struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Stat *FileResponse_Stat `protobuf:"bytes,2,opt,name=stat,proto3" json:"stat,omitempty"` Chunk *FileResponse_Chunk `protobuf:"bytes,3,opt,name=chunk,proto3" json:"chunk,omitempty"` // contains filtered or unexported fields }
func (*FileResponse) Descriptor
deprecated
func (*FileResponse) Descriptor() ([]byte, []int)
Deprecated: Use FileResponse.ProtoReflect.Descriptor instead.
func (*FileResponse) GetChunk ¶
func (x *FileResponse) GetChunk() *FileResponse_Chunk
func (*FileResponse) GetName ¶
func (x *FileResponse) GetName() string
func (*FileResponse) GetStat ¶
func (x *FileResponse) GetStat() *FileResponse_Stat
func (*FileResponse) ProtoMessage ¶
func (*FileResponse) ProtoMessage()
func (*FileResponse) ProtoReflect ¶
func (x *FileResponse) ProtoReflect() protoreflect.Message
func (*FileResponse) Reset ¶
func (x *FileResponse) Reset()
func (*FileResponse) String ¶
func (x *FileResponse) String() string
type FileResponse_Chunk ¶
type FileResponse_Chunk struct { ChunkNumber int32 `protobuf:"varint,1,opt,name=chunk_number,json=chunkNumber,proto3" json:"chunk_number,omitempty"` ChunkSize int32 `protobuf:"varint,2,opt,name=chunk_size,json=chunkSize,proto3" json:"chunk_size,omitempty"` TotalChunks int32 `protobuf:"varint,3,opt,name=total_chunks,json=totalChunks,proto3" json:"total_chunks,omitempty"` End bool `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"` Data []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*FileResponse_Chunk) Descriptor
deprecated
func (*FileResponse_Chunk) Descriptor() ([]byte, []int)
Deprecated: Use FileResponse_Chunk.ProtoReflect.Descriptor instead.
func (*FileResponse_Chunk) GetChunkNumber ¶
func (x *FileResponse_Chunk) GetChunkNumber() int32
func (*FileResponse_Chunk) GetChunkSize ¶
func (x *FileResponse_Chunk) GetChunkSize() int32
func (*FileResponse_Chunk) GetData ¶
func (x *FileResponse_Chunk) GetData() []byte
func (*FileResponse_Chunk) GetEnd ¶
func (x *FileResponse_Chunk) GetEnd() bool
func (*FileResponse_Chunk) GetTotalChunks ¶
func (x *FileResponse_Chunk) GetTotalChunks() int32
func (*FileResponse_Chunk) ProtoMessage ¶
func (*FileResponse_Chunk) ProtoMessage()
func (*FileResponse_Chunk) ProtoReflect ¶
func (x *FileResponse_Chunk) ProtoReflect() protoreflect.Message
func (*FileResponse_Chunk) Reset ¶
func (x *FileResponse_Chunk) Reset()
func (*FileResponse_Chunk) String ¶
func (x *FileResponse_Chunk) String() string
type FileResponse_Stat ¶
type FileResponse_Stat struct { LastModified *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"` TotalSize int32 `protobuf:"varint,2,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"` // contains filtered or unexported fields }
func (*FileResponse_Stat) Descriptor
deprecated
func (*FileResponse_Stat) Descriptor() ([]byte, []int)
Deprecated: Use FileResponse_Stat.ProtoReflect.Descriptor instead.
func (*FileResponse_Stat) GetLastModified ¶
func (x *FileResponse_Stat) GetLastModified() *timestamppb.Timestamp
func (*FileResponse_Stat) GetTotalSize ¶
func (x *FileResponse_Stat) GetTotalSize() int32
func (*FileResponse_Stat) ProtoMessage ¶
func (*FileResponse_Stat) ProtoMessage()
func (*FileResponse_Stat) ProtoReflect ¶
func (x *FileResponse_Stat) ProtoReflect() protoreflect.Message
func (*FileResponse_Stat) Reset ¶
func (x *FileResponse_Stat) Reset()
func (*FileResponse_Stat) String ¶
func (x *FileResponse_Stat) String() string
type FileTransferServiceClient ¶
type FileTransferServiceClient interface {
GetFile(ctx context.Context, in *FileRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[FileResponse], error)
}
FileTransferServiceClient is the client API for FileTransferService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewFileTransferServiceClient ¶
func NewFileTransferServiceClient(cc grpc.ClientConnInterface) FileTransferServiceClient
type FileTransferServiceServer ¶
type FileTransferServiceServer interface {
GetFile(*FileRequest, grpc.ServerStreamingServer[FileResponse]) error
}
FileTransferServiceServer is the server API for FileTransferService service. All implementations should embed UnimplementedFileTransferServiceServer for forward compatibility.
type FileTransferService_GetFileClient ¶
type FileTransferService_GetFileClient = grpc.ServerStreamingClient[FileResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type FileTransferService_GetFileServer ¶
type FileTransferService_GetFileServer = grpc.ServerStreamingServer[FileResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type UnimplementedFileTransferServiceServer ¶
type UnimplementedFileTransferServiceServer struct{}
UnimplementedFileTransferServiceServer should be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedFileTransferServiceServer) GetFile ¶
func (UnimplementedFileTransferServiceServer) GetFile(*FileRequest, grpc.ServerStreamingServer[FileResponse]) error
type UnsafeFileTransferServiceServer ¶
type UnsafeFileTransferServiceServer interface {
// contains filtered or unexported methods
}
UnsafeFileTransferServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FileTransferServiceServer will result in compilation errors.