moonbitstack/moonrpc/service

README
U
Attempts
U
BidiHandler
U
CallReply
U
ClientCall
U
ConnectionPool
U
ConnectivityState
U
DnsRecord
U
DnsResponse
U
FieldDescriptor
U
FieldLabel
U
FieldType
U
FileDescriptor
U
H2Client
U
H2Server
U
Handler
U
HealthService
U
Hedging
U
Keepalive
U
LbPolicy
U
LoadBalancer
U
MessageDescriptor
U
Method
U
MethodDescriptor
U
PbError
U
PbReader
U
PbWriter
U
Pushback
U
ReflectionRequest
U
ReflectionResponse
U
ReflectionService
U
Retry
U
RpcContext
U
ServiceDescriptor
U
ServingStatus
U
SrvStream
U
Status
U
Stream
U
StreamError
U
StreamEvent
U
StreamInterceptor
U
StreamState
U
SubConn
U
Throttle
U
Throttling
U
UnaryInterceptor
U
WireType
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
default_max_frame_size
V
default_max_streams
V
default_window_size
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
parse_grpc_timeout
V
percent_decode
V
reflection_v1_path
V
reflection_v1alpha_path
V
retry
V
split_messages
V
stream_id_valid_for_initiator
V
stream_is_client_initiated
V
stream_is_server_initiated

moonbitstack/moonrpc/service does not have a README file

HealthService

pub struct HealthService {
  statuses : Map[String, ServingStatus]
}

A grpc.health.v1.Health service backed by a per-service status table. The empty key "" is the overall-server status; a fresh service reports the whole server SERVING.

HealthService::check

source

fn HealthService::check(self : HealthService, service : String) -> ServingStatus

The serving status of a named service: its set status, or ServiceUnknown when the service was never registered.

HealthService::handlers

source

fn HealthService::handlers(self : HealthService) -> Array[(String, @moonbitstack/moonrpc/stream.Handler
Handler)]

The (path, handler) pairs implementing the service: Check as a unary method and Watch as a server-streaming method that emits the current status. A live Watch that also pushes on every later change needs a streaming source the pure engine's eager ServerStreaming shape does not model, so this emits the status at subscribe time — the first message a real Watch always sends.

HealthService::install

source

fn HealthService::install(self : HealthService, server : @moonbitstack/moonrpc/server.H2Server
H2Server) -> Unit

HealthService::new

source

fn HealthService::new() -> HealthService

A health service reporting the overall server as SERVING.

HealthService::set_status

source

fn HealthService::set_status(self : HealthService, service : String, status : ServingStatus) -> Unit

Set the serving status of a named service (or the overall server with "").

ReflectionRequest

source

pub(all) enum ReflectionRequest {
  ListServices(String)
  FileByFilename(String)
  FileContainingSymbol(String)
  Unsupported
} derive(Eq)

A decoded ServerReflectionRequest, reduced to the one message_request oneof arm that was set. Extension-number queries are surfaced as Unsupported, which the service answers with an UNIMPLEMENTED error response.

ReflectionRequest::equal

source

fn ReflectionRequest::equal(ReflectionRequest, ReflectionRequest) -> Bool

ReflectionRequest::not_equal

source

fn ReflectionRequest::not_equal(x : ReflectionRequest, y : ReflectionRequest) -> Bool

ReflectionResponse

source

pub(all) enum ReflectionResponse {
  ServiceList(Array[String])
  FileDescriptors(Array[Bytes])
  ReflectionError(Int, String)
} derive(Eq)

A decoded ServerReflectionResponse, reduced to the one message_response arm.

ReflectionResponse::equal

source

fn ReflectionResponse::equal(ReflectionResponse, ReflectionResponse) -> Bool

ReflectionResponse::not_equal

source

fn ReflectionResponse::not_equal(x : ReflectionResponse, y : ReflectionResponse) -> Bool

ReflectionService

source

pub struct ReflectionService {
  files : Array[@moonbitstack/moonrpc/proto.FileDescriptor
FileDescriptor]
  by_symbol : Map[String, Int]
  by_filename : Map[String, Int]
  services : Array[String]
}

A grpc.reflection.v1.ServerReflection service backed by an in-memory descriptor database. Each added FileDescriptor is indexed by filename and by every symbol (package.Service / package.Message) it defines, so a FileContainingSymbol or FileByFilename query resolves to the right file, and ListServices enumerates every registered service.

ReflectionService::add_file

source

fn ReflectionService::add_file(self : ReflectionService, file : @moonbitstack/moonrpc/proto.FileDescriptor
FileDescriptor) -> Unit

Register a file descriptor: index it by filename and by each symbol it defines, and add its services to the ListServices set.

ReflectionService::handle

source

fn ReflectionService::handle(self : ReflectionService, request : Bytes) -> Bytes

Answer one ServerReflectionRequest (raw bytes) with the encoded ServerReflectionResponse. A decode failure or an unknown symbol/filename yields an ErrorResponse rather than raising, since it rides a non-raising stream handler.

ReflectionService::handler

source

fn ReflectionService::handler(self : ReflectionService) -> @moonbitstack/moonrpc/stream.Handler
Handler

The bidi handler backing ServerReflectionInfo: one response per request, none at half-close.

ReflectionService::install

source

fn ReflectionService::install(self : ReflectionService, server : @moonbitstack/moonrpc/server.H2Server
H2Server) -> Unit

ReflectionService::new

source

fn ReflectionService::new() -> ReflectionService

An empty reflection service. Add the descriptors of the services you serve with add_file.

ServingStatus

source

pub(all) enum ServingStatus {
  StatusUnknown
  Serving
  NotServing
  ServiceUnknown
} derive(Eq)

The grpc.health.v1.HealthCheckResponse.ServingStatus enum.

ServingStatus::code

source

fn ServingStatus::code(self : ServingStatus) -> Int

The wire value of a serving status (the protobuf enum number).

ServingStatus::equal

source

fn ServingStatus::equal(ServingStatus, ServingStatus) -> Bool

ServingStatus::from_code

source

fn ServingStatus::from_code(n : Int) -> ServingStatus

The serving status for a protobuf enum number; out-of-range numbers read as StatusUnknown.

ServingStatus::not_equal

source

fn ServingStatus::not_equal(x : ServingStatus, y : ServingStatus) -> Bool

decode_health_request

source

fn decode_health_request(msg : Bytes) -> Bytes

Decode the service field of a HealthCheckRequest, or empty bytes when the field is absent (the overall-server check). Unknown fields are skipped.

decode_health_response

source

fn decode_health_response(msg : Bytes) -> ServingStatus

Decode the status field of a HealthCheckResponse; an absent field reads as the 0 default (StatusUnknown).

decode_reflection_request

source

fn decode_reflection_request(body : Bytes) -> ReflectionRequest raise @moonbitstack/moonrpc/proto.PbError
PbError

Decode a ServerReflectionRequest down to its message_request oneof arm. host (field 1) is accepted and ignored; an unset oneof reads as Unsupported.

decode_reflection_response

source

fn decode_reflection_response(body : Bytes) -> ReflectionResponse raise @moonbitstack/moonrpc/proto.PbError
PbError

Decode a ServerReflectionResponse down to its message_response arm — the half an in-process reflection client (and the tests) needs to read an answer.

encode_health_request

source

fn encode_health_request(service : Bytes) -> Bytes

Encode a HealthCheckRequest: field 1 (service, a length-delimited string). An empty service name encodes to the empty message, the wire form of the overall-server check.

encode_health_response

source

fn encode_health_response(status : ServingStatus) -> Bytes

Encode a HealthCheckResponse: field 1 (status, a varint enum). The SERVING default 0 still encodes to the empty message per protobuf default-omission.

encode_reflection_request

source

fn encode_reflection_request(req : ReflectionRequest) -> Bytes

Encode a ServerReflectionRequest carrying a single oneof arm. Used by an in-process reflection client (and by the round-trip tests).

health_check_path

source

let health_check_path : String

The gRPC HTTP/2 path of the Check method.

health_watch_path

source

let health_watch_path : String

The gRPC HTTP/2 path of the Watch method.

reflection_v1_path

source

let reflection_v1_path : String

The gRPC HTTP/2 path of the v1 reflection stream.

reflection_v1alpha_path

source

let reflection_v1alpha_path : String

The gRPC HTTP/2 path of the legacy v1alpha reflection stream. grpcurl tries v1 first and falls back to this, so a server registers both.

Source Files

Install

Download zip

Real gRPC for MoonBit over HTTP/2: all four call kinds, metadata, deadlines, rich errors, health checking, server reflection, retries, hedging and load balancing, with pure client and server engines that run on every backend.

grpcrpcprotobufhttp2moonbit

moonbitstack

Apache-2.0

github.com/moonbitstack/moonrpc

Updated 2 hours ago

549 downloads

Dependencies

Site source Report issue Packages Build queue Skills Statistics

#HealthService

#HealthService::check

#HealthService::handlers

#HealthService::install

#HealthService::new

#HealthService::set_status

#ReflectionRequest

#ReflectionRequest::equal

#ReflectionRequest::not_equal

#ReflectionResponse

#ReflectionResponse::equal

#ReflectionResponse::not_equal

#ReflectionService

#ReflectionService::add_file

#ReflectionService::handle

#ReflectionService::handler

#ReflectionService::install

#ReflectionService::new

#ServingStatus

#ServingStatus::code

#ServingStatus::equal

#ServingStatus::from_code

#ServingStatus::not_equal

#decode_health_request

#decode_health_response

#decode_reflection_request

#decode_reflection_response

#encode_health_request

#encode_health_response

#encode_reflection_request

#health_check_path

#health_watch_path

#reflection_v1_path

#reflection_v1alpha_path

Source Files

HealthService

HealthService::check

HealthService::handlers

HealthService::install

HealthService::new

HealthService::set_status

ReflectionRequest

ReflectionRequest::equal

ReflectionRequest::not_equal

ReflectionResponse

ReflectionResponse::equal

ReflectionResponse::not_equal

ReflectionService

ReflectionService::add_file

ReflectionService::handle

ReflectionService::handler

ReflectionService::install

ReflectionService::new

ServingStatus

ServingStatus::code

ServingStatus::equal

ServingStatus::from_code

ServingStatus::not_equal

decode_health_request

decode_health_response

decode_reflection_request

decode_reflection_response

encode_health_request

encode_health_response

encode_reflection_request

health_check_path

health_watch_path

reflection_v1_path

reflection_v1alpha_path