API
#github.com/xulang-org/packages/grpcgRPC & HTTP/2 High-Performance RPC Driver for Xu Implements HTTP/2 frame framing, HPACK headers, Protobuf serialization, and Unary RPC connection pooling.
github.com/xulang-org/packages · 0.1.1 · Install and use
struct Responsepub struct Response {
pub status int
pub message string
pub payload string
}Public struct `Response`.
status intmessage stringpayload stringstruct GrpcClientpub struct GrpcClient {
pub host string
pub port int
}Public struct `GrpcClient`.
host stringport intnew_clientpub fn new_client(endpoint string) GrpcClientConstruct client.
endpoint stringGrpcClient — a value of this type
(GrpcClient) read_h2_framepub fn (c GrpcClient) read_h2_frame(fd int) H2FrameMethod on `GrpcClient`: read h2 frame. Throws on failure.
c GrpcClientfd intH2Frame — a value of this type
(GrpcClient) connectpub fn (c GrpcClient) connect() intCall `connect` on `GrpcClient`. Throws on failure.
c GrpcClientint — a value of this type
(GrpcClient) call_unarypub fn (c GrpcClient) call_unary(path string, req_bytes string) ResponseExecutes an Unary RPC Call over HTTP/2 with gRPC framing Throws on failure.
c GrpcClientpath stringreq_bytes stringResponse — a value of this type
(GrpcClient) call_unary_on_fdpub fn (c GrpcClient) call_unary_on_fd(fd int, path string, req_bytes string, stream_id int) ResponseMethod on `GrpcClient`: call unary on fd. Throws on failure.
c GrpcClientfd intpath stringreq_bytes stringstream_id intResponse — a value of this type
const h2_client_prefacepub const h2_client_preface = "PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n"Public constant `h2_client_preface`. Value `"PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n"`.
none
const frame_datapub const frame_data = 0HTTP/2 Frame Types Value `0`.
none
const frame_headerspub const frame_headers = 1Public constant `frame_headers`. Value `1`.
none
const frame_prioritypub const frame_priority = 2Public constant `frame_priority`. Value `2`.
none
const frame_rst_streampub const frame_rst_stream = 3Public constant `frame_rst_stream`. Value `3`.
none
const frame_settingspub const frame_settings = 4Public constant `frame_settings`. Value `4`.
none
const frame_push_promisepub const frame_push_promise = 5Public constant `frame_push_promise`. Value `5`.
none
const frame_pingpub const frame_ping = 6Public constant `frame_ping`. Value `6`.
none
const frame_goawaypub const frame_goaway = 7Public constant `frame_goaway`. Value `7`.
none
const frame_window_updatepub const frame_window_update = 8Public constant `frame_window_update`. Value `8`.
none
const frame_continuationpub const frame_continuation = 9Public constant `frame_continuation`. Value `9`.
none
const flag_ackpub const flag_ack = 1HTTP/2 Flags Value `1`.
none
const flag_end_streampub const flag_end_stream = 1Public constant `flag_end_stream`. Value `1`.
none
const flag_end_headerspub const flag_end_headers = 4Public constant `flag_end_headers`. Value `4`.
none
const flag_paddedpub const flag_padded = 8Public constant `flag_padded`. Value `8`.
none
const flag_prioritypub const flag_priority = 32Public constant `flag_priority`. Value `32`.
none
struct H2Framepub struct H2Frame {
pub length int
pub frame_type int
pub flags int
pub stream_id int
pub payload string
}Public struct `H2Frame`.
length intframe_type intflags intstream_id intpayload stringencode_h2_headerpub fn encode_h2_header(len int, frame_type int, flags int, stream_id int) stringEncode.
len intframe_type intflags intstream_id intstring — result string
build_settings_framepub fn build_settings_frame(ack bool) stringBuild settings frame.
ack boolstring — result string
build_data_framepub fn build_data_frame(stream_id int, data string, end_stream bool) stringBuild data frame.
stream_id intdata stringend_stream boolstring — result string
build_grpc_hpack_headerspub fn build_grpc_hpack_headers(path string) stringBuilds HPACK block for gRPC request method: POST (Index 3 -> 0x83) scheme: http (Index 6 -> 0x86) path: path content-type: application/grpc te: trailers
path stringstring — result string
build_headers_framepub fn build_headers_frame(stream_id int, path string, end_stream bool) stringBuild headers frame.
stream_id intpath stringend_stream boolstring — result string
struct Poolpub struct Pool {
pub client GrpcClient
pub idle chan int
pub max_idle int
}Public struct `Pool`.
client GrpcClientidle chan intmax_idle intnew_poolpub fn new_pool(endpoint string, max_idle int) PoolConstruct pool.
endpoint stringmax_idle intPool — a value of this type
open_poolpub fn open_pool(endpoint string, max_idle int) PoolOpen pool.
endpoint stringmax_idle intPool — a value of this type
(&Pool) get_connpub fn (p &Pool) get_conn() intMethod on `&Pool`: read conn.
p &Poolint — a value of this type
(&Pool) put_connpub fn (p &Pool) put_conn(fd int)Method on `&Pool`: put connection.
p &Poolfd int(&Pool) call_unarypub fn (p &Pool) call_unary(path string, req_bytes string) ResponseMethod on `&Pool`: call unary. Throws on failure.
p &Poolpath stringreq_bytes stringResponse — a value of this type
(&Pool) closepub fn (p &Pool) close()Method on `&Pool`: close the resource.
p &Poolconst wire_varintpub const wire_varint = 0Protocol Buffers Wire Types Value `0`.
none
const wire_fixed64pub const wire_fixed64 = 1Public constant `wire_fixed64`. Value `1`.
none
const wire_length_delimitedpub const wire_length_delimited = 2Public constant `wire_length_delimited`. Value `2`.
none
const wire_fixed32pub const wire_fixed32 = 5Public constant `wire_fixed32`. Value `5`.
none
encode_varintpub fn encode_varint(val int) stringEncode.
val intstring — result string
struct VarintResultpub struct VarintResult {
pub value int
pub bytes_read int
}Public struct `VarintResult`.
value intbytes_read intdecode_varint_fullpub fn decode_varint_full(buf &string, pos int) VarintResultDecode.
buf &stringpos intVarintResult — a value of this type
decode_varintpub fn decode_varint(buf &string, pos int) intDecode.
buf &stringpos intint — a value of this type
encode_tagpub fn encode_tag(field_num int, wire_type int) stringEncode.
field_num intwire_type intstring — result string
encode_string_fieldpub fn encode_string_field(field_num int, val string) stringEncode.
field_num intval stringstring — result string
encode_int_fieldpub fn encode_int_field(field_num int, val int) stringEncode.
field_num intval intstring — result string
build_grpc_messagepub fn build_grpc_message(payload string) stringPackages Protobuf payload into a 5-byte prefixed gRPC frame [1 byte compressed flag] + [4 bytes big-endian length] + [payload]
payload stringstring — result string
parse_grpc_messagepub fn parse_grpc_message(raw string) stringParses gRPC message frame and extracts raw protobuf payload
raw stringstring — result string
decode_grpc_messagepub fn decode_grpc_message(raw string) stringDecode. Throws on failure.
raw stringstring — result string
get_string_fieldpub fn get_string_field(payload string, target_field int) stringRead string field.
payload stringtarget_field intstring — result string
get_int_fieldpub fn get_int_field(payload string, target_field int) intRead int field.
payload stringtarget_field intint — a value of this type