bench

type BenchServiceClient interface {
	Echo(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption) (*EchoReply, error)
	Download(ctx context.Context, in *DownloadRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Chunk], error)
	// Read is a fast unary range read (the FUSE cache-miss path): one small round trip on
	// the QUIC interactive channel, isolated from TCP bulk.
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadReply, error)
}

type BenchServiceServer interface {
	Echo(context.Context, *EchoRequest) (*EchoReply, error)
	Download(*DownloadRequest, grpc.ServerStreamingServer[Chunk]) error
	// Read is a fast unary range read (the FUSE cache-miss path): one small round trip on
	// the QUIC interactive channel, isolated from TCP bulk.
	Read(context.Context, *ReadRequest) (*ReadReply, error)
	// contains filtered or unexported methods
}

type BenchService_DownloadClient = grpc.ServerStreamingClient[Chunk]

type BenchService_DownloadServer = grpc.ServerStreamingServer[Chunk]

type Chunk struct {
	Data   []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` // byte offset of this chunk within the stream
	// contains filtered or unexported fields
}

type DownloadRequest struct {
	TotalBytes  uint64 `protobuf:"varint,1,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"`    // total size of the transfer
	ChunkSize   uint32 `protobuf:"varint,2,opt,name=chunk_size,json=chunkSize,proto3" json:"chunk_size,omitempty"`       // bytes per Chunk (0 -> server default)
	StartOffset uint64 `protobuf:"varint,3,opt,name=start_offset,json=startOffset,proto3" json:"start_offset,omitempty"` // resume point: stream from here to total_bytes (0 = from start)
	// contains filtered or unexported fields
}

type EchoReply struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type EchoRequest struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type ReadReply struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type ReadRequest struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` // byte offset within the file
	Length uint32 `protobuf:"varint,2,opt,name=length,proto3" json:"length,omitempty"` // bytes to read
	// contains filtered or unexported fields
}

type UnimplementedBenchServiceServer struct{}

type UnsafeBenchServiceServer interface {
	// contains filtered or unexported methods
}