moonbitstack/moonrpc/channelz

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/channelz does not have a README file

Channel

pub(all) struct Channel {
  reference : ChannelRef
  state : Int
  target : String
  calls_started : Int64
  calls_succeeded : Int64
  calls_failed : Int64
  last_call_ms : Int64?
  channel_refs : Array[ChannelRef]
  subchannel_refs : Array[SubchannelRef]
  socket_refs : Array[SocketRef]
}

Channel::empty

source

fn Channel::empty() -> Channel

ChannelRef

source

pub(all) struct ChannelRef {
  id : Int64
  name : String
}

ChannelzService

source

pub(all) struct ChannelzService {
  registry : @moonbitstack/moonrpc/service.Registry
Registry
}

The channelz service over one registry.

ChannelzService::add_to_reflection

source

fn ChannelzService::add_to_reflection(self : ChannelzService, reflection : @moonbitstack/moonrpc/service.ReflectionService
ReflectionService) -> Unit

Add channelz.proto and the well-known files it imports to a reflection service.

ChannelzService::install

source

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

ChannelzService::new

source

fn ChannelzService::new(registry : @moonbitstack/moonrpc/service.Registry
Registry) -> ChannelzService

A channelz service reading registry.

GetChannelRequest

source

pub(all) struct GetChannelRequest {
  channel_id : Int64
}

impl Message for GetChannelRequest

GetChannelRequest::decode

source

fn GetChannelRequest::decode(b : Bytes) -> GetChannelRequest raise @moonbitstack/moonrpc/proto.PbError
PbError

GetChannelRequest::encode

source

fn GetChannelRequest::encode(self : GetChannelRequest) -> Bytes

GetChannelResponse

source

pub(all) struct GetChannelResponse {
  channel : Channel
}

impl Message for GetChannelResponse

GetChannelResponse::decode

source

fn GetChannelResponse::decode(_b : Bytes) -> GetChannelResponse raise @moonbitstack/moonrpc/proto.PbError
PbError

GetChannelResponse::encode

source

fn GetChannelResponse::encode(self : GetChannelResponse) -> Bytes

GetServerRequest

source

pub(all) struct GetServerRequest {
  server_id : Int64
}

impl Message for GetServerRequest

GetServerRequest::decode

source

fn GetServerRequest::decode(b : Bytes) -> GetServerRequest raise @moonbitstack/moonrpc/proto.PbError
PbError

GetServerRequest::encode

source

fn GetServerRequest::encode(self : GetServerRequest) -> Bytes

GetServerResponse

source

pub(all) struct GetServerResponse {
  server : Server
}

impl Message for GetServerResponse

GetServerResponse::decode

source

fn GetServerResponse::decode(_b : Bytes) -> GetServerResponse raise @moonbitstack/moonrpc/proto.PbError
PbError

GetServerResponse::encode

source

fn GetServerResponse::encode(self : GetServerResponse) -> Bytes

GetServerSocketsRequest

source

pub(all) struct GetServerSocketsRequest {
  server_id : Int64
  start_socket_id : Int64
  max_results : Int64
}

impl Message for GetServerSocketsRequest

GetServerSocketsRequest::decode

source

fn GetServerSocketsRequest::decode(b : Bytes) -> GetServerSocketsRequest raise @moonbitstack/moonrpc/proto.PbError
PbError

GetServerSocketsRequest::encode

source

fn GetServerSocketsRequest::encode(self : GetServerSocketsRequest) -> Bytes

GetServerSocketsResponse

source

pub(all) struct GetServerSocketsResponse {
  socket_ref : Array[SocketRef]
  is_end : Bool
}

impl Message for GetServerSocketsResponse

GetServerSocketsResponse::decode

source

fn GetServerSocketsResponse::decode(_b : Bytes) -> GetServerSocketsResponse raise @moonbitstack/moonrpc/proto.PbError
PbError

GetServerSocketsResponse::encode

source

fn GetServerSocketsResponse::encode(self : GetServerSocketsResponse) -> Bytes

GetServersRequest

source

pub(all) struct GetServersRequest {
  start_server_id : Int64
  max_results : Int64
}

impl Message for GetServersRequest

GetServersRequest::decode

source

fn GetServersRequest::decode(b : Bytes) -> GetServersRequest raise @moonbitstack/moonrpc/proto.PbError
PbError

GetServersRequest::encode

source

fn GetServersRequest::encode(self : GetServersRequest) -> Bytes

GetServersResponse

source

pub(all) struct GetServersResponse {
  server : Array[Server]
  is_end : Bool
}

impl Message for GetServersResponse

GetServersResponse::decode

source

fn GetServersResponse::decode(_b : Bytes) -> GetServersResponse raise @moonbitstack/moonrpc/proto.PbError
PbError

GetServersResponse::encode

source

fn GetServersResponse::encode(self : GetServersResponse) -> Bytes

GetSocketRequest

source

pub(all) struct GetSocketRequest {
  socket_id : Int64
  summary : Bool
}

impl Message for GetSocketRequest

GetSocketRequest::decode

source

fn GetSocketRequest::decode(b : Bytes) -> GetSocketRequest raise @moonbitstack/moonrpc/proto.PbError
PbError

GetSocketRequest::encode

source

fn GetSocketRequest::encode(self : GetSocketRequest) -> Bytes

GetSocketResponse

source

pub(all) struct GetSocketResponse {
  socket : Socket
}

impl Message for GetSocketResponse

GetSocketResponse::decode

source

fn GetSocketResponse::decode(_b : Bytes) -> GetSocketResponse raise @moonbitstack/moonrpc/proto.PbError
PbError

GetSocketResponse::encode

source

fn GetSocketResponse::encode(self : GetSocketResponse) -> Bytes

GetSubchannelRequest

source

pub(all) struct GetSubchannelRequest {
  subchannel_id : Int64
}

impl Message for GetSubchannelRequest

GetSubchannelRequest::decode

source

fn GetSubchannelRequest::decode(b : Bytes) -> GetSubchannelRequest raise @moonbitstack/moonrpc/proto.PbError
PbError

GetSubchannelRequest::encode

source

fn GetSubchannelRequest::encode(self : GetSubchannelRequest) -> Bytes

GetSubchannelResponse

source

pub(all) struct GetSubchannelResponse {
  subchannel : Subchannel
}

impl Message for GetSubchannelResponse

GetSubchannelResponse::decode

source

fn GetSubchannelResponse::decode(_b : Bytes) -> GetSubchannelResponse raise @moonbitstack/moonrpc/proto.PbError
PbError

GetSubchannelResponse::encode

source

fn GetSubchannelResponse::encode(self : GetSubchannelResponse) -> Bytes

GetTopChannelsRequest

source

pub(all) struct GetTopChannelsRequest {
  start_channel_id : Int64
  max_results : Int64
}

impl Message for GetTopChannelsRequest

GetTopChannelsRequest::decode

source

fn GetTopChannelsRequest::decode(b : Bytes) -> GetTopChannelsRequest raise @moonbitstack/moonrpc/proto.PbError
PbError

GetTopChannelsRequest::encode

source

fn GetTopChannelsRequest::encode(self : GetTopChannelsRequest) -> Bytes

GetTopChannelsResponse

source

pub(all) struct GetTopChannelsResponse {
  channel : Array[Channel]
  is_end : Bool
}

impl Message for GetTopChannelsResponse

GetTopChannelsResponse::decode

source

fn GetTopChannelsResponse::decode(_b : Bytes) -> GetTopChannelsResponse raise @moonbitstack/moonrpc/proto.PbError
PbError

GetTopChannelsResponse::encode

source

fn GetTopChannelsResponse::encode(self : GetTopChannelsResponse) -> Bytes

Server

source

pub(all) struct Server {
  reference : ServerRef
  calls_started : Int64
  calls_succeeded : Int64
  calls_failed : Int64
  last_call_ms : Int64?
  listen_sockets : Array[SocketRef]
}

Server::empty

source

fn Server::empty() -> Server

ServerRef

source

pub(all) struct ServerRef {
  id : Int64
  name : String
}

Socket

source

pub(all) struct Socket {
  reference : SocketRef
  address : String
  streams_started : Int64
  streams_succeeded : Int64
  streams_failed : Int64
  messages_sent : Int64
  messages_received : Int64
}

Socket::empty

source

fn Socket::empty() -> Socket

SocketRef

source

pub(all) struct SocketRef {
  id : Int64
  name : String
}

Subchannel

source

pub(all) struct Subchannel {
  reference : SubchannelRef
  state : Int
  target : String
  calls_started : Int64
  calls_succeeded : Int64
  calls_failed : Int64
  channel_refs : Array[ChannelRef]
  subchannel_refs : Array[SubchannelRef]
  socket_refs : Array[SocketRef]
}

Subchannel::empty

source

fn Subchannel::empty() -> Subchannel

SubchannelRef

source

pub(all) struct SubchannelRef {
  id : Int64
  name : String
}

any_file

source

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

google/protobuf/any.proto.

channel_path

source

let channel_path : String

descriptor

source

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

The grpc/channelz/v1/channelz.proto descriptor: every message, the two nested enums, the three oneofs, and the seven methods of Channelz.

duration_file

source

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

google/protobuf/duration.proto.

server_path

source

let server_path : String

server_sockets_path

source

let server_sockets_path : String

servers_path

source

let servers_path : String

socket_path

source

let socket_path : String

subchannel_path

source

let subchannel_path : String

timestamp_file

source

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

google/protobuf/timestamp.proto.

top_channels_path

source

let top_channels_path : String

well_known_files

source

fn well_known_files() -> Array[@moonbitstack/moonrpc/proto.FileDescriptor
FileDescriptor]

Every dependency file, in the order channelz.proto imports them.

wrappers_file

source

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

google/protobuf/wrappers.proto, with the two wrappers channelz uses.

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

979 downloads

Site source Report issue Modules Skills CLI Build queue Statistics

#Channel

#Channel::empty

#ChannelRef

#ChannelzService

#ChannelzService::add_to_reflection

#ChannelzService::install

#ChannelzService::new

#GetChannelRequest

#GetChannelRequest::decode

#GetChannelRequest::encode

#GetChannelResponse

#GetChannelResponse::decode

#GetChannelResponse::encode

#GetServerRequest

#GetServerRequest::decode

#GetServerRequest::encode

#GetServerResponse

#GetServerResponse::decode

#GetServerResponse::encode

#GetServerSocketsRequest

#GetServerSocketsRequest::decode

#GetServerSocketsRequest::encode

#GetServerSocketsResponse

#GetServerSocketsResponse::decode

#GetServerSocketsResponse::encode

#GetServersRequest

#GetServersRequest::decode

#GetServersRequest::encode

#GetServersResponse

#GetServersResponse::decode

#GetServersResponse::encode

#GetSocketRequest

#GetSocketRequest::decode

#GetSocketRequest::encode

#GetSocketResponse

#GetSocketResponse::decode

#GetSocketResponse::encode

#GetSubchannelRequest

#GetSubchannelRequest::decode

#GetSubchannelRequest::encode

#GetSubchannelResponse

#GetSubchannelResponse::decode

#GetSubchannelResponse::encode

#GetTopChannelsRequest

#GetTopChannelsRequest::decode

#GetTopChannelsRequest::encode

#GetTopChannelsResponse

#GetTopChannelsResponse::decode

#GetTopChannelsResponse::encode

#Server

#Server::empty

#ServerRef

#Socket

#Socket::empty

#SocketRef

#Subchannel

#Subchannel::empty

#SubchannelRef

#any_file

#channel_path

#descriptor

#duration_file

#server_path

#server_sockets_path

#servers_path

#socket_path

#subchannel_path

#timestamp_file

#top_channels_path

#well_known_files

#wrappers_file

Source Files

Channel

Channel::empty

ChannelRef

ChannelzService

ChannelzService::add_to_reflection

ChannelzService::install

ChannelzService::new

GetChannelRequest

GetChannelRequest::decode

GetChannelRequest::encode

GetChannelResponse

GetChannelResponse::decode

GetChannelResponse::encode

GetServerRequest

GetServerRequest::decode

GetServerRequest::encode

GetServerResponse

GetServerResponse::decode

GetServerResponse::encode

GetServerSocketsRequest

GetServerSocketsRequest::decode

GetServerSocketsRequest::encode

GetServerSocketsResponse

GetServerSocketsResponse::decode

GetServerSocketsResponse::encode

GetServersRequest

GetServersRequest::decode

GetServersRequest::encode

GetServersResponse

GetServersResponse::decode

GetServersResponse::encode

GetSocketRequest

GetSocketRequest::decode

GetSocketRequest::encode

GetSocketResponse

GetSocketResponse::decode

GetSocketResponse::encode

GetSubchannelRequest

GetSubchannelRequest::decode

GetSubchannelRequest::encode

GetSubchannelResponse

GetSubchannelResponse::decode

GetSubchannelResponse::encode

GetTopChannelsRequest

GetTopChannelsRequest::decode

GetTopChannelsRequest::encode

GetTopChannelsResponse

GetTopChannelsResponse::decode

GetTopChannelsResponse::encode

Server

Server::empty

ServerRef

Socket

Socket::empty

SocketRef

Subchannel

Subchannel::empty

SubchannelRef

any_file

channel_path

descriptor

duration_file

server_path

server_sockets_path

servers_path

socket_path

subchannel_path

timestamp_file

top_channels_path

well_known_files

wrappers_file