moonbitstack/moonrpc/thrift

README
U
Attempts
U
Backoff
U
BidiHandler
U
Call
U
CallInfo
U
CallReply
U
Caller
U
ChannelNode
U
ChannelzService
U
ClientCall
U
ConnStats
U
ConnectionPool
U
ConnectivityState
U
Counters
U
DnsRecord
U
DnsResponse
U
Encoding
U
Enum
U
EnumDescriptor
U
EnumValueDescriptor
U
FieldDescriptor
U
FieldLabel
U
FieldType
U
FileDescriptor
U
H2Client
U
H2Server
U
Handler
U
Header
U
HealthService
U
Hedging
U
Invocation
U
Keepalive
U
LbPolicy
U
LoadBalancer
U
Message
U
MessageDescriptor
U
Method
U
MethodConfig
U
MethodDescriptor
U
PbError
U
PbReader
U
PbWriter
U
Pushback
U
Reconnect
U
ReflectionRequest
U
ReflectionResponse
U
ReflectionService
U
Registrar
U
Registry
U
Responder
U
Retry
U
RpcContext
U
RpcStats
U
ServerNode
U
ServiceConfig
U
ServiceDescriptor
U
ServingStatus
U
SrvStream
U
StatsHandler
U
Status
U
StatusDetails
U
StatusError
U
Stream
U
StreamError
U
StreamEvent
U
StreamInterceptor
U
StreamState
U
SubConn
U
Throttle
U
Throttling
U
UnaryInterceptor
U
WireType
V
accept_encodings
V
backoff
V
bidi
V
bidi_each
V
channel_path
V
client_streaming
V
decode_file_descriptor_set
V
decode_health_request
V
decode_health_response
V
decode_message
V
decode_reflection_request
V
decode_reflection_response
V
decode_status_details
V
default_max_frame_size
V
default_max_streams
V
default_window_size
V
detail_body
V
detail_type_url
V
dns_decode_response
V
dns_encode_query
V
dns_type_a
V
dns_type_aaaa
V
encode_file_descriptor_set
V
encode_grpc_timeout
V
encode_health_request
V
encode_health_response
V
encode_message
V
encode_reflection_request
V
health_check_path
V
health_watch_path
V
hedging
V
is_binary_metadata
V
limit
V
max_header_list_size
V
max_message_size
V
message_len
V
metadata_value_from_wire
V
metadata_value_to_wire
V
negotiated
V
parse_grpc_timeout
V
percent_decode
V
reflection_v1_path
V
reflection_v1alpha_path
V
retry
V
server_path
V
server_sockets_path
V
server_streaming
V
servers_path
V
socket_path
V
split_messages
V
stream_id_valid_for_initiator
V
stream_is_client_initiated
V
stream_is_server_initiated
V
subchannel_path
V
top_channels_path
V
unary

moonbitstack/moonrpc/thrift does not have a README file

Method

type Method = (&Protocol) -> Unit raise ThriftError

One method: read its arguments from the protocol, write its result fields (field 0 for a success value).

Protocol

source

pub(open) trait Protocol {
  fn reset(Self, Bytes) -> Unit
  fn output(Self) -> Bytes
  fn read_message_begin(Self) -> (String, Int, Int) raise ThriftError
  fn write_message_begin(Self, String, Int, Int) -> Unit
  fn read_struct_begin(Self) -> Unit
  fn read_struct_end(Self) -> Unit
  fn write_struct_begin(Self, String) -> Unit
  fn write_struct_end(Self) -> Unit
  fn read_field_begin(Self) -> (Int, Int) raise ThriftError
  fn write_field_begin(Self, Int, Int) -> Unit
  fn write_field_stop(Self) -> Unit
  fn read_bool(Self) -> Bool raise ThriftError
  fn read_byte(Self) -> Int raise ThriftError
  fn read_i16(Self) -> Int raise ThriftError
  fn read_i32(Self) -> Int raise ThriftError
  fn read_i64(Self) -> Int64 raise ThriftError
  fn read_double(Self) -> Double raise ThriftError
  fn read_string(Self) -> String raise ThriftError
  fn read_bytes(Self) -> Bytes raise ThriftError
  fn read_list_begin(Self) -> (Int, Int) raise ThriftError
  fn read_map_begin(Self) -> (Int, Int, Int) raise ThriftError
  fn write_bool(Self, Bool) -> Unit
  fn write_byte(Self, Int) -> Unit
  fn write_i16(Self, Int) -> Unit
  fn write_i32(Self, Int) -> Unit
  fn write_i64(Self, Int64) -> Unit
  fn write_double(Self, Double) -> Unit
  fn write_string(Self, String) -> Unit
  fn write_bytes(Self, Bytes) -> Unit
  fn write_list_begin(Self, Int, Int) -> Unit
  fn write_map_begin(Self, Int, Int, Int) -> Unit
}

One message's worth of reading and writing. reset points a protocol at the bytes to read and clears what it has written, so one object serves a whole connection: read a frame, write the reply, read the next frame.

Both byte orders live behind this contract. TBinaryProtocol writes fixed-width big-endian numbers; TCompactProtocol writes zigzag varints and encodes a boolean's value inside its field header. Nothing above this trait — the processor, the client request, a service's handlers — knows which one it is talking to.

Transport

source

pub(open) trait Transport {
  async fn round_trip(Self, Bytes) -> Bytes raise ThriftError
}

One framed round trip: a body out, a body back. The native driver puts a length prefix on it; an in-memory transport can carry the bytes directly.

ThriftError

source

pub(all) suberror ThriftError {
  BadVersion(Int)
  Truncated
  BadType(Int)
  Depth
  Unsupported(String)
  Application(String)
}

impl Show for ThriftError

ThriftError::output

source

fn ThriftError::output(self : ThriftError, logger : &Logger) -> Unit

ThriftError::to_string

source

fn ThriftError::to_string(self : ThriftError) -> String

Binary

source

pub struct Binary {
  data : Bytes
  off : Int
  out : @moonbitlang/core/buffer.Buffer
Buffer
}

A binary-protocol reader and writer over one message.

impl Protocol for Binary

fn output(self : Binary) -> Bytes

source

fn read_bool(self : Binary) -> Bool raise ThriftError

source

fn read_byte(self : Binary) -> Int raise ThriftError

source

fn read_bytes(self : Binary) -> Bytes raise ThriftError

source

fn read_double(self : Binary) -> Double raise ThriftError

source

fn read_field_begin(self : Binary) -> (Int, Int) raise ThriftError

source

fn read_i16(self : Binary) -> Int raise ThriftError

source

fn read_i32(self : Binary) -> Int raise ThriftError

source

fn read_i64(self : Binary) -> Int64 raise ThriftError

source

fn read_list_begin(self : Binary) -> (Int, Int) raise ThriftError

source

fn read_map_begin(self : Binary) -> (Int, Int, Int) raise ThriftError

source

fn read_message_begin(self : Binary) -> (String, Int, Int) raise ThriftError

source

fn read_string(self : Binary) -> String raise ThriftError

source

fn read_struct_begin(self : Binary) -> Unit

source

fn read_struct_end(self : Binary) -> Unit

source

fn reset(self : Binary, input : Bytes) -> Unit

source

fn write_bool(self : Binary, value : Bool) -> Unit

source

fn write_byte(self : Binary, value : Int) -> Unit

source

fn write_bytes(self : Binary, body : Bytes) -> Unit

source

fn write_double(self : Binary, value : Double) -> Unit

source

fn write_field_begin(self : Binary, type_ : Int, id : Int) -> Unit

source

fn write_field_stop(self : Binary) -> Unit

source

fn write_i16(self : Binary, value : Int) -> Unit

source

fn write_i32(self : Binary, value : Int) -> Unit

source

fn write_i64(self : Binary, value : Int64) -> Unit

source

fn write_list_begin(self : Binary, elem : Int, size : Int) -> Unit

source

fn write_map_begin(self : Binary, key : Int, value : Int, size : Int) -> Unit

source

fn write_message_begin(self : Binary, name : String, kind : Int, seqid : Int) -> Unit

source

fn write_string(self : Binary, value : String) -> Unit

source

fn write_struct_begin(self : Binary, name : String) -> Unit

source

fn write_struct_end(self : Binary) -> Unit

source

Binary::eof

source

fn Binary::eof(self : Binary) -> Bool

Binary::new

source

fn Binary::new(input : Bytes) -> Binary

Binary::output

source

fn Binary::output(self : Binary) -> Bytes

Binary::read_bool

source

fn Binary::read_bool(self : Binary) -> Bool raise ThriftError

Binary::read_byte

source

fn Binary::read_byte(self : Binary) -> Int raise ThriftError

Binary::read_bytes

source

fn Binary::read_bytes(self : Binary) -> Bytes raise ThriftError

Binary::read_double

source

fn Binary::read_double(self : Binary) -> Double raise ThriftError

Binary::read_field_begin

source

fn Binary::read_field_begin(self : Binary) -> (Int, Int) raise ThriftError

Binary::read_i16

source

fn Binary::read_i16(self : Binary) -> Int raise ThriftError

Binary::read_i32

source

fn Binary::read_i32(self : Binary) -> Int raise ThriftError

Binary::read_i64

source

fn Binary::read_i64(self : Binary) -> Int64 raise ThriftError

Binary::read_list_begin

source

fn Binary::read_list_begin(self : Binary) -> (Int, Int) raise ThriftError

Binary::read_map_begin

source

fn Binary::read_map_begin(self : Binary) -> (Int, Int, Int) raise ThriftError

Binary::read_message_begin

source

fn Binary::read_message_begin(self : Binary) -> (String, Int, Int) raise ThriftError

Binary::read_string

source

fn Binary::read_string(self : Binary) -> String raise ThriftError

Binary::read_struct_begin

source

fn Binary::read_struct_begin(self : Binary) -> Unit

Binary::read_struct_end

source

fn Binary::read_struct_end(self : Binary) -> Unit

Binary::reset

source

fn Binary::reset(self : Binary, input : Bytes) -> Unit

Binary::write_bool

source

fn Binary::write_bool(self : Binary, value : Bool) -> Unit

Binary::write_byte

source

fn Binary::write_byte(self : Binary, value : Int) -> Unit

Binary::write_bytes

source

fn Binary::write_bytes(self : Binary, body : Bytes) -> Unit

Binary::write_double

source

fn Binary::write_double(self : Binary, value : Double) -> Unit

Binary::write_field_begin

source

fn Binary::write_field_begin(self : Binary, type_ : Int, id : Int) -> Unit

Binary::write_field_stop

source

fn Binary::write_field_stop(self : Binary) -> Unit

Binary::write_i16

source

fn Binary::write_i16(self : Binary, value : Int) -> Unit

Binary::write_i32

source

fn Binary::write_i32(self : Binary, value : Int) -> Unit

Binary::write_i64

source

fn Binary::write_i64(self : Binary, value : Int64) -> Unit

Binary::write_list_begin

source

fn Binary::write_list_begin(self : Binary, elem : Int, size : Int) -> Unit

Binary::write_map_begin

source

fn Binary::write_map_begin(self : Binary, key : Int, value : Int, size : Int) -> Unit

Binary::write_message_begin

source

fn Binary::write_message_begin(self : Binary, name : String, kind : Int, seqid : Int) -> Unit

Binary::write_string

source

fn Binary::write_string(self : Binary, value : String) -> Unit

Binary::write_struct_begin

source

fn Binary::write_struct_begin(self : Binary, name : String) -> Unit

Binary::write_struct_end

source

fn Binary::write_struct_end(self : Binary) -> Unit

Compact

source

pub struct Compact {
  data : Bytes
  off : Int
  out : @moonbitlang/core/buffer.Buffer
Buffer
  last_field : Int
  field_stack : Array[Int]
  pending_field : Bool
  pending_id : Int
  bool_value : Bool
  bool_ready : Bool
}

A compact-protocol reader and writer over one message.

impl Protocol for Compact

fn output(self : Compact) -> Bytes

source

fn read_bool(self : Compact) -> Bool raise ThriftError

source

fn read_byte(self : Compact) -> Int raise ThriftError

source

fn read_bytes(self : Compact) -> Bytes raise ThriftError

source

fn read_double(self : Compact) -> Double raise ThriftError

source

fn read_field_begin(self : Compact) -> (Int, Int) raise ThriftError

source

fn read_i16(self : Compact) -> Int raise ThriftError

source

fn read_i32(self : Compact) -> Int raise ThriftError

source

fn read_i64(self : Compact) -> Int64 raise ThriftError

source

fn read_list_begin(self : Compact) -> (Int, Int) raise ThriftError

source

fn read_map_begin(self : Compact) -> (Int, Int, Int) raise ThriftError

source

fn read_message_begin(self : Compact) -> (String, Int, Int) raise ThriftError

source

fn read_string(self : Compact) -> String raise ThriftError

source

fn read_struct_begin(self : Compact) -> Unit

source

fn read_struct_end(self : Compact) -> Unit

source

fn reset(self : Compact, input : Bytes) -> Unit

source

fn write_bool(self : Compact, value : Bool) -> Unit

source

fn write_byte(self : Compact, value : Int) -> Unit

source

fn write_bytes(self : Compact, body : Bytes) -> Unit

source

fn write_double(self : Compact, value : Double) -> Unit

source

fn write_field_begin(self : Compact, type_ : Int, id : Int) -> Unit

source

fn write_field_stop(self : Compact) -> Unit

source

fn write_i16(self : Compact, value : Int) -> Unit

source

fn write_i32(self : Compact, value : Int) -> Unit

source

fn write_i64(self : Compact, value : Int64) -> Unit

source

fn write_list_begin(self : Compact, elem : Int, size : Int) -> Unit

source

fn write_map_begin(self : Compact, key : Int, value : Int, size : Int) -> Unit

source

fn write_message_begin(self : Compact, name : String, kind : Int, seqid : Int) -> Unit

source

fn write_string(self : Compact, value : String) -> Unit

source

fn write_struct_begin(self : Compact, name : String) -> Unit

source

fn write_struct_end(self : Compact) -> Unit

source

Compact::new

source

fn Compact::new(input : Bytes) -> Compact

Compact::output

source

fn Compact::output(self : Compact) -> Bytes

Compact::read_bool

source

fn Compact::read_bool(self : Compact) -> Bool raise ThriftError

Compact::read_byte

source

fn Compact::read_byte(self : Compact) -> Int raise ThriftError

Compact::read_bytes

source

fn Compact::read_bytes(self : Compact) -> Bytes raise ThriftError

Compact::read_double

source

fn Compact::read_double(self : Compact) -> Double raise ThriftError

Compact::read_field_begin

source

fn Compact::read_field_begin(self : Compact) -> (Int, Int) raise ThriftError

Compact::read_i16

source

fn Compact::read_i16(self : Compact) -> Int raise ThriftError

Compact::read_i32

source

fn Compact::read_i32(self : Compact) -> Int raise ThriftError

Compact::read_i64

source

fn Compact::read_i64(self : Compact) -> Int64 raise ThriftError

Compact::read_list_begin

source

fn Compact::read_list_begin(self : Compact) -> (Int, Int) raise ThriftError

Compact::read_map_begin

source

fn Compact::read_map_begin(self : Compact) -> (Int, Int, Int) raise ThriftError

Compact::read_message_begin

source

fn Compact::read_message_begin(self : Compact) -> (String, Int, Int) raise ThriftError

Compact::read_string

source

fn Compact::read_string(self : Compact) -> String raise ThriftError

Compact::read_struct_begin

source

fn Compact::read_struct_begin(self : Compact) -> Unit

Compact::read_struct_end

source

fn Compact::read_struct_end(self : Compact) -> Unit

Compact::reset

source

fn Compact::reset(self : Compact, input : Bytes) -> Unit

Compact::write_bool

source

fn Compact::write_bool(self : Compact, value : Bool) -> Unit

Compact::write_byte

source

fn Compact::write_byte(self : Compact, value : Int) -> Unit

Compact::write_bytes

source

fn Compact::write_bytes(self : Compact, body : Bytes) -> Unit

Compact::write_double

source

fn Compact::write_double(self : Compact, value : Double) -> Unit

Compact::write_field_begin

source

fn Compact::write_field_begin(self : Compact, type_ : Int, id : Int) -> Unit

Compact::write_field_stop

source

fn Compact::write_field_stop(self : Compact) -> Unit

Compact::write_i16

source

fn Compact::write_i16(self : Compact, value : Int) -> Unit

Compact::write_i32

source

fn Compact::write_i32(self : Compact, value : Int) -> Unit

Compact::write_i64

source

fn Compact::write_i64(self : Compact, value : Int64) -> Unit

Compact::write_list_begin

source

fn Compact::write_list_begin(self : Compact, elem : Int, size : Int) -> Unit

Compact::write_map_begin

source

fn Compact::write_map_begin(self : Compact, key : Int, value : Int, size : Int) -> Unit

Compact::write_message_begin

source

fn Compact::write_message_begin(self : Compact, name : String, kind : Int, seqid : Int) -> Unit

Compact::write_string

source

fn Compact::write_string(self : Compact, value : String) -> Unit

Compact::write_struct_begin

source

fn Compact::write_struct_begin(self : Compact, name : String) -> Unit

Compact::write_struct_end

source

fn Compact::write_struct_end(self : Compact) -> Unit

Processor

source

pub(all) struct Processor {
  methods : Map[String, (&Protocol) -> Unit raise ThriftError]
}

A dispatcher over method names, one Method each.

Processor::add

source

fn Processor::add(self : Processor, name : String, handler : (&Protocol) -> Unit raise ThriftError) -> Unit

Processor::new

source

fn Processor::new() -> Processor

Processor::process

source

fn Processor::process(self : Processor, proto : &Protocol, frame : Bytes) -> Bytes raise ThriftError

Answer one CALL frame. A method that is not registered gets a TApplicationException with UNKNOWN_METHOD, as Apache Thrift's processors do. A ONEWAY call is run and answered with no bytes.

call

source

async fn[T : Transport, R] call(transport : T, proto : &Protocol, name : String, seqid : Int, args : (&Protocol) -> Unit raise ThriftError, read : (&Protocol) -> R raise ThriftError) -> R raise ThriftError

Send one CALL and decode its success value with read.

call_result

source

async fn[T : Transport, R, E] call_result(transport : T, proto : &Protocol, name : String, seqid : Int, args : (&Protocol) -> Unit raise ThriftError, read : (&Protocol) -> R raise ThriftError, exception : (&Protocol, Int) -> E? raise ThriftError) -> Result[R, E] raise ThriftError

Send one CALL and read a result that may be a declared exception.

call_result_unit

source

async fn[T : Transport, E] call_result_unit(transport : T, proto : &Protocol, name : String, seqid : Int, args : (&Protocol) -> Unit raise ThriftError, exception : (&Protocol, Int) -> E? raise ThriftError) -> Result[Unit, E] raise ThriftError

The same, for a method that returns nothing and may still throw.

frame

source

fn frame(body : Bytes) -> Bytes

A length-prefixed frame, as TFramedTransport writes it.

frame_len

source

fn frame_len(header : Bytes) -> Int raise ThriftError

The body length a frame header announces.

max_depth

source

let max_depth : Int

The largest nesting skip will follow before giving up.

max_frame

source

let max_frame : Int

The largest framed body this library will accept, in octets.

message_call

source

let message_call : Int

message_exception

source

let message_exception : Int

message_oneway

source

let message_oneway : Int

message_reply

source

let message_reply : Int

read_result

source

fn[R, E] read_result(proto : &Protocol, read : (&Protocol) -> R raise ThriftError, exception : (&Protocol, Int) -> E? raise ThriftError) -> Result[R, E] raise ThriftError

Read a result struct whose method declares exceptions: field 0 is the success value, any other field is a failure that exception decodes by its field id. The decoder answers None for a field it does not know and must not have read it; that one is skipped and raised as Application, so a failure nobody declared is not swallowed as a value.

read_result_unit

source

fn[E] read_result_unit(proto : &Protocol, exception : (&Protocol, Int) -> E? raise ThriftError) -> Result[Unit, E] raise ThriftError

The same, for a method that answers nothing: an empty result struct is success.

read_success

source

fn[R] read_success(proto : &Protocol, read : (&Protocol) -> R raise ThriftError) -> R raise ThriftError

Read a result struct: field 0 is the success value; any other field is an exception, whose string message (when it has one) is raised.

request

source

async fn[T : Transport] request(transport : T, proto : &Protocol, name : String, seqid : Int, args : (&Protocol) -> Unit raise ThriftError) -> Unit raise ThriftError

Send one CALL and leave proto positioned inside its result struct.

skip

source

fn skip(proto : &Protocol, type_ : Int) -> Unit raise ThriftError

Walk past one value of type_, whatever it contains.

type_bool

source

let type_bool : Int

type_byte

source

let type_byte : Int

type_double

source

let type_double : Int

type_i16

source

let type_i16 : Int

type_i32

source

let type_i32 : Int

type_i64

source

let type_i64 : Int

type_list

source

let type_list : Int

type_map

source

let type_map : Int

type_set

source

let type_set : Int

type_stop

source

let type_stop : Int

type_string

source

let type_string : Int

type_struct

source

let type_struct : Int

Source Files

Install

Download zip

gRPC for MoonBit.

grpcrpcprotobufprotocol-buffershttp2microservicestreamingunarybidirectional-streaminginterceptorload-balancinghealth-checkreflectiontlscompressiongzipdeflatedeadlineretrykeepaliveannotationsstatschannelzservice-configwait-for-readyinteropthriftidlgrpc-gowasmmoonbit

moonbitstack

Apache-2.0

github.com/moonbitstack/moonrpc

Updated 10 hours ago

980 downloads

Site source Report issue Modules Skills CLI Build queue Statistics

#Method

#Protocol

#Transport

#ThriftError

#ThriftError::output

#ThriftError::to_string

#Binary

#Binary::eof

#Binary::new

#Binary::output

#Binary::read_bool

#Binary::read_byte

#Binary::read_bytes

#Binary::read_double

#Binary::read_field_begin

#Binary::read_i16

#Binary::read_i32

#Binary::read_i64

#Binary::read_list_begin

#Binary::read_map_begin

#Binary::read_message_begin

#Binary::read_string

#Binary::read_struct_begin

#Binary::read_struct_end

#Binary::reset

#Binary::write_bool

#Binary::write_byte

#Binary::write_bytes

#Binary::write_double

#Binary::write_field_begin

#Binary::write_field_stop

#Binary::write_i16

#Binary::write_i32

#Binary::write_i64

#Binary::write_list_begin

#Binary::write_map_begin

#Binary::write_message_begin

#Binary::write_string

#Binary::write_struct_begin

#Binary::write_struct_end

#Compact

#Compact::new

#Compact::output

#Compact::read_bool

#Compact::read_byte

#Compact::read_bytes

#Compact::read_double

#Compact::read_field_begin

#Compact::read_i16

#Compact::read_i32

#Compact::read_i64

#Compact::read_list_begin

#Compact::read_map_begin

#Compact::read_message_begin

#Compact::read_string

#Compact::read_struct_begin

#Compact::read_struct_end

#Compact::reset

#Compact::write_bool

#Compact::write_byte

#Compact::write_bytes

#Compact::write_double

#Compact::write_field_begin

#Compact::write_field_stop

#Compact::write_i16

#Compact::write_i32

#Compact::write_i64

#Compact::write_list_begin

#Compact::write_map_begin

#Compact::write_message_begin

#Compact::write_string

#Compact::write_struct_begin

#Compact::write_struct_end

#Processor

#Processor::add

#Processor::new

#Processor::process

#call

#call_result

#call_result_unit

Method

Protocol

Transport

ThriftError

ThriftError::output

ThriftError::to_string

Binary

Binary::eof

Binary::new

Binary::output

Binary::read_bool

Binary::read_byte

Binary::read_bytes

Binary::read_double

Binary::read_field_begin

Binary::read_i16

Binary::read_i32

Binary::read_i64

Binary::read_list_begin

Binary::read_map_begin

Binary::read_message_begin

Binary::read_string

Binary::read_struct_begin

Binary::read_struct_end

Binary::reset

Binary::write_bool

Binary::write_byte

Binary::write_bytes

Binary::write_double

Binary::write_field_begin

Binary::write_field_stop

Binary::write_i16

Binary::write_i32

Binary::write_i64

Binary::write_list_begin

Binary::write_map_begin

Binary::write_message_begin

Binary::write_string

Binary::write_struct_begin

Binary::write_struct_end

Compact

Compact::new

Compact::output

Compact::read_bool

Compact::read_byte

Compact::read_bytes

Compact::read_double

Compact::read_field_begin

Compact::read_i16

Compact::read_i32

Compact::read_i64

Compact::read_list_begin

Compact::read_map_begin

Compact::read_message_begin

Compact::read_string

Compact::read_struct_begin

Compact::read_struct_end

Compact::reset

Compact::write_bool

Compact::write_byte

Compact::write_bytes

Compact::write_double

Compact::write_field_begin

Compact::write_field_stop

Compact::write_i16

Compact::write_i32

Compact::write_i64

Compact::write_list_begin

Compact::write_map_begin

Compact::write_message_begin

Compact::write_string

Compact::write_struct_begin

Compact::write_struct_end

Processor

Processor::add

Processor::new

Processor::process

call

call_result

call_result_unit