package grpc_channelz_v1
import "google.golang.org/grpc/channelz/grpc_channelz_v1"
Index ¶
- Constants
- Variables
- func RegisterChannelzServer(s grpc.ServiceRegistrar, srv ChannelzServer)
- type Address
- func (*Address) Descriptor() ([]byte, []int)
- func (m *Address) GetAddress() isAddress_Address
- func (x *Address) GetOtherAddress() *Address_OtherAddress
- func (x *Address) GetTcpipAddress() *Address_TcpIpAddress
- func (x *Address) GetUdsAddress() *Address_UdsAddress
- func (*Address) ProtoMessage()
- func (x *Address) ProtoReflect() protoreflect.Message
- func (x *Address) Reset()
- func (x *Address) String() string
- type Address_OtherAddress
- func (*Address_OtherAddress) Descriptor() ([]byte, []int)
- func (x *Address_OtherAddress) GetName() string
- func (x *Address_OtherAddress) GetValue() *anypb.Any
- func (*Address_OtherAddress) ProtoMessage()
- func (x *Address_OtherAddress) ProtoReflect() protoreflect.Message
- func (x *Address_OtherAddress) Reset()
- func (x *Address_OtherAddress) String() string
- type Address_OtherAddress_
- type Address_TcpIpAddress
- func (*Address_TcpIpAddress) Descriptor() ([]byte, []int)
- func (x *Address_TcpIpAddress) GetIpAddress() []byte
- func (x *Address_TcpIpAddress) GetPort() int32
- func (*Address_TcpIpAddress) ProtoMessage()
- func (x *Address_TcpIpAddress) ProtoReflect() protoreflect.Message
- func (x *Address_TcpIpAddress) Reset()
- func (x *Address_TcpIpAddress) String() string
- type Address_TcpipAddress
- type Address_UdsAddress
- func (*Address_UdsAddress) Descriptor() ([]byte, []int)
- func (x *Address_UdsAddress) GetFilename() string
- func (*Address_UdsAddress) ProtoMessage()
- func (x *Address_UdsAddress) ProtoReflect() protoreflect.Message
- func (x *Address_UdsAddress) Reset()
- func (x *Address_UdsAddress) String() string
- type Address_UdsAddress_
- type Channel
- func (*Channel) Descriptor() ([]byte, []int)
- func (x *Channel) GetChannelRef() []*ChannelRef
- func (x *Channel) GetData() *ChannelData
- func (x *Channel) GetRef() *ChannelRef
- func (x *Channel) GetSocketRef() []*SocketRef
- func (x *Channel) GetSubchannelRef() []*SubchannelRef
- func (*Channel) ProtoMessage()
- func (x *Channel) ProtoReflect() protoreflect.Message
- func (x *Channel) Reset()
- func (x *Channel) String() string
- type ChannelConnectivityState
- func (*ChannelConnectivityState) Descriptor() ([]byte, []int)
- func (x *ChannelConnectivityState) GetState() ChannelConnectivityState_State
- func (*ChannelConnectivityState) ProtoMessage()
- func (x *ChannelConnectivityState) ProtoReflect() protoreflect.Message
- func (x *ChannelConnectivityState) Reset()
- func (x *ChannelConnectivityState) String() string
- type ChannelConnectivityState_State
- func (ChannelConnectivityState_State) Descriptor() protoreflect.EnumDescriptor
- func (x ChannelConnectivityState_State) Enum() *ChannelConnectivityState_State
- func (ChannelConnectivityState_State) EnumDescriptor() ([]byte, []int)
- func (x ChannelConnectivityState_State) Number() protoreflect.EnumNumber
- func (x ChannelConnectivityState_State) String() string
- func (ChannelConnectivityState_State) Type() protoreflect.EnumType
- type ChannelData
- func (*ChannelData) Descriptor() ([]byte, []int)
- func (x *ChannelData) GetCallsFailed() int64
- func (x *ChannelData) GetCallsStarted() int64
- func (x *ChannelData) GetCallsSucceeded() int64
- func (x *ChannelData) GetLastCallStartedTimestamp() *timestamppb.Timestamp
- func (x *ChannelData) GetState() *ChannelConnectivityState
- func (x *ChannelData) GetTarget() string
- func (x *ChannelData) GetTrace() *ChannelTrace
- func (*ChannelData) ProtoMessage()
- func (x *ChannelData) ProtoReflect() protoreflect.Message
- func (x *ChannelData) Reset()
- func (x *ChannelData) String() string
- type ChannelRef
- func (*ChannelRef) Descriptor() ([]byte, []int)
- func (x *ChannelRef) GetChannelId() int64
- func (x *ChannelRef) GetName() string
- func (*ChannelRef) ProtoMessage()
- func (x *ChannelRef) ProtoReflect() protoreflect.Message
- func (x *ChannelRef) Reset()
- func (x *ChannelRef) String() string
- type ChannelTrace
- func (*ChannelTrace) Descriptor() ([]byte, []int)
- func (x *ChannelTrace) GetCreationTimestamp() *timestamppb.Timestamp
- func (x *ChannelTrace) GetEvents() []*ChannelTraceEvent
- func (x *ChannelTrace) GetNumEventsLogged() int64
- func (*ChannelTrace) ProtoMessage()
- func (x *ChannelTrace) ProtoReflect() protoreflect.Message
- func (x *ChannelTrace) Reset()
- func (x *ChannelTrace) String() string
- type ChannelTraceEvent
- func (*ChannelTraceEvent) Descriptor() ([]byte, []int)
- func (x *ChannelTraceEvent) GetChannelRef() *ChannelRef
- func (m *ChannelTraceEvent) GetChildRef() isChannelTraceEvent_ChildRef
- func (x *ChannelTraceEvent) GetDescription() string
- func (x *ChannelTraceEvent) GetSeverity() ChannelTraceEvent_Severity
- func (x *ChannelTraceEvent) GetSubchannelRef() *SubchannelRef
- func (x *ChannelTraceEvent) GetTimestamp() *timestamppb.Timestamp
- func (*ChannelTraceEvent) ProtoMessage()
- func (x *ChannelTraceEvent) ProtoReflect() protoreflect.Message
- func (x *ChannelTraceEvent) Reset()
- func (x *ChannelTraceEvent) String() string
- type ChannelTraceEvent_ChannelRef
- type ChannelTraceEvent_Severity
- func (ChannelTraceEvent_Severity) Descriptor() protoreflect.EnumDescriptor
- func (x ChannelTraceEvent_Severity) Enum() *ChannelTraceEvent_Severity
- func (ChannelTraceEvent_Severity) EnumDescriptor() ([]byte, []int)
- func (x ChannelTraceEvent_Severity) Number() protoreflect.EnumNumber
- func (x ChannelTraceEvent_Severity) String() string
- func (ChannelTraceEvent_Severity) Type() protoreflect.EnumType
- type ChannelTraceEvent_SubchannelRef
- type ChannelzClient
- type ChannelzServer
- type GetChannelRequest
- func (*GetChannelRequest) Descriptor() ([]byte, []int)
- func (x *GetChannelRequest) GetChannelId() int64
- func (*GetChannelRequest) ProtoMessage()
- func (x *GetChannelRequest) ProtoReflect() protoreflect.Message
- func (x *GetChannelRequest) Reset()
- func (x *GetChannelRequest) String() string
- type GetChannelResponse
- func (*GetChannelResponse) Descriptor() ([]byte, []int)
- func (x *GetChannelResponse) GetChannel() *Channel
- func (*GetChannelResponse) ProtoMessage()
- func (x *GetChannelResponse) ProtoReflect() protoreflect.Message
- func (x *GetChannelResponse) Reset()
- func (x *GetChannelResponse) String() string
- type GetServerRequest
- func (*GetServerRequest) Descriptor() ([]byte, []int)
- func (x *GetServerRequest) GetServerId() int64
- func (*GetServerRequest) ProtoMessage()
- func (x *GetServerRequest) ProtoReflect() protoreflect.Message
- func (x *GetServerRequest) Reset()
- func (x *GetServerRequest) String() string
- type GetServerResponse
- func (*GetServerResponse) Descriptor() ([]byte, []int)
- func (x *GetServerResponse) GetServer() *Server
- func (*GetServerResponse) ProtoMessage()
- func (x *GetServerResponse) ProtoReflect() protoreflect.Message
- func (x *GetServerResponse) Reset()
- func (x *GetServerResponse) String() string
- type GetServerSocketsRequest
- func (*GetServerSocketsRequest) Descriptor() ([]byte, []int)
- func (x *GetServerSocketsRequest) GetMaxResults() int64
- func (x *GetServerSocketsRequest) GetServerId() int64
- func (x *GetServerSocketsRequest) GetStartSocketId() int64
- func (*GetServerSocketsRequest) ProtoMessage()
- func (x *GetServerSocketsRequest) ProtoReflect() protoreflect.Message
- func (x *GetServerSocketsRequest) Reset()
- func (x *GetServerSocketsRequest) String() string
- type GetServerSocketsResponse
- func (*GetServerSocketsResponse) Descriptor() ([]byte, []int)
- func (x *GetServerSocketsResponse) GetEnd() bool
- func (x *GetServerSocketsResponse) GetSocketRef() []*SocketRef
- func (*GetServerSocketsResponse) ProtoMessage()
- func (x *GetServerSocketsResponse) ProtoReflect() protoreflect.Message
- func (x *GetServerSocketsResponse) Reset()
- func (x *GetServerSocketsResponse) String() string
- type GetServersRequest
- func (*GetServersRequest) Descriptor() ([]byte, []int)
- func (x *GetServersRequest) GetMaxResults() int64
- func (x *GetServersRequest) GetStartServerId() int64
- func (*GetServersRequest) ProtoMessage()
- func (x *GetServersRequest) ProtoReflect() protoreflect.Message
- func (x *GetServersRequest) Reset()
- func (x *GetServersRequest) String() string
- type GetServersResponse
- func (*GetServersResponse) Descriptor() ([]byte, []int)
- func (x *GetServersResponse) GetEnd() bool
- func (x *GetServersResponse) GetServer() []*Server
- func (*GetServersResponse) ProtoMessage()
- func (x *GetServersResponse) ProtoReflect() protoreflect.Message
- func (x *GetServersResponse) Reset()
- func (x *GetServersResponse) String() string
- type GetSocketRequest
- func (*GetSocketRequest) Descriptor() ([]byte, []int)
- func (x *GetSocketRequest) GetSocketId() int64
- func (x *GetSocketRequest) GetSummary() bool
- func (*GetSocketRequest) ProtoMessage()
- func (x *GetSocketRequest) ProtoReflect() protoreflect.Message
- func (x *GetSocketRequest) Reset()
- func (x *GetSocketRequest) String() string
- type GetSocketResponse
- func (*GetSocketResponse) Descriptor() ([]byte, []int)
- func (x *GetSocketResponse) GetSocket() *Socket
- func (*GetSocketResponse) ProtoMessage()
- func (x *GetSocketResponse) ProtoReflect() protoreflect.Message
- func (x *GetSocketResponse) Reset()
- func (x *GetSocketResponse) String() string
- type GetSubchannelRequest
- func (*GetSubchannelRequest) Descriptor() ([]byte, []int)
- func (x *GetSubchannelRequest) GetSubchannelId() int64
- func (*GetSubchannelRequest) ProtoMessage()
- func (x *GetSubchannelRequest) ProtoReflect() protoreflect.Message
- func (x *GetSubchannelRequest) Reset()
- func (x *GetSubchannelRequest) String() string
- type GetSubchannelResponse
- func (*GetSubchannelResponse) Descriptor() ([]byte, []int)
- func (x *GetSubchannelResponse) GetSubchannel() *Subchannel
- func (*GetSubchannelResponse) ProtoMessage()
- func (x *GetSubchannelResponse) ProtoReflect() protoreflect.Message
- func (x *GetSubchannelResponse) Reset()
- func (x *GetSubchannelResponse) String() string
- type GetTopChannelsRequest
- func (*GetTopChannelsRequest) Descriptor() ([]byte, []int)
- func (x *GetTopChannelsRequest) GetMaxResults() int64
- func (x *GetTopChannelsRequest) GetStartChannelId() int64
- func (*GetTopChannelsRequest) ProtoMessage()
- func (x *GetTopChannelsRequest) ProtoReflect() protoreflect.Message
- func (x *GetTopChannelsRequest) Reset()
- func (x *GetTopChannelsRequest) String() string
- type GetTopChannelsResponse
- func (*GetTopChannelsResponse) Descriptor() ([]byte, []int)
- func (x *GetTopChannelsResponse) GetChannel() []*Channel
- func (x *GetTopChannelsResponse) GetEnd() bool
- func (*GetTopChannelsResponse) ProtoMessage()
- func (x *GetTopChannelsResponse) ProtoReflect() protoreflect.Message
- func (x *GetTopChannelsResponse) Reset()
- func (x *GetTopChannelsResponse) String() string
- type Security
- func (*Security) Descriptor() ([]byte, []int)
- func (m *Security) GetModel() isSecurity_Model
- func (x *Security) GetOther() *Security_OtherSecurity
- func (x *Security) GetTls() *Security_Tls
- func (*Security) ProtoMessage()
- func (x *Security) ProtoReflect() protoreflect.Message
- func (x *Security) Reset()
- func (x *Security) String() string
- type Security_Other
- type Security_OtherSecurity
- func (*Security_OtherSecurity) Descriptor() ([]byte, []int)
- func (x *Security_OtherSecurity) GetName() string
- func (x *Security_OtherSecurity) GetValue() *anypb.Any
- func (*Security_OtherSecurity) ProtoMessage()
- func (x *Security_OtherSecurity) ProtoReflect() protoreflect.Message
- func (x *Security_OtherSecurity) Reset()
- func (x *Security_OtherSecurity) String() string
- type Security_Tls
- func (*Security_Tls) Descriptor() ([]byte, []int)
- func (m *Security_Tls) GetCipherSuite() isSecurity_Tls_CipherSuite
- func (x *Security_Tls) GetLocalCertificate() []byte
- func (x *Security_Tls) GetOtherName() string
- func (x *Security_Tls) GetRemoteCertificate() []byte
- func (x *Security_Tls) GetStandardName() string
- func (*Security_Tls) ProtoMessage()
- func (x *Security_Tls) ProtoReflect() protoreflect.Message
- func (x *Security_Tls) Reset()
- func (x *Security_Tls) String() string
- type Security_Tls_
- type Security_Tls_OtherName
- type Security_Tls_StandardName
- type Server
- func (*Server) Descriptor() ([]byte, []int)
- func (x *Server) GetData() *ServerData
- func (x *Server) GetListenSocket() []*SocketRef
- func (x *Server) GetRef() *ServerRef
- func (*Server) ProtoMessage()
- func (x *Server) ProtoReflect() protoreflect.Message
- func (x *Server) Reset()
- func (x *Server) String() string
- type ServerData
- func (*ServerData) Descriptor() ([]byte, []int)
- func (x *ServerData) GetCallsFailed() int64
- func (x *ServerData) GetCallsStarted() int64
- func (x *ServerData) GetCallsSucceeded() int64
- func (x *ServerData) GetLastCallStartedTimestamp() *timestamppb.Timestamp
- func (x *ServerData) GetTrace() *ChannelTrace
- func (*ServerData) ProtoMessage()
- func (x *ServerData) ProtoReflect() protoreflect.Message
- func (x *ServerData) Reset()
- func (x *ServerData) String() string
- type ServerRef
- func (*ServerRef) Descriptor() ([]byte, []int)
- func (x *ServerRef) GetName() string
- func (x *ServerRef) GetServerId() int64
- func (*ServerRef) ProtoMessage()
- func (x *ServerRef) ProtoReflect() protoreflect.Message
- func (x *ServerRef) Reset()
- func (x *ServerRef) String() string
- type Socket
- func (*Socket) Descriptor() ([]byte, []int)
- func (x *Socket) GetData() *SocketData
- func (x *Socket) GetLocal() *Address
- func (x *Socket) GetRef() *SocketRef
- func (x *Socket) GetRemote() *Address
- func (x *Socket) GetRemoteName() string
- func (x *Socket) GetSecurity() *Security
- func (*Socket) ProtoMessage()
- func (x *Socket) ProtoReflect() protoreflect.Message
- func (x *Socket) Reset()
- func (x *Socket) String() string
- type SocketData
- func (*SocketData) Descriptor() ([]byte, []int)
- func (x *SocketData) GetKeepAlivesSent() int64
- func (x *SocketData) GetLastLocalStreamCreatedTimestamp() *timestamppb.Timestamp
- func (x *SocketData) GetLastMessageReceivedTimestamp() *timestamppb.Timestamp
- func (x *SocketData) GetLastMessageSentTimestamp() *timestamppb.Timestamp
- func (x *SocketData) GetLastRemoteStreamCreatedTimestamp() *timestamppb.Timestamp
- func (x *SocketData) GetLocalFlowControlWindow() *wrapperspb.Int64Value
- func (x *SocketData) GetMessagesReceived() int64
- func (x *SocketData) GetMessagesSent() int64
- func (x *SocketData) GetOption() []*SocketOption
- func (x *SocketData) GetRemoteFlowControlWindow() *wrapperspb.Int64Value
- func (x *SocketData) GetStreamsFailed() int64
- func (x *SocketData) GetStreamsStarted() int64
- func (x *SocketData) GetStreamsSucceeded() int64
- func (*SocketData) ProtoMessage()
- func (x *SocketData) ProtoReflect() protoreflect.Message
- func (x *SocketData) Reset()
- func (x *SocketData) String() string
- type SocketOption
- func (*SocketOption) Descriptor() ([]byte, []int)
- func (x *SocketOption) GetAdditional() *anypb.Any
- func (x *SocketOption) GetName() string
- func (x *SocketOption) GetValue() string
- func (*SocketOption) ProtoMessage()
- func (x *SocketOption) ProtoReflect() protoreflect.Message
- func (x *SocketOption) Reset()
- func (x *SocketOption) String() string
- type SocketOptionLinger
- func (*SocketOptionLinger) Descriptor() ([]byte, []int)
- func (x *SocketOptionLinger) GetActive() bool
- func (x *SocketOptionLinger) GetDuration() *durationpb.Duration
- func (*SocketOptionLinger) ProtoMessage()
- func (x *SocketOptionLinger) ProtoReflect() protoreflect.Message
- func (x *SocketOptionLinger) Reset()
- func (x *SocketOptionLinger) String() string
- type SocketOptionTcpInfo
- func (*SocketOptionTcpInfo) Descriptor() ([]byte, []int)
- func (x *SocketOptionTcpInfo) GetTcpiAdvmss() uint32
- func (x *SocketOptionTcpInfo) GetTcpiAto() uint32
- func (x *SocketOptionTcpInfo) GetTcpiBackoff() uint32
- func (x *SocketOptionTcpInfo) GetTcpiCaState() uint32
- func (x *SocketOptionTcpInfo) GetTcpiFackets() uint32
- func (x *SocketOptionTcpInfo) GetTcpiLastAckRecv() uint32
- func (x *SocketOptionTcpInfo) GetTcpiLastAckSent() uint32
- func (x *SocketOptionTcpInfo) GetTcpiLastDataRecv() uint32
- func (x *SocketOptionTcpInfo) GetTcpiLastDataSent() uint32
- func (x *SocketOptionTcpInfo) GetTcpiLost() uint32
- func (x *SocketOptionTcpInfo) GetTcpiOptions() uint32
- func (x *SocketOptionTcpInfo) GetTcpiPmtu() uint32
- func (x *SocketOptionTcpInfo) GetTcpiProbes() uint32
- func (x *SocketOptionTcpInfo) GetTcpiRcvMss() uint32
- func (x *SocketOptionTcpInfo) GetTcpiRcvSsthresh() uint32
- func (x *SocketOptionTcpInfo) GetTcpiRcvWscale() uint32
- func (x *SocketOptionTcpInfo) GetTcpiReordering() uint32
- func (x *SocketOptionTcpInfo) GetTcpiRetrans() uint32
- func (x *SocketOptionTcpInfo) GetTcpiRetransmits() uint32
- func (x *SocketOptionTcpInfo) GetTcpiRto() uint32
- func (x *SocketOptionTcpInfo) GetTcpiRtt() uint32
- func (x *SocketOptionTcpInfo) GetTcpiRttvar() uint32
- func (x *SocketOptionTcpInfo) GetTcpiSacked() uint32
- func (x *SocketOptionTcpInfo) GetTcpiSndCwnd() uint32
- func (x *SocketOptionTcpInfo) GetTcpiSndMss() uint32
- func (x *SocketOptionTcpInfo) GetTcpiSndSsthresh() uint32
- func (x *SocketOptionTcpInfo) GetTcpiSndWscale() uint32
- func (x *SocketOptionTcpInfo) GetTcpiState() uint32
- func (x *SocketOptionTcpInfo) GetTcpiUnacked() uint32
- func (*SocketOptionTcpInfo) ProtoMessage()
- func (x *SocketOptionTcpInfo) ProtoReflect() protoreflect.Message
- func (x *SocketOptionTcpInfo) Reset()
- func (x *SocketOptionTcpInfo) String() string
- type SocketOptionTimeout
- func (*SocketOptionTimeout) Descriptor() ([]byte, []int)
- func (x *SocketOptionTimeout) GetDuration() *durationpb.Duration
- func (*SocketOptionTimeout) ProtoMessage()
- func (x *SocketOptionTimeout) ProtoReflect() protoreflect.Message
- func (x *SocketOptionTimeout) Reset()
- func (x *SocketOptionTimeout) String() string
- type SocketRef
- func (*SocketRef) Descriptor() ([]byte, []int)
- func (x *SocketRef) GetName() string
- func (x *SocketRef) GetSocketId() int64
- func (*SocketRef) ProtoMessage()
- func (x *SocketRef) ProtoReflect() protoreflect.Message
- func (x *SocketRef) Reset()
- func (x *SocketRef) String() string
- type Subchannel
- func (*Subchannel) Descriptor() ([]byte, []int)
- func (x *Subchannel) GetChannelRef() []*ChannelRef
- func (x *Subchannel) GetData() *ChannelData
- func (x *Subchannel) GetRef() *SubchannelRef
- func (x *Subchannel) GetSocketRef() []*SocketRef
- func (x *Subchannel) GetSubchannelRef() []*SubchannelRef
- func (*Subchannel) ProtoMessage()
- func (x *Subchannel) ProtoReflect() protoreflect.Message
- func (x *Subchannel) Reset()
- func (x *Subchannel) String() string
- type SubchannelRef
- func (*SubchannelRef) Descriptor() ([]byte, []int)
- func (x *SubchannelRef) GetName() string
- func (x *SubchannelRef) GetSubchannelId() int64
- func (*SubchannelRef) ProtoMessage()
- func (x *SubchannelRef) ProtoReflect() protoreflect.Message
- func (x *SubchannelRef) Reset()
- func (x *SubchannelRef) String() string
- type UnimplementedChannelzServer
- func (UnimplementedChannelzServer) GetChannel(context.Context, *GetChannelRequest) (*GetChannelResponse, error)
- func (UnimplementedChannelzServer) GetServer(context.Context, *GetServerRequest) (*GetServerResponse, error)
- func (UnimplementedChannelzServer) GetServerSockets(context.Context, *GetServerSocketsRequest) (*GetServerSocketsResponse, error)
- func (UnimplementedChannelzServer) GetServers(context.Context, *GetServersRequest) (*GetServersResponse, error)
- func (UnimplementedChannelzServer) GetSocket(context.Context, *GetSocketRequest) (*GetSocketResponse, error)
- func (UnimplementedChannelzServer) GetSubchannel(context.Context, *GetSubchannelRequest) (*GetSubchannelResponse, error)
- func (UnimplementedChannelzServer) GetTopChannels(context.Context, *GetTopChannelsRequest) (*GetTopChannelsResponse, error)
- type UnsafeChannelzServer
Constants ¶
const ( Channelz_GetTopChannels_FullMethodName = "/grpc.channelz.v1.Channelz/GetTopChannels" Channelz_GetServers_FullMethodName = "/grpc.channelz.v1.Channelz/GetServers" Channelz_GetServer_FullMethodName = "/grpc.channelz.v1.Channelz/GetServer" Channelz_GetServerSockets_FullMethodName = "/grpc.channelz.v1.Channelz/GetServerSockets" Channelz_GetChannel_FullMethodName = "/grpc.channelz.v1.Channelz/GetChannel" Channelz_GetSubchannel_FullMethodName = "/grpc.channelz.v1.Channelz/GetSubchannel" Channelz_GetSocket_FullMethodName = "/grpc.channelz.v1.Channelz/GetSocket" )
Variables ¶
var ( ChannelConnectivityState_State_name = map[int32]string{ 0: "UNKNOWN", 1: "IDLE", 2: "CONNECTING", 3: "READY", 4: "TRANSIENT_FAILURE", 5: "SHUTDOWN", } ChannelConnectivityState_State_value = map[string]int32{ "UNKNOWN": 0, "IDLE": 1, "CONNECTING": 2, "READY": 3, "TRANSIENT_FAILURE": 4, "SHUTDOWN": 5, } )
Enum value maps for ChannelConnectivityState_State.
var ( ChannelTraceEvent_Severity_name = map[int32]string{ 0: "CT_UNKNOWN", 1: "CT_INFO", 2: "CT_WARNING", 3: "CT_ERROR", } ChannelTraceEvent_Severity_value = map[string]int32{ "CT_UNKNOWN": 0, "CT_INFO": 1, "CT_WARNING": 2, "CT_ERROR": 3, } )
Enum value maps for ChannelTraceEvent_Severity.
var Channelz_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.channelz.v1.Channelz", HandlerType: (*ChannelzServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetTopChannels", Handler: _Channelz_GetTopChannels_Handler, }, { MethodName: "GetServers", Handler: _Channelz_GetServers_Handler, }, { MethodName: "GetServer", Handler: _Channelz_GetServer_Handler, }, { MethodName: "GetServerSockets", Handler: _Channelz_GetServerSockets_Handler, }, { MethodName: "GetChannel", Handler: _Channelz_GetChannel_Handler, }, { MethodName: "GetSubchannel", Handler: _Channelz_GetSubchannel_Handler, }, { MethodName: "GetSocket", Handler: _Channelz_GetSocket_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc/channelz/v1/channelz.proto", }
Channelz_ServiceDesc is the grpc.ServiceDesc for Channelz service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_grpc_channelz_v1_channelz_proto protoreflect.FileDescriptor
Functions ¶
func RegisterChannelzServer ¶
func RegisterChannelzServer(s grpc.ServiceRegistrar, srv ChannelzServer)
Types ¶
type Address ¶
type Address struct { // Types that are assignable to Address: // // *Address_TcpipAddress // *Address_UdsAddress_ // *Address_OtherAddress_ Address isAddress_Address `protobuf_oneof:"address"` // contains filtered or unexported fields }
Address represents the address used to create the socket.
func (*Address) Descriptor ¶
Deprecated: Use Address.ProtoReflect.Descriptor instead.
func (*Address) GetAddress ¶
func (m *Address) GetAddress() isAddress_Address
func (*Address) GetOtherAddress ¶
func (x *Address) GetOtherAddress() *Address_OtherAddress
func (*Address) GetTcpipAddress ¶
func (x *Address) GetTcpipAddress() *Address_TcpIpAddress
func (*Address) GetUdsAddress ¶
func (x *Address) GetUdsAddress() *Address_UdsAddress
func (*Address) ProtoMessage ¶
func (*Address) ProtoMessage()
func (*Address) ProtoReflect ¶
func (x *Address) ProtoReflect() protoreflect.Message
func (*Address) Reset ¶
func (x *Address) Reset()
func (*Address) String ¶
type Address_OtherAddress ¶
type Address_OtherAddress struct { // The human readable version of the value. This value should be set. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The actual address message. Value *anypb.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An address type not included above.
func (*Address_OtherAddress) Descriptor ¶
func (*Address_OtherAddress) Descriptor() ([]byte, []int)
Deprecated: Use Address_OtherAddress.ProtoReflect.Descriptor instead.
func (*Address_OtherAddress) GetName ¶
func (x *Address_OtherAddress) GetName() string
func (*Address_OtherAddress) GetValue ¶
func (x *Address_OtherAddress) GetValue() *anypb.Any
func (*Address_OtherAddress) ProtoMessage ¶
func (*Address_OtherAddress) ProtoMessage()
func (*Address_OtherAddress) ProtoReflect ¶
func (x *Address_OtherAddress) ProtoReflect() protoreflect.Message
func (*Address_OtherAddress) Reset ¶
func (x *Address_OtherAddress) Reset()
func (*Address_OtherAddress) String ¶
func (x *Address_OtherAddress) String() string
type Address_OtherAddress_ ¶
type Address_OtherAddress_ struct { OtherAddress *Address_OtherAddress `protobuf:"bytes,3,opt,name=other_address,json=otherAddress,proto3,oneof"` }
type Address_TcpIpAddress ¶
type Address_TcpIpAddress struct { // Either the IPv4 or IPv6 address in bytes. Will be either 4 bytes or 16 // bytes in length. IpAddress []byte `protobuf:"bytes,1,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"` // 0-64k, or -1 if not appropriate. Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
func (*Address_TcpIpAddress) Descriptor ¶
func (*Address_TcpIpAddress) Descriptor() ([]byte, []int)
Deprecated: Use Address_TcpIpAddress.ProtoReflect.Descriptor instead.
func (*Address_TcpIpAddress) GetIpAddress ¶
func (x *Address_TcpIpAddress) GetIpAddress() []byte
func (*Address_TcpIpAddress) GetPort ¶
func (x *Address_TcpIpAddress) GetPort() int32
func (*Address_TcpIpAddress) ProtoMessage ¶
func (*Address_TcpIpAddress) ProtoMessage()
func (*Address_TcpIpAddress) ProtoReflect ¶
func (x *Address_TcpIpAddress) ProtoReflect() protoreflect.Message
func (*Address_TcpIpAddress) Reset ¶
func (x *Address_TcpIpAddress) Reset()
func (*Address_TcpIpAddress) String ¶
func (x *Address_TcpIpAddress) String() string
type Address_TcpipAddress ¶
type Address_TcpipAddress struct { TcpipAddress *Address_TcpIpAddress `protobuf:"bytes,1,opt,name=tcpip_address,json=tcpipAddress,proto3,oneof"` }
type Address_UdsAddress ¶
type Address_UdsAddress struct { Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"` // contains filtered or unexported fields }
A Unix Domain Socket address.
func (*Address_UdsAddress) Descriptor ¶
func (*Address_UdsAddress) Descriptor() ([]byte, []int)
Deprecated: Use Address_UdsAddress.ProtoReflect.Descriptor instead.
func (*Address_UdsAddress) GetFilename ¶
func (x *Address_UdsAddress) GetFilename() string
func (*Address_UdsAddress) ProtoMessage ¶
func (*Address_UdsAddress) ProtoMessage()
func (*Address_UdsAddress) ProtoReflect ¶
func (x *Address_UdsAddress) ProtoReflect() protoreflect.Message
func (*Address_UdsAddress) Reset ¶
func (x *Address_UdsAddress) Reset()
func (*Address_UdsAddress) String ¶
func (x *Address_UdsAddress) String() string
type Address_UdsAddress_ ¶
type Address_UdsAddress_ struct { UdsAddress *Address_UdsAddress `protobuf:"bytes,2,opt,name=uds_address,json=udsAddress,proto3,oneof"` }
type Channel ¶
type Channel struct { // The identifier for this channel. This should be set. Ref *ChannelRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"` // Data specific to this channel. Data *ChannelData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // At most one of 'channel_ref+subchannel_ref' and 'socket' is set. // There are no ordering guarantees on the order of channel refs. // There may not be cycles in the ref graph. // A channel ref may be present in more than one channel or subchannel. ChannelRef []*ChannelRef `protobuf:"bytes,3,rep,name=channel_ref,json=channelRef,proto3" json:"channel_ref,omitempty"` // At most one of 'channel_ref+subchannel_ref' and 'socket' is set. // There are no ordering guarantees on the order of subchannel refs. // There may not be cycles in the ref graph. // A sub channel ref may be present in more than one channel or subchannel. SubchannelRef []*SubchannelRef `protobuf:"bytes,4,rep,name=subchannel_ref,json=subchannelRef,proto3" json:"subchannel_ref,omitempty"` // There are no ordering guarantees on the order of sockets. SocketRef []*SocketRef `protobuf:"bytes,5,rep,name=socket_ref,json=socketRef,proto3" json:"socket_ref,omitempty"` // contains filtered or unexported fields }
Channel is a logical grouping of channels, subchannels, and sockets.
func (*Channel) Descriptor ¶
Deprecated: Use Channel.ProtoReflect.Descriptor instead.
func (*Channel) GetChannelRef ¶
func (x *Channel) GetChannelRef() []*ChannelRef
func (*Channel) GetData ¶
func (x *Channel) GetData() *ChannelData
func (*Channel) GetRef ¶
func (x *Channel) GetRef() *ChannelRef
func (*Channel) GetSocketRef ¶
func (*Channel) GetSubchannelRef ¶
func (x *Channel) GetSubchannelRef() []*SubchannelRef
func (*Channel) ProtoMessage ¶
func (*Channel) ProtoMessage()
func (*Channel) ProtoReflect ¶
func (x *Channel) ProtoReflect() protoreflect.Message
func (*Channel) Reset ¶
func (x *Channel) Reset()
func (*Channel) String ¶
type ChannelConnectivityState ¶
type ChannelConnectivityState struct { State ChannelConnectivityState_State `protobuf:"varint,1,opt,name=state,proto3,enum=grpc.channelz.v1.ChannelConnectivityState_State" json:"state,omitempty"` // contains filtered or unexported fields }
These come from the specified states in this document: https://github.com/grpc/grpc/blob/master/doc/connectivity-semantics-and-api.md
func (*ChannelConnectivityState) Descriptor ¶
func (*ChannelConnectivityState) Descriptor() ([]byte, []int)
Deprecated: Use ChannelConnectivityState.ProtoReflect.Descriptor instead.
func (*ChannelConnectivityState) GetState ¶
func (x *ChannelConnectivityState) GetState() ChannelConnectivityState_State
func (*ChannelConnectivityState) ProtoMessage ¶
func (*ChannelConnectivityState) ProtoMessage()
func (*ChannelConnectivityState) ProtoReflect ¶
func (x *ChannelConnectivityState) ProtoReflect() protoreflect.Message
func (*ChannelConnectivityState) Reset ¶
func (x *ChannelConnectivityState) Reset()
func (*ChannelConnectivityState) String ¶
func (x *ChannelConnectivityState) String() string
type ChannelConnectivityState_State ¶
type ChannelConnectivityState_State int32
const ( ChannelConnectivityState_UNKNOWN ChannelConnectivityState_State = 0 ChannelConnectivityState_IDLE ChannelConnectivityState_State = 1 ChannelConnectivityState_CONNECTING ChannelConnectivityState_State = 2 ChannelConnectivityState_READY ChannelConnectivityState_State = 3 ChannelConnectivityState_TRANSIENT_FAILURE ChannelConnectivityState_State = 4 ChannelConnectivityState_SHUTDOWN ChannelConnectivityState_State = 5 )
func (ChannelConnectivityState_State) Descriptor ¶
func (ChannelConnectivityState_State) Descriptor() protoreflect.EnumDescriptor
func (ChannelConnectivityState_State) Enum ¶
func (x ChannelConnectivityState_State) Enum() *ChannelConnectivityState_State
func (ChannelConnectivityState_State) EnumDescriptor ¶
func (ChannelConnectivityState_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use ChannelConnectivityState_State.Descriptor instead.
func (ChannelConnectivityState_State) Number ¶
func (x ChannelConnectivityState_State) Number() protoreflect.EnumNumber
func (ChannelConnectivityState_State) String ¶
func (x ChannelConnectivityState_State) String() string
func (ChannelConnectivityState_State) Type ¶
func (ChannelConnectivityState_State) Type() protoreflect.EnumType
type ChannelData ¶
type ChannelData struct { // The connectivity state of the channel or subchannel. Implementations // should always set this. State *ChannelConnectivityState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` // The target this channel originally tried to connect to. May be absent Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` // A trace of recent events on the channel. May be absent. Trace *ChannelTrace `protobuf:"bytes,3,opt,name=trace,proto3" json:"trace,omitempty"` // The number of calls started on the channel CallsStarted int64 `protobuf:"varint,4,opt,name=calls_started,json=callsStarted,proto3" json:"calls_started,omitempty"` // The number of calls that have completed with an OK status CallsSucceeded int64 `protobuf:"varint,5,opt,name=calls_succeeded,json=callsSucceeded,proto3" json:"calls_succeeded,omitempty"` // The number of calls that have completed with a non-OK status CallsFailed int64 `protobuf:"varint,6,opt,name=calls_failed,json=callsFailed,proto3" json:"calls_failed,omitempty"` // The last time a call was started on the channel. LastCallStartedTimestamp *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_call_started_timestamp,json=lastCallStartedTimestamp,proto3" json:"last_call_started_timestamp,omitempty"` // contains filtered or unexported fields }
Channel data is data related to a specific Channel or Subchannel.
func (*ChannelData) Descriptor ¶
func (*ChannelData) Descriptor() ([]byte, []int)
Deprecated: Use ChannelData.ProtoReflect.Descriptor instead.
func (*ChannelData) GetCallsFailed ¶
func (x *ChannelData) GetCallsFailed() int64
func (*ChannelData) GetCallsStarted ¶
func (x *ChannelData) GetCallsStarted() int64
func (*ChannelData) GetCallsSucceeded ¶
func (x *ChannelData) GetCallsSucceeded() int64
func (*ChannelData) GetLastCallStartedTimestamp ¶
func (x *ChannelData) GetLastCallStartedTimestamp() *timestamppb.Timestamp
func (*ChannelData) GetState ¶
func (x *ChannelData) GetState() *ChannelConnectivityState
func (*ChannelData) GetTarget ¶
func (x *ChannelData) GetTarget() string
func (*ChannelData) GetTrace ¶
func (x *ChannelData) GetTrace() *ChannelTrace
func (*ChannelData) ProtoMessage ¶
func (*ChannelData) ProtoMessage()
func (*ChannelData) ProtoReflect ¶
func (x *ChannelData) ProtoReflect() protoreflect.Message
func (*ChannelData) Reset ¶
func (x *ChannelData) Reset()
func (*ChannelData) String ¶
func (x *ChannelData) String() string
type ChannelRef ¶
type ChannelRef struct { // The globally unique id for this channel. Must be a positive number. ChannelId int64 `protobuf:"varint,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // An optional name associated with the channel. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
ChannelRef is a reference to a Channel.
func (*ChannelRef) Descriptor ¶
func (*ChannelRef) Descriptor() ([]byte, []int)
Deprecated: Use ChannelRef.ProtoReflect.Descriptor instead.
func (*ChannelRef) GetChannelId ¶
func (x *ChannelRef) GetChannelId() int64
func (*ChannelRef) GetName ¶
func (x *ChannelRef) GetName() string
func (*ChannelRef) ProtoMessage ¶
func (*ChannelRef) ProtoMessage()
func (*ChannelRef) ProtoReflect ¶
func (x *ChannelRef) ProtoReflect() protoreflect.Message
func (*ChannelRef) Reset ¶
func (x *ChannelRef) Reset()
func (*ChannelRef) String ¶
func (x *ChannelRef) String() string
type ChannelTrace ¶
type ChannelTrace struct { // Number of events ever logged in this tracing object. This can differ from // events.size() because events can be overwritten or garbage collected by // implementations. NumEventsLogged int64 `protobuf:"varint,1,opt,name=num_events_logged,json=numEventsLogged,proto3" json:"num_events_logged,omitempty"` // Time that this channel was created. CreationTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=creation_timestamp,json=creationTimestamp,proto3" json:"creation_timestamp,omitempty"` // List of events that have occurred on this channel. Events []*ChannelTraceEvent `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
ChannelTrace represents the recent events that have occurred on the channel.
func (*ChannelTrace) Descriptor ¶
func (*ChannelTrace) Descriptor() ([]byte, []int)
Deprecated: Use ChannelTrace.ProtoReflect.Descriptor instead.
func (*ChannelTrace) GetCreationTimestamp ¶
func (x *ChannelTrace) GetCreationTimestamp() *timestamppb.Timestamp
func (*ChannelTrace) GetEvents ¶
func (x *ChannelTrace) GetEvents() []*ChannelTraceEvent
func (*ChannelTrace) GetNumEventsLogged ¶
func (x *ChannelTrace) GetNumEventsLogged() int64
func (*ChannelTrace) ProtoMessage ¶
func (*ChannelTrace) ProtoMessage()
func (*ChannelTrace) ProtoReflect ¶
func (x *ChannelTrace) ProtoReflect() protoreflect.Message
func (*ChannelTrace) Reset ¶
func (x *ChannelTrace) Reset()
func (*ChannelTrace) String ¶
func (x *ChannelTrace) String() string
type ChannelTraceEvent ¶
type ChannelTraceEvent struct { // High level description of the event. Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"` // the severity of the trace event Severity ChannelTraceEvent_Severity `protobuf:"varint,2,opt,name=severity,proto3,enum=grpc.channelz.v1.ChannelTraceEvent_Severity" json:"severity,omitempty"` // When this event occurred. Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // ref of referenced channel or subchannel. // Optional, only present if this event refers to a child object. For example, // this field would be filled if this trace event was for a subchannel being // created. // // Types that are assignable to ChildRef: // // *ChannelTraceEvent_ChannelRef // *ChannelTraceEvent_SubchannelRef ChildRef isChannelTraceEvent_ChildRef `protobuf_oneof:"child_ref"` // contains filtered or unexported fields }
A trace event is an interesting thing that happened to a channel or subchannel, such as creation, address resolution, subchannel creation, etc.
func (*ChannelTraceEvent) Descriptor ¶
func (*ChannelTraceEvent) Descriptor() ([]byte, []int)
Deprecated: Use ChannelTraceEvent.ProtoReflect.Descriptor instead.
func (*ChannelTraceEvent) GetChannelRef ¶
func (x *ChannelTraceEvent) GetChannelRef() *ChannelRef
func (*ChannelTraceEvent) GetChildRef ¶
func (m *ChannelTraceEvent) GetChildRef() isChannelTraceEvent_ChildRef
func (*ChannelTraceEvent) GetDescription ¶
func (x *ChannelTraceEvent) GetDescription() string
func (*ChannelTraceEvent) GetSeverity ¶
func (x *ChannelTraceEvent) GetSeverity() ChannelTraceEvent_Severity
func (*ChannelTraceEvent) GetSubchannelRef ¶
func (x *ChannelTraceEvent) GetSubchannelRef() *SubchannelRef
func (*ChannelTraceEvent) GetTimestamp ¶
func (x *ChannelTraceEvent) GetTimestamp() *timestamppb.Timestamp
func (*ChannelTraceEvent) ProtoMessage ¶
func (*ChannelTraceEvent) ProtoMessage()
func (*ChannelTraceEvent) ProtoReflect ¶
func (x *ChannelTraceEvent) ProtoReflect() protoreflect.Message
func (*ChannelTraceEvent) Reset ¶
func (x *ChannelTraceEvent) Reset()
func (*ChannelTraceEvent) String ¶
func (x *ChannelTraceEvent) String() string
type ChannelTraceEvent_ChannelRef ¶
type ChannelTraceEvent_ChannelRef struct { ChannelRef *ChannelRef `protobuf:"bytes,4,opt,name=channel_ref,json=channelRef,proto3,oneof"` }
type ChannelTraceEvent_Severity ¶
type ChannelTraceEvent_Severity int32
The supported severity levels of trace events.
const ( ChannelTraceEvent_CT_UNKNOWN ChannelTraceEvent_Severity = 0 ChannelTraceEvent_CT_INFO ChannelTraceEvent_Severity = 1 ChannelTraceEvent_CT_WARNING ChannelTraceEvent_Severity = 2 ChannelTraceEvent_CT_ERROR ChannelTraceEvent_Severity = 3 )
func (ChannelTraceEvent_Severity) Descriptor ¶
func (ChannelTraceEvent_Severity) Descriptor() protoreflect.EnumDescriptor
func (ChannelTraceEvent_Severity) Enum ¶
func (x ChannelTraceEvent_Severity) Enum() *ChannelTraceEvent_Severity
func (ChannelTraceEvent_Severity) EnumDescriptor ¶
func (ChannelTraceEvent_Severity) EnumDescriptor() ([]byte, []int)
Deprecated: Use ChannelTraceEvent_Severity.Descriptor instead.
func (ChannelTraceEvent_Severity) Number ¶
func (x ChannelTraceEvent_Severity) Number() protoreflect.EnumNumber
func (ChannelTraceEvent_Severity) String ¶
func (x ChannelTraceEvent_Severity) String() string
func (ChannelTraceEvent_Severity) Type ¶
func (ChannelTraceEvent_Severity) Type() protoreflect.EnumType
type ChannelTraceEvent_SubchannelRef ¶
type ChannelTraceEvent_SubchannelRef struct { SubchannelRef *SubchannelRef `protobuf:"bytes,5,opt,name=subchannel_ref,json=subchannelRef,proto3,oneof"` }
type ChannelzClient ¶
type ChannelzClient interface { // Gets all root channels (i.e. channels the application has directly // created). This does not include subchannels nor non-top level channels. GetTopChannels(ctx context.Context, in *GetTopChannelsRequest, opts ...grpc.CallOption) (*GetTopChannelsResponse, error) // Gets all servers that exist in the process. GetServers(ctx context.Context, in *GetServersRequest, opts ...grpc.CallOption) (*GetServersResponse, error) // Returns a single Server, or else a NOT_FOUND code. GetServer(ctx context.Context, in *GetServerRequest, opts ...grpc.CallOption) (*GetServerResponse, error) // Gets all server sockets that exist in the process. GetServerSockets(ctx context.Context, in *GetServerSocketsRequest, opts ...grpc.CallOption) (*GetServerSocketsResponse, error) // Returns a single Channel, or else a NOT_FOUND code. GetChannel(ctx context.Context, in *GetChannelRequest, opts ...grpc.CallOption) (*GetChannelResponse, error) // Returns a single Subchannel, or else a NOT_FOUND code. GetSubchannel(ctx context.Context, in *GetSubchannelRequest, opts ...grpc.CallOption) (*GetSubchannelResponse, error) // Returns a single Socket or else a NOT_FOUND code. GetSocket(ctx context.Context, in *GetSocketRequest, opts ...grpc.CallOption) (*GetSocketResponse, error) }
ChannelzClient is the client API for Channelz service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
Channelz is a service exposed by gRPC servers that provides detailed debug information.
func NewChannelzClient ¶
func NewChannelzClient(cc grpc.ClientConnInterface) ChannelzClient
type ChannelzServer ¶
type ChannelzServer interface { // Gets all root channels (i.e. channels the application has directly // created). This does not include subchannels nor non-top level channels. GetTopChannels(context.Context, *GetTopChannelsRequest) (*GetTopChannelsResponse, error) // Gets all servers that exist in the process. GetServers(context.Context, *GetServersRequest) (*GetServersResponse, error) // Returns a single Server, or else a NOT_FOUND code. GetServer(context.Context, *GetServerRequest) (*GetServerResponse, error) // Gets all server sockets that exist in the process. GetServerSockets(context.Context, *GetServerSocketsRequest) (*GetServerSocketsResponse, error) // Returns a single Channel, or else a NOT_FOUND code. GetChannel(context.Context, *GetChannelRequest) (*GetChannelResponse, error) // Returns a single Subchannel, or else a NOT_FOUND code. GetSubchannel(context.Context, *GetSubchannelRequest) (*GetSubchannelResponse, error) // Returns a single Socket or else a NOT_FOUND code. GetSocket(context.Context, *GetSocketRequest) (*GetSocketResponse, error) }
ChannelzServer is the server API for Channelz service. All implementations should embed UnimplementedChannelzServer for forward compatibility.
Channelz is a service exposed by gRPC servers that provides detailed debug information.
type GetChannelRequest ¶
type GetChannelRequest struct { // channel_id is the identifier of the specific channel to get. ChannelId int64 `protobuf:"varint,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // contains filtered or unexported fields }
func (*GetChannelRequest) Descriptor ¶
func (*GetChannelRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetChannelRequest.ProtoReflect.Descriptor instead.
func (*GetChannelRequest) GetChannelId ¶
func (x *GetChannelRequest) GetChannelId() int64
func (*GetChannelRequest) ProtoMessage ¶
func (*GetChannelRequest) ProtoMessage()
func (*GetChannelRequest) ProtoReflect ¶
func (x *GetChannelRequest) ProtoReflect() protoreflect.Message
func (*GetChannelRequest) Reset ¶
func (x *GetChannelRequest) Reset()
func (*GetChannelRequest) String ¶
func (x *GetChannelRequest) String() string
type GetChannelResponse ¶
type GetChannelResponse struct { // The Channel that corresponds to the requested channel_id. This field // should be set. Channel *Channel `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` // contains filtered or unexported fields }
func (*GetChannelResponse) Descriptor ¶
func (*GetChannelResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetChannelResponse.ProtoReflect.Descriptor instead.
func (*GetChannelResponse) GetChannel ¶
func (x *GetChannelResponse) GetChannel() *Channel
func (*GetChannelResponse) ProtoMessage ¶
func (*GetChannelResponse) ProtoMessage()
func (*GetChannelResponse) ProtoReflect ¶
func (x *GetChannelResponse) ProtoReflect() protoreflect.Message
func (*GetChannelResponse) Reset ¶
func (x *GetChannelResponse) Reset()
func (*GetChannelResponse) String ¶
func (x *GetChannelResponse) String() string
type GetServerRequest ¶
type GetServerRequest struct { // server_id is the identifier of the specific server to get. ServerId int64 `protobuf:"varint,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"` // contains filtered or unexported fields }
func (*GetServerRequest) Descriptor ¶
func (*GetServerRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetServerRequest.ProtoReflect.Descriptor instead.
func (*GetServerRequest) GetServerId ¶
func (x *GetServerRequest) GetServerId() int64
func (*GetServerRequest) ProtoMessage ¶
func (*GetServerRequest) ProtoMessage()
func (*GetServerRequest) ProtoReflect ¶
func (x *GetServerRequest) ProtoReflect() protoreflect.Message
func (*GetServerRequest) Reset ¶
func (x *GetServerRequest) Reset()
func (*GetServerRequest) String ¶
func (x *GetServerRequest) String() string
type GetServerResponse ¶
type GetServerResponse struct { // The Server that corresponds to the requested server_id. This field // should be set. Server *Server `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` // contains filtered or unexported fields }
func (*GetServerResponse) Descriptor ¶
func (*GetServerResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetServerResponse.ProtoReflect.Descriptor instead.
func (*GetServerResponse) GetServer ¶
func (x *GetServerResponse) GetServer() *Server
func (*GetServerResponse) ProtoMessage ¶
func (*GetServerResponse) ProtoMessage()
func (*GetServerResponse) ProtoReflect ¶
func (x *GetServerResponse) ProtoReflect() protoreflect.Message
func (*GetServerResponse) Reset ¶
func (x *GetServerResponse) Reset()
func (*GetServerResponse) String ¶
func (x *GetServerResponse) String() string
type GetServerSocketsRequest ¶
type GetServerSocketsRequest struct { ServerId int64 `protobuf:"varint,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"` // start_socket_id indicates that only sockets at or above this id should be // included in the results. // To request the first page, this must be set to 0. To request // subsequent pages, the client generates this value by adding 1 to // the highest seen result ID. StartSocketId int64 `protobuf:"varint,2,opt,name=start_socket_id,json=startSocketId,proto3" json:"start_socket_id,omitempty"` // If non-zero, the server will return a page of results containing // at most this many items. If zero, the server will choose a // reasonable page size. Must never be negative. MaxResults int64 `protobuf:"varint,3,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"` // contains filtered or unexported fields }
func (*GetServerSocketsRequest) Descriptor ¶
func (*GetServerSocketsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetServerSocketsRequest.ProtoReflect.Descriptor instead.
func (*GetServerSocketsRequest) GetMaxResults ¶
func (x *GetServerSocketsRequest) GetMaxResults() int64
func (*GetServerSocketsRequest) GetServerId ¶
func (x *GetServerSocketsRequest) GetServerId() int64
func (*GetServerSocketsRequest) GetStartSocketId ¶
func (x *GetServerSocketsRequest) GetStartSocketId() int64
func (*GetServerSocketsRequest) ProtoMessage ¶
func (*GetServerSocketsRequest) ProtoMessage()
func (*GetServerSocketsRequest) ProtoReflect ¶
func (x *GetServerSocketsRequest) ProtoReflect() protoreflect.Message
func (*GetServerSocketsRequest) Reset ¶
func (x *GetServerSocketsRequest) Reset()
func (*GetServerSocketsRequest) String ¶
func (x *GetServerSocketsRequest) String() string
type GetServerSocketsResponse ¶
type GetServerSocketsResponse struct { // list of socket refs that the connection detail service knows about. Sorted in // ascending socket_id order. // Must contain at least 1 result, otherwise 'end' must be true. SocketRef []*SocketRef `protobuf:"bytes,1,rep,name=socket_ref,json=socketRef,proto3" json:"socket_ref,omitempty"` // If set, indicates that the list of sockets is the final list. Requesting // more sockets will only return more if they are created after this RPC // completes. End bool `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"` // contains filtered or unexported fields }
func (*GetServerSocketsResponse) Descriptor ¶
func (*GetServerSocketsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetServerSocketsResponse.ProtoReflect.Descriptor instead.
func (*GetServerSocketsResponse) GetEnd ¶
func (x *GetServerSocketsResponse) GetEnd() bool
func (*GetServerSocketsResponse) GetSocketRef ¶
func (x *GetServerSocketsResponse) GetSocketRef() []*SocketRef
func (*GetServerSocketsResponse) ProtoMessage ¶
func (*GetServerSocketsResponse) ProtoMessage()
func (*GetServerSocketsResponse) ProtoReflect ¶
func (x *GetServerSocketsResponse) ProtoReflect() protoreflect.Message
func (*GetServerSocketsResponse) Reset ¶
func (x *GetServerSocketsResponse) Reset()
func (*GetServerSocketsResponse) String ¶
func (x *GetServerSocketsResponse) String() string
type GetServersRequest ¶
type GetServersRequest struct { // start_server_id indicates that only servers at or above this id should be // included in the results. // To request the first page, this must be set to 0. To request // subsequent pages, the client generates this value by adding 1 to // the highest seen result ID. StartServerId int64 `protobuf:"varint,1,opt,name=start_server_id,json=startServerId,proto3" json:"start_server_id,omitempty"` // If non-zero, the server will return a page of results containing // at most this many items. If zero, the server will choose a // reasonable page size. Must never be negative. MaxResults int64 `protobuf:"varint,2,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"` // contains filtered or unexported fields }
func (*GetServersRequest) Descriptor ¶
func (*GetServersRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetServersRequest.ProtoReflect.Descriptor instead.
func (*GetServersRequest) GetMaxResults ¶
func (x *GetServersRequest) GetMaxResults() int64
func (*GetServersRequest) GetStartServerId ¶
func (x *GetServersRequest) GetStartServerId() int64
func (*GetServersRequest) ProtoMessage ¶
func (*GetServersRequest) ProtoMessage()
func (*GetServersRequest) ProtoReflect ¶
func (x *GetServersRequest) ProtoReflect() protoreflect.Message
func (*GetServersRequest) Reset ¶
func (x *GetServersRequest) Reset()
func (*GetServersRequest) String ¶
func (x *GetServersRequest) String() string
type GetServersResponse ¶
type GetServersResponse struct { // list of servers that the connection detail service knows about. Sorted in // ascending server_id order. // Must contain at least 1 result, otherwise 'end' must be true. Server []*Server `protobuf:"bytes,1,rep,name=server,proto3" json:"server,omitempty"` // If set, indicates that the list of servers is the final list. Requesting // more servers will only return more if they are created after this RPC // completes. End bool `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"` // contains filtered or unexported fields }
func (*GetServersResponse) Descriptor ¶
func (*GetServersResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetServersResponse.ProtoReflect.Descriptor instead.
func (*GetServersResponse) GetEnd ¶
func (x *GetServersResponse) GetEnd() bool
func (*GetServersResponse) GetServer ¶
func (x *GetServersResponse) GetServer() []*Server
func (*GetServersResponse) ProtoMessage ¶
func (*GetServersResponse) ProtoMessage()
func (*GetServersResponse) ProtoReflect ¶
func (x *GetServersResponse) ProtoReflect() protoreflect.Message
func (*GetServersResponse) Reset ¶
func (x *GetServersResponse) Reset()
func (*GetServersResponse) String ¶
func (x *GetServersResponse) String() string
type GetSocketRequest ¶
type GetSocketRequest struct { // socket_id is the identifier of the specific socket to get. SocketId int64 `protobuf:"varint,1,opt,name=socket_id,json=socketId,proto3" json:"socket_id,omitempty"` // If true, the response will contain only high level information // that is inexpensive to obtain. Fields that may be omitted are // documented. Summary bool `protobuf:"varint,2,opt,name=summary,proto3" json:"summary,omitempty"` // contains filtered or unexported fields }
func (*GetSocketRequest) Descriptor ¶
func (*GetSocketRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSocketRequest.ProtoReflect.Descriptor instead.
func (*GetSocketRequest) GetSocketId ¶
func (x *GetSocketRequest) GetSocketId() int64
func (*GetSocketRequest) GetSummary ¶
func (x *GetSocketRequest) GetSummary() bool
func (*GetSocketRequest) ProtoMessage ¶
func (*GetSocketRequest) ProtoMessage()
func (*GetSocketRequest) ProtoReflect ¶
func (x *GetSocketRequest) ProtoReflect() protoreflect.Message
func (*GetSocketRequest) Reset ¶
func (x *GetSocketRequest) Reset()
func (*GetSocketRequest) String ¶
func (x *GetSocketRequest) String() string
type GetSocketResponse ¶
type GetSocketResponse struct { // The Socket that corresponds to the requested socket_id. This field // should be set. Socket *Socket `protobuf:"bytes,1,opt,name=socket,proto3" json:"socket,omitempty"` // contains filtered or unexported fields }
func (*GetSocketResponse) Descriptor ¶
func (*GetSocketResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSocketResponse.ProtoReflect.Descriptor instead.
func (*GetSocketResponse) GetSocket ¶
func (x *GetSocketResponse) GetSocket() *Socket
func (*GetSocketResponse) ProtoMessage ¶
func (*GetSocketResponse) ProtoMessage()
func (*GetSocketResponse) ProtoReflect ¶
func (x *GetSocketResponse) ProtoReflect() protoreflect.Message
func (*GetSocketResponse) Reset ¶
func (x *GetSocketResponse) Reset()
func (*GetSocketResponse) String ¶
func (x *GetSocketResponse) String() string
type GetSubchannelRequest ¶
type GetSubchannelRequest struct { // subchannel_id is the identifier of the specific subchannel to get. SubchannelId int64 `protobuf:"varint,1,opt,name=subchannel_id,json=subchannelId,proto3" json:"subchannel_id,omitempty"` // contains filtered or unexported fields }
func (*GetSubchannelRequest) Descriptor ¶
func (*GetSubchannelRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSubchannelRequest.ProtoReflect.Descriptor instead.
func (*GetSubchannelRequest) GetSubchannelId ¶
func (x *GetSubchannelRequest) GetSubchannelId() int64
func (*GetSubchannelRequest) ProtoMessage ¶
func (*GetSubchannelRequest) ProtoMessage()
func (*GetSubchannelRequest) ProtoReflect ¶
func (x *GetSubchannelRequest) ProtoReflect() protoreflect.Message
func (*GetSubchannelRequest) Reset ¶
func (x *GetSubchannelRequest) Reset()
func (*GetSubchannelRequest) String ¶
func (x *GetSubchannelRequest) String() string
type GetSubchannelResponse ¶
type GetSubchannelResponse struct { // The Subchannel that corresponds to the requested subchannel_id. This // field should be set. Subchannel *Subchannel `protobuf:"bytes,1,opt,name=subchannel,proto3" json:"subchannel,omitempty"` // contains filtered or unexported fields }
func (*GetSubchannelResponse) Descriptor ¶
func (*GetSubchannelResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSubchannelResponse.ProtoReflect.Descriptor instead.
func (*GetSubchannelResponse) GetSubchannel ¶
func (x *GetSubchannelResponse) GetSubchannel() *Subchannel
func (*GetSubchannelResponse) ProtoMessage ¶
func (*GetSubchannelResponse) ProtoMessage()
func (*GetSubchannelResponse) ProtoReflect ¶
func (x *GetSubchannelResponse) ProtoReflect() protoreflect.Message
func (*GetSubchannelResponse) Reset ¶
func (x *GetSubchannelResponse) Reset()
func (*GetSubchannelResponse) String ¶
func (x *GetSubchannelResponse) String() string
type GetTopChannelsRequest ¶
type GetTopChannelsRequest struct { // start_channel_id indicates that only channels at or above this id should be // included in the results. // To request the first page, this should be set to 0. To request // subsequent pages, the client generates this value by adding 1 to // the highest seen result ID. StartChannelId int64 `protobuf:"varint,1,opt,name=start_channel_id,json=startChannelId,proto3" json:"start_channel_id,omitempty"` // If non-zero, the server will return a page of results containing // at most this many items. If zero, the server will choose a // reasonable page size. Must never be negative. MaxResults int64 `protobuf:"varint,2,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"` // contains filtered or unexported fields }
func (*GetTopChannelsRequest) Descriptor ¶
func (*GetTopChannelsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTopChannelsRequest.ProtoReflect.Descriptor instead.
func (*GetTopChannelsRequest) GetMaxResults ¶
func (x *GetTopChannelsRequest) GetMaxResults() int64
func (*GetTopChannelsRequest) GetStartChannelId ¶
func (x *GetTopChannelsRequest) GetStartChannelId() int64
func (*GetTopChannelsRequest) ProtoMessage ¶
func (*GetTopChannelsRequest) ProtoMessage()
func (*GetTopChannelsRequest) ProtoReflect ¶
func (x *GetTopChannelsRequest) ProtoReflect() protoreflect.Message
func (*GetTopChannelsRequest) Reset ¶
func (x *GetTopChannelsRequest) Reset()
func (*GetTopChannelsRequest) String ¶
func (x *GetTopChannelsRequest) String() string
type GetTopChannelsResponse ¶
type GetTopChannelsResponse struct { // list of channels that the connection detail service knows about. Sorted in // ascending channel_id order. // Must contain at least 1 result, otherwise 'end' must be true. Channel []*Channel `protobuf:"bytes,1,rep,name=channel,proto3" json:"channel,omitempty"` // If set, indicates that the list of channels is the final list. Requesting // more channels can only return more if they are created after this RPC // completes. End bool `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"` // contains filtered or unexported fields }
func (*GetTopChannelsResponse) Descriptor ¶
func (*GetTopChannelsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTopChannelsResponse.ProtoReflect.Descriptor instead.
func (*GetTopChannelsResponse) GetChannel ¶
func (x *GetTopChannelsResponse) GetChannel() []*Channel
func (*GetTopChannelsResponse) GetEnd ¶
func (x *GetTopChannelsResponse) GetEnd() bool
func (*GetTopChannelsResponse) ProtoMessage ¶
func (*GetTopChannelsResponse) ProtoMessage()
func (*GetTopChannelsResponse) ProtoReflect ¶
func (x *GetTopChannelsResponse) ProtoReflect() protoreflect.Message
func (*GetTopChannelsResponse) Reset ¶
func (x *GetTopChannelsResponse) Reset()
func (*GetTopChannelsResponse) String ¶
func (x *GetTopChannelsResponse) String() string
type Security ¶
type Security struct { // Types that are assignable to Model: // // *Security_Tls_ // *Security_Other Model isSecurity_Model `protobuf_oneof:"model"` // contains filtered or unexported fields }
Security represents details about how secure the socket is.
func (*Security) Descriptor ¶
Deprecated: Use Security.ProtoReflect.Descriptor instead.
func (*Security) GetModel ¶
func (m *Security) GetModel() isSecurity_Model
func (*Security) GetOther ¶
func (x *Security) GetOther() *Security_OtherSecurity
func (*Security) GetTls ¶
func (x *Security) GetTls() *Security_Tls
func (*Security) ProtoMessage ¶
func (*Security) ProtoMessage()
func (*Security) ProtoReflect ¶
func (x *Security) ProtoReflect() protoreflect.Message
func (*Security) Reset ¶
func (x *Security) Reset()
func (*Security) String ¶
type Security_Other ¶
type Security_Other struct { Other *Security_OtherSecurity `protobuf:"bytes,2,opt,name=other,proto3,oneof"` }
type Security_OtherSecurity ¶
type Security_OtherSecurity struct { // The human readable version of the value. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The actual security details message. Value *anypb.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Security_OtherSecurity) Descriptor ¶
func (*Security_OtherSecurity) Descriptor() ([]byte, []int)
Deprecated: Use Security_OtherSecurity.ProtoReflect.Descriptor instead.
func (*Security_OtherSecurity) GetName ¶
func (x *Security_OtherSecurity) GetName() string
func (*Security_OtherSecurity) GetValue ¶
func (x *Security_OtherSecurity) GetValue() *anypb.Any
func (*Security_OtherSecurity) ProtoMessage ¶
func (*Security_OtherSecurity) ProtoMessage()
func (*Security_OtherSecurity) ProtoReflect ¶
func (x *Security_OtherSecurity) ProtoReflect() protoreflect.Message
func (*Security_OtherSecurity) Reset ¶
func (x *Security_OtherSecurity) Reset()
func (*Security_OtherSecurity) String ¶
func (x *Security_OtherSecurity) String() string
type Security_Tls ¶
type Security_Tls struct { // Types that are assignable to CipherSuite: // // *Security_Tls_StandardName // *Security_Tls_OtherName CipherSuite isSecurity_Tls_CipherSuite `protobuf_oneof:"cipher_suite"` // the certificate used by this endpoint. LocalCertificate []byte `protobuf:"bytes,3,opt,name=local_certificate,json=localCertificate,proto3" json:"local_certificate,omitempty"` // the certificate used by the remote endpoint. RemoteCertificate []byte `protobuf:"bytes,4,opt,name=remote_certificate,json=remoteCertificate,proto3" json:"remote_certificate,omitempty"` // contains filtered or unexported fields }
func (*Security_Tls) Descriptor ¶
func (*Security_Tls) Descriptor() ([]byte, []int)
Deprecated: Use Security_Tls.ProtoReflect.Descriptor instead.
func (*Security_Tls) GetCipherSuite ¶
func (m *Security_Tls) GetCipherSuite() isSecurity_Tls_CipherSuite
func (*Security_Tls) GetLocalCertificate ¶
func (x *Security_Tls) GetLocalCertificate() []byte
func (*Security_Tls) GetOtherName ¶
func (x *Security_Tls) GetOtherName() string
func (*Security_Tls) GetRemoteCertificate ¶
func (x *Security_Tls) GetRemoteCertificate() []byte
func (*Security_Tls) GetStandardName ¶
func (x *Security_Tls) GetStandardName() string
func (*Security_Tls) ProtoMessage ¶
func (*Security_Tls) ProtoMessage()
func (*Security_Tls) ProtoReflect ¶
func (x *Security_Tls) ProtoReflect() protoreflect.Message
func (*Security_Tls) Reset ¶
func (x *Security_Tls) Reset()
func (*Security_Tls) String ¶
func (x *Security_Tls) String() string
type Security_Tls_ ¶
type Security_Tls_ struct { Tls *Security_Tls `protobuf:"bytes,1,opt,name=tls,proto3,oneof"` }
type Security_Tls_OtherName ¶
type Security_Tls_OtherName struct { // Some other way to describe the cipher suite if // the RFC 4346 name is not available. OtherName string `protobuf:"bytes,2,opt,name=other_name,json=otherName,proto3,oneof"` }
type Security_Tls_StandardName ¶
type Security_Tls_StandardName struct { // The cipher suite name in the RFC 4346 format: // https://tools.ietf.org/html/rfc4346#appendix-C StandardName string `protobuf:"bytes,1,opt,name=standard_name,json=standardName,proto3,oneof"` }
type Server ¶
type Server struct { // The identifier for a Server. This should be set. Ref *ServerRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"` // The associated data of the Server. Data *ServerData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // The sockets that the server is listening on. There are no ordering // guarantees. This may be absent. ListenSocket []*SocketRef `protobuf:"bytes,3,rep,name=listen_socket,json=listenSocket,proto3" json:"listen_socket,omitempty"` // contains filtered or unexported fields }
Server represents a single server. There may be multiple servers in a single program.
func (*Server) Descriptor ¶
Deprecated: Use Server.ProtoReflect.Descriptor instead.
func (*Server) GetData ¶
func (x *Server) GetData() *ServerData
func (*Server) GetListenSocket ¶
func (*Server) GetRef ¶
func (*Server) ProtoMessage ¶
func (*Server) ProtoMessage()
func (*Server) ProtoReflect ¶
func (x *Server) ProtoReflect() protoreflect.Message
func (*Server) Reset ¶
func (x *Server) Reset()
func (*Server) String ¶
type ServerData ¶
type ServerData struct { // A trace of recent events on the server. May be absent. Trace *ChannelTrace `protobuf:"bytes,1,opt,name=trace,proto3" json:"trace,omitempty"` // The number of incoming calls started on the server CallsStarted int64 `protobuf:"varint,2,opt,name=calls_started,json=callsStarted,proto3" json:"calls_started,omitempty"` // The number of incoming calls that have completed with an OK status CallsSucceeded int64 `protobuf:"varint,3,opt,name=calls_succeeded,json=callsSucceeded,proto3" json:"calls_succeeded,omitempty"` // The number of incoming calls that have a completed with a non-OK status CallsFailed int64 `protobuf:"varint,4,opt,name=calls_failed,json=callsFailed,proto3" json:"calls_failed,omitempty"` // The last time a call was started on the server. LastCallStartedTimestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_call_started_timestamp,json=lastCallStartedTimestamp,proto3" json:"last_call_started_timestamp,omitempty"` // contains filtered or unexported fields }
ServerData is data for a specific Server.
func (*ServerData) Descriptor ¶
func (*ServerData) Descriptor() ([]byte, []int)
Deprecated: Use ServerData.ProtoReflect.Descriptor instead.
func (*ServerData) GetCallsFailed ¶
func (x *ServerData) GetCallsFailed() int64
func (*ServerData) GetCallsStarted ¶
func (x *ServerData) GetCallsStarted() int64
func (*ServerData) GetCallsSucceeded ¶
func (x *ServerData) GetCallsSucceeded() int64
func (*ServerData) GetLastCallStartedTimestamp ¶
func (x *ServerData) GetLastCallStartedTimestamp() *timestamppb.Timestamp
func (*ServerData) GetTrace ¶
func (x *ServerData) GetTrace() *ChannelTrace
func (*ServerData) ProtoMessage ¶
func (*ServerData) ProtoMessage()
func (*ServerData) ProtoReflect ¶
func (x *ServerData) ProtoReflect() protoreflect.Message
func (*ServerData) Reset ¶
func (x *ServerData) Reset()
func (*ServerData) String ¶
func (x *ServerData) String() string
type ServerRef ¶
type ServerRef struct { // A globally unique identifier for this server. Must be a positive number. ServerId int64 `protobuf:"varint,5,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"` // An optional name associated with the server. Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
ServerRef is a reference to a Server.
func (*ServerRef) Descriptor ¶
Deprecated: Use ServerRef.ProtoReflect.Descriptor instead.
func (*ServerRef) GetName ¶
func (*ServerRef) GetServerId ¶
func (*ServerRef) ProtoMessage ¶
func (*ServerRef) ProtoMessage()
func (*ServerRef) ProtoReflect ¶
func (x *ServerRef) ProtoReflect() protoreflect.Message
func (*ServerRef) Reset ¶
func (x *ServerRef) Reset()
func (*ServerRef) String ¶
type Socket ¶
type Socket struct { // The identifier for the Socket. Ref *SocketRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"` // Data specific to this Socket. Data *SocketData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // The locally bound address. Local *Address `protobuf:"bytes,3,opt,name=local,proto3" json:"local,omitempty"` // The remote bound address. May be absent. Remote *Address `protobuf:"bytes,4,opt,name=remote,proto3" json:"remote,omitempty"` // Security details for this socket. May be absent if not available, or // there is no security on the socket. Security *Security `protobuf:"bytes,5,opt,name=security,proto3" json:"security,omitempty"` // Optional, represents the name of the remote endpoint, if different than // the original target name. RemoteName string `protobuf:"bytes,6,opt,name=remote_name,json=remoteName,proto3" json:"remote_name,omitempty"` // contains filtered or unexported fields }
Information about an actual connection. Pronounced "sock-ay".
func (*Socket) Descriptor ¶
Deprecated: Use Socket.ProtoReflect.Descriptor instead.
func (*Socket) GetData ¶
func (x *Socket) GetData() *SocketData
func (*Socket) GetLocal ¶
func (*Socket) GetRef ¶
func (*Socket) GetRemote ¶
func (*Socket) GetRemoteName ¶
func (*Socket) GetSecurity ¶
func (*Socket) ProtoMessage ¶
func (*Socket) ProtoMessage()
func (*Socket) ProtoReflect ¶
func (x *Socket) ProtoReflect() protoreflect.Message
func (*Socket) Reset ¶
func (x *Socket) Reset()
func (*Socket) String ¶
type SocketData ¶
type SocketData struct { // The number of streams that have been started. StreamsStarted int64 `protobuf:"varint,1,opt,name=streams_started,json=streamsStarted,proto3" json:"streams_started,omitempty"` // The number of streams that have ended successfully: // On client side, received frame with eos bit set; // On server side, sent frame with eos bit set. StreamsSucceeded int64 `protobuf:"varint,2,opt,name=streams_succeeded,json=streamsSucceeded,proto3" json:"streams_succeeded,omitempty"` // The number of streams that have ended unsuccessfully: // On client side, ended without receiving frame with eos bit set; // On server side, ended without sending frame with eos bit set. StreamsFailed int64 `protobuf:"varint,3,opt,name=streams_failed,json=streamsFailed,proto3" json:"streams_failed,omitempty"` // The number of grpc messages successfully sent on this socket. MessagesSent int64 `protobuf:"varint,4,opt,name=messages_sent,json=messagesSent,proto3" json:"messages_sent,omitempty"` // The number of grpc messages received on this socket. MessagesReceived int64 `protobuf:"varint,5,opt,name=messages_received,json=messagesReceived,proto3" json:"messages_received,omitempty"` // The number of keep alives sent. This is typically implemented with HTTP/2 // ping messages. KeepAlivesSent int64 `protobuf:"varint,6,opt,name=keep_alives_sent,json=keepAlivesSent,proto3" json:"keep_alives_sent,omitempty"` // The last time a stream was created by this endpoint. Usually unset for // servers. LastLocalStreamCreatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_local_stream_created_timestamp,json=lastLocalStreamCreatedTimestamp,proto3" json:"last_local_stream_created_timestamp,omitempty"` // The last time a stream was created by the remote endpoint. Usually unset // for clients. LastRemoteStreamCreatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=last_remote_stream_created_timestamp,json=lastRemoteStreamCreatedTimestamp,proto3" json:"last_remote_stream_created_timestamp,omitempty"` // The last time a message was sent by this endpoint. LastMessageSentTimestamp *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=last_message_sent_timestamp,json=lastMessageSentTimestamp,proto3" json:"last_message_sent_timestamp,omitempty"` // The last time a message was received by this endpoint. LastMessageReceivedTimestamp *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=last_message_received_timestamp,json=lastMessageReceivedTimestamp,proto3" json:"last_message_received_timestamp,omitempty"` // The amount of window, granted to the local endpoint by the remote endpoint. // This may be slightly out of date due to network latency. This does NOT // include stream level or TCP level flow control info. LocalFlowControlWindow *wrapperspb.Int64Value `protobuf:"bytes,11,opt,name=local_flow_control_window,json=localFlowControlWindow,proto3" json:"local_flow_control_window,omitempty"` // The amount of window, granted to the remote endpoint by the local endpoint. // This may be slightly out of date due to network latency. This does NOT // include stream level or TCP level flow control info. RemoteFlowControlWindow *wrapperspb.Int64Value `protobuf:"bytes,12,opt,name=remote_flow_control_window,json=remoteFlowControlWindow,proto3" json:"remote_flow_control_window,omitempty"` // Socket options set on this socket. May be absent if 'summary' is set // on GetSocketRequest. Option []*SocketOption `protobuf:"bytes,13,rep,name=option,proto3" json:"option,omitempty"` // contains filtered or unexported fields }
SocketData is data associated for a specific Socket. The fields present are specific to the implementation, so there may be minor differences in the semantics. (e.g. flow control windows)
func (*SocketData) Descriptor ¶
func (*SocketData) Descriptor() ([]byte, []int)
Deprecated: Use SocketData.ProtoReflect.Descriptor instead.
func (*SocketData) GetKeepAlivesSent ¶
func (x *SocketData) GetKeepAlivesSent() int64
func (*SocketData) GetLastLocalStreamCreatedTimestamp ¶
func (x *SocketData) GetLastLocalStreamCreatedTimestamp() *timestamppb.Timestamp
func (*SocketData) GetLastMessageReceivedTimestamp ¶
func (x *SocketData) GetLastMessageReceivedTimestamp() *timestamppb.Timestamp
func (*SocketData) GetLastMessageSentTimestamp ¶
func (x *SocketData) GetLastMessageSentTimestamp() *timestamppb.Timestamp
func (*SocketData) GetLastRemoteStreamCreatedTimestamp ¶
func (x *SocketData) GetLastRemoteStreamCreatedTimestamp() *timestamppb.Timestamp
func (*SocketData) GetLocalFlowControlWindow ¶
func (x *SocketData) GetLocalFlowControlWindow() *wrapperspb.Int64Value
func (*SocketData) GetMessagesReceived ¶
func (x *SocketData) GetMessagesReceived() int64
func (*SocketData) GetMessagesSent ¶
func (x *SocketData) GetMessagesSent() int64
func (*SocketData) GetOption ¶
func (x *SocketData) GetOption() []*SocketOption
func (*SocketData) GetRemoteFlowControlWindow ¶
func (x *SocketData) GetRemoteFlowControlWindow() *wrapperspb.Int64Value
func (*SocketData) GetStreamsFailed ¶
func (x *SocketData) GetStreamsFailed() int64
func (*SocketData) GetStreamsStarted ¶
func (x *SocketData) GetStreamsStarted() int64
func (*SocketData) GetStreamsSucceeded ¶
func (x *SocketData) GetStreamsSucceeded() int64
func (*SocketData) ProtoMessage ¶
func (*SocketData) ProtoMessage()
func (*SocketData) ProtoReflect ¶
func (x *SocketData) ProtoReflect() protoreflect.Message
func (*SocketData) Reset ¶
func (x *SocketData) Reset()
func (*SocketData) String ¶
func (x *SocketData) String() string
type SocketOption ¶
type SocketOption struct { // The full name of the socket option. Typically this will be the upper case // name, such as "SO_REUSEPORT". Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The human readable value of this socket option. At least one of value or // additional will be set. Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // Additional data associated with the socket option. At least one of value // or additional will be set. Additional *anypb.Any `protobuf:"bytes,3,opt,name=additional,proto3" json:"additional,omitempty"` // contains filtered or unexported fields }
SocketOption represents socket options for a socket. Specifically, these are the options returned by getsockopt().
func (*SocketOption) Descriptor ¶
func (*SocketOption) Descriptor() ([]byte, []int)
Deprecated: Use SocketOption.ProtoReflect.Descriptor instead.
func (*SocketOption) GetAdditional ¶
func (x *SocketOption) GetAdditional() *anypb.Any
func (*SocketOption) GetName ¶
func (x *SocketOption) GetName() string
func (*SocketOption) GetValue ¶
func (x *SocketOption) GetValue() string
func (*SocketOption) ProtoMessage ¶
func (*SocketOption) ProtoMessage()
func (*SocketOption) ProtoReflect ¶
func (x *SocketOption) ProtoReflect() protoreflect.Message
func (*SocketOption) Reset ¶
func (x *SocketOption) Reset()
func (*SocketOption) String ¶
func (x *SocketOption) String() string
type SocketOptionLinger ¶
type SocketOptionLinger struct { // active maps to `struct linger.l_onoff` Active bool `protobuf:"varint,1,opt,name=active,proto3" json:"active,omitempty"` // duration maps to `struct linger.l_linger` Duration *durationpb.Duration `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"` // contains filtered or unexported fields }
For use with SocketOption's additional field. This is primarily used for SO_LINGER.
func (*SocketOptionLinger) Descriptor ¶
func (*SocketOptionLinger) Descriptor() ([]byte, []int)
Deprecated: Use SocketOptionLinger.ProtoReflect.Descriptor instead.
func (*SocketOptionLinger) GetActive ¶
func (x *SocketOptionLinger) GetActive() bool
func (*SocketOptionLinger) GetDuration ¶
func (x *SocketOptionLinger) GetDuration() *durationpb.Duration
func (*SocketOptionLinger) ProtoMessage ¶
func (*SocketOptionLinger) ProtoMessage()
func (*SocketOptionLinger) ProtoReflect ¶
func (x *SocketOptionLinger) ProtoReflect() protoreflect.Message
func (*SocketOptionLinger) Reset ¶
func (x *SocketOptionLinger) Reset()
func (*SocketOptionLinger) String ¶
func (x *SocketOptionLinger) String() string
type SocketOptionTcpInfo ¶
type SocketOptionTcpInfo struct { TcpiState uint32 `protobuf:"varint,1,opt,name=tcpi_state,json=tcpiState,proto3" json:"tcpi_state,omitempty"` TcpiCaState uint32 `protobuf:"varint,2,opt,name=tcpi_ca_state,json=tcpiCaState,proto3" json:"tcpi_ca_state,omitempty"` TcpiRetransmits uint32 `protobuf:"varint,3,opt,name=tcpi_retransmits,json=tcpiRetransmits,proto3" json:"tcpi_retransmits,omitempty"` TcpiProbes uint32 `protobuf:"varint,4,opt,name=tcpi_probes,json=tcpiProbes,proto3" json:"tcpi_probes,omitempty"` TcpiBackoff uint32 `protobuf:"varint,5,opt,name=tcpi_backoff,json=tcpiBackoff,proto3" json:"tcpi_backoff,omitempty"` TcpiOptions uint32 `protobuf:"varint,6,opt,name=tcpi_options,json=tcpiOptions,proto3" json:"tcpi_options,omitempty"` TcpiSndWscale uint32 `protobuf:"varint,7,opt,name=tcpi_snd_wscale,json=tcpiSndWscale,proto3" json:"tcpi_snd_wscale,omitempty"` TcpiRcvWscale uint32 `protobuf:"varint,8,opt,name=tcpi_rcv_wscale,json=tcpiRcvWscale,proto3" json:"tcpi_rcv_wscale,omitempty"` TcpiRto uint32 `protobuf:"varint,9,opt,name=tcpi_rto,json=tcpiRto,proto3" json:"tcpi_rto,omitempty"` TcpiAto uint32 `protobuf:"varint,10,opt,name=tcpi_ato,json=tcpiAto,proto3" json:"tcpi_ato,omitempty"` TcpiSndMss uint32 `protobuf:"varint,11,opt,name=tcpi_snd_mss,json=tcpiSndMss,proto3" json:"tcpi_snd_mss,omitempty"` TcpiRcvMss uint32 `protobuf:"varint,12,opt,name=tcpi_rcv_mss,json=tcpiRcvMss,proto3" json:"tcpi_rcv_mss,omitempty"` TcpiUnacked uint32 `protobuf:"varint,13,opt,name=tcpi_unacked,json=tcpiUnacked,proto3" json:"tcpi_unacked,omitempty"` TcpiSacked uint32 `protobuf:"varint,14,opt,name=tcpi_sacked,json=tcpiSacked,proto3" json:"tcpi_sacked,omitempty"` TcpiLost uint32 `protobuf:"varint,15,opt,name=tcpi_lost,json=tcpiLost,proto3" json:"tcpi_lost,omitempty"` TcpiRetrans uint32 `protobuf:"varint,16,opt,name=tcpi_retrans,json=tcpiRetrans,proto3" json:"tcpi_retrans,omitempty"` TcpiFackets uint32 `protobuf:"varint,17,opt,name=tcpi_fackets,json=tcpiFackets,proto3" json:"tcpi_fackets,omitempty"` TcpiLastDataSent uint32 `protobuf:"varint,18,opt,name=tcpi_last_data_sent,json=tcpiLastDataSent,proto3" json:"tcpi_last_data_sent,omitempty"` TcpiLastAckSent uint32 `protobuf:"varint,19,opt,name=tcpi_last_ack_sent,json=tcpiLastAckSent,proto3" json:"tcpi_last_ack_sent,omitempty"` TcpiLastDataRecv uint32 `protobuf:"varint,20,opt,name=tcpi_last_data_recv,json=tcpiLastDataRecv,proto3" json:"tcpi_last_data_recv,omitempty"` TcpiLastAckRecv uint32 `protobuf:"varint,21,opt,name=tcpi_last_ack_recv,json=tcpiLastAckRecv,proto3" json:"tcpi_last_ack_recv,omitempty"` TcpiPmtu uint32 `protobuf:"varint,22,opt,name=tcpi_pmtu,json=tcpiPmtu,proto3" json:"tcpi_pmtu,omitempty"` TcpiRcvSsthresh uint32 `protobuf:"varint,23,opt,name=tcpi_rcv_ssthresh,json=tcpiRcvSsthresh,proto3" json:"tcpi_rcv_ssthresh,omitempty"` TcpiRtt uint32 `protobuf:"varint,24,opt,name=tcpi_rtt,json=tcpiRtt,proto3" json:"tcpi_rtt,omitempty"` TcpiRttvar uint32 `protobuf:"varint,25,opt,name=tcpi_rttvar,json=tcpiRttvar,proto3" json:"tcpi_rttvar,omitempty"` TcpiSndSsthresh uint32 `protobuf:"varint,26,opt,name=tcpi_snd_ssthresh,json=tcpiSndSsthresh,proto3" json:"tcpi_snd_ssthresh,omitempty"` TcpiSndCwnd uint32 `protobuf:"varint,27,opt,name=tcpi_snd_cwnd,json=tcpiSndCwnd,proto3" json:"tcpi_snd_cwnd,omitempty"` TcpiAdvmss uint32 `protobuf:"varint,28,opt,name=tcpi_advmss,json=tcpiAdvmss,proto3" json:"tcpi_advmss,omitempty"` TcpiReordering uint32 `protobuf:"varint,29,opt,name=tcpi_reordering,json=tcpiReordering,proto3" json:"tcpi_reordering,omitempty"` // contains filtered or unexported fields }
For use with SocketOption's additional field. Tcp info for SOL_TCP and TCP_INFO.
func (*SocketOptionTcpInfo) Descriptor ¶
func (*SocketOptionTcpInfo) Descriptor() ([]byte, []int)
Deprecated: Use SocketOptionTcpInfo.ProtoReflect.Descriptor instead.
func (*SocketOptionTcpInfo) GetTcpiAdvmss ¶
func (x *SocketOptionTcpInfo) GetTcpiAdvmss() uint32
func (*SocketOptionTcpInfo) GetTcpiAto ¶
func (x *SocketOptionTcpInfo) GetTcpiAto() uint32
func (*SocketOptionTcpInfo) GetTcpiBackoff ¶
func (x *SocketOptionTcpInfo) GetTcpiBackoff() uint32
func (*SocketOptionTcpInfo) GetTcpiCaState ¶
func (x *SocketOptionTcpInfo) GetTcpiCaState() uint32
func (*SocketOptionTcpInfo) GetTcpiFackets ¶
func (x *SocketOptionTcpInfo) GetTcpiFackets() uint32
func (*SocketOptionTcpInfo) GetTcpiLastAckRecv ¶
func (x *SocketOptionTcpInfo) GetTcpiLastAckRecv() uint32
func (*SocketOptionTcpInfo) GetTcpiLastAckSent ¶
func (x *SocketOptionTcpInfo) GetTcpiLastAckSent() uint32
func (*SocketOptionTcpInfo) GetTcpiLastDataRecv ¶
func (x *SocketOptionTcpInfo) GetTcpiLastDataRecv() uint32
func (*SocketOptionTcpInfo) GetTcpiLastDataSent ¶
func (x *SocketOptionTcpInfo) GetTcpiLastDataSent() uint32
func (*SocketOptionTcpInfo) GetTcpiLost ¶
func (x *SocketOptionTcpInfo) GetTcpiLost() uint32
func (*SocketOptionTcpInfo) GetTcpiOptions ¶
func (x *SocketOptionTcpInfo) GetTcpiOptions() uint32
func (*SocketOptionTcpInfo) GetTcpiPmtu ¶
func (x *SocketOptionTcpInfo) GetTcpiPmtu() uint32
func (*SocketOptionTcpInfo) GetTcpiProbes ¶
func (x *SocketOptionTcpInfo) GetTcpiProbes() uint32
func (*SocketOptionTcpInfo) GetTcpiRcvMss ¶
func (x *SocketOptionTcpInfo) GetTcpiRcvMss() uint32
func (*SocketOptionTcpInfo) GetTcpiRcvSsthresh ¶
func (x *SocketOptionTcpInfo) GetTcpiRcvSsthresh() uint32
func (*SocketOptionTcpInfo) GetTcpiRcvWscale ¶
func (x *SocketOptionTcpInfo) GetTcpiRcvWscale() uint32
func (*SocketOptionTcpInfo) GetTcpiReordering ¶
func (x *SocketOptionTcpInfo) GetTcpiReordering() uint32
func (*SocketOptionTcpInfo) GetTcpiRetrans ¶
func (x *SocketOptionTcpInfo) GetTcpiRetrans() uint32
func (*SocketOptionTcpInfo) GetTcpiRetransmits ¶
func (x *SocketOptionTcpInfo) GetTcpiRetransmits() uint32
func (*SocketOptionTcpInfo) GetTcpiRto ¶
func (x *SocketOptionTcpInfo) GetTcpiRto() uint32
func (*SocketOptionTcpInfo) GetTcpiRtt ¶
func (x *SocketOptionTcpInfo) GetTcpiRtt() uint32
func (*SocketOptionTcpInfo) GetTcpiRttvar ¶
func (x *SocketOptionTcpInfo) GetTcpiRttvar() uint32
func (*SocketOptionTcpInfo) GetTcpiSacked ¶
func (x *SocketOptionTcpInfo) GetTcpiSacked() uint32
func (*SocketOptionTcpInfo) GetTcpiSndCwnd ¶
func (x *SocketOptionTcpInfo) GetTcpiSndCwnd() uint32
func (*SocketOptionTcpInfo) GetTcpiSndMss ¶
func (x *SocketOptionTcpInfo) GetTcpiSndMss() uint32
func (*SocketOptionTcpInfo) GetTcpiSndSsthresh ¶
func (x *SocketOptionTcpInfo) GetTcpiSndSsthresh() uint32
func (*SocketOptionTcpInfo) GetTcpiSndWscale ¶
func (x *SocketOptionTcpInfo) GetTcpiSndWscale() uint32
func (*SocketOptionTcpInfo) GetTcpiState ¶
func (x *SocketOptionTcpInfo) GetTcpiState() uint32
func (*SocketOptionTcpInfo) GetTcpiUnacked ¶
func (x *SocketOptionTcpInfo) GetTcpiUnacked() uint32
func (*SocketOptionTcpInfo) ProtoMessage ¶
func (*SocketOptionTcpInfo) ProtoMessage()
func (*SocketOptionTcpInfo) ProtoReflect ¶
func (x *SocketOptionTcpInfo) ProtoReflect() protoreflect.Message
func (*SocketOptionTcpInfo) Reset ¶
func (x *SocketOptionTcpInfo) Reset()
func (*SocketOptionTcpInfo) String ¶
func (x *SocketOptionTcpInfo) String() string
type SocketOptionTimeout ¶
type SocketOptionTimeout struct { Duration *durationpb.Duration `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"` // contains filtered or unexported fields }
For use with SocketOption's additional field. This is primarily used for SO_RCVTIMEO and SO_SNDTIMEO
func (*SocketOptionTimeout) Descriptor ¶
func (*SocketOptionTimeout) Descriptor() ([]byte, []int)
Deprecated: Use SocketOptionTimeout.ProtoReflect.Descriptor instead.
func (*SocketOptionTimeout) GetDuration ¶
func (x *SocketOptionTimeout) GetDuration() *durationpb.Duration
func (*SocketOptionTimeout) ProtoMessage ¶
func (*SocketOptionTimeout) ProtoMessage()
func (*SocketOptionTimeout) ProtoReflect ¶
func (x *SocketOptionTimeout) ProtoReflect() protoreflect.Message
func (*SocketOptionTimeout) Reset ¶
func (x *SocketOptionTimeout) Reset()
func (*SocketOptionTimeout) String ¶
func (x *SocketOptionTimeout) String() string
type SocketRef ¶
type SocketRef struct { // The globally unique id for this socket. Must be a positive number. SocketId int64 `protobuf:"varint,3,opt,name=socket_id,json=socketId,proto3" json:"socket_id,omitempty"` // An optional name associated with the socket. Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
SocketRef is a reference to a Socket.
func (*SocketRef) Descriptor ¶
Deprecated: Use SocketRef.ProtoReflect.Descriptor instead.
func (*SocketRef) GetName ¶
func (*SocketRef) GetSocketId ¶
func (*SocketRef) ProtoMessage ¶
func (*SocketRef) ProtoMessage()
func (*SocketRef) ProtoReflect ¶
func (x *SocketRef) ProtoReflect() protoreflect.Message
func (*SocketRef) Reset ¶
func (x *SocketRef) Reset()
func (*SocketRef) String ¶
type Subchannel ¶
type Subchannel struct { // The identifier for this channel. Ref *SubchannelRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"` // Data specific to this channel. Data *ChannelData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // At most one of 'channel_ref+subchannel_ref' and 'socket' is set. // There are no ordering guarantees on the order of channel refs. // There may not be cycles in the ref graph. // A channel ref may be present in more than one channel or subchannel. ChannelRef []*ChannelRef `protobuf:"bytes,3,rep,name=channel_ref,json=channelRef,proto3" json:"channel_ref,omitempty"` // At most one of 'channel_ref+subchannel_ref' and 'socket' is set. // There are no ordering guarantees on the order of subchannel refs. // There may not be cycles in the ref graph. // A sub channel ref may be present in more than one channel or subchannel. SubchannelRef []*SubchannelRef `protobuf:"bytes,4,rep,name=subchannel_ref,json=subchannelRef,proto3" json:"subchannel_ref,omitempty"` // There are no ordering guarantees on the order of sockets. SocketRef []*SocketRef `protobuf:"bytes,5,rep,name=socket_ref,json=socketRef,proto3" json:"socket_ref,omitempty"` // contains filtered or unexported fields }
Subchannel is a logical grouping of channels, subchannels, and sockets. A subchannel is load balanced over by its ancestor
func (*Subchannel) Descriptor ¶
func (*Subchannel) Descriptor() ([]byte, []int)
Deprecated: Use Subchannel.ProtoReflect.Descriptor instead.
func (*Subchannel) GetChannelRef ¶
func (x *Subchannel) GetChannelRef() []*ChannelRef
func (*Subchannel) GetData ¶
func (x *Subchannel) GetData() *ChannelData
func (*Subchannel) GetRef ¶
func (x *Subchannel) GetRef() *SubchannelRef
func (*Subchannel) GetSocketRef ¶
func (x *Subchannel) GetSocketRef() []*SocketRef
func (*Subchannel) GetSubchannelRef ¶
func (x *Subchannel) GetSubchannelRef() []*SubchannelRef
func (*Subchannel) ProtoMessage ¶
func (*Subchannel) ProtoMessage()
func (*Subchannel) ProtoReflect ¶
func (x *Subchannel) ProtoReflect() protoreflect.Message
func (*Subchannel) Reset ¶
func (x *Subchannel) Reset()
func (*Subchannel) String ¶
func (x *Subchannel) String() string
type SubchannelRef ¶
type SubchannelRef struct { // The globally unique id for this subchannel. Must be a positive number. SubchannelId int64 `protobuf:"varint,7,opt,name=subchannel_id,json=subchannelId,proto3" json:"subchannel_id,omitempty"` // An optional name associated with the subchannel. Name string `protobuf:"bytes,8,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
SubchannelRef is a reference to a Subchannel.
func (*SubchannelRef) Descriptor ¶
func (*SubchannelRef) Descriptor() ([]byte, []int)
Deprecated: Use SubchannelRef.ProtoReflect.Descriptor instead.
func (*SubchannelRef) GetName ¶
func (x *SubchannelRef) GetName() string
func (*SubchannelRef) GetSubchannelId ¶
func (x *SubchannelRef) GetSubchannelId() int64
func (*SubchannelRef) ProtoMessage ¶
func (*SubchannelRef) ProtoMessage()
func (*SubchannelRef) ProtoReflect ¶
func (x *SubchannelRef) ProtoReflect() protoreflect.Message
func (*SubchannelRef) Reset ¶
func (x *SubchannelRef) Reset()
func (*SubchannelRef) String ¶
func (x *SubchannelRef) String() string
type UnimplementedChannelzServer ¶
type UnimplementedChannelzServer struct{}
UnimplementedChannelzServer should be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedChannelzServer) GetChannel ¶
func (UnimplementedChannelzServer) GetChannel(context.Context, *GetChannelRequest) (*GetChannelResponse, error)
func (UnimplementedChannelzServer) GetServer ¶
func (UnimplementedChannelzServer) GetServer(context.Context, *GetServerRequest) (*GetServerResponse, error)
func (UnimplementedChannelzServer) GetServerSockets ¶
func (UnimplementedChannelzServer) GetServerSockets(context.Context, *GetServerSocketsRequest) (*GetServerSocketsResponse, error)
func (UnimplementedChannelzServer) GetServers ¶
func (UnimplementedChannelzServer) GetServers(context.Context, *GetServersRequest) (*GetServersResponse, error)
func (UnimplementedChannelzServer) GetSocket ¶
func (UnimplementedChannelzServer) GetSocket(context.Context, *GetSocketRequest) (*GetSocketResponse, error)
func (UnimplementedChannelzServer) GetSubchannel ¶
func (UnimplementedChannelzServer) GetSubchannel(context.Context, *GetSubchannelRequest) (*GetSubchannelResponse, error)
func (UnimplementedChannelzServer) GetTopChannels ¶
func (UnimplementedChannelzServer) GetTopChannels(context.Context, *GetTopChannelsRequest) (*GetTopChannelsResponse, error)
type UnsafeChannelzServer ¶
type UnsafeChannelzServer interface {
// contains filtered or unexported methods
}
UnsafeChannelzServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ChannelzServer will result in compilation errors.
Source Files ¶
channelz.pb.go channelz_grpc.pb.go
- Version
- v1.70.0 (latest)
- Published
- Jan 23, 2025
- Platform
- linux/amd64
- Imports
- 12 packages
- Last checked
- 17 hours ago –
Tools for package owners.