grpc_channelz_v1

package
v1.33.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 1, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ChannelConnectivityState_State_name = map[int32]string{
	0: "UNKNOWN",
	1: "IDLE",
	2: "CONNECTING",
	3: "READY",
	4: "TRANSIENT_FAILURE",
	5: "SHUTDOWN",
}
View Source 
var ChannelConnectivityState_State_value = map[string]int32{
	"UNKNOWN":           0,
	"IDLE":              1,
	"CONNECTING":        2,
	"READY":             3,
	"TRANSIENT_FAILURE": 4,
	"SHUTDOWN":          5,
}
View Source 
var ChannelTraceEvent_Severity_name = map[int32]string{
	0: "CT_UNKNOWN",
	1: "CT_INFO",
	2: "CT_WARNING",
	3: "CT_ERROR",
}
View Source 
var ChannelTraceEvent_Severity_value = map[string]int32{
	"CT_UNKNOWN": 0,
	"CT_INFO":    1,
	"CT_WARNING": 2,
	"CT_ERROR":   3,
}

Functions

func RegisterChannelzServer 

func RegisterChannelzServer(s *grpc.Server, srv ChannelzServer)

func RegisterChannelzService added in v1.33.1 

func RegisterChannelzService(s grpc.ServiceRegistrar, srv *ChannelzService)

RegisterChannelzService registers a service implementation with a gRPC server.

Types

type Address 

type Address struct {
	// Types that are valid to be assigned to Address:
	//	*Address_TcpipAddress
	//	*Address_UdsAddress_
	//	*Address_OtherAddress_
	Address              isAddress_Address `protobuf_oneof:"address"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Address represents the address used to create the socket.

func (*Address) Descriptor 

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

func (*Address) GetAddress 

func (m *Address) GetAddress() isAddress_Address

func (*Address) GetOtherAddress 

func (m *Address) GetOtherAddress() *Address_OtherAddress

func (*Address) GetTcpipAddress 

func (m *Address) GetTcpipAddress() *Address_TcpIpAddress

func (*Address) GetUdsAddress 

func (m *Address) GetUdsAddress() *Address_UdsAddress

func (*Address) ProtoMessage 

func (*Address) ProtoMessage()

func (*Address) Reset 

func (m *Address) Reset()

func (*Address) String 

func (m *Address) String() string

func (*Address) XXX_DiscardUnknown 

func (m *Address) XXX_DiscardUnknown()

func (*Address) XXX_Marshal 

func (m *Address) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Address) XXX_Merge 

func (m *Address) XXX_Merge(src proto.Message)

func (*Address) XXX_OneofWrappers added in v1.33.1 

func (*Address) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Address) XXX_Size 

func (m *Address) XXX_Size() int

func (*Address) XXX_Unmarshal 

func (m *Address) XXX_Unmarshal(b []byte) error

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                *any.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

An address type not included above.

func (*Address_OtherAddress) Descriptor 

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

func (*Address_OtherAddress) GetName 

func (m *Address_OtherAddress) GetName() string

func (*Address_OtherAddress) GetValue 

func (m *Address_OtherAddress) GetValue() *any.Any

func (*Address_OtherAddress) ProtoMessage 

func (*Address_OtherAddress) ProtoMessage()

func (*Address_OtherAddress) Reset 

func (m *Address_OtherAddress) Reset()

func (*Address_OtherAddress) String 

func (m *Address_OtherAddress) String() string

func (*Address_OtherAddress) XXX_DiscardUnknown 

func (m *Address_OtherAddress) XXX_DiscardUnknown()

func (*Address_OtherAddress) XXX_Marshal 

func (m *Address_OtherAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Address_OtherAddress) XXX_Merge 

func (m *Address_OtherAddress) XXX_Merge(src proto.Message)

func (*Address_OtherAddress) XXX_Size 

func (m *Address_OtherAddress) XXX_Size() int

func (*Address_OtherAddress) XXX_Unmarshal 

func (m *Address_OtherAddress) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Address_TcpIpAddress) Descriptor 

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

func (*Address_TcpIpAddress) GetIpAddress 

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

func (*Address_TcpIpAddress) GetPort 

func (m *Address_TcpIpAddress) GetPort() int32

func (*Address_TcpIpAddress) ProtoMessage 

func (*Address_TcpIpAddress) ProtoMessage()

func (*Address_TcpIpAddress) Reset 

func (m *Address_TcpIpAddress) Reset()

func (*Address_TcpIpAddress) String 

func (m *Address_TcpIpAddress) String() string

func (*Address_TcpIpAddress) XXX_DiscardUnknown 

func (m *Address_TcpIpAddress) XXX_DiscardUnknown()

func (*Address_TcpIpAddress) XXX_Marshal 

func (m *Address_TcpIpAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Address_TcpIpAddress) XXX_Merge 

func (m *Address_TcpIpAddress) XXX_Merge(src proto.Message)

func (*Address_TcpIpAddress) XXX_Size 

func (m *Address_TcpIpAddress) XXX_Size() int

func (*Address_TcpIpAddress) XXX_Unmarshal 

func (m *Address_TcpIpAddress) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A Unix Domain Socket address.

func (*Address_UdsAddress) Descriptor 

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

func (*Address_UdsAddress) GetFilename 

func (m *Address_UdsAddress) GetFilename() string

func (*Address_UdsAddress) ProtoMessage 

func (*Address_UdsAddress) ProtoMessage()

func (*Address_UdsAddress) Reset 

func (m *Address_UdsAddress) Reset()

func (*Address_UdsAddress) String 

func (m *Address_UdsAddress) String() string

func (*Address_UdsAddress) XXX_DiscardUnknown 

func (m *Address_UdsAddress) XXX_DiscardUnknown()

func (*Address_UdsAddress) XXX_Marshal 

func (m *Address_UdsAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Address_UdsAddress) XXX_Merge 

func (m *Address_UdsAddress) XXX_Merge(src proto.Message)

func (*Address_UdsAddress) XXX_Size 

func (m *Address_UdsAddress) XXX_Size() int

func (*Address_UdsAddress) XXX_Unmarshal 

func (m *Address_UdsAddress) XXX_Unmarshal(b []byte) error

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 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"`
	// 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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Channel is a logical grouping of channels, subchannels, and sockets.

func (*Channel) Descriptor 

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

func (*Channel) GetChannelRef 

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

func (*Channel) GetData 

func (m *Channel) GetData() *ChannelData

func (*Channel) GetRef 

func (m *Channel) GetRef() *ChannelRef

func (*Channel) GetSocketRef 

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

func (*Channel) GetSubchannelRef 

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

func (*Channel) ProtoMessage 

func (*Channel) ProtoMessage()

func (*Channel) Reset 

func (m *Channel) Reset()

func (*Channel) String 

func (m *Channel) String() string

func (*Channel) XXX_DiscardUnknown 

func (m *Channel) XXX_DiscardUnknown()

func (*Channel) XXX_Marshal 

func (m *Channel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Channel) XXX_Merge 

func (m *Channel) XXX_Merge(src proto.Message)

func (*Channel) XXX_Size 

func (m *Channel) XXX_Size() int

func (*Channel) XXX_Unmarshal 

func (m *Channel) XXX_Unmarshal(b []byte) error

type ChannelConnectivityState 

type ChannelConnectivityState struct {
	State                ChannelConnectivityState_State `protobuf:"varint,1,opt,name=state,proto3,enum=grpc.channelz.v1.ChannelConnectivityState_State" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

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)

func (*ChannelConnectivityState) GetState 

func (m *ChannelConnectivityState) GetState() ChannelConnectivityState_State

func (*ChannelConnectivityState) ProtoMessage 

func (*ChannelConnectivityState) ProtoMessage()

func (*ChannelConnectivityState) Reset 

func (m *ChannelConnectivityState) Reset()

func (*ChannelConnectivityState) String 

func (m *ChannelConnectivityState) String() string

func (*ChannelConnectivityState) XXX_DiscardUnknown 

func (m *ChannelConnectivityState) XXX_DiscardUnknown()

func (*ChannelConnectivityState) XXX_Marshal 

func (m *ChannelConnectivityState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChannelConnectivityState) XXX_Merge 

func (m *ChannelConnectivityState) XXX_Merge(src proto.Message)

func (*ChannelConnectivityState) XXX_Size 

func (m *ChannelConnectivityState) XXX_Size() int

func (*ChannelConnectivityState) XXX_Unmarshal 

func (m *ChannelConnectivityState) XXX_Unmarshal(b []byte) error

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) EnumDescriptor 

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

func (ChannelConnectivityState_State) String 

func (x ChannelConnectivityState_State) String() string

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 *timestamp.Timestamp `` /* 137-byte string literal not displayed */
	XXX_NoUnkeyedLiteral     struct{}             `json:"-"`
	XXX_unrecognized         []byte               `json:"-"`
	XXX_sizecache            int32                `json:"-"`
}

Channel data is data related to a specific Channel or Subchannel.

func (*ChannelData) Descriptor 

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

func (*ChannelData) GetCallsFailed 

func (m *ChannelData) GetCallsFailed() int64

func (*ChannelData) GetCallsStarted 

func (m *ChannelData) GetCallsStarted() int64

func (*ChannelData) GetCallsSucceeded 

func (m *ChannelData) GetCallsSucceeded() int64

func (*ChannelData) GetLastCallStartedTimestamp 

func (m *ChannelData) GetLastCallStartedTimestamp() *timestamp.Timestamp

func (*ChannelData) GetState 

func (m *ChannelData) GetState() *ChannelConnectivityState

func (*ChannelData) GetTarget 

func (m *ChannelData) GetTarget() string

func (*ChannelData) GetTrace 

func (m *ChannelData) GetTrace() *ChannelTrace

func (*ChannelData) ProtoMessage 

func (*ChannelData) ProtoMessage()

func (*ChannelData) Reset 

func (m *ChannelData) Reset()

func (*ChannelData) String 

func (m *ChannelData) String() string

func (*ChannelData) XXX_DiscardUnknown 

func (m *ChannelData) XXX_DiscardUnknown()

func (*ChannelData) XXX_Marshal 

func (m *ChannelData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChannelData) XXX_Merge 

func (m *ChannelData) XXX_Merge(src proto.Message)

func (*ChannelData) XXX_Size 

func (m *ChannelData) XXX_Size() int

func (*ChannelData) XXX_Unmarshal 

func (m *ChannelData) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ChannelRef is a reference to a Channel.

func (*ChannelRef) Descriptor 

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

func (*ChannelRef) GetChannelId 

func (m *ChannelRef) GetChannelId() int64

func (*ChannelRef) GetName 

func (m *ChannelRef) GetName() string

func (*ChannelRef) ProtoMessage 

func (*ChannelRef) ProtoMessage()

func (*ChannelRef) Reset 

func (m *ChannelRef) Reset()

func (*ChannelRef) String 

func (m *ChannelRef) String() string

func (*ChannelRef) XXX_DiscardUnknown 

func (m *ChannelRef) XXX_DiscardUnknown()

func (*ChannelRef) XXX_Marshal 

func (m *ChannelRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChannelRef) XXX_Merge 

func (m *ChannelRef) XXX_Merge(src proto.Message)

func (*ChannelRef) XXX_Size 

func (m *ChannelRef) XXX_Size() int

func (*ChannelRef) XXX_Unmarshal 

func (m *ChannelRef) XXX_Unmarshal(b []byte) error

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 *timestamp.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"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

ChannelTrace represents the recent events that have occurred on the channel.

func (*ChannelTrace) Descriptor 

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

func (*ChannelTrace) GetCreationTimestamp added in v1.13.0 

func (m *ChannelTrace) GetCreationTimestamp() *timestamp.Timestamp

func (*ChannelTrace) GetEvents added in v1.13.0 

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

func (*ChannelTrace) GetNumEventsLogged added in v1.13.0 

func (m *ChannelTrace) GetNumEventsLogged() int64

func (*ChannelTrace) ProtoMessage 

func (*ChannelTrace) ProtoMessage()

func (*ChannelTrace) Reset 

func (m *ChannelTrace) Reset()

func (*ChannelTrace) String 

func (m *ChannelTrace) String() string

func (*ChannelTrace) XXX_DiscardUnknown 

func (m *ChannelTrace) XXX_DiscardUnknown()

func (*ChannelTrace) XXX_Marshal 

func (m *ChannelTrace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChannelTrace) XXX_Merge 

func (m *ChannelTrace) XXX_Merge(src proto.Message)

func (*ChannelTrace) XXX_Size 

func (m *ChannelTrace) XXX_Size() int

func (*ChannelTrace) XXX_Unmarshal 

func (m *ChannelTrace) XXX_Unmarshal(b []byte) error

type ChannelTraceEvent added in v1.13.0 

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 *timestamp.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 valid to be assigned to ChildRef:
	//	*ChannelTraceEvent_ChannelRef
	//	*ChannelTraceEvent_SubchannelRef
	ChildRef             isChannelTraceEvent_ChildRef `protobuf_oneof:"child_ref"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

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 added in v1.13.0 

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

func (*ChannelTraceEvent) GetChannelRef added in v1.13.0 

func (m *ChannelTraceEvent) GetChannelRef() *ChannelRef

func (*ChannelTraceEvent) GetChildRef added in v1.13.0 

func (m *ChannelTraceEvent) GetChildRef() isChannelTraceEvent_ChildRef

func (*ChannelTraceEvent) GetDescription added in v1.13.0 

func (m *ChannelTraceEvent) GetDescription() string

func (*ChannelTraceEvent) GetSeverity added in v1.13.0 

func (m *ChannelTraceEvent) GetSeverity() ChannelTraceEvent_Severity

func (*ChannelTraceEvent) GetSubchannelRef added in v1.13.0 

func (m *ChannelTraceEvent) GetSubchannelRef() *SubchannelRef

func (*ChannelTraceEvent) GetTimestamp added in v1.13.0 

func (m *ChannelTraceEvent) GetTimestamp() *timestamp.Timestamp

func (*ChannelTraceEvent) ProtoMessage added in v1.13.0 

func (*ChannelTraceEvent) ProtoMessage()

func (*ChannelTraceEvent) Reset added in v1.13.0 

func (m *ChannelTraceEvent) Reset()

func (*ChannelTraceEvent) String added in v1.13.0 

func (m *ChannelTraceEvent) String() string

func (*ChannelTraceEvent) XXX_DiscardUnknown added in v1.13.0 

func (m *ChannelTraceEvent) XXX_DiscardUnknown()

func (*ChannelTraceEvent) XXX_Marshal added in v1.13.0 

func (m *ChannelTraceEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChannelTraceEvent) XXX_Merge added in v1.13.0 

func (m *ChannelTraceEvent) XXX_Merge(src proto.Message)

func (*ChannelTraceEvent) XXX_OneofWrappers added in v1.33.1 

func (*ChannelTraceEvent) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ChannelTraceEvent) XXX_Size added in v1.13.0 

func (m *ChannelTraceEvent) XXX_Size() int

func (*ChannelTraceEvent) XXX_Unmarshal added in v1.13.0 

func (m *ChannelTraceEvent) XXX_Unmarshal(b []byte) error

type ChannelTraceEvent_ChannelRef added in v1.13.0 

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

type ChannelTraceEvent_Severity added in v1.13.0 

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) EnumDescriptor added in v1.13.0 

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

func (ChannelTraceEvent_Severity) String added in v1.13.0 

func (x ChannelTraceEvent_Severity) String() string

type ChannelTraceEvent_SubchannelRef added in v1.13.0 

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://godoc.org/github.com/fgiudici/grpc-go#ClientConn.NewStream.

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.

type ChannelzService added in v1.33.1 

type ChannelzService struct {
	// Gets all root channels (i.e. channels the application has directly
	// created). This does not include subchannels nor non-top level channels.
	GetTopChannels func(context.Context, *GetTopChannelsRequest) (*GetTopChannelsResponse, error)
	// Gets all servers that exist in the process.
	GetServers func(context.Context, *GetServersRequest) (*GetServersResponse, error)
	// Returns a single Server, or else a NOT_FOUND code.
	GetServer func(context.Context, *GetServerRequest) (*GetServerResponse, error)
	// Gets all server sockets that exist in the process.
	GetServerSockets func(context.Context, *GetServerSocketsRequest) (*GetServerSocketsResponse, error)
	// Returns a single Channel, or else a NOT_FOUND code.
	GetChannel func(context.Context, *GetChannelRequest) (*GetChannelResponse, error)
	// Returns a single Subchannel, or else a NOT_FOUND code.
	GetSubchannel func(context.Context, *GetSubchannelRequest) (*GetSubchannelResponse, error)
	// Returns a single Socket or else a NOT_FOUND code.
	GetSocket func(context.Context, *GetSocketRequest) (*GetSocketResponse, error)
}

ChannelzService is the service API for Channelz service. Fields should be assigned to their respective handler implementations only before RegisterChannelzService is called. Any unassigned fields will result in the handler for that method returning an Unimplemented error.

func NewChannelzService added in v1.33.1 

func NewChannelzService(s interface{}) *ChannelzService

NewChannelzService creates a new ChannelzService containing the implemented methods of the Channelz service in s. Any unimplemented methods will result in the gRPC server returning an UNIMPLEMENTED status to the client. This includes situations where the method handler is misspelled or has the wrong signature. For this reason, this function should be used with great care and is not recommended to be used by most users.

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetChannelRequest) Descriptor 

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

func (*GetChannelRequest) GetChannelId 

func (m *GetChannelRequest) GetChannelId() int64

func (*GetChannelRequest) ProtoMessage 

func (*GetChannelRequest) ProtoMessage()

func (*GetChannelRequest) Reset 

func (m *GetChannelRequest) Reset()

func (*GetChannelRequest) String 

func (m *GetChannelRequest) String() string

func (*GetChannelRequest) XXX_DiscardUnknown 

func (m *GetChannelRequest) XXX_DiscardUnknown()

func (*GetChannelRequest) XXX_Marshal 

func (m *GetChannelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetChannelRequest) XXX_Merge 

func (m *GetChannelRequest) XXX_Merge(src proto.Message)

func (*GetChannelRequest) XXX_Size 

func (m *GetChannelRequest) XXX_Size() int

func (*GetChannelRequest) XXX_Unmarshal 

func (m *GetChannelRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetChannelResponse) Descriptor 

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

func (*GetChannelResponse) GetChannel 

func (m *GetChannelResponse) GetChannel() *Channel

func (*GetChannelResponse) ProtoMessage 

func (*GetChannelResponse) ProtoMessage()

func (*GetChannelResponse) Reset 

func (m *GetChannelResponse) Reset()

func (*GetChannelResponse) String 

func (m *GetChannelResponse) String() string

func (*GetChannelResponse) XXX_DiscardUnknown 

func (m *GetChannelResponse) XXX_DiscardUnknown()

func (*GetChannelResponse) XXX_Marshal 

func (m *GetChannelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetChannelResponse) XXX_Merge 

func (m *GetChannelResponse) XXX_Merge(src proto.Message)

func (*GetChannelResponse) XXX_Size 

func (m *GetChannelResponse) XXX_Size() int

func (*GetChannelResponse) XXX_Unmarshal 

func (m *GetChannelResponse) XXX_Unmarshal(b []byte) error

type GetServerRequest added in v1.33.1 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetServerRequest) Descriptor added in v1.33.1 

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

func (*GetServerRequest) GetServerId added in v1.33.1 

func (m *GetServerRequest) GetServerId() int64

func (*GetServerRequest) ProtoMessage added in v1.33.1 

func (*GetServerRequest) ProtoMessage()

func (*GetServerRequest) Reset added in v1.33.1 

func (m *GetServerRequest) Reset()

func (*GetServerRequest) String added in v1.33.1 

func (m *GetServerRequest) String() string

func (*GetServerRequest) XXX_DiscardUnknown added in v1.33.1 

func (m *GetServerRequest) XXX_DiscardUnknown()

func (*GetServerRequest) XXX_Marshal added in v1.33.1 

func (m *GetServerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetServerRequest) XXX_Merge added in v1.33.1 

func (m *GetServerRequest) XXX_Merge(src proto.Message)

func (*GetServerRequest) XXX_Size added in v1.33.1 

func (m *GetServerRequest) XXX_Size() int

func (*GetServerRequest) XXX_Unmarshal added in v1.33.1 

func (m *GetServerRequest) XXX_Unmarshal(b []byte) error

type GetServerResponse added in v1.33.1 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetServerResponse) Descriptor added in v1.33.1 

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

func (*GetServerResponse) GetServer added in v1.33.1 

func (m *GetServerResponse) GetServer() *Server

func (*GetServerResponse) ProtoMessage added in v1.33.1 

func (*GetServerResponse) ProtoMessage()

func (*GetServerResponse) Reset added in v1.33.1 

func (m *GetServerResponse) Reset()

func (*GetServerResponse) String added in v1.33.1 

func (m *GetServerResponse) String() string

func (*GetServerResponse) XXX_DiscardUnknown added in v1.33.1 

func (m *GetServerResponse) XXX_DiscardUnknown()

func (*GetServerResponse) XXX_Marshal added in v1.33.1 

func (m *GetServerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetServerResponse) XXX_Merge added in v1.33.1 

func (m *GetServerResponse) XXX_Merge(src proto.Message)

func (*GetServerResponse) XXX_Size added in v1.33.1 

func (m *GetServerResponse) XXX_Size() int

func (*GetServerResponse) XXX_Unmarshal added in v1.33.1 

func (m *GetServerResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetServerSocketsRequest) Descriptor 

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

func (*GetServerSocketsRequest) GetMaxResults added in v1.33.1 

func (m *GetServerSocketsRequest) GetMaxResults() int64

func (*GetServerSocketsRequest) GetServerId 

func (m *GetServerSocketsRequest) GetServerId() int64

func (*GetServerSocketsRequest) GetStartSocketId 

func (m *GetServerSocketsRequest) GetStartSocketId() int64

func (*GetServerSocketsRequest) ProtoMessage 

func (*GetServerSocketsRequest) ProtoMessage()

func (*GetServerSocketsRequest) Reset 

func (m *GetServerSocketsRequest) Reset()

func (*GetServerSocketsRequest) String 

func (m *GetServerSocketsRequest) String() string

func (*GetServerSocketsRequest) XXX_DiscardUnknown 

func (m *GetServerSocketsRequest) XXX_DiscardUnknown()

func (*GetServerSocketsRequest) XXX_Marshal 

func (m *GetServerSocketsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetServerSocketsRequest) XXX_Merge 

func (m *GetServerSocketsRequest) XXX_Merge(src proto.Message)

func (*GetServerSocketsRequest) XXX_Size 

func (m *GetServerSocketsRequest) XXX_Size() int

func (*GetServerSocketsRequest) XXX_Unmarshal 

func (m *GetServerSocketsRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetServerSocketsResponse) Descriptor 

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

func (*GetServerSocketsResponse) GetEnd 

func (m *GetServerSocketsResponse) GetEnd() bool

func (*GetServerSocketsResponse) GetSocketRef 

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

func (*GetServerSocketsResponse) ProtoMessage 

func (*GetServerSocketsResponse) ProtoMessage()

func (*GetServerSocketsResponse) Reset 

func (m *GetServerSocketsResponse) Reset()

func (*GetServerSocketsResponse) String 

func (m *GetServerSocketsResponse) String() string

func (*GetServerSocketsResponse) XXX_DiscardUnknown 

func (m *GetServerSocketsResponse) XXX_DiscardUnknown()

func (*GetServerSocketsResponse) XXX_Marshal 

func (m *GetServerSocketsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetServerSocketsResponse) XXX_Merge 

func (m *GetServerSocketsResponse) XXX_Merge(src proto.Message)

func (*GetServerSocketsResponse) XXX_Size 

func (m *GetServerSocketsResponse) XXX_Size() int

func (*GetServerSocketsResponse) XXX_Unmarshal 

func (m *GetServerSocketsResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetServersRequest) Descriptor 

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

func (*GetServersRequest) GetMaxResults added in v1.33.1 

func (m *GetServersRequest) GetMaxResults() int64

func (*GetServersRequest) GetStartServerId 

func (m *GetServersRequest) GetStartServerId() int64

func (*GetServersRequest) ProtoMessage 

func (*GetServersRequest) ProtoMessage()

func (*GetServersRequest) Reset 

func (m *GetServersRequest) Reset()

func (*GetServersRequest) String 

func (m *GetServersRequest) String() string

func (*GetServersRequest) XXX_DiscardUnknown 

func (m *GetServersRequest) XXX_DiscardUnknown()

func (*GetServersRequest) XXX_Marshal 

func (m *GetServersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetServersRequest) XXX_Merge 

func (m *GetServersRequest) XXX_Merge(src proto.Message)

func (*GetServersRequest) XXX_Size 

func (m *GetServersRequest) XXX_Size() int

func (*GetServersRequest) XXX_Unmarshal 

func (m *GetServersRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetServersResponse) Descriptor 

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

func (*GetServersResponse) GetEnd 

func (m *GetServersResponse) GetEnd() bool

func (*GetServersResponse) GetServer 

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

func (*GetServersResponse) ProtoMessage 

func (*GetServersResponse) ProtoMessage()

func (*GetServersResponse) Reset 

func (m *GetServersResponse) Reset()

func (*GetServersResponse) String 

func (m *GetServersResponse) String() string

func (*GetServersResponse) XXX_DiscardUnknown 

func (m *GetServersResponse) XXX_DiscardUnknown()

func (*GetServersResponse) XXX_Marshal 

func (m *GetServersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetServersResponse) XXX_Merge 

func (m *GetServersResponse) XXX_Merge(src proto.Message)

func (*GetServersResponse) XXX_Size 

func (m *GetServersResponse) XXX_Size() int

func (*GetServersResponse) XXX_Unmarshal 

func (m *GetServersResponse) XXX_Unmarshal(b []byte) error

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 thay may be omitted are
	// documented.
	Summary              bool     `protobuf:"varint,2,opt,name=summary,proto3" json:"summary,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSocketRequest) Descriptor 

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

func (*GetSocketRequest) GetSocketId 

func (m *GetSocketRequest) GetSocketId() int64

func (*GetSocketRequest) GetSummary added in v1.33.1 

func (m *GetSocketRequest) GetSummary() bool

func (*GetSocketRequest) ProtoMessage 

func (*GetSocketRequest) ProtoMessage()

func (*GetSocketRequest) Reset 

func (m *GetSocketRequest) Reset()

func (*GetSocketRequest) String 

func (m *GetSocketRequest) String() string

func (*GetSocketRequest) XXX_DiscardUnknown 

func (m *GetSocketRequest) XXX_DiscardUnknown()

func (*GetSocketRequest) XXX_Marshal 

func (m *GetSocketRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSocketRequest) XXX_Merge 

func (m *GetSocketRequest) XXX_Merge(src proto.Message)

func (*GetSocketRequest) XXX_Size 

func (m *GetSocketRequest) XXX_Size() int

func (*GetSocketRequest) XXX_Unmarshal 

func (m *GetSocketRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSocketResponse) Descriptor 

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

func (*GetSocketResponse) GetSocket 

func (m *GetSocketResponse) GetSocket() *Socket

func (*GetSocketResponse) ProtoMessage 

func (*GetSocketResponse) ProtoMessage()

func (*GetSocketResponse) Reset 

func (m *GetSocketResponse) Reset()

func (*GetSocketResponse) String 

func (m *GetSocketResponse) String() string

func (*GetSocketResponse) XXX_DiscardUnknown 

func (m *GetSocketResponse) XXX_DiscardUnknown()

func (*GetSocketResponse) XXX_Marshal 

func (m *GetSocketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSocketResponse) XXX_Merge 

func (m *GetSocketResponse) XXX_Merge(src proto.Message)

func (*GetSocketResponse) XXX_Size 

func (m *GetSocketResponse) XXX_Size() int

func (*GetSocketResponse) XXX_Unmarshal 

func (m *GetSocketResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSubchannelRequest) Descriptor 

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

func (*GetSubchannelRequest) GetSubchannelId 

func (m *GetSubchannelRequest) GetSubchannelId() int64

func (*GetSubchannelRequest) ProtoMessage 

func (*GetSubchannelRequest) ProtoMessage()

func (*GetSubchannelRequest) Reset 

func (m *GetSubchannelRequest) Reset()

func (*GetSubchannelRequest) String 

func (m *GetSubchannelRequest) String() string

func (*GetSubchannelRequest) XXX_DiscardUnknown 

func (m *GetSubchannelRequest) XXX_DiscardUnknown()

func (*GetSubchannelRequest) XXX_Marshal 

func (m *GetSubchannelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSubchannelRequest) XXX_Merge 

func (m *GetSubchannelRequest) XXX_Merge(src proto.Message)

func (*GetSubchannelRequest) XXX_Size 

func (m *GetSubchannelRequest) XXX_Size() int

func (*GetSubchannelRequest) XXX_Unmarshal 

func (m *GetSubchannelRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*GetSubchannelResponse) Descriptor 

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

func (*GetSubchannelResponse) GetSubchannel 

func (m *GetSubchannelResponse) GetSubchannel() *Subchannel

func (*GetSubchannelResponse) ProtoMessage 

func (*GetSubchannelResponse) ProtoMessage()

func (*GetSubchannelResponse) Reset 

func (m *GetSubchannelResponse) Reset()

func (*GetSubchannelResponse) String 

func (m *GetSubchannelResponse) String() string

func (*GetSubchannelResponse) XXX_DiscardUnknown 

func (m *GetSubchannelResponse) XXX_DiscardUnknown()

func (*GetSubchannelResponse) XXX_Marshal 

func (m *GetSubchannelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSubchannelResponse) XXX_Merge 

func (m *GetSubchannelResponse) XXX_Merge(src proto.Message)

func (*GetSubchannelResponse) XXX_Size 

func (m *GetSubchannelResponse) XXX_Size() int

func (*GetSubchannelResponse) XXX_Unmarshal 

func (m *GetSubchannelResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTopChannelsRequest) Descriptor 

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

func (*GetTopChannelsRequest) GetMaxResults added in v1.33.1 

func (m *GetTopChannelsRequest) GetMaxResults() int64

func (*GetTopChannelsRequest) GetStartChannelId 

func (m *GetTopChannelsRequest) GetStartChannelId() int64

func (*GetTopChannelsRequest) ProtoMessage 

func (*GetTopChannelsRequest) ProtoMessage()

func (*GetTopChannelsRequest) Reset 

func (m *GetTopChannelsRequest) Reset()

func (*GetTopChannelsRequest) String 

func (m *GetTopChannelsRequest) String() string

func (*GetTopChannelsRequest) XXX_DiscardUnknown 

func (m *GetTopChannelsRequest) XXX_DiscardUnknown()

func (*GetTopChannelsRequest) XXX_Marshal 

func (m *GetTopChannelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTopChannelsRequest) XXX_Merge 

func (m *GetTopChannelsRequest) XXX_Merge(src proto.Message)

func (*GetTopChannelsRequest) XXX_Size 

func (m *GetTopChannelsRequest) XXX_Size() int

func (*GetTopChannelsRequest) XXX_Unmarshal 

func (m *GetTopChannelsRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTopChannelsResponse) Descriptor 

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

func (*GetTopChannelsResponse) GetChannel 

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

func (*GetTopChannelsResponse) GetEnd 

func (m *GetTopChannelsResponse) GetEnd() bool

func (*GetTopChannelsResponse) ProtoMessage 

func (*GetTopChannelsResponse) ProtoMessage()

func (*GetTopChannelsResponse) Reset 

func (m *GetTopChannelsResponse) Reset()

func (*GetTopChannelsResponse) String 

func (m *GetTopChannelsResponse) String() string

func (*GetTopChannelsResponse) XXX_DiscardUnknown 

func (m *GetTopChannelsResponse) XXX_DiscardUnknown()

func (*GetTopChannelsResponse) XXX_Marshal 

func (m *GetTopChannelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTopChannelsResponse) XXX_Merge 

func (m *GetTopChannelsResponse) XXX_Merge(src proto.Message)

func (*GetTopChannelsResponse) XXX_Size 

func (m *GetTopChannelsResponse) XXX_Size() int

func (*GetTopChannelsResponse) XXX_Unmarshal 

func (m *GetTopChannelsResponse) XXX_Unmarshal(b []byte) error

type Security 

type Security struct {
	// Types that are valid to be assigned to Model:
	//	*Security_Tls_
	//	*Security_Other
	Model                isSecurity_Model `protobuf_oneof:"model"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Security represents details about how secure the socket is.

func (*Security) Descriptor 

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

func (*Security) GetModel 

func (m *Security) GetModel() isSecurity_Model

func (*Security) GetOther 

func (m *Security) GetOther() *Security_OtherSecurity

func (*Security) GetTls 

func (m *Security) GetTls() *Security_Tls

func (*Security) ProtoMessage 

func (*Security) ProtoMessage()

func (*Security) Reset 

func (m *Security) Reset()

func (*Security) String 

func (m *Security) String() string

func (*Security) XXX_DiscardUnknown 

func (m *Security) XXX_DiscardUnknown()

func (*Security) XXX_Marshal 

func (m *Security) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Security) XXX_Merge 

func (m *Security) XXX_Merge(src proto.Message)

func (*Security) XXX_OneofWrappers added in v1.33.1 

func (*Security) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Security) XXX_Size 

func (m *Security) XXX_Size() int

func (*Security) XXX_Unmarshal 

func (m *Security) XXX_Unmarshal(b []byte) error

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                *any.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Security_OtherSecurity) Descriptor 

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

func (*Security_OtherSecurity) GetName 

func (m *Security_OtherSecurity) GetName() string

func (*Security_OtherSecurity) GetValue 

func (m *Security_OtherSecurity) GetValue() *any.Any

func (*Security_OtherSecurity) ProtoMessage 

func (*Security_OtherSecurity) ProtoMessage()

func (*Security_OtherSecurity) Reset 

func (m *Security_OtherSecurity) Reset()

func (*Security_OtherSecurity) String 

func (m *Security_OtherSecurity) String() string

func (*Security_OtherSecurity) XXX_DiscardUnknown 

func (m *Security_OtherSecurity) XXX_DiscardUnknown()

func (*Security_OtherSecurity) XXX_Marshal 

func (m *Security_OtherSecurity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Security_OtherSecurity) XXX_Merge 

func (m *Security_OtherSecurity) XXX_Merge(src proto.Message)

func (*Security_OtherSecurity) XXX_Size 

func (m *Security_OtherSecurity) XXX_Size() int

func (*Security_OtherSecurity) XXX_Unmarshal 

func (m *Security_OtherSecurity) XXX_Unmarshal(b []byte) error

type Security_Tls 

type Security_Tls struct {
	// Types that are valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Security_Tls) Descriptor 

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

func (*Security_Tls) GetCipherSuite 

func (m *Security_Tls) GetCipherSuite() isSecurity_Tls_CipherSuite

func (*Security_Tls) GetLocalCertificate 

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

func (*Security_Tls) GetOtherName 

func (m *Security_Tls) GetOtherName() string

func (*Security_Tls) GetRemoteCertificate 

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

func (*Security_Tls) GetStandardName 

func (m *Security_Tls) GetStandardName() string

func (*Security_Tls) ProtoMessage 

func (*Security_Tls) ProtoMessage()

func (*Security_Tls) Reset 

func (m *Security_Tls) Reset()

func (*Security_Tls) String 

func (m *Security_Tls) String() string

func (*Security_Tls) XXX_DiscardUnknown 

func (m *Security_Tls) XXX_DiscardUnknown()

func (*Security_Tls) XXX_Marshal 

func (m *Security_Tls) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Security_Tls) XXX_Merge 

func (m *Security_Tls) XXX_Merge(src proto.Message)

func (*Security_Tls) XXX_OneofWrappers added in v1.33.1 

func (*Security_Tls) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Security_Tls) XXX_Size 

func (m *Security_Tls) XXX_Size() int

func (*Security_Tls) XXX_Unmarshal 

func (m *Security_Tls) XXX_Unmarshal(b []byte) error

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 {
	OtherName string `protobuf:"bytes,2,opt,name=other_name,json=otherName,proto3,oneof"`
}

type Security_Tls_StandardName 

type Security_Tls_StandardName struct {
	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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Server represents a single server. There may be multiple servers in a single program.

func (*Server) Descriptor 

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

func (*Server) GetData 

func (m *Server) GetData() *ServerData

func (*Server) GetListenSocket 

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

func (*Server) GetRef 

func (m *Server) GetRef() *ServerRef

func (*Server) ProtoMessage 

func (*Server) ProtoMessage()

func (*Server) Reset 

func (m *Server) Reset()

func (*Server) String 

func (m *Server) String() string

func (*Server) XXX_DiscardUnknown 

func (m *Server) XXX_DiscardUnknown()

func (*Server) XXX_Marshal 

func (m *Server) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Server) XXX_Merge 

func (m *Server) XXX_Merge(src proto.Message)

func (*Server) XXX_Size 

func (m *Server) XXX_Size() int

func (*Server) XXX_Unmarshal 

func (m *Server) XXX_Unmarshal(b []byte) error

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 *timestamp.Timestamp `` /* 137-byte string literal not displayed */
	XXX_NoUnkeyedLiteral     struct{}             `json:"-"`
	XXX_unrecognized         []byte               `json:"-"`
	XXX_sizecache            int32                `json:"-"`
}

ServerData is data for a specific Server.

func (*ServerData) Descriptor 

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

func (*ServerData) GetCallsFailed 

func (m *ServerData) GetCallsFailed() int64

func (*ServerData) GetCallsStarted 

func (m *ServerData) GetCallsStarted() int64

func (*ServerData) GetCallsSucceeded 

func (m *ServerData) GetCallsSucceeded() int64

func (*ServerData) GetLastCallStartedTimestamp 

func (m *ServerData) GetLastCallStartedTimestamp() *timestamp.Timestamp

func (*ServerData) GetTrace 

func (m *ServerData) GetTrace() *ChannelTrace

func (*ServerData) ProtoMessage 

func (*ServerData) ProtoMessage()

func (*ServerData) Reset 

func (m *ServerData) Reset()

func (*ServerData) String 

func (m *ServerData) String() string

func (*ServerData) XXX_DiscardUnknown 

func (m *ServerData) XXX_DiscardUnknown()

func (*ServerData) XXX_Marshal 

func (m *ServerData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerData) XXX_Merge 

func (m *ServerData) XXX_Merge(src proto.Message)

func (*ServerData) XXX_Size 

func (m *ServerData) XXX_Size() int

func (*ServerData) XXX_Unmarshal 

func (m *ServerData) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ServerRef is a reference to a Server.

func (*ServerRef) Descriptor 

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

func (*ServerRef) GetName 

func (m *ServerRef) GetName() string

func (*ServerRef) GetServerId 

func (m *ServerRef) GetServerId() int64

func (*ServerRef) ProtoMessage 

func (*ServerRef) ProtoMessage()

func (*ServerRef) Reset 

func (m *ServerRef) Reset()

func (*ServerRef) String 

func (m *ServerRef) String() string

func (*ServerRef) XXX_DiscardUnknown 

func (m *ServerRef) XXX_DiscardUnknown()

func (*ServerRef) XXX_Marshal 

func (m *ServerRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerRef) XXX_Merge 

func (m *ServerRef) XXX_Merge(src proto.Message)

func (*ServerRef) XXX_Size 

func (m *ServerRef) XXX_Size() int

func (*ServerRef) XXX_Unmarshal 

func (m *ServerRef) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Information about an actual connection. Pronounced "sock-ay".

func (*Socket) Descriptor 

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

func (*Socket) GetData 

func (m *Socket) GetData() *SocketData

func (*Socket) GetLocal 

func (m *Socket) GetLocal() *Address

func (*Socket) GetRef 

func (m *Socket) GetRef() *SocketRef

func (*Socket) GetRemote 

func (m *Socket) GetRemote() *Address

func (*Socket) GetRemoteName 

func (m *Socket) GetRemoteName() string

func (*Socket) GetSecurity 

func (m *Socket) GetSecurity() *Security

func (*Socket) ProtoMessage 

func (*Socket) ProtoMessage()

func (*Socket) Reset 

func (m *Socket) Reset()

func (*Socket) String 

func (m *Socket) String() string

func (*Socket) XXX_DiscardUnknown 

func (m *Socket) XXX_DiscardUnknown()

func (*Socket) XXX_Marshal 

func (m *Socket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Socket) XXX_Merge 

func (m *Socket) XXX_Merge(src proto.Message)

func (*Socket) XXX_Size 

func (m *Socket) XXX_Size() int

func (*Socket) XXX_Unmarshal 

func (m *Socket) XXX_Unmarshal(b []byte) error

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 *timestamp.Timestamp `` /* 160-byte string literal not displayed */
	// The last time a stream was created by the remote endpoint.  Usually unset
	// for clients.
	LastRemoteStreamCreatedTimestamp *timestamp.Timestamp `` /* 163-byte string literal not displayed */
	// The last time a message was sent by this endpoint.
	LastMessageSentTimestamp *timestamp.Timestamp `` /* 137-byte string literal not displayed */
	// The last time a message was received by this endpoint.
	LastMessageReceivedTimestamp *timestamp.Timestamp `` /* 150-byte string literal not displayed */
	// 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 *wrappers.Int64Value `` /* 132-byte string literal not displayed */
	// 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 *wrappers.Int64Value `` /* 135-byte string literal not displayed */
	// 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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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)

func (*SocketData) GetKeepAlivesSent 

func (m *SocketData) GetKeepAlivesSent() int64

func (*SocketData) GetLastLocalStreamCreatedTimestamp 

func (m *SocketData) GetLastLocalStreamCreatedTimestamp() *timestamp.Timestamp

func (*SocketData) GetLastMessageReceivedTimestamp 

func (m *SocketData) GetLastMessageReceivedTimestamp() *timestamp.Timestamp

func (*SocketData) GetLastMessageSentTimestamp 

func (m *SocketData) GetLastMessageSentTimestamp() *timestamp.Timestamp

func (*SocketData) GetLastRemoteStreamCreatedTimestamp 

func (m *SocketData) GetLastRemoteStreamCreatedTimestamp() *timestamp.Timestamp

func (*SocketData) GetLocalFlowControlWindow 

func (m *SocketData) GetLocalFlowControlWindow() *wrappers.Int64Value

func (*SocketData) GetMessagesReceived 

func (m *SocketData) GetMessagesReceived() int64

func (*SocketData) GetMessagesSent 

func (m *SocketData) GetMessagesSent() int64

func (*SocketData) GetOption 

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

func (*SocketData) GetRemoteFlowControlWindow 

func (m *SocketData) GetRemoteFlowControlWindow() *wrappers.Int64Value

func (*SocketData) GetStreamsFailed 

func (m *SocketData) GetStreamsFailed() int64

func (*SocketData) GetStreamsStarted 

func (m *SocketData) GetStreamsStarted() int64

func (*SocketData) GetStreamsSucceeded 

func (m *SocketData) GetStreamsSucceeded() int64

func (*SocketData) ProtoMessage 

func (*SocketData) ProtoMessage()

func (*SocketData) Reset 

func (m *SocketData) Reset()

func (*SocketData) String 

func (m *SocketData) String() string

func (*SocketData) XXX_DiscardUnknown 

func (m *SocketData) XXX_DiscardUnknown()

func (*SocketData) XXX_Marshal 

func (m *SocketData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SocketData) XXX_Merge 

func (m *SocketData) XXX_Merge(src proto.Message)

func (*SocketData) XXX_Size 

func (m *SocketData) XXX_Size() int

func (*SocketData) XXX_Unmarshal 

func (m *SocketData) XXX_Unmarshal(b []byte) error

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           *any.Any `protobuf:"bytes,3,opt,name=additional,proto3" json:"additional,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SocketOption represents socket options for a socket. Specifically, these are the options returned by getsockopt().

func (*SocketOption) Descriptor 

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

func (*SocketOption) GetAdditional 

func (m *SocketOption) GetAdditional() *any.Any

func (*SocketOption) GetName 

func (m *SocketOption) GetName() string

func (*SocketOption) GetValue 

func (m *SocketOption) GetValue() string

func (*SocketOption) ProtoMessage 

func (*SocketOption) ProtoMessage()

func (*SocketOption) Reset 

func (m *SocketOption) Reset()

func (*SocketOption) String 

func (m *SocketOption) String() string

func (*SocketOption) XXX_DiscardUnknown 

func (m *SocketOption) XXX_DiscardUnknown()

func (*SocketOption) XXX_Marshal 

func (m *SocketOption) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SocketOption) XXX_Merge 

func (m *SocketOption) XXX_Merge(src proto.Message)

func (*SocketOption) XXX_Size 

func (m *SocketOption) XXX_Size() int

func (*SocketOption) XXX_Unmarshal 

func (m *SocketOption) XXX_Unmarshal(b []byte) error

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             *duration.Duration `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

For use with SocketOption's additional field. This is primarily used for SO_LINGER.

func (*SocketOptionLinger) Descriptor 

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

func (*SocketOptionLinger) GetActive 

func (m *SocketOptionLinger) GetActive() bool

func (*SocketOptionLinger) GetDuration 

func (m *SocketOptionLinger) GetDuration() *duration.Duration

func (*SocketOptionLinger) ProtoMessage 

func (*SocketOptionLinger) ProtoMessage()

func (*SocketOptionLinger) Reset 

func (m *SocketOptionLinger) Reset()

func (*SocketOptionLinger) String 

func (m *SocketOptionLinger) String() string

func (*SocketOptionLinger) XXX_DiscardUnknown 

func (m *SocketOptionLinger) XXX_DiscardUnknown()

func (*SocketOptionLinger) XXX_Marshal 

func (m *SocketOptionLinger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SocketOptionLinger) XXX_Merge 

func (m *SocketOptionLinger) XXX_Merge(src proto.Message)

func (*SocketOptionLinger) XXX_Size 

func (m *SocketOptionLinger) XXX_Size() int

func (*SocketOptionLinger) XXX_Unmarshal 

func (m *SocketOptionLinger) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

For use with SocketOption's additional field. Tcp info for SOL_TCP and TCP_INFO.

func (*SocketOptionTcpInfo) Descriptor 

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

func (*SocketOptionTcpInfo) GetTcpiAdvmss 

func (m *SocketOptionTcpInfo) GetTcpiAdvmss() uint32

func (*SocketOptionTcpInfo) GetTcpiAto 

func (m *SocketOptionTcpInfo) GetTcpiAto() uint32

func (*SocketOptionTcpInfo) GetTcpiBackoff 

func (m *SocketOptionTcpInfo) GetTcpiBackoff() uint32

func (*SocketOptionTcpInfo) GetTcpiCaState 

func (m *SocketOptionTcpInfo) GetTcpiCaState() uint32

func (*SocketOptionTcpInfo) GetTcpiFackets 

func (m *SocketOptionTcpInfo) GetTcpiFackets() uint32

func (*SocketOptionTcpInfo) GetTcpiLastAckRecv 

func (m *SocketOptionTcpInfo) GetTcpiLastAckRecv() uint32

func (*SocketOptionTcpInfo) GetTcpiLastAckSent 

func (m *SocketOptionTcpInfo) GetTcpiLastAckSent() uint32

func (*SocketOptionTcpInfo) GetTcpiLastDataRecv 

func (m *SocketOptionTcpInfo) GetTcpiLastDataRecv() uint32

func (*SocketOptionTcpInfo) GetTcpiLastDataSent 

func (m *SocketOptionTcpInfo) GetTcpiLastDataSent() uint32

func (*SocketOptionTcpInfo) GetTcpiLost 

func (m *SocketOptionTcpInfo) GetTcpiLost() uint32

func (*SocketOptionTcpInfo) GetTcpiOptions 

func (m *SocketOptionTcpInfo) GetTcpiOptions() uint32

func (*SocketOptionTcpInfo) GetTcpiPmtu 

func (m *SocketOptionTcpInfo) GetTcpiPmtu() uint32

func (*SocketOptionTcpInfo) GetTcpiProbes 

func (m *SocketOptionTcpInfo) GetTcpiProbes() uint32

func (*SocketOptionTcpInfo) GetTcpiRcvMss 

func (m *SocketOptionTcpInfo) GetTcpiRcvMss() uint32

func (*SocketOptionTcpInfo) GetTcpiRcvSsthresh 

func (m *SocketOptionTcpInfo) GetTcpiRcvSsthresh() uint32

func (*SocketOptionTcpInfo) GetTcpiRcvWscale 

func (m *SocketOptionTcpInfo) GetTcpiRcvWscale() uint32

func (*SocketOptionTcpInfo) GetTcpiReordering 

func (m *SocketOptionTcpInfo) GetTcpiReordering() uint32

func (*SocketOptionTcpInfo) GetTcpiRetrans 

func (m *SocketOptionTcpInfo) GetTcpiRetrans() uint32

func (*SocketOptionTcpInfo) GetTcpiRetransmits 

func (m *SocketOptionTcpInfo) GetTcpiRetransmits() uint32

func (*SocketOptionTcpInfo) GetTcpiRto 

func (m *SocketOptionTcpInfo) GetTcpiRto() uint32

func (*SocketOptionTcpInfo) GetTcpiRtt 

func (m *SocketOptionTcpInfo) GetTcpiRtt() uint32

func (*SocketOptionTcpInfo) GetTcpiRttvar 

func (m *SocketOptionTcpInfo) GetTcpiRttvar() uint32

func (*SocketOptionTcpInfo) GetTcpiSacked 

func (m *SocketOptionTcpInfo) GetTcpiSacked() uint32

func (*SocketOptionTcpInfo) GetTcpiSndCwnd 

func (m *SocketOptionTcpInfo) GetTcpiSndCwnd() uint32

func (*SocketOptionTcpInfo) GetTcpiSndMss 

func (m *SocketOptionTcpInfo) GetTcpiSndMss() uint32

func (*SocketOptionTcpInfo) GetTcpiSndSsthresh 

func (m *SocketOptionTcpInfo) GetTcpiSndSsthresh() uint32

func (*SocketOptionTcpInfo) GetTcpiSndWscale 

func (m *SocketOptionTcpInfo) GetTcpiSndWscale() uint32

func (*SocketOptionTcpInfo) GetTcpiState 

func (m *SocketOptionTcpInfo) GetTcpiState() uint32

func (*SocketOptionTcpInfo) GetTcpiUnacked 

func (m *SocketOptionTcpInfo) GetTcpiUnacked() uint32

func (*SocketOptionTcpInfo) ProtoMessage 

func (*SocketOptionTcpInfo) ProtoMessage()

func (*SocketOptionTcpInfo) Reset 

func (m *SocketOptionTcpInfo) Reset()

func (*SocketOptionTcpInfo) String 

func (m *SocketOptionTcpInfo) String() string

func (*SocketOptionTcpInfo) XXX_DiscardUnknown 

func (m *SocketOptionTcpInfo) XXX_DiscardUnknown()

func (*SocketOptionTcpInfo) XXX_Marshal 

func (m *SocketOptionTcpInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SocketOptionTcpInfo) XXX_Merge 

func (m *SocketOptionTcpInfo) XXX_Merge(src proto.Message)

func (*SocketOptionTcpInfo) XXX_Size 

func (m *SocketOptionTcpInfo) XXX_Size() int

func (*SocketOptionTcpInfo) XXX_Unmarshal 

func (m *SocketOptionTcpInfo) XXX_Unmarshal(b []byte) error

type SocketOptionTimeout 

type SocketOptionTimeout struct {
	Duration             *duration.Duration `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

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)

func (*SocketOptionTimeout) GetDuration 

func (m *SocketOptionTimeout) GetDuration() *duration.Duration

func (*SocketOptionTimeout) ProtoMessage 

func (*SocketOptionTimeout) ProtoMessage()

func (*SocketOptionTimeout) Reset 

func (m *SocketOptionTimeout) Reset()

func (*SocketOptionTimeout) String 

func (m *SocketOptionTimeout) String() string

func (*SocketOptionTimeout) XXX_DiscardUnknown 

func (m *SocketOptionTimeout) XXX_DiscardUnknown()

func (*SocketOptionTimeout) XXX_Marshal 

func (m *SocketOptionTimeout) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SocketOptionTimeout) XXX_Merge 

func (m *SocketOptionTimeout) XXX_Merge(src proto.Message)

func (*SocketOptionTimeout) XXX_Size 

func (m *SocketOptionTimeout) XXX_Size() int

func (*SocketOptionTimeout) XXX_Unmarshal 

func (m *SocketOptionTimeout) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SocketRef is a reference to a Socket.

func (*SocketRef) Descriptor 

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

func (*SocketRef) GetName 

func (m *SocketRef) GetName() string

func (*SocketRef) GetSocketId 

func (m *SocketRef) GetSocketId() int64

func (*SocketRef) ProtoMessage 

func (*SocketRef) ProtoMessage()

func (*SocketRef) Reset 

func (m *SocketRef) Reset()

func (*SocketRef) String 

func (m *SocketRef) String() string

func (*SocketRef) XXX_DiscardUnknown 

func (m *SocketRef) XXX_DiscardUnknown()

func (*SocketRef) XXX_Marshal 

func (m *SocketRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SocketRef) XXX_Merge 

func (m *SocketRef) XXX_Merge(src proto.Message)

func (*SocketRef) XXX_Size 

func (m *SocketRef) XXX_Size() int

func (*SocketRef) XXX_Unmarshal 

func (m *SocketRef) XXX_Unmarshal(b []byte) error

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"`
	// 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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Subchannel is a logical grouping of channels, subchannels, and sockets. A subchannel is load balanced over by it's ancestor

func (*Subchannel) Descriptor 

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

func (*Subchannel) GetChannelRef 

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

func (*Subchannel) GetData 

func (m *Subchannel) GetData() *ChannelData

func (*Subchannel) GetRef 

func (m *Subchannel) GetRef() *SubchannelRef

func (*Subchannel) GetSocketRef 

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

func (*Subchannel) GetSubchannelRef 

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

func (*Subchannel) ProtoMessage 

func (*Subchannel) ProtoMessage()

func (*Subchannel) Reset 

func (m *Subchannel) Reset()

func (*Subchannel) String 

func (m *Subchannel) String() string

func (*Subchannel) XXX_DiscardUnknown 

func (m *Subchannel) XXX_DiscardUnknown()

func (*Subchannel) XXX_Marshal 

func (m *Subchannel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Subchannel) XXX_Merge 

func (m *Subchannel) XXX_Merge(src proto.Message)

func (*Subchannel) XXX_Size 

func (m *Subchannel) XXX_Size() int

func (*Subchannel) XXX_Unmarshal 

func (m *Subchannel) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SubchannelRef is a reference to a Subchannel.

func (*SubchannelRef) Descriptor 

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

func (*SubchannelRef) GetName 

func (m *SubchannelRef) GetName() string

func (*SubchannelRef) GetSubchannelId 

func (m *SubchannelRef) GetSubchannelId() int64

func (*SubchannelRef) ProtoMessage 

func (*SubchannelRef) ProtoMessage()

func (*SubchannelRef) Reset 

func (m *SubchannelRef) Reset()

func (*SubchannelRef) String 

func (m *SubchannelRef) String() string

func (*SubchannelRef) XXX_DiscardUnknown 

func (m *SubchannelRef) XXX_DiscardUnknown()

func (*SubchannelRef) XXX_Marshal 

func (m *SubchannelRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubchannelRef) XXX_Merge 

func (m *SubchannelRef) XXX_Merge(src proto.Message)

func (*SubchannelRef) XXX_Size 

func (m *SubchannelRef) XXX_Size() int

func (*SubchannelRef) XXX_Unmarshal 

func (m *SubchannelRef) XXX_Unmarshal(b []byte) error

type UnimplementedChannelzServer added in v1.33.1 

type UnimplementedChannelzServer struct {
}

UnimplementedChannelzServer can be embedded to have forward compatible implementations.

func (*UnimplementedChannelzServer) GetChannel added in v1.33.1 

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

func (*UnimplementedChannelzServer) GetServer added in v1.33.1 

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

func (*UnimplementedChannelzServer) GetServerSockets added in v1.33.1 

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

func (*UnimplementedChannelzServer) GetServers added in v1.33.1 

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

func (*UnimplementedChannelzServer) GetSocket added in v1.33.1 

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

func (*UnimplementedChannelzServer) GetSubchannel added in v1.33.1 

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

func (*UnimplementedChannelzServer) GetTopChannels added in v1.33.1 

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

type UnstableChannelzService added in v1.33.1 

type UnstableChannelzService 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)
}

UnstableChannelzService is the service API for Channelz service. New methods may be added to this interface if they are added to the service definition, which is not a backward-compatible change. For this reason, use of this type is not recommended.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.