grpc: google.golang.org/grpc/channelz/grpc_channelz_v1 Index | Files

package grpc_channelz_v1

import "google.golang.org/grpc/channelz/grpc_channelz_v1"

Index

Package Files

channelz.pb.go channelz_grpc.pb.go

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

func RegisterChannelzServer Uses

func RegisterChannelzServer(s grpc.ServiceRegistrar, srv ChannelzServer)

type Address Uses

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 Uses

func (*Address) Descriptor() ([]byte, []int)

Deprecated: Use Address.ProtoReflect.Descriptor instead.

func (*Address) GetAddress Uses

func (m *Address) GetAddress() isAddress_Address

func (*Address) GetOtherAddress Uses

func (x *Address) GetOtherAddress() *Address_OtherAddress

func (*Address) GetTcpipAddress Uses

func (x *Address) GetTcpipAddress() *Address_TcpIpAddress

func (*Address) GetUdsAddress Uses

func (x *Address) GetUdsAddress() *Address_UdsAddress

func (*Address) ProtoMessage Uses

func (*Address) ProtoMessage()

func (*Address) ProtoReflect Uses

func (x *Address) ProtoReflect() protoreflect.Message

func (*Address) Reset Uses

func (x *Address) Reset()

func (*Address) String Uses

func (x *Address) String() string

type Address_OtherAddress Uses

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 Uses

func (*Address_OtherAddress) Descriptor() ([]byte, []int)

Deprecated: Use Address_OtherAddress.ProtoReflect.Descriptor instead.

func (*Address_OtherAddress) GetName Uses

func (x *Address_OtherAddress) GetName() string

func (*Address_OtherAddress) GetValue Uses

func (x *Address_OtherAddress) GetValue() *anypb.Any

func (*Address_OtherAddress) ProtoMessage Uses

func (*Address_OtherAddress) ProtoMessage()

func (*Address_OtherAddress) ProtoReflect Uses

func (x *Address_OtherAddress) ProtoReflect() protoreflect.Message

func (*Address_OtherAddress) Reset Uses

func (x *Address_OtherAddress) Reset()

func (*Address_OtherAddress) String Uses

func (x *Address_OtherAddress) String() string

type Address_OtherAddress_ Uses

type Address_OtherAddress_ struct {
    OtherAddress *Address_OtherAddress `protobuf:"bytes,3,opt,name=other_address,json=otherAddress,proto3,oneof"`
}

type Address_TcpIpAddress Uses

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 Uses

func (*Address_TcpIpAddress) Descriptor() ([]byte, []int)

Deprecated: Use Address_TcpIpAddress.ProtoReflect.Descriptor instead.

func (*Address_TcpIpAddress) GetIpAddress Uses

func (x *Address_TcpIpAddress) GetIpAddress() []byte

func (*Address_TcpIpAddress) GetPort Uses

func (x *Address_TcpIpAddress) GetPort() int32

func (*Address_TcpIpAddress) ProtoMessage Uses

func (*Address_TcpIpAddress) ProtoMessage()

func (*Address_TcpIpAddress) ProtoReflect Uses

func (x *Address_TcpIpAddress) ProtoReflect() protoreflect.Message

func (*Address_TcpIpAddress) Reset Uses

func (x *Address_TcpIpAddress) Reset()

func (*Address_TcpIpAddress) String Uses

func (x *Address_TcpIpAddress) String() string

type Address_TcpipAddress Uses

type Address_TcpipAddress struct {
    TcpipAddress *Address_TcpIpAddress `protobuf:"bytes,1,opt,name=tcpip_address,json=tcpipAddress,proto3,oneof"`
}

type Address_UdsAddress Uses

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 Uses

func (*Address_UdsAddress) Descriptor() ([]byte, []int)

Deprecated: Use Address_UdsAddress.ProtoReflect.Descriptor instead.

func (*Address_UdsAddress) GetFilename Uses

func (x *Address_UdsAddress) GetFilename() string

func (*Address_UdsAddress) ProtoMessage Uses

func (*Address_UdsAddress) ProtoMessage()

func (*Address_UdsAddress) ProtoReflect Uses

func (x *Address_UdsAddress) ProtoReflect() protoreflect.Message

func (*Address_UdsAddress) Reset Uses

func (x *Address_UdsAddress) Reset()

func (*Address_UdsAddress) String Uses

func (x *Address_UdsAddress) String() string

type Address_UdsAddress_ Uses

type Address_UdsAddress_ struct {
    UdsAddress *Address_UdsAddress `protobuf:"bytes,2,opt,name=uds_address,json=udsAddress,proto3,oneof"`
}

type Channel Uses

type Channel struct {

    // The identifier for this channel. This should bet 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 Uses

func (*Channel) Descriptor() ([]byte, []int)

Deprecated: Use Channel.ProtoReflect.Descriptor instead.

func (*Channel) GetChannelRef Uses

func (x *Channel) GetChannelRef() []*ChannelRef

func (*Channel) GetData Uses

func (x *Channel) GetData() *ChannelData

func (*Channel) GetRef Uses

func (x *Channel) GetRef() *ChannelRef

func (*Channel) GetSocketRef Uses

func (x *Channel) GetSocketRef() []*SocketRef

func (*Channel) GetSubchannelRef Uses

func (x *Channel) GetSubchannelRef() []*SubchannelRef

func (*Channel) ProtoMessage Uses

func (*Channel) ProtoMessage()

func (*Channel) ProtoReflect Uses

func (x *Channel) ProtoReflect() protoreflect.Message

func (*Channel) Reset Uses

func (x *Channel) Reset()

func (*Channel) String Uses

func (x *Channel) String() string

type ChannelConnectivityState Uses

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 Uses

func (*ChannelConnectivityState) Descriptor() ([]byte, []int)

Deprecated: Use ChannelConnectivityState.ProtoReflect.Descriptor instead.

func (*ChannelConnectivityState) GetState Uses

func (x *ChannelConnectivityState) GetState() ChannelConnectivityState_State

func (*ChannelConnectivityState) ProtoMessage Uses

func (*ChannelConnectivityState) ProtoMessage()

func (*ChannelConnectivityState) ProtoReflect Uses

func (x *ChannelConnectivityState) ProtoReflect() protoreflect.Message

func (*ChannelConnectivityState) Reset Uses

func (x *ChannelConnectivityState) Reset()

func (*ChannelConnectivityState) String Uses

func (x *ChannelConnectivityState) String() string

type ChannelConnectivityState_State Uses

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 Uses

func (ChannelConnectivityState_State) Descriptor() protoreflect.EnumDescriptor

func (ChannelConnectivityState_State) Enum Uses

func (x ChannelConnectivityState_State) Enum() *ChannelConnectivityState_State

func (ChannelConnectivityState_State) EnumDescriptor Uses

func (ChannelConnectivityState_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use ChannelConnectivityState_State.Descriptor instead.

func (ChannelConnectivityState_State) Number Uses

func (x ChannelConnectivityState_State) Number() protoreflect.EnumNumber

func (ChannelConnectivityState_State) String Uses

func (x ChannelConnectivityState_State) String() string

func (ChannelConnectivityState_State) Type Uses

func (ChannelConnectivityState_State) Type() protoreflect.EnumType

type ChannelData Uses

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 Uses

func (*ChannelData) Descriptor() ([]byte, []int)

Deprecated: Use ChannelData.ProtoReflect.Descriptor instead.

func (*ChannelData) GetCallsFailed Uses

func (x *ChannelData) GetCallsFailed() int64

func (*ChannelData) GetCallsStarted Uses

func (x *ChannelData) GetCallsStarted() int64

func (*ChannelData) GetCallsSucceeded Uses

func (x *ChannelData) GetCallsSucceeded() int64

func (*ChannelData) GetLastCallStartedTimestamp Uses

func (x *ChannelData) GetLastCallStartedTimestamp() *timestamppb.Timestamp

func (*ChannelData) GetState Uses

func (x *ChannelData) GetState() *ChannelConnectivityState

func (*ChannelData) GetTarget Uses

func (x *ChannelData) GetTarget() string

func (*ChannelData) GetTrace Uses

func (x *ChannelData) GetTrace() *ChannelTrace

func (*ChannelData) ProtoMessage Uses

func (*ChannelData) ProtoMessage()

func (*ChannelData) ProtoReflect Uses

func (x *ChannelData) ProtoReflect() protoreflect.Message

func (*ChannelData) Reset Uses

func (x *ChannelData) Reset()

func (*ChannelData) String Uses

func (x *ChannelData) String() string

type ChannelRef Uses

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 Uses

func (*ChannelRef) Descriptor() ([]byte, []int)

Deprecated: Use ChannelRef.ProtoReflect.Descriptor instead.

func (*ChannelRef) GetChannelId Uses

func (x *ChannelRef) GetChannelId() int64

func (*ChannelRef) GetName Uses

func (x *ChannelRef) GetName() string

func (*ChannelRef) ProtoMessage Uses

func (*ChannelRef) ProtoMessage()

func (*ChannelRef) ProtoReflect Uses

func (x *ChannelRef) ProtoReflect() protoreflect.Message

func (*ChannelRef) Reset Uses

func (x *ChannelRef) Reset()

func (*ChannelRef) String Uses

func (x *ChannelRef) String() string

type ChannelTrace Uses

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 Uses

func (*ChannelTrace) Descriptor() ([]byte, []int)

Deprecated: Use ChannelTrace.ProtoReflect.Descriptor instead.

func (*ChannelTrace) GetCreationTimestamp Uses

func (x *ChannelTrace) GetCreationTimestamp() *timestamppb.Timestamp

func (*ChannelTrace) GetEvents Uses

func (x *ChannelTrace) GetEvents() []*ChannelTraceEvent

func (*ChannelTrace) GetNumEventsLogged Uses

func (x *ChannelTrace) GetNumEventsLogged() int64

func (*ChannelTrace) ProtoMessage Uses

func (*ChannelTrace) ProtoMessage()

func (*ChannelTrace) ProtoReflect Uses

func (x *ChannelTrace) ProtoReflect() protoreflect.Message

func (*ChannelTrace) Reset Uses

func (x *ChannelTrace) Reset()

func (*ChannelTrace) String Uses

func (x *ChannelTrace) String() string

type ChannelTraceEvent Uses

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 Uses

func (*ChannelTraceEvent) Descriptor() ([]byte, []int)

Deprecated: Use ChannelTraceEvent.ProtoReflect.Descriptor instead.

func (*ChannelTraceEvent) GetChannelRef Uses

func (x *ChannelTraceEvent) GetChannelRef() *ChannelRef

func (*ChannelTraceEvent) GetChildRef Uses

func (m *ChannelTraceEvent) GetChildRef() isChannelTraceEvent_ChildRef

func (*ChannelTraceEvent) GetDescription Uses

func (x *ChannelTraceEvent) GetDescription() string

func (*ChannelTraceEvent) GetSeverity Uses

func (x *ChannelTraceEvent) GetSeverity() ChannelTraceEvent_Severity

func (*ChannelTraceEvent) GetSubchannelRef Uses

func (x *ChannelTraceEvent) GetSubchannelRef() *SubchannelRef

func (*ChannelTraceEvent) GetTimestamp Uses

func (x *ChannelTraceEvent) GetTimestamp() *timestamppb.Timestamp

func (*ChannelTraceEvent) ProtoMessage Uses

func (*ChannelTraceEvent) ProtoMessage()

func (*ChannelTraceEvent) ProtoReflect Uses

func (x *ChannelTraceEvent) ProtoReflect() protoreflect.Message

func (*ChannelTraceEvent) Reset Uses

func (x *ChannelTraceEvent) Reset()

func (*ChannelTraceEvent) String Uses

func (x *ChannelTraceEvent) String() string

type ChannelTraceEvent_ChannelRef Uses

type ChannelTraceEvent_ChannelRef struct {
    ChannelRef *ChannelRef `protobuf:"bytes,4,opt,name=channel_ref,json=channelRef,proto3,oneof"`
}

type ChannelTraceEvent_Severity Uses

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 Uses

func (ChannelTraceEvent_Severity) Descriptor() protoreflect.EnumDescriptor

func (ChannelTraceEvent_Severity) Enum Uses

func (x ChannelTraceEvent_Severity) Enum() *ChannelTraceEvent_Severity

func (ChannelTraceEvent_Severity) EnumDescriptor Uses

func (ChannelTraceEvent_Severity) EnumDescriptor() ([]byte, []int)

Deprecated: Use ChannelTraceEvent_Severity.Descriptor instead.

func (ChannelTraceEvent_Severity) Number Uses

func (x ChannelTraceEvent_Severity) Number() protoreflect.EnumNumber

func (ChannelTraceEvent_Severity) String Uses

func (x ChannelTraceEvent_Severity) String() string

func (ChannelTraceEvent_Severity) Type Uses

func (ChannelTraceEvent_Severity) Type() protoreflect.EnumType

type ChannelTraceEvent_SubchannelRef Uses

type ChannelTraceEvent_SubchannelRef struct {
    SubchannelRef *SubchannelRef `protobuf:"bytes,5,opt,name=subchannel_ref,json=subchannelRef,proto3,oneof"`
}

type ChannelzClient Uses

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.

func NewChannelzClient Uses

func NewChannelzClient(cc grpc.ClientConnInterface) ChannelzClient

type ChannelzServer Uses

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

type GetChannelRequest Uses

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 Uses

func (*GetChannelRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetChannelRequest.ProtoReflect.Descriptor instead.

func (*GetChannelRequest) GetChannelId Uses

func (x *GetChannelRequest) GetChannelId() int64

func (*GetChannelRequest) ProtoMessage Uses

func (*GetChannelRequest) ProtoMessage()

func (*GetChannelRequest) ProtoReflect Uses

func (x *GetChannelRequest) ProtoReflect() protoreflect.Message

func (*GetChannelRequest) Reset Uses

func (x *GetChannelRequest) Reset()

func (*GetChannelRequest) String Uses

func (x *GetChannelRequest) String() string

type GetChannelResponse Uses

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 Uses

func (*GetChannelResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetChannelResponse.ProtoReflect.Descriptor instead.

func (*GetChannelResponse) GetChannel Uses

func (x *GetChannelResponse) GetChannel() *Channel

func (*GetChannelResponse) ProtoMessage Uses

func (*GetChannelResponse) ProtoMessage()

func (*GetChannelResponse) ProtoReflect Uses

func (x *GetChannelResponse) ProtoReflect() protoreflect.Message

func (*GetChannelResponse) Reset Uses

func (x *GetChannelResponse) Reset()

func (*GetChannelResponse) String Uses

func (x *GetChannelResponse) String() string

type GetServerRequest Uses

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 Uses

func (*GetServerRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetServerRequest.ProtoReflect.Descriptor instead.

func (*GetServerRequest) GetServerId Uses

func (x *GetServerRequest) GetServerId() int64

func (*GetServerRequest) ProtoMessage Uses

func (*GetServerRequest) ProtoMessage()

func (*GetServerRequest) ProtoReflect Uses

func (x *GetServerRequest) ProtoReflect() protoreflect.Message

func (*GetServerRequest) Reset Uses

func (x *GetServerRequest) Reset()

func (*GetServerRequest) String Uses

func (x *GetServerRequest) String() string

type GetServerResponse Uses

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 Uses

func (*GetServerResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetServerResponse.ProtoReflect.Descriptor instead.

func (*GetServerResponse) GetServer Uses

func (x *GetServerResponse) GetServer() *Server

func (*GetServerResponse) ProtoMessage Uses

func (*GetServerResponse) ProtoMessage()

func (*GetServerResponse) ProtoReflect Uses

func (x *GetServerResponse) ProtoReflect() protoreflect.Message

func (*GetServerResponse) Reset Uses

func (x *GetServerResponse) Reset()

func (*GetServerResponse) String Uses

func (x *GetServerResponse) String() string

type GetServerSocketsRequest Uses

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 Uses

func (*GetServerSocketsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetServerSocketsRequest.ProtoReflect.Descriptor instead.

func (*GetServerSocketsRequest) GetMaxResults Uses

func (x *GetServerSocketsRequest) GetMaxResults() int64

func (*GetServerSocketsRequest) GetServerId Uses

func (x *GetServerSocketsRequest) GetServerId() int64

func (*GetServerSocketsRequest) GetStartSocketId Uses

func (x *GetServerSocketsRequest) GetStartSocketId() int64

func (*GetServerSocketsRequest) ProtoMessage Uses

func (*GetServerSocketsRequest) ProtoMessage()

func (*GetServerSocketsRequest) ProtoReflect Uses

func (x *GetServerSocketsRequest) ProtoReflect() protoreflect.Message

func (*GetServerSocketsRequest) Reset Uses

func (x *GetServerSocketsRequest) Reset()

func (*GetServerSocketsRequest) String Uses

func (x *GetServerSocketsRequest) String() string

type GetServerSocketsResponse Uses

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 Uses

func (*GetServerSocketsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetServerSocketsResponse.ProtoReflect.Descriptor instead.

func (*GetServerSocketsResponse) GetEnd Uses

func (x *GetServerSocketsResponse) GetEnd() bool

func (*GetServerSocketsResponse) GetSocketRef Uses

func (x *GetServerSocketsResponse) GetSocketRef() []*SocketRef

func (*GetServerSocketsResponse) ProtoMessage Uses

func (*GetServerSocketsResponse) ProtoMessage()

func (*GetServerSocketsResponse) ProtoReflect Uses

func (x *GetServerSocketsResponse) ProtoReflect() protoreflect.Message

func (*GetServerSocketsResponse) Reset Uses

func (x *GetServerSocketsResponse) Reset()

func (*GetServerSocketsResponse) String Uses

func (x *GetServerSocketsResponse) String() string

type GetServersRequest Uses

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 Uses

func (*GetServersRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetServersRequest.ProtoReflect.Descriptor instead.

func (*GetServersRequest) GetMaxResults Uses

func (x *GetServersRequest) GetMaxResults() int64

func (*GetServersRequest) GetStartServerId Uses

func (x *GetServersRequest) GetStartServerId() int64

func (*GetServersRequest) ProtoMessage Uses

func (*GetServersRequest) ProtoMessage()

func (*GetServersRequest) ProtoReflect Uses

func (x *GetServersRequest) ProtoReflect() protoreflect.Message

func (*GetServersRequest) Reset Uses

func (x *GetServersRequest) Reset()

func (*GetServersRequest) String Uses

func (x *GetServersRequest) String() string

type GetServersResponse Uses

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 Uses

func (*GetServersResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetServersResponse.ProtoReflect.Descriptor instead.

func (*GetServersResponse) GetEnd Uses

func (x *GetServersResponse) GetEnd() bool

func (*GetServersResponse) GetServer Uses

func (x *GetServersResponse) GetServer() []*Server

func (*GetServersResponse) ProtoMessage Uses

func (*GetServersResponse) ProtoMessage()

func (*GetServersResponse) ProtoReflect Uses

func (x *GetServersResponse) ProtoReflect() protoreflect.Message

func (*GetServersResponse) Reset Uses

func (x *GetServersResponse) Reset()

func (*GetServersResponse) String Uses

func (x *GetServersResponse) String() string

type GetSocketRequest Uses

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 thay 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 Uses

func (*GetSocketRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetSocketRequest.ProtoReflect.Descriptor instead.

func (*GetSocketRequest) GetSocketId Uses

func (x *GetSocketRequest) GetSocketId() int64

func (*GetSocketRequest) GetSummary Uses

func (x *GetSocketRequest) GetSummary() bool

func (*GetSocketRequest) ProtoMessage Uses

func (*GetSocketRequest) ProtoMessage()

func (*GetSocketRequest) ProtoReflect Uses

func (x *GetSocketRequest) ProtoReflect() protoreflect.Message

func (*GetSocketRequest) Reset Uses

func (x *GetSocketRequest) Reset()

func (*GetSocketRequest) String Uses

func (x *GetSocketRequest) String() string

type GetSocketResponse Uses

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 Uses

func (*GetSocketResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetSocketResponse.ProtoReflect.Descriptor instead.

func (*GetSocketResponse) GetSocket Uses

func (x *GetSocketResponse) GetSocket() *Socket

func (*GetSocketResponse) ProtoMessage Uses

func (*GetSocketResponse) ProtoMessage()

func (*GetSocketResponse) ProtoReflect Uses

func (x *GetSocketResponse) ProtoReflect() protoreflect.Message

func (*GetSocketResponse) Reset Uses

func (x *GetSocketResponse) Reset()

func (*GetSocketResponse) String Uses

func (x *GetSocketResponse) String() string

type GetSubchannelRequest Uses

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 Uses

func (*GetSubchannelRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetSubchannelRequest.ProtoReflect.Descriptor instead.

func (*GetSubchannelRequest) GetSubchannelId Uses

func (x *GetSubchannelRequest) GetSubchannelId() int64

func (*GetSubchannelRequest) ProtoMessage Uses

func (*GetSubchannelRequest) ProtoMessage()

func (*GetSubchannelRequest) ProtoReflect Uses

func (x *GetSubchannelRequest) ProtoReflect() protoreflect.Message

func (*GetSubchannelRequest) Reset Uses

func (x *GetSubchannelRequest) Reset()

func (*GetSubchannelRequest) String Uses

func (x *GetSubchannelRequest) String() string

type GetSubchannelResponse Uses

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 Uses

func (*GetSubchannelResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetSubchannelResponse.ProtoReflect.Descriptor instead.

func (*GetSubchannelResponse) GetSubchannel Uses

func (x *GetSubchannelResponse) GetSubchannel() *Subchannel

func (*GetSubchannelResponse) ProtoMessage Uses

func (*GetSubchannelResponse) ProtoMessage()

func (*GetSubchannelResponse) ProtoReflect Uses

func (x *GetSubchannelResponse) ProtoReflect() protoreflect.Message

func (*GetSubchannelResponse) Reset Uses

func (x *GetSubchannelResponse) Reset()

func (*GetSubchannelResponse) String Uses

func (x *GetSubchannelResponse) String() string

type GetTopChannelsRequest Uses

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 Uses

func (*GetTopChannelsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetTopChannelsRequest.ProtoReflect.Descriptor instead.

func (*GetTopChannelsRequest) GetMaxResults Uses

func (x *GetTopChannelsRequest) GetMaxResults() int64

func (*GetTopChannelsRequest) GetStartChannelId Uses

func (x *GetTopChannelsRequest) GetStartChannelId() int64

func (*GetTopChannelsRequest) ProtoMessage Uses

func (*GetTopChannelsRequest) ProtoMessage()

func (*GetTopChannelsRequest) ProtoReflect Uses

func (x *GetTopChannelsRequest) ProtoReflect() protoreflect.Message

func (*GetTopChannelsRequest) Reset Uses

func (x *GetTopChannelsRequest) Reset()

func (*GetTopChannelsRequest) String Uses

func (x *GetTopChannelsRequest) String() string

type GetTopChannelsResponse Uses

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 Uses

func (*GetTopChannelsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetTopChannelsResponse.ProtoReflect.Descriptor instead.

func (*GetTopChannelsResponse) GetChannel Uses

func (x *GetTopChannelsResponse) GetChannel() []*Channel

func (*GetTopChannelsResponse) GetEnd Uses

func (x *GetTopChannelsResponse) GetEnd() bool

func (*GetTopChannelsResponse) ProtoMessage Uses

func (*GetTopChannelsResponse) ProtoMessage()

func (*GetTopChannelsResponse) ProtoReflect Uses

func (x *GetTopChannelsResponse) ProtoReflect() protoreflect.Message

func (*GetTopChannelsResponse) Reset Uses

func (x *GetTopChannelsResponse) Reset()

func (*GetTopChannelsResponse) String Uses

func (x *GetTopChannelsResponse) String() string

type Security Uses

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 Uses

func (*Security) Descriptor() ([]byte, []int)

Deprecated: Use Security.ProtoReflect.Descriptor instead.

func (*Security) GetModel Uses

func (m *Security) GetModel() isSecurity_Model

func (*Security) GetOther Uses

func (x *Security) GetOther() *Security_OtherSecurity

func (*Security) GetTls Uses

func (x *Security) GetTls() *Security_Tls

func (*Security) ProtoMessage Uses

func (*Security) ProtoMessage()

func (*Security) ProtoReflect Uses

func (x *Security) ProtoReflect() protoreflect.Message

func (*Security) Reset Uses

func (x *Security) Reset()

func (*Security) String Uses

func (x *Security) String() string

type Security_Other Uses

type Security_Other struct {
    Other *Security_OtherSecurity `protobuf:"bytes,2,opt,name=other,proto3,oneof"`
}

type Security_OtherSecurity Uses

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 Uses

func (*Security_OtherSecurity) Descriptor() ([]byte, []int)

Deprecated: Use Security_OtherSecurity.ProtoReflect.Descriptor instead.

func (*Security_OtherSecurity) GetName Uses

func (x *Security_OtherSecurity) GetName() string

func (*Security_OtherSecurity) GetValue Uses

func (x *Security_OtherSecurity) GetValue() *anypb.Any

func (*Security_OtherSecurity) ProtoMessage Uses

func (*Security_OtherSecurity) ProtoMessage()

func (*Security_OtherSecurity) ProtoReflect Uses

func (x *Security_OtherSecurity) ProtoReflect() protoreflect.Message

func (*Security_OtherSecurity) Reset Uses

func (x *Security_OtherSecurity) Reset()

func (*Security_OtherSecurity) String Uses

func (x *Security_OtherSecurity) String() string

type Security_Tls Uses

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 Uses

func (*Security_Tls) Descriptor() ([]byte, []int)

Deprecated: Use Security_Tls.ProtoReflect.Descriptor instead.

func (*Security_Tls) GetCipherSuite Uses

func (m *Security_Tls) GetCipherSuite() isSecurity_Tls_CipherSuite

func (*Security_Tls) GetLocalCertificate Uses

func (x *Security_Tls) GetLocalCertificate() []byte

func (*Security_Tls) GetOtherName Uses

func (x *Security_Tls) GetOtherName() string

func (*Security_Tls) GetRemoteCertificate Uses

func (x *Security_Tls) GetRemoteCertificate() []byte

func (*Security_Tls) GetStandardName Uses

func (x *Security_Tls) GetStandardName() string

func (*Security_Tls) ProtoMessage Uses

func (*Security_Tls) ProtoMessage()

func (*Security_Tls) ProtoReflect Uses

func (x *Security_Tls) ProtoReflect() protoreflect.Message

func (*Security_Tls) Reset Uses

func (x *Security_Tls) Reset()

func (*Security_Tls) String Uses

func (x *Security_Tls) String() string

type Security_Tls_ Uses

type Security_Tls_ struct {
    Tls *Security_Tls `protobuf:"bytes,1,opt,name=tls,proto3,oneof"`
}

type Security_Tls_OtherName Uses

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 Uses

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 Uses

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 Uses

func (*Server) Descriptor() ([]byte, []int)

Deprecated: Use Server.ProtoReflect.Descriptor instead.

func (*Server) GetData Uses

func (x *Server) GetData() *ServerData

func (*Server) GetListenSocket Uses

func (x *Server) GetListenSocket() []*SocketRef

func (*Server) GetRef Uses

func (x *Server) GetRef() *ServerRef

func (*Server) ProtoMessage Uses

func (*Server) ProtoMessage()

func (*Server) ProtoReflect Uses

func (x *Server) ProtoReflect() protoreflect.Message

func (*Server) Reset Uses

func (x *Server) Reset()

func (*Server) String Uses

func (x *Server) String() string

type ServerData Uses

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 Uses

func (*ServerData) Descriptor() ([]byte, []int)

Deprecated: Use ServerData.ProtoReflect.Descriptor instead.

func (*ServerData) GetCallsFailed Uses

func (x *ServerData) GetCallsFailed() int64

func (*ServerData) GetCallsStarted Uses

func (x *ServerData) GetCallsStarted() int64

func (*ServerData) GetCallsSucceeded Uses

func (x *ServerData) GetCallsSucceeded() int64

func (*ServerData) GetLastCallStartedTimestamp Uses

func (x *ServerData) GetLastCallStartedTimestamp() *timestamppb.Timestamp

func (*ServerData) GetTrace Uses

func (x *ServerData) GetTrace() *ChannelTrace

func (*ServerData) ProtoMessage Uses

func (*ServerData) ProtoMessage()

func (*ServerData) ProtoReflect Uses

func (x *ServerData) ProtoReflect() protoreflect.Message

func (*ServerData) Reset Uses

func (x *ServerData) Reset()

func (*ServerData) String Uses

func (x *ServerData) String() string

type ServerRef Uses

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 Uses

func (*ServerRef) Descriptor() ([]byte, []int)

Deprecated: Use ServerRef.ProtoReflect.Descriptor instead.

func (*ServerRef) GetName Uses

func (x *ServerRef) GetName() string

func (*ServerRef) GetServerId Uses

func (x *ServerRef) GetServerId() int64

func (*ServerRef) ProtoMessage Uses

func (*ServerRef) ProtoMessage()

func (*ServerRef) ProtoReflect Uses

func (x *ServerRef) ProtoReflect() protoreflect.Message

func (*ServerRef) Reset Uses

func (x *ServerRef) Reset()

func (*ServerRef) String Uses

func (x *ServerRef) String() string

type Socket Uses

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 Uses

func (*Socket) Descriptor() ([]byte, []int)

Deprecated: Use Socket.ProtoReflect.Descriptor instead.

func (*Socket) GetData Uses

func (x *Socket) GetData() *SocketData

func (*Socket) GetLocal Uses

func (x *Socket) GetLocal() *Address

func (*Socket) GetRef Uses

func (x *Socket) GetRef() *SocketRef

func (*Socket) GetRemote Uses

func (x *Socket) GetRemote() *Address

func (*Socket) GetRemoteName Uses

func (x *Socket) GetRemoteName() string

func (*Socket) GetSecurity Uses

func (x *Socket) GetSecurity() *Security

func (*Socket) ProtoMessage Uses

func (*Socket) ProtoMessage()

func (*Socket) ProtoReflect Uses

func (x *Socket) ProtoReflect() protoreflect.Message

func (*Socket) Reset Uses

func (x *Socket) Reset()

func (*Socket) String Uses

func (x *Socket) String() string

type SocketData Uses

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 Uses

func (*SocketData) Descriptor() ([]byte, []int)

Deprecated: Use SocketData.ProtoReflect.Descriptor instead.

func (*SocketData) GetKeepAlivesSent Uses

func (x *SocketData) GetKeepAlivesSent() int64

func (*SocketData) GetLastLocalStreamCreatedTimestamp Uses

func (x *SocketData) GetLastLocalStreamCreatedTimestamp() *timestamppb.Timestamp

func (*SocketData) GetLastMessageReceivedTimestamp Uses

func (x *SocketData) GetLastMessageReceivedTimestamp() *timestamppb.Timestamp

func (*SocketData) GetLastMessageSentTimestamp Uses

func (x *SocketData) GetLastMessageSentTimestamp() *timestamppb.Timestamp

func (*SocketData) GetLastRemoteStreamCreatedTimestamp Uses

func (x *SocketData) GetLastRemoteStreamCreatedTimestamp() *timestamppb.Timestamp

func (*SocketData) GetLocalFlowControlWindow Uses

func (x *SocketData) GetLocalFlowControlWindow() *wrapperspb.Int64Value

func (*SocketData) GetMessagesReceived Uses

func (x *SocketData) GetMessagesReceived() int64

func (*SocketData) GetMessagesSent Uses

func (x *SocketData) GetMessagesSent() int64

func (*SocketData) GetOption Uses

func (x *SocketData) GetOption() []*SocketOption

func (*SocketData) GetRemoteFlowControlWindow Uses

func (x *SocketData) GetRemoteFlowControlWindow() *wrapperspb.Int64Value

func (*SocketData) GetStreamsFailed Uses

func (x *SocketData) GetStreamsFailed() int64

func (*SocketData) GetStreamsStarted Uses

func (x *SocketData) GetStreamsStarted() int64

func (*SocketData) GetStreamsSucceeded Uses

func (x *SocketData) GetStreamsSucceeded() int64

func (*SocketData) ProtoMessage Uses

func (*SocketData) ProtoMessage()

func (*SocketData) ProtoReflect Uses

func (x *SocketData) ProtoReflect() protoreflect.Message

func (*SocketData) Reset Uses

func (x *SocketData) Reset()

func (*SocketData) String Uses

func (x *SocketData) String() string

type SocketOption Uses

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 Uses

func (*SocketOption) Descriptor() ([]byte, []int)

Deprecated: Use SocketOption.ProtoReflect.Descriptor instead.

func (*SocketOption) GetAdditional Uses

func (x *SocketOption) GetAdditional() *anypb.Any

func (*SocketOption) GetName Uses

func (x *SocketOption) GetName() string

func (*SocketOption) GetValue Uses

func (x *SocketOption) GetValue() string

func (*SocketOption) ProtoMessage Uses

func (*SocketOption) ProtoMessage()

func (*SocketOption) ProtoReflect Uses

func (x *SocketOption) ProtoReflect() protoreflect.Message

func (*SocketOption) Reset Uses

func (x *SocketOption) Reset()

func (*SocketOption) String Uses

func (x *SocketOption) String() string

type SocketOptionLinger Uses

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 Uses

func (*SocketOptionLinger) Descriptor() ([]byte, []int)

Deprecated: Use SocketOptionLinger.ProtoReflect.Descriptor instead.

func (*SocketOptionLinger) GetActive Uses

func (x *SocketOptionLinger) GetActive() bool

func (*SocketOptionLinger) GetDuration Uses

func (x *SocketOptionLinger) GetDuration() *durationpb.Duration

func (*SocketOptionLinger) ProtoMessage Uses

func (*SocketOptionLinger) ProtoMessage()

func (*SocketOptionLinger) ProtoReflect Uses

func (x *SocketOptionLinger) ProtoReflect() protoreflect.Message

func (*SocketOptionLinger) Reset Uses

func (x *SocketOptionLinger) Reset()

func (*SocketOptionLinger) String Uses

func (x *SocketOptionLinger) String() string

type SocketOptionTcpInfo Uses

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 Uses

func (*SocketOptionTcpInfo) Descriptor() ([]byte, []int)

Deprecated: Use SocketOptionTcpInfo.ProtoReflect.Descriptor instead.

func (*SocketOptionTcpInfo) GetTcpiAdvmss Uses

func (x *SocketOptionTcpInfo) GetTcpiAdvmss() uint32

func (*SocketOptionTcpInfo) GetTcpiAto Uses

func (x *SocketOptionTcpInfo) GetTcpiAto() uint32

func (*SocketOptionTcpInfo) GetTcpiBackoff Uses

func (x *SocketOptionTcpInfo) GetTcpiBackoff() uint32

func (*SocketOptionTcpInfo) GetTcpiCaState Uses

func (x *SocketOptionTcpInfo) GetTcpiCaState() uint32

func (*SocketOptionTcpInfo) GetTcpiFackets Uses

func (x *SocketOptionTcpInfo) GetTcpiFackets() uint32

func (*SocketOptionTcpInfo) GetTcpiLastAckRecv Uses

func (x *SocketOptionTcpInfo) GetTcpiLastAckRecv() uint32

func (*SocketOptionTcpInfo) GetTcpiLastAckSent Uses

func (x *SocketOptionTcpInfo) GetTcpiLastAckSent() uint32

func (*SocketOptionTcpInfo) GetTcpiLastDataRecv Uses

func (x *SocketOptionTcpInfo) GetTcpiLastDataRecv() uint32

func (*SocketOptionTcpInfo) GetTcpiLastDataSent Uses

func (x *SocketOptionTcpInfo) GetTcpiLastDataSent() uint32

func (*SocketOptionTcpInfo) GetTcpiLost Uses

func (x *SocketOptionTcpInfo) GetTcpiLost() uint32

func (*SocketOptionTcpInfo) GetTcpiOptions Uses

func (x *SocketOptionTcpInfo) GetTcpiOptions() uint32

func (*SocketOptionTcpInfo) GetTcpiPmtu Uses

func (x *SocketOptionTcpInfo) GetTcpiPmtu() uint32

func (*SocketOptionTcpInfo) GetTcpiProbes Uses

func (x *SocketOptionTcpInfo) GetTcpiProbes() uint32

func (*SocketOptionTcpInfo) GetTcpiRcvMss Uses

func (x *SocketOptionTcpInfo) GetTcpiRcvMss() uint32

func (*SocketOptionTcpInfo) GetTcpiRcvSsthresh Uses

func (x *SocketOptionTcpInfo) GetTcpiRcvSsthresh() uint32

func (*SocketOptionTcpInfo) GetTcpiRcvWscale Uses

func (x *SocketOptionTcpInfo) GetTcpiRcvWscale() uint32

func (*SocketOptionTcpInfo) GetTcpiReordering Uses

func (x *SocketOptionTcpInfo) GetTcpiReordering() uint32

func (*SocketOptionTcpInfo) GetTcpiRetrans Uses

func (x *SocketOptionTcpInfo) GetTcpiRetrans() uint32

func (*SocketOptionTcpInfo) GetTcpiRetransmits Uses

func (x *SocketOptionTcpInfo) GetTcpiRetransmits() uint32

func (*SocketOptionTcpInfo) GetTcpiRto Uses

func (x *SocketOptionTcpInfo) GetTcpiRto() uint32

func (*SocketOptionTcpInfo) GetTcpiRtt Uses

func (x *SocketOptionTcpInfo) GetTcpiRtt() uint32

func (*SocketOptionTcpInfo) GetTcpiRttvar Uses

func (x *SocketOptionTcpInfo) GetTcpiRttvar() uint32

func (*SocketOptionTcpInfo) GetTcpiSacked Uses

func (x *SocketOptionTcpInfo) GetTcpiSacked() uint32

func (*SocketOptionTcpInfo) GetTcpiSndCwnd Uses

func (x *SocketOptionTcpInfo) GetTcpiSndCwnd() uint32

func (*SocketOptionTcpInfo) GetTcpiSndMss Uses

func (x *SocketOptionTcpInfo) GetTcpiSndMss() uint32

func (*SocketOptionTcpInfo) GetTcpiSndSsthresh Uses

func (x *SocketOptionTcpInfo) GetTcpiSndSsthresh() uint32

func (*SocketOptionTcpInfo) GetTcpiSndWscale Uses

func (x *SocketOptionTcpInfo) GetTcpiSndWscale() uint32

func (*SocketOptionTcpInfo) GetTcpiState Uses

func (x *SocketOptionTcpInfo) GetTcpiState() uint32

func (*SocketOptionTcpInfo) GetTcpiUnacked Uses

func (x *SocketOptionTcpInfo) GetTcpiUnacked() uint32

func (*SocketOptionTcpInfo) ProtoMessage Uses

func (*SocketOptionTcpInfo) ProtoMessage()

func (*SocketOptionTcpInfo) ProtoReflect Uses

func (x *SocketOptionTcpInfo) ProtoReflect() protoreflect.Message

func (*SocketOptionTcpInfo) Reset Uses

func (x *SocketOptionTcpInfo) Reset()

func (*SocketOptionTcpInfo) String Uses

func (x *SocketOptionTcpInfo) String() string

type SocketOptionTimeout Uses

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 Uses

func (*SocketOptionTimeout) Descriptor() ([]byte, []int)

Deprecated: Use SocketOptionTimeout.ProtoReflect.Descriptor instead.

func (*SocketOptionTimeout) GetDuration Uses

func (x *SocketOptionTimeout) GetDuration() *durationpb.Duration

func (*SocketOptionTimeout) ProtoMessage Uses

func (*SocketOptionTimeout) ProtoMessage()

func (*SocketOptionTimeout) ProtoReflect Uses

func (x *SocketOptionTimeout) ProtoReflect() protoreflect.Message

func (*SocketOptionTimeout) Reset Uses

func (x *SocketOptionTimeout) Reset()

func (*SocketOptionTimeout) String Uses

func (x *SocketOptionTimeout) String() string

type SocketRef Uses

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 Uses

func (*SocketRef) Descriptor() ([]byte, []int)

Deprecated: Use SocketRef.ProtoReflect.Descriptor instead.

func (*SocketRef) GetName Uses

func (x *SocketRef) GetName() string

func (*SocketRef) GetSocketId Uses

func (x *SocketRef) GetSocketId() int64

func (*SocketRef) ProtoMessage Uses

func (*SocketRef) ProtoMessage()

func (*SocketRef) ProtoReflect Uses

func (x *SocketRef) ProtoReflect() protoreflect.Message

func (*SocketRef) Reset Uses

func (x *SocketRef) Reset()

func (*SocketRef) String Uses

func (x *SocketRef) String() string

type Subchannel Uses

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 it's ancestor

func (*Subchannel) Descriptor Uses

func (*Subchannel) Descriptor() ([]byte, []int)

Deprecated: Use Subchannel.ProtoReflect.Descriptor instead.

func (*Subchannel) GetChannelRef Uses

func (x *Subchannel) GetChannelRef() []*ChannelRef

func (*Subchannel) GetData Uses

func (x *Subchannel) GetData() *ChannelData

func (*Subchannel) GetRef Uses

func (x *Subchannel) GetRef() *SubchannelRef

func (*Subchannel) GetSocketRef Uses

func (x *Subchannel) GetSocketRef() []*SocketRef

func (*Subchannel) GetSubchannelRef Uses

func (x *Subchannel) GetSubchannelRef() []*SubchannelRef

func (*Subchannel) ProtoMessage Uses

func (*Subchannel) ProtoMessage()

func (*Subchannel) ProtoReflect Uses

func (x *Subchannel) ProtoReflect() protoreflect.Message

func (*Subchannel) Reset Uses

func (x *Subchannel) Reset()

func (*Subchannel) String Uses

func (x *Subchannel) String() string

type SubchannelRef Uses

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 Uses

func (*SubchannelRef) Descriptor() ([]byte, []int)

Deprecated: Use SubchannelRef.ProtoReflect.Descriptor instead.

func (*SubchannelRef) GetName Uses

func (x *SubchannelRef) GetName() string

func (*SubchannelRef) GetSubchannelId Uses

func (x *SubchannelRef) GetSubchannelId() int64

func (*SubchannelRef) ProtoMessage Uses

func (*SubchannelRef) ProtoMessage()

func (*SubchannelRef) ProtoReflect Uses

func (x *SubchannelRef) ProtoReflect() protoreflect.Message

func (*SubchannelRef) Reset Uses

func (x *SubchannelRef) Reset()

func (*SubchannelRef) String Uses

func (x *SubchannelRef) String() string

type UnimplementedChannelzServer Uses

type UnimplementedChannelzServer struct {
}

UnimplementedChannelzServer should be embedded to have forward compatible implementations.

func (UnimplementedChannelzServer) GetChannel Uses

func (UnimplementedChannelzServer) GetChannel(context.Context, *GetChannelRequest) (*GetChannelResponse, error)

func (UnimplementedChannelzServer) GetServer Uses

func (UnimplementedChannelzServer) GetServer(context.Context, *GetServerRequest) (*GetServerResponse, error)

func (UnimplementedChannelzServer) GetServerSockets Uses

func (UnimplementedChannelzServer) GetServerSockets(context.Context, *GetServerSocketsRequest) (*GetServerSocketsResponse, error)

func (UnimplementedChannelzServer) GetServers Uses

func (UnimplementedChannelzServer) GetServers(context.Context, *GetServersRequest) (*GetServersResponse, error)

func (UnimplementedChannelzServer) GetSocket Uses

func (UnimplementedChannelzServer) GetSocket(context.Context, *GetSocketRequest) (*GetSocketResponse, error)

func (UnimplementedChannelzServer) GetSubchannel Uses

func (UnimplementedChannelzServer) GetSubchannel(context.Context, *GetSubchannelRequest) (*GetSubchannelResponse, error)

func (UnimplementedChannelzServer) GetTopChannels Uses

func (UnimplementedChannelzServer) GetTopChannels(context.Context, *GetTopChannelsRequest) (*GetTopChannelsResponse, error)

type UnsafeChannelzServer Uses

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.

Package grpc_channelz_v1 imports 13 packages (graph) and is imported by 7 packages. Updated 2021-01-17. Refresh now. Tools for package owners.