moonbitstack/moonrpc/examples/21-annotations

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/examples/21-annotations does not have a README file

Badge

pub struct Badge {
  label : String
}

A dotted name nests the message in another: .greet.HelloReply.Badge.

impl Message for Badge

Greeter

source

pub struct Greeter {
  greeting : String
}

A service is a struct, so it carries state; its #rpc.methods are the RPCs, named in PascalCase. name is the full name, its package before the last dot.

Greeter::register

source

fn[R : @moonbitstack/moonrpc/stream.Registrar
Registrar] Greeter::register(self : Greeter, server : R) -> Unit

GreeterClient

source

pub struct GreeterClient[C] {
  channel : C
}

GreeterClient::add_up

source

async fn[C : @moonbitstack/moonrpc/client.Caller
Caller] GreeterClient::add_up(self : GreeterClient[C], req : Array[Number], metadata? : Array[@moonbitstack/moonhttp/header.Header
Header], timeout_millis? : Int, retry? : @moonbitstack/moonrpc/balance.Retry
Retry) -> Number

GreeterClient::count_to

source

async fn[C : @moonbitstack/moonrpc/client.Caller
Caller] GreeterClient::count_to(self : GreeterClient[C], req : Upto, metadata? : Array[@moonbitstack/moonhttp/header.Header
Header], timeout_millis? : Int, retry? : @moonbitstack/moonrpc/balance.Retry
Retry) -> Array[Number]

GreeterClient::echo

source

async fn[C : @moonbitstack/moonrpc/client.Caller
Caller] GreeterClient::echo(self : GreeterClient[C], req : Array[Number], metadata? : Array[@moonbitstack/moonhttp/header.Header
Header], timeout_millis? : Int, retry? : @moonbitstack/moonrpc/balance.Retry
Retry) -> Array[Number]

GreeterClient::new

source

fn[C] GreeterClient::new(channel : C) -> GreeterClient[C]

GreeterClient::say_hello

source

async fn[C : @moonbitstack/moonrpc/client.Caller
Caller] GreeterClient::say_hello(self : GreeterClient[C], req : HelloRequest, metadata? : Array[@moonbitstack/moonhttp/header.Header
Header], timeout_millis? : Int, retry? : @moonbitstack/moonrpc/balance.Retry
Retry) -> HelloReply

HelloReply

source

pub struct HelloReply {
  message : String
  calls : Int64
  scores : Array[Int]
  ratio : Double
  badges : Array[Badge]
  cached : Bool
}

impl Message for HelloReply

HelloRequest

source

pub struct HelloRequest {
  name : String
  tags : Array[String]
  nickname : String?
  mood : Mood
  extras : Map[String, Int64]
}

Fields are numbered in declaration order; number= sets one, and the count carries on from there. T? is proto3 optional, Map[K, V] is a map<K, V>.

impl Message for HelloRequest

Mood

source

pub enum Mood {
  Calm
  Glad
  Grumpy
}

An enum's values are numbered by its tags, or in order from 0, and named with the enum's name in front: MOOD_CALM. A number it does not know reads as its first value.

impl Enum for Mood

Number

source

pub struct Number {
  value : Int
}

impl Message for Number

Upto

source

pub struct Upto {
  n : Int
}

impl Message for Upto

descriptor

source

fn descriptor() -> @moonbitstack/moonrpc/proto.FileDescriptor
FileDescriptor

Source Files

Install

Download zip

gRPC for MoonBit.

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

moonbitstack

Apache-2.0