grpc_channelz_v1

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 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)

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 

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 

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

func (*ChannelTrace) GetEvents 

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

func (*ChannelTrace) GetNumEventsLogged 

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 

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 

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

func (*ChannelTraceEvent) GetChannelRef 

func (m *ChannelTraceEvent) GetChannelRef() *ChannelRef

func (*ChannelTraceEvent) GetChildRef 

func (m *ChannelTraceEvent) GetChildRef() isChannelTraceEvent_ChildRef

func (*ChannelTraceEvent) GetDescription 

func (m *ChannelTraceEvent) GetDescription() string

func (*ChannelTraceEvent) GetSeverity 

func (m *ChannelTraceEvent) GetSeverity() ChannelTraceEvent_Severity

func (*ChannelTraceEvent) GetSubchannelRef 

func (m *ChannelTraceEvent) GetSubchannelRef() *SubchannelRef

func (*ChannelTraceEvent) GetTimestamp 

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

func (*ChannelTraceEvent) ProtoMessage 

func (*ChannelTraceEvent) ProtoMessage()

func (*ChannelTraceEvent) Reset 

func (m *ChannelTraceEvent) Reset()

func (*ChannelTraceEvent) String 

func (m *ChannelTraceEvent) String() string

func (*ChannelTraceEvent) XXX_DiscardUnknown 

func (m *ChannelTraceEvent) XXX_DiscardUnknown()

func (*ChannelTraceEvent) XXX_Marshal 

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

func (*ChannelTraceEvent) XXX_Merge 

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

func (*ChannelTraceEvent) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ChannelTraceEvent) XXX_Size 

func (m *ChannelTraceEvent) XXX_Size() int

func (*ChannelTraceEvent) XXX_Unmarshal 

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

type ChannelTraceEvent_ChannelRef 

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

type ChannelTraceEvent_Severity 

type ChannelTraceEvent_Severity int32

The supported severity levels of trace events. 

const (
	ChannelTraceEvent_CT_UNKNOWN ChannelTraceEvent_Severity = 0
	ChannelTraceEvent_CT_INFO    ChannelTraceEvent_Severity = 1
	ChannelTraceEvent_CT_WARNING ChannelTraceEvent_Severity = 2
	ChannelTraceEvent_CT_ERROR   ChannelTraceEvent_Severity = 3
)

func (ChannelTraceEvent_Severity) EnumDescriptor 

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

func (ChannelTraceEvent_Severity) String 

func (x ChannelTraceEvent_Severity) String() string

type ChannelTraceEvent_SubchannelRef 

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

type ChannelzClient 

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

ChannelzClient is the client API for Channelz service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/code.aliyun.com/yjkj.ink/grpc#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 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 

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 

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

func (*GetServerRequest) GetServerId 

func (m *GetServerRequest) GetServerId() int64

func (*GetServerRequest) ProtoMessage 

func (*GetServerRequest) ProtoMessage()

func (*GetServerRequest) Reset 

func (m *GetServerRequest) Reset()

func (*GetServerRequest) String 

func (m *GetServerRequest) String() string

func (*GetServerRequest) XXX_DiscardUnknown 

func (m *GetServerRequest) XXX_DiscardUnknown()

func (*GetServerRequest) XXX_Marshal 

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

func (*GetServerRequest) XXX_Merge 

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

func (*GetServerRequest) XXX_Size 

func (m *GetServerRequest) XXX_Size() int

func (*GetServerRequest) XXX_Unmarshal 

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

type GetServerResponse 

type GetServerResponse struct {
	// The Server that corresponds to the requested server_id.  This field
	// should be set.
	Server               *Server  `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetServerResponse) Descriptor 

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

func (*GetServerResponse) GetServer 

func (m *GetServerResponse) GetServer() *Server

func (*GetServerResponse) ProtoMessage 

func (*GetServerResponse) ProtoMessage()

func (*GetServerResponse) Reset 

func (m *GetServerResponse) Reset()

func (*GetServerResponse) String 

func (m *GetServerResponse) String() string

func (*GetServerResponse) XXX_DiscardUnknown 

func (m *GetServerResponse) XXX_DiscardUnknown()

func (*GetServerResponse) XXX_Marshal 

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

func (*GetServerResponse) XXX_Merge 

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

func (*GetServerResponse) XXX_Size 

func (m *GetServerResponse) XXX_Size() int

func (*GetServerResponse) XXX_Unmarshal 

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 

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 

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 

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 

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 

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 

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 

type UnimplementedChannelzServer struct {
}

UnimplementedChannelzServer can be embedded to have forward compatible implementations.

func (*UnimplementedChannelzServer) GetChannel 

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

func (*UnimplementedChannelzServer) GetServer 

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

func (*UnimplementedChannelzServer) GetServerSockets 

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

func (*UnimplementedChannelzServer) GetServers 

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

func (*UnimplementedChannelzServer) GetSocket 

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

func (*UnimplementedChannelzServer) GetSubchannel 

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

func (*UnimplementedChannelzServer) GetTopChannels 

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

Source Files

  • channelz.pb.go

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.