channelzv1

package
v1.36.11-2026020320145... Latest Latest
Warning

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

 Go to latest Published: unknown License: Apache-2.0 Imports: 8 Imported by: 3

Documentation

Index

Constants

View Source 
const Address_Address_not_set_case case_Address_Address = 0
View Source 
const Address_OtherAddress_case case_Address_Address = 3
View Source 
const Address_TcpipAddress_case case_Address_Address = 1
View Source 
const Address_UdsAddress_case case_Address_Address = 2
View Source 
const ChannelTraceEvent_ChannelRef_case case_ChannelTraceEvent_ChildRef = 4
View Source 
const ChannelTraceEvent_ChildRef_not_set_case case_ChannelTraceEvent_ChildRef = 0
View Source 
const ChannelTraceEvent_SubchannelRef_case case_ChannelTraceEvent_ChildRef = 5
View Source 
const Security_Model_not_set_case case_Security_Model = 0
View Source 
const Security_Other_case case_Security_Model = 2
View Source 
const Security_Tls_CipherSuite_not_set_case case_Security_Tls_CipherSuite = 0
View Source 
const Security_Tls_OtherName_case case_Security_Tls_CipherSuite = 2
View Source 
const Security_Tls_StandardName_case case_Security_Tls_CipherSuite = 1
View Source 
const Security_Tls_case case_Security_Model = 1

Variables

View Source 
var (
	ChannelConnectivityState_State_name = map[int32]string{
		0: "UNKNOWN",
		1: "IDLE",
		2: "CONNECTING",
		3: "READY",
		4: "TRANSIENT_FAILURE",
		5: "SHUTDOWN",
	}
	ChannelConnectivityState_State_value = map[string]int32{
		"UNKNOWN":           0,
		"IDLE":              1,
		"CONNECTING":        2,
		"READY":             3,
		"TRANSIENT_FAILURE": 4,
		"SHUTDOWN":          5,
	}
)

Enum value maps for ChannelConnectivityState_State.

View Source 
var (
	ChannelTraceEvent_Severity_name = map[int32]string{
		0: "CT_UNKNOWN",
		1: "CT_INFO",
		2: "CT_WARNING",
		3: "CT_ERROR",
	}
	ChannelTraceEvent_Severity_value = map[string]int32{
		"CT_UNKNOWN": 0,
		"CT_INFO":    1,
		"CT_WARNING": 2,
		"CT_ERROR":   3,
	}
)

Enum value maps for ChannelTraceEvent_Severity.

View Source 
var File_grpc_channelz_v1_channelz_proto protoreflect.FileDescriptor

Functions

This section is empty.

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"`
	// contains filtered or unexported fields
}

Address represents the address used to create the socket.

func (*Address) ClearAddress 

func (x *Address) ClearAddress()

func (*Address) ClearOtherAddress 

func (x *Address) ClearOtherAddress()

func (*Address) ClearTcpipAddress 

func (x *Address) ClearTcpipAddress()

func (*Address) ClearUdsAddress 

func (x *Address) ClearUdsAddress()

func (*Address) GetAddress 

func (x *Address) GetAddress() isAddress_Address

func (*Address) GetOtherAddress 

func (x *Address) GetOtherAddress() *Address_OtherAddress

func (*Address) GetTcpipAddress 

func (x *Address) GetTcpipAddress() *Address_TcpIpAddress

func (*Address) GetUdsAddress 

func (x *Address) GetUdsAddress() *Address_UdsAddress

func (*Address) HasAddress 

func (x *Address) HasAddress() bool

func (*Address) HasOtherAddress 

func (x *Address) HasOtherAddress() bool

func (*Address) HasTcpipAddress 

func (x *Address) HasTcpipAddress() bool

func (*Address) HasUdsAddress 

func (x *Address) HasUdsAddress() bool

func (*Address) ProtoMessage 

func (*Address) ProtoMessage()

func (*Address) ProtoReflect 

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

func (*Address) Reset 

func (x *Address) Reset()

func (*Address) SetOtherAddress 

func (x *Address) SetOtherAddress(v *Address_OtherAddress)

func (*Address) SetTcpipAddress 

func (x *Address) SetTcpipAddress(v *Address_TcpIpAddress)

func (*Address) SetUdsAddress 

func (x *Address) SetUdsAddress(v *Address_UdsAddress)

func (*Address) String 

func (x *Address) String() string

func (*Address) WhichAddress 

func (x *Address) WhichAddress() case_Address_Address

type Address_OtherAddress 

type Address_OtherAddress struct {

	// The human readable version of the value.  This value should be set.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The actual address message.
	Value *anypb.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

An address type not included above.

func (*Address_OtherAddress) ClearValue 

func (x *Address_OtherAddress) ClearValue()

func (*Address_OtherAddress) GetName 

func (x *Address_OtherAddress) GetName() string

func (*Address_OtherAddress) GetValue 

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

func (*Address_OtherAddress) HasValue 

func (x *Address_OtherAddress) HasValue() bool

func (*Address_OtherAddress) ProtoMessage 

func (*Address_OtherAddress) ProtoMessage()

func (*Address_OtherAddress) ProtoReflect 

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

func (*Address_OtherAddress) Reset 

func (x *Address_OtherAddress) Reset()

func (*Address_OtherAddress) SetName 

func (x *Address_OtherAddress) SetName(v string)

func (*Address_OtherAddress) SetValue 

func (x *Address_OtherAddress) SetValue(v *anypb.Any)

func (*Address_OtherAddress) String 

func (x *Address_OtherAddress) String() string

type Address_OtherAddress_ 

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

type Address_OtherAddress_builder 

type Address_OtherAddress_builder struct {

	// The human readable version of the value.  This value should be set.
	Name string
	// The actual address message.
	Value *anypb.Any
	// contains filtered or unexported fields
}

func (Address_OtherAddress_builder) Build 

func (b0 Address_OtherAddress_builder) Build() *Address_OtherAddress

type Address_TcpIpAddress 

type Address_TcpIpAddress struct {

	// Either the IPv4 or IPv6 address in bytes.  Will be either 4 bytes or 16
	// bytes in length.
	IpAddress []byte `protobuf:"bytes,1,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`
	// 0-64k, or -1 if not appropriate.
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*Address_TcpIpAddress) GetIpAddress 

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

func (*Address_TcpIpAddress) GetPort 

func (x *Address_TcpIpAddress) GetPort() int32

func (*Address_TcpIpAddress) ProtoMessage 

func (*Address_TcpIpAddress) ProtoMessage()

func (*Address_TcpIpAddress) ProtoReflect 

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

func (*Address_TcpIpAddress) Reset 

func (x *Address_TcpIpAddress) Reset()

func (*Address_TcpIpAddress) SetIpAddress 

func (x *Address_TcpIpAddress) SetIpAddress(v []byte)

func (*Address_TcpIpAddress) SetPort 

func (x *Address_TcpIpAddress) SetPort(v int32)

func (*Address_TcpIpAddress) String 

func (x *Address_TcpIpAddress) String() string

type Address_TcpIpAddress_builder 

type Address_TcpIpAddress_builder struct {

	// Either the IPv4 or IPv6 address in bytes.  Will be either 4 bytes or 16
	// bytes in length.
	IpAddress []byte
	// 0-64k, or -1 if not appropriate.
	Port int32
	// contains filtered or unexported fields
}

func (Address_TcpIpAddress_builder) Build 

func (b0 Address_TcpIpAddress_builder) Build() *Address_TcpIpAddress

type Address_TcpipAddress 

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

type Address_UdsAddress 

type Address_UdsAddress struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	// contains filtered or unexported fields
}

A Unix Domain Socket address.

func (*Address_UdsAddress) GetFilename 

func (x *Address_UdsAddress) GetFilename() string

func (*Address_UdsAddress) ProtoMessage 

func (*Address_UdsAddress) ProtoMessage()

func (*Address_UdsAddress) ProtoReflect 

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

func (*Address_UdsAddress) Reset 

func (x *Address_UdsAddress) Reset()

func (*Address_UdsAddress) SetFilename 

func (x *Address_UdsAddress) SetFilename(v string)

func (*Address_UdsAddress) String 

func (x *Address_UdsAddress) String() string

type Address_UdsAddress_ 

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

type Address_UdsAddress_builder 

type Address_UdsAddress_builder struct {
	Filename string
	// contains filtered or unexported fields
}

func (Address_UdsAddress_builder) Build 

func (b0 Address_UdsAddress_builder) Build() *Address_UdsAddress

type Address_builder 

type Address_builder struct {

	// Fields of oneof Address:
	TcpipAddress *Address_TcpIpAddress
	UdsAddress   *Address_UdsAddress
	OtherAddress *Address_OtherAddress
	// contains filtered or unexported fields
}

func (Address_builder) Build 

func (b0 Address_builder) Build() *Address

type Channel 

type Channel struct {

	// The identifier for this channel. This should be set.
	Ref *ChannelRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// Data specific to this channel.
	Data *ChannelData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // At most one of 'channel_ref+subchannel_ref' and 'socket' is set.
	// There are no ordering guarantees on the order of channel refs.
	// There may not be cycles in the ref graph.
	// A channel ref may be present in more than one channel or subchannel.
	ChannelRef []*ChannelRef `protobuf:"bytes,3,rep,name=channel_ref,json=channelRef,proto3" json:"channel_ref,omitempty"`
	// At most one of 'channel_ref+subchannel_ref' and 'socket' is set.
	// There are no ordering guarantees on the order of subchannel refs.
	// There may not be cycles in the ref graph.
	// A sub channel ref may be present in more than one channel or subchannel.
	SubchannelRef []*SubchannelRef `protobuf:"bytes,4,rep,name=subchannel_ref,json=subchannelRef,proto3" json:"subchannel_ref,omitempty"`
	// There are no ordering guarantees on the order of sockets.
	SocketRef []*SocketRef `protobuf:"bytes,5,rep,name=socket_ref,json=socketRef,proto3" json:"socket_ref,omitempty"`
	// contains filtered or unexported fields
}

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

func (*Channel) ClearData 

func (x *Channel) ClearData()

func (*Channel) ClearRef 

func (x *Channel) ClearRef()

func (*Channel) GetChannelRef 

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

func (*Channel) GetData 

func (x *Channel) GetData() *ChannelData

func (*Channel) GetRef 

func (x *Channel) GetRef() *ChannelRef

func (*Channel) GetSocketRef 

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

func (*Channel) GetSubchannelRef 

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

func (*Channel) HasData 

func (x *Channel) HasData() bool

func (*Channel) HasRef 

func (x *Channel) HasRef() bool

func (*Channel) ProtoMessage 

func (*Channel) ProtoMessage()

func (*Channel) ProtoReflect 

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

func (*Channel) Reset 

func (x *Channel) Reset()

func (*Channel) SetChannelRef 

func (x *Channel) SetChannelRef(v []*ChannelRef)

func (*Channel) SetData 

func (x *Channel) SetData(v *ChannelData)

func (*Channel) SetRef 

func (x *Channel) SetRef(v *ChannelRef)

func (*Channel) SetSocketRef 

func (x *Channel) SetSocketRef(v []*SocketRef)

func (*Channel) SetSubchannelRef 

func (x *Channel) SetSubchannelRef(v []*SubchannelRef)

func (*Channel) String 

func (x *Channel) String() string

type ChannelConnectivityState 

type ChannelConnectivityState struct {
	State ChannelConnectivityState_State `protobuf:"varint,1,opt,name=state,proto3,enum=grpc.channelz.v1.ChannelConnectivityState_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

These come from the specified states in this document: https://github.com/grpc/grpc/blob/master/doc/connectivity-semantics-and-api.md

func (*ChannelConnectivityState) GetState 

func (x *ChannelConnectivityState) GetState() ChannelConnectivityState_State

func (*ChannelConnectivityState) ProtoMessage 

func (*ChannelConnectivityState) ProtoMessage()

func (*ChannelConnectivityState) ProtoReflect 

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

func (*ChannelConnectivityState) Reset 

func (x *ChannelConnectivityState) Reset()

func (*ChannelConnectivityState) SetState 

func (x *ChannelConnectivityState) SetState(v ChannelConnectivityState_State)

func (*ChannelConnectivityState) String 

func (x *ChannelConnectivityState) String() string

type ChannelConnectivityState_State 

type ChannelConnectivityState_State int32
const (
	ChannelConnectivityState_UNKNOWN           ChannelConnectivityState_State = 0
	ChannelConnectivityState_IDLE              ChannelConnectivityState_State = 1
	ChannelConnectivityState_CONNECTING        ChannelConnectivityState_State = 2
	ChannelConnectivityState_READY             ChannelConnectivityState_State = 3
	ChannelConnectivityState_TRANSIENT_FAILURE ChannelConnectivityState_State = 4
	ChannelConnectivityState_SHUTDOWN          ChannelConnectivityState_State = 5
)

func (ChannelConnectivityState_State) Descriptor 

func (ChannelConnectivityState_State) Descriptor() protoreflect.EnumDescriptor

func (ChannelConnectivityState_State) Enum 

func (x ChannelConnectivityState_State) Enum() *ChannelConnectivityState_State

func (ChannelConnectivityState_State) Number 

func (x ChannelConnectivityState_State) Number() protoreflect.EnumNumber

func (ChannelConnectivityState_State) String 

func (x ChannelConnectivityState_State) String() string

func (ChannelConnectivityState_State) Type 

func (ChannelConnectivityState_State) Type() protoreflect.EnumType

type ChannelConnectivityState_builder 

type ChannelConnectivityState_builder struct {
	State ChannelConnectivityState_State
	// contains filtered or unexported fields
}

func (ChannelConnectivityState_builder) Build 

func (b0 ChannelConnectivityState_builder) Build() *ChannelConnectivityState

type ChannelData 

type ChannelData struct {

	// The connectivity state of the channel or subchannel.  Implementations
	// should always set this.
	State *ChannelConnectivityState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// The target this channel originally tried to connect to.  May be absent
	Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// A trace of recent events on the channel.  May be absent.
	Trace *ChannelTrace `protobuf:"bytes,3,opt,name=trace,proto3" json:"trace,omitempty"`
	// The number of calls started on the channel
	CallsStarted int64 `protobuf:"varint,4,opt,name=calls_started,json=callsStarted,proto3" json:"calls_started,omitempty"`
	// The number of calls that have completed with an OK status
	CallsSucceeded int64 `protobuf:"varint,5,opt,name=calls_succeeded,json=callsSucceeded,proto3" json:"calls_succeeded,omitempty"`
	// The number of calls that have completed with a non-OK status
	CallsFailed int64 `protobuf:"varint,6,opt,name=calls_failed,json=callsFailed,proto3" json:"calls_failed,omitempty"`
	// The last time a call was started on the channel.
	LastCallStartedTimestamp *timestamppb.Timestamp `` /* 137-byte string literal not displayed */
	// Populated for subchannels only.
	MaxConnectionsPerSubchannel uint32 `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

func (*ChannelData) ClearLastCallStartedTimestamp 

func (x *ChannelData) ClearLastCallStartedTimestamp()

func (*ChannelData) ClearState 

func (x *ChannelData) ClearState()

func (*ChannelData) ClearTrace 

func (x *ChannelData) ClearTrace()

func (*ChannelData) GetCallsFailed 

func (x *ChannelData) GetCallsFailed() int64

func (*ChannelData) GetCallsStarted 

func (x *ChannelData) GetCallsStarted() int64

func (*ChannelData) GetCallsSucceeded 

func (x *ChannelData) GetCallsSucceeded() int64

func (*ChannelData) GetLastCallStartedTimestamp 

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

func (*ChannelData) GetMaxConnectionsPerSubchannel 

func (x *ChannelData) GetMaxConnectionsPerSubchannel() uint32

func (*ChannelData) GetState 

func (x *ChannelData) GetState() *ChannelConnectivityState

func (*ChannelData) GetTarget 

func (x *ChannelData) GetTarget() string

func (*ChannelData) GetTrace 

func (x *ChannelData) GetTrace() *ChannelTrace

func (*ChannelData) HasLastCallStartedTimestamp 

func (x *ChannelData) HasLastCallStartedTimestamp() bool

func (*ChannelData) HasState 

func (x *ChannelData) HasState() bool

func (*ChannelData) HasTrace 

func (x *ChannelData) HasTrace() bool

func (*ChannelData) ProtoMessage 

func (*ChannelData) ProtoMessage()

func (*ChannelData) ProtoReflect 

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

func (*ChannelData) Reset 

func (x *ChannelData) Reset()

func (*ChannelData) SetCallsFailed 

func (x *ChannelData) SetCallsFailed(v int64)

func (*ChannelData) SetCallsStarted 

func (x *ChannelData) SetCallsStarted(v int64)

func (*ChannelData) SetCallsSucceeded 

func (x *ChannelData) SetCallsSucceeded(v int64)

func (*ChannelData) SetLastCallStartedTimestamp 

func (x *ChannelData) SetLastCallStartedTimestamp(v *timestamppb.Timestamp)

func (*ChannelData) SetMaxConnectionsPerSubchannel 

func (x *ChannelData) SetMaxConnectionsPerSubchannel(v uint32)

func (*ChannelData) SetState 

func (x *ChannelData) SetState(v *ChannelConnectivityState)

func (*ChannelData) SetTarget 

func (x *ChannelData) SetTarget(v string)

func (*ChannelData) SetTrace 

func (x *ChannelData) SetTrace(v *ChannelTrace)

func (*ChannelData) String 

func (x *ChannelData) String() string

type ChannelData_builder 

type ChannelData_builder struct {

	// The connectivity state of the channel or subchannel.  Implementations
	// should always set this.
	State *ChannelConnectivityState
	// The target this channel originally tried to connect to.  May be absent
	Target string
	// A trace of recent events on the channel.  May be absent.
	Trace *ChannelTrace
	// The number of calls started on the channel
	CallsStarted int64
	// The number of calls that have completed with an OK status
	CallsSucceeded int64
	// The number of calls that have completed with a non-OK status
	CallsFailed int64
	// The last time a call was started on the channel.
	LastCallStartedTimestamp *timestamppb.Timestamp
	// Populated for subchannels only.
	MaxConnectionsPerSubchannel uint32
	// contains filtered or unexported fields
}

func (ChannelData_builder) Build 

func (b0 ChannelData_builder) Build() *ChannelData

type ChannelRef 

type ChannelRef struct {

	// The globally unique id for this channel.  Must be a positive number.
	ChannelId int64 `protobuf:"varint,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	// An optional name associated with the channel.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

ChannelRef is a reference to a Channel.

func (*ChannelRef) GetChannelId 

func (x *ChannelRef) GetChannelId() int64

func (*ChannelRef) GetName 

func (x *ChannelRef) GetName() string

func (*ChannelRef) ProtoMessage 

func (*ChannelRef) ProtoMessage()

func (*ChannelRef) ProtoReflect 

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

func (*ChannelRef) Reset 

func (x *ChannelRef) Reset()

func (*ChannelRef) SetChannelId 

func (x *ChannelRef) SetChannelId(v int64)

func (*ChannelRef) SetName 

func (x *ChannelRef) SetName(v string)

func (*ChannelRef) String 

func (x *ChannelRef) String() string

type ChannelRef_builder 

type ChannelRef_builder struct {

	// The globally unique id for this channel.  Must be a positive number.
	ChannelId int64
	// An optional name associated with the channel.
	Name string
	// contains filtered or unexported fields
}

func (ChannelRef_builder) Build 

func (b0 ChannelRef_builder) Build() *ChannelRef

type ChannelTrace 

type ChannelTrace struct {

	// Number of events ever logged in this tracing object. This can differ from
	// events.size() because events can be overwritten or garbage collected by
	// implementations.
	NumEventsLogged int64 `protobuf:"varint,1,opt,name=num_events_logged,json=numEventsLogged,proto3" json:"num_events_logged,omitempty"`
	// Time that this channel was created.
	CreationTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=creation_timestamp,json=creationTimestamp,proto3" json:"creation_timestamp,omitempty"`
	// List of events that have occurred on this channel.
	Events []*ChannelTraceEvent `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

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

func (*ChannelTrace) ClearCreationTimestamp 

func (x *ChannelTrace) ClearCreationTimestamp()

func (*ChannelTrace) GetCreationTimestamp 

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

func (*ChannelTrace) GetEvents 

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

func (*ChannelTrace) GetNumEventsLogged 

func (x *ChannelTrace) GetNumEventsLogged() int64

func (*ChannelTrace) HasCreationTimestamp 

func (x *ChannelTrace) HasCreationTimestamp() bool

func (*ChannelTrace) ProtoMessage 

func (*ChannelTrace) ProtoMessage()

func (*ChannelTrace) ProtoReflect 

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

func (*ChannelTrace) Reset 

func (x *ChannelTrace) Reset()

func (*ChannelTrace) SetCreationTimestamp 

func (x *ChannelTrace) SetCreationTimestamp(v *timestamppb.Timestamp)

func (*ChannelTrace) SetEvents 

func (x *ChannelTrace) SetEvents(v []*ChannelTraceEvent)

func (*ChannelTrace) SetNumEventsLogged 

func (x *ChannelTrace) SetNumEventsLogged(v int64)

func (*ChannelTrace) String 

func (x *ChannelTrace) String() string

type ChannelTraceEvent 

type ChannelTraceEvent struct {

	// High level description of the event.
	Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	// the severity of the trace event
	Severity ChannelTraceEvent_Severity `protobuf:"varint,2,opt,name=severity,proto3,enum=grpc.channelz.v1.ChannelTraceEvent_Severity" json:"severity,omitempty"`
	// When this event occurred.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// ref of referenced channel or subchannel.
	// Optional, only present if this event refers to a child object. For example,
	// this field would be filled if this trace event was for a subchannel being
	// created.
	//
	// Types that are valid to be assigned to ChildRef:
	//
	//	*ChannelTraceEvent_ChannelRef
	//	*ChannelTraceEvent_SubchannelRef
	ChildRef isChannelTraceEvent_ChildRef `protobuf_oneof:"child_ref"`
	// contains filtered or unexported fields
}

A trace event is an interesting thing that happened to a channel or subchannel, such as creation, address resolution, subchannel creation, etc.

func (*ChannelTraceEvent) ClearChannelRef 

func (x *ChannelTraceEvent) ClearChannelRef()

func (*ChannelTraceEvent) ClearChildRef 

func (x *ChannelTraceEvent) ClearChildRef()

func (*ChannelTraceEvent) ClearSubchannelRef 

func (x *ChannelTraceEvent) ClearSubchannelRef()

func (*ChannelTraceEvent) ClearTimestamp 

func (x *ChannelTraceEvent) ClearTimestamp()

func (*ChannelTraceEvent) GetChannelRef 

func (x *ChannelTraceEvent) GetChannelRef() *ChannelRef

func (*ChannelTraceEvent) GetChildRef 

func (x *ChannelTraceEvent) GetChildRef() isChannelTraceEvent_ChildRef

func (*ChannelTraceEvent) GetDescription 

func (x *ChannelTraceEvent) GetDescription() string

func (*ChannelTraceEvent) GetSeverity 

func (x *ChannelTraceEvent) GetSeverity() ChannelTraceEvent_Severity

func (*ChannelTraceEvent) GetSubchannelRef 

func (x *ChannelTraceEvent) GetSubchannelRef() *SubchannelRef

func (*ChannelTraceEvent) GetTimestamp 

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

func (*ChannelTraceEvent) HasChannelRef 

func (x *ChannelTraceEvent) HasChannelRef() bool

func (*ChannelTraceEvent) HasChildRef 

func (x *ChannelTraceEvent) HasChildRef() bool

func (*ChannelTraceEvent) HasSubchannelRef 

func (x *ChannelTraceEvent) HasSubchannelRef() bool

func (*ChannelTraceEvent) HasTimestamp 

func (x *ChannelTraceEvent) HasTimestamp() bool

func (*ChannelTraceEvent) ProtoMessage 

func (*ChannelTraceEvent) ProtoMessage()

func (*ChannelTraceEvent) ProtoReflect 

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

func (*ChannelTraceEvent) Reset 

func (x *ChannelTraceEvent) Reset()

func (*ChannelTraceEvent) SetChannelRef 

func (x *ChannelTraceEvent) SetChannelRef(v *ChannelRef)

func (*ChannelTraceEvent) SetDescription 

func (x *ChannelTraceEvent) SetDescription(v string)

func (*ChannelTraceEvent) SetSeverity 

func (x *ChannelTraceEvent) SetSeverity(v ChannelTraceEvent_Severity)

func (*ChannelTraceEvent) SetSubchannelRef 

func (x *ChannelTraceEvent) SetSubchannelRef(v *SubchannelRef)

func (*ChannelTraceEvent) SetTimestamp 

func (x *ChannelTraceEvent) SetTimestamp(v *timestamppb.Timestamp)

func (*ChannelTraceEvent) String 

func (x *ChannelTraceEvent) String() string

func (*ChannelTraceEvent) WhichChildRef 

func (x *ChannelTraceEvent) WhichChildRef() case_ChannelTraceEvent_ChildRef

type ChannelTraceEvent_ChannelRef 

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

type ChannelTraceEvent_Severity 

type ChannelTraceEvent_Severity int32

The supported severity levels of trace events. 

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

func (ChannelTraceEvent_Severity) Descriptor 

func (ChannelTraceEvent_Severity) Descriptor() protoreflect.EnumDescriptor

func (ChannelTraceEvent_Severity) Enum 

func (x ChannelTraceEvent_Severity) Enum() *ChannelTraceEvent_Severity

func (ChannelTraceEvent_Severity) Number 

func (x ChannelTraceEvent_Severity) Number() protoreflect.EnumNumber

func (ChannelTraceEvent_Severity) String 

func (x ChannelTraceEvent_Severity) String() string

func (ChannelTraceEvent_Severity) Type 

func (ChannelTraceEvent_Severity) Type() protoreflect.EnumType

type ChannelTraceEvent_SubchannelRef 

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

type ChannelTraceEvent_builder 

type ChannelTraceEvent_builder struct {

	// High level description of the event.
	Description string
	// the severity of the trace event
	Severity ChannelTraceEvent_Severity
	// When this event occurred.
	Timestamp *timestamppb.Timestamp

	// Fields of oneof ChildRef:
	ChannelRef    *ChannelRef
	SubchannelRef *SubchannelRef
	// contains filtered or unexported fields
}

func (ChannelTraceEvent_builder) Build 

func (b0 ChannelTraceEvent_builder) Build() *ChannelTraceEvent

type ChannelTrace_builder 

type ChannelTrace_builder 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
	// Time that this channel was created.
	CreationTimestamp *timestamppb.Timestamp
	// List of events that have occurred on this channel.
	Events []*ChannelTraceEvent
	// contains filtered or unexported fields
}

func (ChannelTrace_builder) Build 

func (b0 ChannelTrace_builder) Build() *ChannelTrace

type Channel_builder 

type Channel_builder struct {

	// The identifier for this channel. This should be set.
	Ref *ChannelRef
	// Data specific to this channel.
	Data *ChannelData
	// 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
	// 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
	// There are no ordering guarantees on the order of sockets.
	SocketRef []*SocketRef
	// contains filtered or unexported fields
}

func (Channel_builder) Build 

func (b0 Channel_builder) Build() *Channel

type GetChannelRequest 

type GetChannelRequest struct {

	// channel_id is the identifier of the specific channel to get.
	ChannelId int64 `protobuf:"varint,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetChannelRequest) GetChannelId 

func (x *GetChannelRequest) GetChannelId() int64

func (*GetChannelRequest) ProtoMessage 

func (*GetChannelRequest) ProtoMessage()

func (*GetChannelRequest) ProtoReflect 

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

func (*GetChannelRequest) Reset 

func (x *GetChannelRequest) Reset()

func (*GetChannelRequest) SetChannelId 

func (x *GetChannelRequest) SetChannelId(v int64)

func (*GetChannelRequest) String 

func (x *GetChannelRequest) String() string

type GetChannelRequest_builder 

type GetChannelRequest_builder struct {

	// channel_id is the identifier of the specific channel to get.
	ChannelId int64
	// contains filtered or unexported fields
}

func (GetChannelRequest_builder) Build 

func (b0 GetChannelRequest_builder) Build() *GetChannelRequest

type GetChannelResponse 

type GetChannelResponse struct {

	// The Channel that corresponds to the requested channel_id.  This field
	// should be set.
	Channel *Channel `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

func (*GetChannelResponse) ClearChannel 

func (x *GetChannelResponse) ClearChannel()

func (*GetChannelResponse) GetChannel 

func (x *GetChannelResponse) GetChannel() *Channel

func (*GetChannelResponse) HasChannel 

func (x *GetChannelResponse) HasChannel() bool

func (*GetChannelResponse) ProtoMessage 

func (*GetChannelResponse) ProtoMessage()

func (*GetChannelResponse) ProtoReflect 

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

func (*GetChannelResponse) Reset 

func (x *GetChannelResponse) Reset()

func (*GetChannelResponse) SetChannel 

func (x *GetChannelResponse) SetChannel(v *Channel)

func (*GetChannelResponse) String 

func (x *GetChannelResponse) String() string

type GetChannelResponse_builder 

type GetChannelResponse_builder struct {

	// The Channel that corresponds to the requested channel_id.  This field
	// should be set.
	Channel *Channel
	// contains filtered or unexported fields
}

func (GetChannelResponse_builder) Build 

func (b0 GetChannelResponse_builder) Build() *GetChannelResponse

type GetServerRequest 

type GetServerRequest struct {

	// server_id is the identifier of the specific server to get.
	ServerId int64 `protobuf:"varint,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServerRequest) GetServerId 

func (x *GetServerRequest) GetServerId() int64

func (*GetServerRequest) ProtoMessage 

func (*GetServerRequest) ProtoMessage()

func (*GetServerRequest) ProtoReflect 

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

func (*GetServerRequest) Reset 

func (x *GetServerRequest) Reset()

func (*GetServerRequest) SetServerId 

func (x *GetServerRequest) SetServerId(v int64)

func (*GetServerRequest) String 

func (x *GetServerRequest) String() string

type GetServerRequest_builder 

type GetServerRequest_builder struct {

	// server_id is the identifier of the specific server to get.
	ServerId int64
	// contains filtered or unexported fields
}

func (GetServerRequest_builder) Build 

func (b0 GetServerRequest_builder) Build() *GetServerRequest

type GetServerResponse 

type GetServerResponse struct {

	// The Server that corresponds to the requested server_id.  This field
	// should be set.
	Server *Server `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServerResponse) ClearServer 

func (x *GetServerResponse) ClearServer()

func (*GetServerResponse) GetServer 

func (x *GetServerResponse) GetServer() *Server

func (*GetServerResponse) HasServer 

func (x *GetServerResponse) HasServer() bool

func (*GetServerResponse) ProtoMessage 

func (*GetServerResponse) ProtoMessage()

func (*GetServerResponse) ProtoReflect 

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

func (*GetServerResponse) Reset 

func (x *GetServerResponse) Reset()

func (*GetServerResponse) SetServer 

func (x *GetServerResponse) SetServer(v *Server)

func (*GetServerResponse) String 

func (x *GetServerResponse) String() string

type GetServerResponse_builder 

type GetServerResponse_builder struct {

	// The Server that corresponds to the requested server_id.  This field
	// should be set.
	Server *Server
	// contains filtered or unexported fields
}

func (GetServerResponse_builder) Build 

func (b0 GetServerResponse_builder) Build() *GetServerResponse

type GetServerSocketsRequest 

type GetServerSocketsRequest struct {
	ServerId int64 `protobuf:"varint,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	// start_socket_id indicates that only sockets at or above this id should be
	// included in the results.
	// To request the first page, this must be set to 0. To request
	// subsequent pages, the client generates this value by adding 1 to
	// the highest seen result ID.
	StartSocketId int64 `protobuf:"varint,2,opt,name=start_socket_id,json=startSocketId,proto3" json:"start_socket_id,omitempty"`
	// If non-zero, the server will return a page of results containing
	// at most this many items. If zero, the server will choose a
	// reasonable page size.  Must never be negative.
	MaxResults int64 `protobuf:"varint,3,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServerSocketsRequest) GetMaxResults 

func (x *GetServerSocketsRequest) GetMaxResults() int64

func (*GetServerSocketsRequest) GetServerId 

func (x *GetServerSocketsRequest) GetServerId() int64

func (*GetServerSocketsRequest) GetStartSocketId 

func (x *GetServerSocketsRequest) GetStartSocketId() int64

func (*GetServerSocketsRequest) ProtoMessage 

func (*GetServerSocketsRequest) ProtoMessage()

func (*GetServerSocketsRequest) ProtoReflect 

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

func (*GetServerSocketsRequest) Reset 

func (x *GetServerSocketsRequest) Reset()

func (*GetServerSocketsRequest) SetMaxResults 

func (x *GetServerSocketsRequest) SetMaxResults(v int64)

func (*GetServerSocketsRequest) SetServerId 

func (x *GetServerSocketsRequest) SetServerId(v int64)

func (*GetServerSocketsRequest) SetStartSocketId 

func (x *GetServerSocketsRequest) SetStartSocketId(v int64)

func (*GetServerSocketsRequest) String 

func (x *GetServerSocketsRequest) String() string

type GetServerSocketsRequest_builder 

type GetServerSocketsRequest_builder struct {
	ServerId int64
	// 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
	// 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
	// contains filtered or unexported fields
}

func (GetServerSocketsRequest_builder) Build 

func (b0 GetServerSocketsRequest_builder) Build() *GetServerSocketsRequest

type GetServerSocketsResponse 

type GetServerSocketsResponse struct {

	// list of socket refs that the connection detail service knows about.  Sorted in
	// ascending socket_id order.
	// Must contain at least 1 result, otherwise 'end' must be true.
	SocketRef []*SocketRef `protobuf:"bytes,1,rep,name=socket_ref,json=socketRef,proto3" json:"socket_ref,omitempty"`
	// If set, indicates that the list of sockets is the final list.  Requesting
	// more sockets will only return more if they are created after this RPC
	// completes.
	End bool `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServerSocketsResponse) GetEnd 

func (x *GetServerSocketsResponse) GetEnd() bool

func (*GetServerSocketsResponse) GetSocketRef 

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

func (*GetServerSocketsResponse) ProtoMessage 

func (*GetServerSocketsResponse) ProtoMessage()

func (*GetServerSocketsResponse) ProtoReflect 

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

func (*GetServerSocketsResponse) Reset 

func (x *GetServerSocketsResponse) Reset()

func (*GetServerSocketsResponse) SetEnd 

func (x *GetServerSocketsResponse) SetEnd(v bool)

func (*GetServerSocketsResponse) SetSocketRef 

func (x *GetServerSocketsResponse) SetSocketRef(v []*SocketRef)

func (*GetServerSocketsResponse) String 

func (x *GetServerSocketsResponse) String() string

type GetServerSocketsResponse_builder 

type GetServerSocketsResponse_builder 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
	// 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
	// contains filtered or unexported fields
}

func (GetServerSocketsResponse_builder) Build 

func (b0 GetServerSocketsResponse_builder) Build() *GetServerSocketsResponse

type GetServersRequest 

type GetServersRequest struct {

	// start_server_id indicates that only servers at or above this id should be
	// included in the results.
	// To request the first page, this must be set to 0. To request
	// subsequent pages, the client generates this value by adding 1 to
	// the highest seen result ID.
	StartServerId int64 `protobuf:"varint,1,opt,name=start_server_id,json=startServerId,proto3" json:"start_server_id,omitempty"`
	// If non-zero, the server will return a page of results containing
	// at most this many items. If zero, the server will choose a
	// reasonable page size.  Must never be negative.
	MaxResults int64 `protobuf:"varint,2,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServersRequest) GetMaxResults 

func (x *GetServersRequest) GetMaxResults() int64

func (*GetServersRequest) GetStartServerId 

func (x *GetServersRequest) GetStartServerId() int64

func (*GetServersRequest) ProtoMessage 

func (*GetServersRequest) ProtoMessage()

func (*GetServersRequest) ProtoReflect 

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

func (*GetServersRequest) Reset 

func (x *GetServersRequest) Reset()

func (*GetServersRequest) SetMaxResults 

func (x *GetServersRequest) SetMaxResults(v int64)

func (*GetServersRequest) SetStartServerId 

func (x *GetServersRequest) SetStartServerId(v int64)

func (*GetServersRequest) String 

func (x *GetServersRequest) String() string

type GetServersRequest_builder 

type GetServersRequest_builder 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
	// 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
	// contains filtered or unexported fields
}

func (GetServersRequest_builder) Build 

func (b0 GetServersRequest_builder) Build() *GetServersRequest

type GetServersResponse 

type GetServersResponse struct {

	// list of servers that the connection detail service knows about.  Sorted in
	// ascending server_id order.
	// Must contain at least 1 result, otherwise 'end' must be true.
	Server []*Server `protobuf:"bytes,1,rep,name=server,proto3" json:"server,omitempty"`
	// If set, indicates that the list of servers is the final list.  Requesting
	// more servers will only return more if they are created after this RPC
	// completes.
	End bool `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServersResponse) GetEnd 

func (x *GetServersResponse) GetEnd() bool

func (*GetServersResponse) GetServer 

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

func (*GetServersResponse) ProtoMessage 

func (*GetServersResponse) ProtoMessage()

func (*GetServersResponse) ProtoReflect 

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

func (*GetServersResponse) Reset 

func (x *GetServersResponse) Reset()

func (*GetServersResponse) SetEnd 

func (x *GetServersResponse) SetEnd(v bool)

func (*GetServersResponse) SetServer 

func (x *GetServersResponse) SetServer(v []*Server)

func (*GetServersResponse) String 

func (x *GetServersResponse) String() string

type GetServersResponse_builder 

type GetServersResponse_builder 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
	// 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
	// contains filtered or unexported fields
}

func (GetServersResponse_builder) Build 

func (b0 GetServersResponse_builder) Build() *GetServersResponse

type GetSocketRequest 

type GetSocketRequest struct {

	// socket_id is the identifier of the specific socket to get.
	SocketId int64 `protobuf:"varint,1,opt,name=socket_id,json=socketId,proto3" json:"socket_id,omitempty"`
	// If true, the response will contain only high level information
	// that is inexpensive to obtain. Fields that may be omitted are
	// documented.
	Summary bool `protobuf:"varint,2,opt,name=summary,proto3" json:"summary,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSocketRequest) GetSocketId 

func (x *GetSocketRequest) GetSocketId() int64

func (*GetSocketRequest) GetSummary 

func (x *GetSocketRequest) GetSummary() bool

func (*GetSocketRequest) ProtoMessage 

func (*GetSocketRequest) ProtoMessage()

func (*GetSocketRequest) ProtoReflect 

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

func (*GetSocketRequest) Reset 

func (x *GetSocketRequest) Reset()

func (*GetSocketRequest) SetSocketId 

func (x *GetSocketRequest) SetSocketId(v int64)

func (*GetSocketRequest) SetSummary 

func (x *GetSocketRequest) SetSummary(v bool)

func (*GetSocketRequest) String 

func (x *GetSocketRequest) String() string

type GetSocketRequest_builder 

type GetSocketRequest_builder struct {

	// socket_id is the identifier of the specific socket to get.
	SocketId int64
	// If true, the response will contain only high level information
	// that is inexpensive to obtain. Fields that may be omitted are
	// documented.
	Summary bool
	// contains filtered or unexported fields
}

func (GetSocketRequest_builder) Build 

func (b0 GetSocketRequest_builder) Build() *GetSocketRequest

type GetSocketResponse 

type GetSocketResponse struct {

	// The Socket that corresponds to the requested socket_id.  This field
	// should be set.
	Socket *Socket `protobuf:"bytes,1,opt,name=socket,proto3" json:"socket,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSocketResponse) ClearSocket 

func (x *GetSocketResponse) ClearSocket()

func (*GetSocketResponse) GetSocket 

func (x *GetSocketResponse) GetSocket() *Socket

func (*GetSocketResponse) HasSocket 

func (x *GetSocketResponse) HasSocket() bool

func (*GetSocketResponse) ProtoMessage 

func (*GetSocketResponse) ProtoMessage()

func (*GetSocketResponse) ProtoReflect 

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

func (*GetSocketResponse) Reset 

func (x *GetSocketResponse) Reset()

func (*GetSocketResponse) SetSocket 

func (x *GetSocketResponse) SetSocket(v *Socket)

func (*GetSocketResponse) String 

func (x *GetSocketResponse) String() string

type GetSocketResponse_builder 

type GetSocketResponse_builder struct {

	// The Socket that corresponds to the requested socket_id.  This field
	// should be set.
	Socket *Socket
	// contains filtered or unexported fields
}

func (GetSocketResponse_builder) Build 

func (b0 GetSocketResponse_builder) Build() *GetSocketResponse

type GetSubchannelRequest 

type GetSubchannelRequest struct {

	// subchannel_id is the identifier of the specific subchannel to get.
	SubchannelId int64 `protobuf:"varint,1,opt,name=subchannel_id,json=subchannelId,proto3" json:"subchannel_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSubchannelRequest) GetSubchannelId 

func (x *GetSubchannelRequest) GetSubchannelId() int64

func (*GetSubchannelRequest) ProtoMessage 

func (*GetSubchannelRequest) ProtoMessage()

func (*GetSubchannelRequest) ProtoReflect 

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

func (*GetSubchannelRequest) Reset 

func (x *GetSubchannelRequest) Reset()

func (*GetSubchannelRequest) SetSubchannelId 

func (x *GetSubchannelRequest) SetSubchannelId(v int64)

func (*GetSubchannelRequest) String 

func (x *GetSubchannelRequest) String() string

type GetSubchannelRequest_builder 

type GetSubchannelRequest_builder struct {

	// subchannel_id is the identifier of the specific subchannel to get.
	SubchannelId int64
	// contains filtered or unexported fields
}

func (GetSubchannelRequest_builder) Build 

func (b0 GetSubchannelRequest_builder) Build() *GetSubchannelRequest

type GetSubchannelResponse 

type GetSubchannelResponse struct {

	// The Subchannel that corresponds to the requested subchannel_id.  This
	// field should be set.
	Subchannel *Subchannel `protobuf:"bytes,1,opt,name=subchannel,proto3" json:"subchannel,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSubchannelResponse) ClearSubchannel 

func (x *GetSubchannelResponse) ClearSubchannel()

func (*GetSubchannelResponse) GetSubchannel 

func (x *GetSubchannelResponse) GetSubchannel() *Subchannel

func (*GetSubchannelResponse) HasSubchannel 

func (x *GetSubchannelResponse) HasSubchannel() bool

func (*GetSubchannelResponse) ProtoMessage 

func (*GetSubchannelResponse) ProtoMessage()

func (*GetSubchannelResponse) ProtoReflect 

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

func (*GetSubchannelResponse) Reset 

func (x *GetSubchannelResponse) Reset()

func (*GetSubchannelResponse) SetSubchannel 

func (x *GetSubchannelResponse) SetSubchannel(v *Subchannel)

func (*GetSubchannelResponse) String 

func (x *GetSubchannelResponse) String() string

type GetSubchannelResponse_builder 

type GetSubchannelResponse_builder struct {

	// The Subchannel that corresponds to the requested subchannel_id.  This
	// field should be set.
	Subchannel *Subchannel
	// contains filtered or unexported fields
}

func (GetSubchannelResponse_builder) Build 

func (b0 GetSubchannelResponse_builder) Build() *GetSubchannelResponse

type GetTopChannelsRequest 

type GetTopChannelsRequest struct {

	// start_channel_id indicates that only channels at or above this id should be
	// included in the results.
	// To request the first page, this should be set to 0. To request
	// subsequent pages, the client generates this value by adding 1 to
	// the highest seen result ID.
	StartChannelId int64 `protobuf:"varint,1,opt,name=start_channel_id,json=startChannelId,proto3" json:"start_channel_id,omitempty"`
	// If non-zero, the server will return a page of results containing
	// at most this many items. If zero, the server will choose a
	// reasonable page size.  Must never be negative.
	MaxResults int64 `protobuf:"varint,2,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTopChannelsRequest) GetMaxResults 

func (x *GetTopChannelsRequest) GetMaxResults() int64

func (*GetTopChannelsRequest) GetStartChannelId 

func (x *GetTopChannelsRequest) GetStartChannelId() int64

func (*GetTopChannelsRequest) ProtoMessage 

func (*GetTopChannelsRequest) ProtoMessage()

func (*GetTopChannelsRequest) ProtoReflect 

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

func (*GetTopChannelsRequest) Reset 

func (x *GetTopChannelsRequest) Reset()

func (*GetTopChannelsRequest) SetMaxResults 

func (x *GetTopChannelsRequest) SetMaxResults(v int64)

func (*GetTopChannelsRequest) SetStartChannelId 

func (x *GetTopChannelsRequest) SetStartChannelId(v int64)

func (*GetTopChannelsRequest) String 

func (x *GetTopChannelsRequest) String() string

type GetTopChannelsRequest_builder 

type GetTopChannelsRequest_builder 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
	// 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
	// contains filtered or unexported fields
}

func (GetTopChannelsRequest_builder) Build 

func (b0 GetTopChannelsRequest_builder) Build() *GetTopChannelsRequest

type GetTopChannelsResponse 

type GetTopChannelsResponse struct {

	// list of channels that the connection detail service knows about.  Sorted in
	// ascending channel_id order.
	// Must contain at least 1 result, otherwise 'end' must be true.
	Channel []*Channel `protobuf:"bytes,1,rep,name=channel,proto3" json:"channel,omitempty"`
	// If set, indicates that the list of channels is the final list.  Requesting
	// more channels can only return more if they are created after this RPC
	// completes.
	End bool `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTopChannelsResponse) GetChannel 

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

func (*GetTopChannelsResponse) GetEnd 

func (x *GetTopChannelsResponse) GetEnd() bool

func (*GetTopChannelsResponse) ProtoMessage 

func (*GetTopChannelsResponse) ProtoMessage()

func (*GetTopChannelsResponse) ProtoReflect 

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

func (*GetTopChannelsResponse) Reset 

func (x *GetTopChannelsResponse) Reset()

func (*GetTopChannelsResponse) SetChannel 

func (x *GetTopChannelsResponse) SetChannel(v []*Channel)

func (*GetTopChannelsResponse) SetEnd 

func (x *GetTopChannelsResponse) SetEnd(v bool)

func (*GetTopChannelsResponse) String 

func (x *GetTopChannelsResponse) String() string

type GetTopChannelsResponse_builder 

type GetTopChannelsResponse_builder 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
	// 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
	// contains filtered or unexported fields
}

func (GetTopChannelsResponse_builder) Build 

func (b0 GetTopChannelsResponse_builder) Build() *GetTopChannelsResponse

type Security 

type Security struct {

	// Types that are valid to be assigned to Model:
	//
	//	*Security_Tls_
	//	*Security_Other
	Model isSecurity_Model `protobuf_oneof:"model"`
	// contains filtered or unexported fields
}

Security represents details about how secure the socket is.

func (*Security) ClearModel 

func (x *Security) ClearModel()

func (*Security) ClearOther 

func (x *Security) ClearOther()

func (*Security) ClearTls 

func (x *Security) ClearTls()

func (*Security) GetModel 

func (x *Security) GetModel() isSecurity_Model

func (*Security) GetOther 

func (x *Security) GetOther() *Security_OtherSecurity

func (*Security) GetTls 

func (x *Security) GetTls() *Security_Tls

func (*Security) HasModel 

func (x *Security) HasModel() bool

func (*Security) HasOther 

func (x *Security) HasOther() bool

func (*Security) HasTls 

func (x *Security) HasTls() bool

func (*Security) ProtoMessage 

func (*Security) ProtoMessage()

func (*Security) ProtoReflect 

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

func (*Security) Reset 

func (x *Security) Reset()

func (*Security) SetOther 

func (x *Security) SetOther(v *Security_OtherSecurity)

func (*Security) SetTls 

func (x *Security) SetTls(v *Security_Tls)

func (*Security) String 

func (x *Security) String() string

func (*Security) WhichModel 

func (x *Security) WhichModel() case_Security_Model

type Security_Other 

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

type Security_OtherSecurity 

type Security_OtherSecurity struct {

	// The human readable version of the value.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The actual security details message.
	Value *anypb.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Security_OtherSecurity) ClearValue 

func (x *Security_OtherSecurity) ClearValue()

func (*Security_OtherSecurity) GetName 

func (x *Security_OtherSecurity) GetName() string

func (*Security_OtherSecurity) GetValue 

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

func (*Security_OtherSecurity) HasValue 

func (x *Security_OtherSecurity) HasValue() bool

func (*Security_OtherSecurity) ProtoMessage 

func (*Security_OtherSecurity) ProtoMessage()

func (*Security_OtherSecurity) ProtoReflect 

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

func (*Security_OtherSecurity) Reset 

func (x *Security_OtherSecurity) Reset()

func (*Security_OtherSecurity) SetName 

func (x *Security_OtherSecurity) SetName(v string)

func (*Security_OtherSecurity) SetValue 

func (x *Security_OtherSecurity) SetValue(v *anypb.Any)

func (*Security_OtherSecurity) String 

func (x *Security_OtherSecurity) String() string

type Security_OtherSecurity_builder 

type Security_OtherSecurity_builder struct {

	// The human readable version of the value.
	Name string
	// The actual security details message.
	Value *anypb.Any
	// contains filtered or unexported fields
}

func (Security_OtherSecurity_builder) Build 

func (b0 Security_OtherSecurity_builder) Build() *Security_OtherSecurity

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"`
	// contains filtered or unexported fields
}

func (*Security_Tls) ClearCipherSuite 

func (x *Security_Tls) ClearCipherSuite()

func (*Security_Tls) ClearOtherName 

func (x *Security_Tls) ClearOtherName()

func (*Security_Tls) ClearStandardName 

func (x *Security_Tls) ClearStandardName()

func (*Security_Tls) GetCipherSuite 

func (x *Security_Tls) GetCipherSuite() isSecurity_Tls_CipherSuite

func (*Security_Tls) GetLocalCertificate 

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

func (*Security_Tls) GetOtherName 

func (x *Security_Tls) GetOtherName() string

func (*Security_Tls) GetRemoteCertificate 

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

func (*Security_Tls) GetStandardName 

func (x *Security_Tls) GetStandardName() string

func (*Security_Tls) HasCipherSuite 

func (x *Security_Tls) HasCipherSuite() bool

func (*Security_Tls) HasOtherName 

func (x *Security_Tls) HasOtherName() bool

func (*Security_Tls) HasStandardName 

func (x *Security_Tls) HasStandardName() bool

func (*Security_Tls) ProtoMessage 

func (*Security_Tls) ProtoMessage()

func (*Security_Tls) ProtoReflect 

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

func (*Security_Tls) Reset 

func (x *Security_Tls) Reset()

func (*Security_Tls) SetLocalCertificate 

func (x *Security_Tls) SetLocalCertificate(v []byte)

func (*Security_Tls) SetOtherName 

func (x *Security_Tls) SetOtherName(v string)

func (*Security_Tls) SetRemoteCertificate 

func (x *Security_Tls) SetRemoteCertificate(v []byte)

func (*Security_Tls) SetStandardName 

func (x *Security_Tls) SetStandardName(v string)

func (*Security_Tls) String 

func (x *Security_Tls) String() string

func (*Security_Tls) WhichCipherSuite 

func (x *Security_Tls) WhichCipherSuite() case_Security_Tls_CipherSuite

type Security_Tls_ 

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

type Security_Tls_OtherName 

type Security_Tls_OtherName struct {
	// Some other way to describe the cipher suite if
	// the RFC 4346 name is not available.
	OtherName string `protobuf:"bytes,2,opt,name=other_name,json=otherName,proto3,oneof"`
}

type Security_Tls_StandardName 

type Security_Tls_StandardName struct {
	// The cipher suite name in the RFC 4346 format:
	// https://tools.ietf.org/html/rfc4346#appendix-C
	StandardName string `protobuf:"bytes,1,opt,name=standard_name,json=standardName,proto3,oneof"`
}

type Security_Tls_builder 

type Security_Tls_builder struct {

	// Fields of oneof CipherSuite:
	// The cipher suite name in the RFC 4346 format:
	// https://tools.ietf.org/html/rfc4346#appendix-C
	StandardName *string
	// Some other way to describe the cipher suite if
	// the RFC 4346 name is not available.
	OtherName *string
	// -- end of CipherSuite
	// the certificate used by this endpoint.
	LocalCertificate []byte
	// the certificate used by the remote endpoint.
	RemoteCertificate []byte
	// contains filtered or unexported fields
}

func (Security_Tls_builder) Build 

func (b0 Security_Tls_builder) Build() *Security_Tls

type Security_builder 

type Security_builder struct {

	// Fields of oneof Model:
	Tls   *Security_Tls
	Other *Security_OtherSecurity
	// contains filtered or unexported fields
}

func (Security_builder) Build 

func (b0 Security_builder) Build() *Security

type Server 

type Server struct {

	// The identifier for a Server.  This should be set.
	Ref *ServerRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// The associated data of the Server.
	Data *ServerData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// The sockets that the server is listening on.  There are no ordering
	// guarantees.  This may be absent.
	ListenSocket []*SocketRef `protobuf:"bytes,3,rep,name=listen_socket,json=listenSocket,proto3" json:"listen_socket,omitempty"`
	// contains filtered or unexported fields
}

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

func (*Server) ClearData 

func (x *Server) ClearData()

func (*Server) ClearRef 

func (x *Server) ClearRef()

func (*Server) GetData 

func (x *Server) GetData() *ServerData

func (*Server) GetListenSocket 

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

func (*Server) GetRef 

func (x *Server) GetRef() *ServerRef

func (*Server) HasData 

func (x *Server) HasData() bool

func (*Server) HasRef 

func (x *Server) HasRef() bool

func (*Server) ProtoMessage 

func (*Server) ProtoMessage()

func (*Server) ProtoReflect 

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

func (*Server) Reset 

func (x *Server) Reset()

func (*Server) SetData 

func (x *Server) SetData(v *ServerData)

func (*Server) SetListenSocket 

func (x *Server) SetListenSocket(v []*SocketRef)

func (*Server) SetRef 

func (x *Server) SetRef(v *ServerRef)

func (*Server) String 

func (x *Server) String() string

type ServerData 

type ServerData struct {

	// A trace of recent events on the server.  May be absent.
	Trace *ChannelTrace `protobuf:"bytes,1,opt,name=trace,proto3" json:"trace,omitempty"`
	// The number of incoming calls started on the server
	CallsStarted int64 `protobuf:"varint,2,opt,name=calls_started,json=callsStarted,proto3" json:"calls_started,omitempty"`
	// The number of incoming calls that have completed with an OK status
	CallsSucceeded int64 `protobuf:"varint,3,opt,name=calls_succeeded,json=callsSucceeded,proto3" json:"calls_succeeded,omitempty"`
	// The number of incoming calls that have a completed with a non-OK status
	CallsFailed int64 `protobuf:"varint,4,opt,name=calls_failed,json=callsFailed,proto3" json:"calls_failed,omitempty"`
	// The last time a call was started on the server.
	LastCallStartedTimestamp *timestamppb.Timestamp `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

ServerData is data for a specific Server.

func (*ServerData) ClearLastCallStartedTimestamp 

func (x *ServerData) ClearLastCallStartedTimestamp()

func (*ServerData) ClearTrace 

func (x *ServerData) ClearTrace()

func (*ServerData) GetCallsFailed 

func (x *ServerData) GetCallsFailed() int64

func (*ServerData) GetCallsStarted 

func (x *ServerData) GetCallsStarted() int64

func (*ServerData) GetCallsSucceeded 

func (x *ServerData) GetCallsSucceeded() int64

func (*ServerData) GetLastCallStartedTimestamp 

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

func (*ServerData) GetTrace 

func (x *ServerData) GetTrace() *ChannelTrace

func (*ServerData) HasLastCallStartedTimestamp 

func (x *ServerData) HasLastCallStartedTimestamp() bool

func (*ServerData) HasTrace 

func (x *ServerData) HasTrace() bool

func (*ServerData) ProtoMessage 

func (*ServerData) ProtoMessage()

func (*ServerData) ProtoReflect 

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

func (*ServerData) Reset 

func (x *ServerData) Reset()

func (*ServerData) SetCallsFailed 

func (x *ServerData) SetCallsFailed(v int64)

func (*ServerData) SetCallsStarted 

func (x *ServerData) SetCallsStarted(v int64)

func (*ServerData) SetCallsSucceeded 

func (x *ServerData) SetCallsSucceeded(v int64)

func (*ServerData) SetLastCallStartedTimestamp 

func (x *ServerData) SetLastCallStartedTimestamp(v *timestamppb.Timestamp)

func (*ServerData) SetTrace 

func (x *ServerData) SetTrace(v *ChannelTrace)

func (*ServerData) String 

func (x *ServerData) String() string

type ServerData_builder 

type ServerData_builder struct {

	// A trace of recent events on the server.  May be absent.
	Trace *ChannelTrace
	// The number of incoming calls started on the server
	CallsStarted int64
	// The number of incoming calls that have completed with an OK status
	CallsSucceeded int64
	// The number of incoming calls that have a completed with a non-OK status
	CallsFailed int64
	// The last time a call was started on the server.
	LastCallStartedTimestamp *timestamppb.Timestamp
	// contains filtered or unexported fields
}

func (ServerData_builder) Build 

func (b0 ServerData_builder) Build() *ServerData

type ServerRef 

type ServerRef struct {

	// A globally unique identifier for this server.  Must be a positive number.
	ServerId int64 `protobuf:"varint,5,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	// An optional name associated with the server.
	Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

ServerRef is a reference to a Server.

func (*ServerRef) GetName 

func (x *ServerRef) GetName() string

func (*ServerRef) GetServerId 

func (x *ServerRef) GetServerId() int64

func (*ServerRef) ProtoMessage 

func (*ServerRef) ProtoMessage()

func (*ServerRef) ProtoReflect 

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

func (*ServerRef) Reset 

func (x *ServerRef) Reset()

func (*ServerRef) SetName 

func (x *ServerRef) SetName(v string)

func (*ServerRef) SetServerId 

func (x *ServerRef) SetServerId(v int64)

func (*ServerRef) String 

func (x *ServerRef) String() string

type ServerRef_builder 

type ServerRef_builder struct {

	// A globally unique identifier for this server.  Must be a positive number.
	ServerId int64
	// An optional name associated with the server.
	Name string
	// contains filtered or unexported fields
}

func (ServerRef_builder) Build 

func (b0 ServerRef_builder) Build() *ServerRef

type Server_builder 

type Server_builder struct {

	// The identifier for a Server.  This should be set.
	Ref *ServerRef
	// The associated data of the Server.
	Data *ServerData
	// The sockets that the server is listening on.  There are no ordering
	// guarantees.  This may be absent.
	ListenSocket []*SocketRef
	// contains filtered or unexported fields
}

func (Server_builder) Build 

func (b0 Server_builder) Build() *Server

type Socket 

type Socket struct {

	// The identifier for the Socket.
	Ref *SocketRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// Data specific to this Socket.
	Data *SocketData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// The locally bound address.
	Local *Address `protobuf:"bytes,3,opt,name=local,proto3" json:"local,omitempty"`
	// The remote bound address.  May be absent.
	Remote *Address `protobuf:"bytes,4,opt,name=remote,proto3" json:"remote,omitempty"`
	// Security details for this socket.  May be absent if not available, or
	// there is no security on the socket.
	Security *Security `protobuf:"bytes,5,opt,name=security,proto3" json:"security,omitempty"`
	// Optional, represents the name of the remote endpoint, if different than
	// the original target name.
	RemoteName string `protobuf:"bytes,6,opt,name=remote_name,json=remoteName,proto3" json:"remote_name,omitempty"`
	// contains filtered or unexported fields
}

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

func (*Socket) ClearData 

func (x *Socket) ClearData()

func (*Socket) ClearLocal 

func (x *Socket) ClearLocal()

func (*Socket) ClearRef 

func (x *Socket) ClearRef()

func (*Socket) ClearRemote 

func (x *Socket) ClearRemote()

func (*Socket) ClearSecurity 

func (x *Socket) ClearSecurity()

func (*Socket) GetData 

func (x *Socket) GetData() *SocketData

func (*Socket) GetLocal 

func (x *Socket) GetLocal() *Address

func (*Socket) GetRef 

func (x *Socket) GetRef() *SocketRef

func (*Socket) GetRemote 

func (x *Socket) GetRemote() *Address

func (*Socket) GetRemoteName 

func (x *Socket) GetRemoteName() string

func (*Socket) GetSecurity 

func (x *Socket) GetSecurity() *Security

func (*Socket) HasData 

func (x *Socket) HasData() bool

func (*Socket) HasLocal 

func (x *Socket) HasLocal() bool

func (*Socket) HasRef 

func (x *Socket) HasRef() bool

func (*Socket) HasRemote 

func (x *Socket) HasRemote() bool

func (*Socket) HasSecurity 

func (x *Socket) HasSecurity() bool

func (*Socket) ProtoMessage 

func (*Socket) ProtoMessage()

func (*Socket) ProtoReflect 

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

func (*Socket) Reset 

func (x *Socket) Reset()

func (*Socket) SetData 

func (x *Socket) SetData(v *SocketData)

func (*Socket) SetLocal 

func (x *Socket) SetLocal(v *Address)

func (*Socket) SetRef 

func (x *Socket) SetRef(v *SocketRef)

func (*Socket) SetRemote 

func (x *Socket) SetRemote(v *Address)

func (*Socket) SetRemoteName 

func (x *Socket) SetRemoteName(v string)

func (*Socket) SetSecurity 

func (x *Socket) SetSecurity(v *Security)

func (*Socket) String 

func (x *Socket) String() string

type SocketData 

type SocketData struct {

	// The number of streams that have been started.
	StreamsStarted int64 `protobuf:"varint,1,opt,name=streams_started,json=streamsStarted,proto3" json:"streams_started,omitempty"`
	// The number of streams that have ended successfully:
	// On client side, received frame with eos bit set;
	// On server side, sent frame with eos bit set.
	StreamsSucceeded int64 `protobuf:"varint,2,opt,name=streams_succeeded,json=streamsSucceeded,proto3" json:"streams_succeeded,omitempty"`
	// The number of streams that have ended unsuccessfully:
	// On client side, ended without receiving frame with eos bit set;
	// On server side, ended without sending frame with eos bit set.
	StreamsFailed int64 `protobuf:"varint,3,opt,name=streams_failed,json=streamsFailed,proto3" json:"streams_failed,omitempty"`
	// The number of grpc messages successfully sent on this socket.
	MessagesSent int64 `protobuf:"varint,4,opt,name=messages_sent,json=messagesSent,proto3" json:"messages_sent,omitempty"`
	// The number of grpc messages received on this socket.
	MessagesReceived int64 `protobuf:"varint,5,opt,name=messages_received,json=messagesReceived,proto3" json:"messages_received,omitempty"`
	// The number of keep alives sent.  This is typically implemented with HTTP/2
	// ping messages.
	KeepAlivesSent int64 `protobuf:"varint,6,opt,name=keep_alives_sent,json=keepAlivesSent,proto3" json:"keep_alives_sent,omitempty"`
	// The last time a stream was created by this endpoint.  Usually unset for
	// servers.
	LastLocalStreamCreatedTimestamp *timestamppb.Timestamp `` /* 160-byte string literal not displayed */
	// The last time a stream was created by the remote endpoint.  Usually unset
	// for clients.
	LastRemoteStreamCreatedTimestamp *timestamppb.Timestamp `` /* 163-byte string literal not displayed */
	// The last time a message was sent by this endpoint.
	LastMessageSentTimestamp *timestamppb.Timestamp `` /* 137-byte string literal not displayed */
	// The last time a message was received by this endpoint.
	LastMessageReceivedTimestamp *timestamppb.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 *wrapperspb.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 *wrapperspb.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"`
	// Populated if a GOAWAY has been received.  The value will be the
	// HTTP/2 error code from the GOAWAY.
	ReceivedGoawayError *wrapperspb.UInt32Value `protobuf:"bytes,14,opt,name=received_goaway_error,json=receivedGoawayError,proto3" json:"received_goaway_error,omitempty"`
	// The value of MAX_CONCURRENT_STREAMS set by the peer.  Populated on
	// client side only.
	PeerMaxConcurrentStreams uint32 `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

SocketData is data associated for a specific Socket. The fields present are specific to the implementation, so there may be minor differences in the semantics. (e.g. flow control windows)

func (*SocketData) ClearLastLocalStreamCreatedTimestamp 

func (x *SocketData) ClearLastLocalStreamCreatedTimestamp()

func (*SocketData) ClearLastMessageReceivedTimestamp 

func (x *SocketData) ClearLastMessageReceivedTimestamp()

func (*SocketData) ClearLastMessageSentTimestamp 

func (x *SocketData) ClearLastMessageSentTimestamp()

func (*SocketData) ClearLastRemoteStreamCreatedTimestamp 

func (x *SocketData) ClearLastRemoteStreamCreatedTimestamp()

func (*SocketData) ClearLocalFlowControlWindow 

func (x *SocketData) ClearLocalFlowControlWindow()

func (*SocketData) ClearReceivedGoawayError 

func (x *SocketData) ClearReceivedGoawayError()

func (*SocketData) ClearRemoteFlowControlWindow 

func (x *SocketData) ClearRemoteFlowControlWindow()

func (*SocketData) GetKeepAlivesSent 

func (x *SocketData) GetKeepAlivesSent() int64

func (*SocketData) GetLastLocalStreamCreatedTimestamp 

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

func (*SocketData) GetLastMessageReceivedTimestamp 

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

func (*SocketData) GetLastMessageSentTimestamp 

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

func (*SocketData) GetLastRemoteStreamCreatedTimestamp 

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

func (*SocketData) GetLocalFlowControlWindow 

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

func (*SocketData) GetMessagesReceived 

func (x *SocketData) GetMessagesReceived() int64

func (*SocketData) GetMessagesSent 

func (x *SocketData) GetMessagesSent() int64

func (*SocketData) GetOption 

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

func (*SocketData) GetPeerMaxConcurrentStreams 

func (x *SocketData) GetPeerMaxConcurrentStreams() uint32

func (*SocketData) GetReceivedGoawayError 

func (x *SocketData) GetReceivedGoawayError() *wrapperspb.UInt32Value

func (*SocketData) GetRemoteFlowControlWindow 

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

func (*SocketData) GetStreamsFailed 

func (x *SocketData) GetStreamsFailed() int64

func (*SocketData) GetStreamsStarted 

func (x *SocketData) GetStreamsStarted() int64

func (*SocketData) GetStreamsSucceeded 

func (x *SocketData) GetStreamsSucceeded() int64

func (*SocketData) HasLastLocalStreamCreatedTimestamp 

func (x *SocketData) HasLastLocalStreamCreatedTimestamp() bool

func (*SocketData) HasLastMessageReceivedTimestamp 

func (x *SocketData) HasLastMessageReceivedTimestamp() bool

func (*SocketData) HasLastMessageSentTimestamp 

func (x *SocketData) HasLastMessageSentTimestamp() bool

func (*SocketData) HasLastRemoteStreamCreatedTimestamp 

func (x *SocketData) HasLastRemoteStreamCreatedTimestamp() bool

func (*SocketData) HasLocalFlowControlWindow 

func (x *SocketData) HasLocalFlowControlWindow() bool

func (*SocketData) HasReceivedGoawayError 

func (x *SocketData) HasReceivedGoawayError() bool

func (*SocketData) HasRemoteFlowControlWindow 

func (x *SocketData) HasRemoteFlowControlWindow() bool

func (*SocketData) ProtoMessage 

func (*SocketData) ProtoMessage()

func (*SocketData) ProtoReflect 

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

func (*SocketData) Reset 

func (x *SocketData) Reset()

func (*SocketData) SetKeepAlivesSent 

func (x *SocketData) SetKeepAlivesSent(v int64)

func (*SocketData) SetLastLocalStreamCreatedTimestamp 

func (x *SocketData) SetLastLocalStreamCreatedTimestamp(v *timestamppb.Timestamp)

func (*SocketData) SetLastMessageReceivedTimestamp 

func (x *SocketData) SetLastMessageReceivedTimestamp(v *timestamppb.Timestamp)

func (*SocketData) SetLastMessageSentTimestamp 

func (x *SocketData) SetLastMessageSentTimestamp(v *timestamppb.Timestamp)

func (*SocketData) SetLastRemoteStreamCreatedTimestamp 

func (x *SocketData) SetLastRemoteStreamCreatedTimestamp(v *timestamppb.Timestamp)

func (*SocketData) SetLocalFlowControlWindow 

func (x *SocketData) SetLocalFlowControlWindow(v *wrapperspb.Int64Value)

func (*SocketData) SetMessagesReceived 

func (x *SocketData) SetMessagesReceived(v int64)

func (*SocketData) SetMessagesSent 

func (x *SocketData) SetMessagesSent(v int64)

func (*SocketData) SetOption 

func (x *SocketData) SetOption(v []*SocketOption)

func (*SocketData) SetPeerMaxConcurrentStreams 

func (x *SocketData) SetPeerMaxConcurrentStreams(v uint32)

func (*SocketData) SetReceivedGoawayError 

func (x *SocketData) SetReceivedGoawayError(v *wrapperspb.UInt32Value)

func (*SocketData) SetRemoteFlowControlWindow 

func (x *SocketData) SetRemoteFlowControlWindow(v *wrapperspb.Int64Value)

func (*SocketData) SetStreamsFailed 

func (x *SocketData) SetStreamsFailed(v int64)

func (*SocketData) SetStreamsStarted 

func (x *SocketData) SetStreamsStarted(v int64)

func (*SocketData) SetStreamsSucceeded 

func (x *SocketData) SetStreamsSucceeded(v int64)

func (*SocketData) String 

func (x *SocketData) String() string

type SocketData_builder 

type SocketData_builder struct {

	// The number of streams that have been started.
	StreamsStarted int64
	// 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
	// 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
	// The number of grpc messages successfully sent on this socket.
	MessagesSent int64
	// The number of grpc messages received on this socket.
	MessagesReceived int64
	// The number of keep alives sent.  This is typically implemented with HTTP/2
	// ping messages.
	KeepAlivesSent int64
	// The last time a stream was created by this endpoint.  Usually unset for
	// servers.
	LastLocalStreamCreatedTimestamp *timestamppb.Timestamp
	// The last time a stream was created by the remote endpoint.  Usually unset
	// for clients.
	LastRemoteStreamCreatedTimestamp *timestamppb.Timestamp
	// The last time a message was sent by this endpoint.
	LastMessageSentTimestamp *timestamppb.Timestamp
	// The last time a message was received by this endpoint.
	LastMessageReceivedTimestamp *timestamppb.Timestamp
	// The amount of window, granted to the local endpoint by the remote endpoint.
	// This may be slightly out of date due to network latency.  This does NOT
	// include stream level or TCP level flow control info.
	LocalFlowControlWindow *wrapperspb.Int64Value
	// The amount of window, granted to the remote endpoint by the local endpoint.
	// This may be slightly out of date due to network latency.  This does NOT
	// include stream level or TCP level flow control info.
	RemoteFlowControlWindow *wrapperspb.Int64Value
	// Socket options set on this socket.  May be absent if 'summary' is set
	// on GetSocketRequest.
	Option []*SocketOption
	// Populated if a GOAWAY has been received.  The value will be the
	// HTTP/2 error code from the GOAWAY.
	ReceivedGoawayError *wrapperspb.UInt32Value
	// The value of MAX_CONCURRENT_STREAMS set by the peer.  Populated on
	// client side only.
	PeerMaxConcurrentStreams uint32
	// contains filtered or unexported fields
}

func (SocketData_builder) Build 

func (b0 SocketData_builder) Build() *SocketData

type SocketOption 

type SocketOption struct {

	// The full name of the socket option.  Typically this will be the upper case
	// name, such as "SO_REUSEPORT".
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The human readable value of this socket option.  At least one of value or
	// additional will be set.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// Additional data associated with the socket option.  At least one of value
	// or additional will be set.
	Additional *anypb.Any `protobuf:"bytes,3,opt,name=additional,proto3" json:"additional,omitempty"`
	// contains filtered or unexported fields
}

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

func (*SocketOption) ClearAdditional 

func (x *SocketOption) ClearAdditional()

func (*SocketOption) GetAdditional 

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

func (*SocketOption) GetName 

func (x *SocketOption) GetName() string

func (*SocketOption) GetValue 

func (x *SocketOption) GetValue() string

func (*SocketOption) HasAdditional 

func (x *SocketOption) HasAdditional() bool

func (*SocketOption) ProtoMessage 

func (*SocketOption) ProtoMessage()

func (*SocketOption) ProtoReflect 

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

func (*SocketOption) Reset 

func (x *SocketOption) Reset()

func (*SocketOption) SetAdditional 

func (x *SocketOption) SetAdditional(v *anypb.Any)

func (*SocketOption) SetName 

func (x *SocketOption) SetName(v string)

func (*SocketOption) SetValue 

func (x *SocketOption) SetValue(v string)

func (*SocketOption) String 

func (x *SocketOption) String() string

type SocketOptionLinger 

type SocketOptionLinger struct {

	// active maps to `struct linger.l_onoff`
	Active bool `protobuf:"varint,1,opt,name=active,proto3" json:"active,omitempty"`
	// duration maps to `struct linger.l_linger`
	Duration *durationpb.Duration `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

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

func (*SocketOptionLinger) ClearDuration 

func (x *SocketOptionLinger) ClearDuration()

func (*SocketOptionLinger) GetActive 

func (x *SocketOptionLinger) GetActive() bool

func (*SocketOptionLinger) GetDuration 

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

func (*SocketOptionLinger) HasDuration 

func (x *SocketOptionLinger) HasDuration() bool

func (*SocketOptionLinger) ProtoMessage 

func (*SocketOptionLinger) ProtoMessage()

func (*SocketOptionLinger) ProtoReflect 

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

func (*SocketOptionLinger) Reset 

func (x *SocketOptionLinger) Reset()

func (*SocketOptionLinger) SetActive 

func (x *SocketOptionLinger) SetActive(v bool)

func (*SocketOptionLinger) SetDuration 

func (x *SocketOptionLinger) SetDuration(v *durationpb.Duration)

func (*SocketOptionLinger) String 

func (x *SocketOptionLinger) String() string

type SocketOptionLinger_builder 

type SocketOptionLinger_builder struct {

	// active maps to `struct linger.l_onoff`
	Active bool
	// duration maps to `struct linger.l_linger`
	Duration *durationpb.Duration
	// contains filtered or unexported fields
}

func (SocketOptionLinger_builder) Build 

func (b0 SocketOptionLinger_builder) Build() *SocketOptionLinger

type SocketOptionTcpInfo 

type SocketOptionTcpInfo struct {
	TcpiState        uint32 `protobuf:"varint,1,opt,name=tcpi_state,json=tcpiState,proto3" json:"tcpi_state,omitempty"`
	TcpiCaState      uint32 `protobuf:"varint,2,opt,name=tcpi_ca_state,json=tcpiCaState,proto3" json:"tcpi_ca_state,omitempty"`
	TcpiRetransmits  uint32 `protobuf:"varint,3,opt,name=tcpi_retransmits,json=tcpiRetransmits,proto3" json:"tcpi_retransmits,omitempty"`
	TcpiProbes       uint32 `protobuf:"varint,4,opt,name=tcpi_probes,json=tcpiProbes,proto3" json:"tcpi_probes,omitempty"`
	TcpiBackoff      uint32 `protobuf:"varint,5,opt,name=tcpi_backoff,json=tcpiBackoff,proto3" json:"tcpi_backoff,omitempty"`
	TcpiOptions      uint32 `protobuf:"varint,6,opt,name=tcpi_options,json=tcpiOptions,proto3" json:"tcpi_options,omitempty"`
	TcpiSndWscale    uint32 `protobuf:"varint,7,opt,name=tcpi_snd_wscale,json=tcpiSndWscale,proto3" json:"tcpi_snd_wscale,omitempty"`
	TcpiRcvWscale    uint32 `protobuf:"varint,8,opt,name=tcpi_rcv_wscale,json=tcpiRcvWscale,proto3" json:"tcpi_rcv_wscale,omitempty"`
	TcpiRto          uint32 `protobuf:"varint,9,opt,name=tcpi_rto,json=tcpiRto,proto3" json:"tcpi_rto,omitempty"`
	TcpiAto          uint32 `protobuf:"varint,10,opt,name=tcpi_ato,json=tcpiAto,proto3" json:"tcpi_ato,omitempty"`
	TcpiSndMss       uint32 `protobuf:"varint,11,opt,name=tcpi_snd_mss,json=tcpiSndMss,proto3" json:"tcpi_snd_mss,omitempty"`
	TcpiRcvMss       uint32 `protobuf:"varint,12,opt,name=tcpi_rcv_mss,json=tcpiRcvMss,proto3" json:"tcpi_rcv_mss,omitempty"`
	TcpiUnacked      uint32 `protobuf:"varint,13,opt,name=tcpi_unacked,json=tcpiUnacked,proto3" json:"tcpi_unacked,omitempty"`
	TcpiSacked       uint32 `protobuf:"varint,14,opt,name=tcpi_sacked,json=tcpiSacked,proto3" json:"tcpi_sacked,omitempty"`
	TcpiLost         uint32 `protobuf:"varint,15,opt,name=tcpi_lost,json=tcpiLost,proto3" json:"tcpi_lost,omitempty"`
	TcpiRetrans      uint32 `protobuf:"varint,16,opt,name=tcpi_retrans,json=tcpiRetrans,proto3" json:"tcpi_retrans,omitempty"`
	TcpiFackets      uint32 `protobuf:"varint,17,opt,name=tcpi_fackets,json=tcpiFackets,proto3" json:"tcpi_fackets,omitempty"`
	TcpiLastDataSent uint32 `protobuf:"varint,18,opt,name=tcpi_last_data_sent,json=tcpiLastDataSent,proto3" json:"tcpi_last_data_sent,omitempty"`
	TcpiLastAckSent  uint32 `protobuf:"varint,19,opt,name=tcpi_last_ack_sent,json=tcpiLastAckSent,proto3" json:"tcpi_last_ack_sent,omitempty"`
	TcpiLastDataRecv uint32 `protobuf:"varint,20,opt,name=tcpi_last_data_recv,json=tcpiLastDataRecv,proto3" json:"tcpi_last_data_recv,omitempty"`
	TcpiLastAckRecv  uint32 `protobuf:"varint,21,opt,name=tcpi_last_ack_recv,json=tcpiLastAckRecv,proto3" json:"tcpi_last_ack_recv,omitempty"`
	TcpiPmtu         uint32 `protobuf:"varint,22,opt,name=tcpi_pmtu,json=tcpiPmtu,proto3" json:"tcpi_pmtu,omitempty"`
	TcpiRcvSsthresh  uint32 `protobuf:"varint,23,opt,name=tcpi_rcv_ssthresh,json=tcpiRcvSsthresh,proto3" json:"tcpi_rcv_ssthresh,omitempty"`
	TcpiRtt          uint32 `protobuf:"varint,24,opt,name=tcpi_rtt,json=tcpiRtt,proto3" json:"tcpi_rtt,omitempty"`
	TcpiRttvar       uint32 `protobuf:"varint,25,opt,name=tcpi_rttvar,json=tcpiRttvar,proto3" json:"tcpi_rttvar,omitempty"`
	TcpiSndSsthresh  uint32 `protobuf:"varint,26,opt,name=tcpi_snd_ssthresh,json=tcpiSndSsthresh,proto3" json:"tcpi_snd_ssthresh,omitempty"`
	TcpiSndCwnd      uint32 `protobuf:"varint,27,opt,name=tcpi_snd_cwnd,json=tcpiSndCwnd,proto3" json:"tcpi_snd_cwnd,omitempty"`
	TcpiAdvmss       uint32 `protobuf:"varint,28,opt,name=tcpi_advmss,json=tcpiAdvmss,proto3" json:"tcpi_advmss,omitempty"`
	TcpiReordering   uint32 `protobuf:"varint,29,opt,name=tcpi_reordering,json=tcpiReordering,proto3" json:"tcpi_reordering,omitempty"`
	// contains filtered or unexported fields
}

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

func (*SocketOptionTcpInfo) GetTcpiAdvmss 

func (x *SocketOptionTcpInfo) GetTcpiAdvmss() uint32

func (*SocketOptionTcpInfo) GetTcpiAto 

func (x *SocketOptionTcpInfo) GetTcpiAto() uint32

func (*SocketOptionTcpInfo) GetTcpiBackoff 

func (x *SocketOptionTcpInfo) GetTcpiBackoff() uint32

func (*SocketOptionTcpInfo) GetTcpiCaState 

func (x *SocketOptionTcpInfo) GetTcpiCaState() uint32

func (*SocketOptionTcpInfo) GetTcpiFackets 

func (x *SocketOptionTcpInfo) GetTcpiFackets() uint32

func (*SocketOptionTcpInfo) GetTcpiLastAckRecv 

func (x *SocketOptionTcpInfo) GetTcpiLastAckRecv() uint32

func (*SocketOptionTcpInfo) GetTcpiLastAckSent 

func (x *SocketOptionTcpInfo) GetTcpiLastAckSent() uint32

func (*SocketOptionTcpInfo) GetTcpiLastDataRecv 

func (x *SocketOptionTcpInfo) GetTcpiLastDataRecv() uint32

func (*SocketOptionTcpInfo) GetTcpiLastDataSent 

func (x *SocketOptionTcpInfo) GetTcpiLastDataSent() uint32

func (*SocketOptionTcpInfo) GetTcpiLost 

func (x *SocketOptionTcpInfo) GetTcpiLost() uint32

func (*SocketOptionTcpInfo) GetTcpiOptions 

func (x *SocketOptionTcpInfo) GetTcpiOptions() uint32

func (*SocketOptionTcpInfo) GetTcpiPmtu 

func (x *SocketOptionTcpInfo) GetTcpiPmtu() uint32

func (*SocketOptionTcpInfo) GetTcpiProbes 

func (x *SocketOptionTcpInfo) GetTcpiProbes() uint32

func (*SocketOptionTcpInfo) GetTcpiRcvMss 

func (x *SocketOptionTcpInfo) GetTcpiRcvMss() uint32

func (*SocketOptionTcpInfo) GetTcpiRcvSsthresh 

func (x *SocketOptionTcpInfo) GetTcpiRcvSsthresh() uint32

func (*SocketOptionTcpInfo) GetTcpiRcvWscale 

func (x *SocketOptionTcpInfo) GetTcpiRcvWscale() uint32

func (*SocketOptionTcpInfo) GetTcpiReordering 

func (x *SocketOptionTcpInfo) GetTcpiReordering() uint32

func (*SocketOptionTcpInfo) GetTcpiRetrans 

func (x *SocketOptionTcpInfo) GetTcpiRetrans() uint32

func (*SocketOptionTcpInfo) GetTcpiRetransmits 

func (x *SocketOptionTcpInfo) GetTcpiRetransmits() uint32

func (*SocketOptionTcpInfo) GetTcpiRto 

func (x *SocketOptionTcpInfo) GetTcpiRto() uint32

func (*SocketOptionTcpInfo) GetTcpiRtt 

func (x *SocketOptionTcpInfo) GetTcpiRtt() uint32

func (*SocketOptionTcpInfo) GetTcpiRttvar 

func (x *SocketOptionTcpInfo) GetTcpiRttvar() uint32

func (*SocketOptionTcpInfo) GetTcpiSacked 

func (x *SocketOptionTcpInfo) GetTcpiSacked() uint32

func (*SocketOptionTcpInfo) GetTcpiSndCwnd 

func (x *SocketOptionTcpInfo) GetTcpiSndCwnd() uint32

func (*SocketOptionTcpInfo) GetTcpiSndMss 

func (x *SocketOptionTcpInfo) GetTcpiSndMss() uint32

func (*SocketOptionTcpInfo) GetTcpiSndSsthresh 

func (x *SocketOptionTcpInfo) GetTcpiSndSsthresh() uint32

func (*SocketOptionTcpInfo) GetTcpiSndWscale 

func (x *SocketOptionTcpInfo) GetTcpiSndWscale() uint32

func (*SocketOptionTcpInfo) GetTcpiState 

func (x *SocketOptionTcpInfo) GetTcpiState() uint32

func (*SocketOptionTcpInfo) GetTcpiUnacked 

func (x *SocketOptionTcpInfo) GetTcpiUnacked() uint32

func (*SocketOptionTcpInfo) ProtoMessage 

func (*SocketOptionTcpInfo) ProtoMessage()

func (*SocketOptionTcpInfo) ProtoReflect 

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

func (*SocketOptionTcpInfo) Reset 

func (x *SocketOptionTcpInfo) Reset()

func (*SocketOptionTcpInfo) SetTcpiAdvmss 

func (x *SocketOptionTcpInfo) SetTcpiAdvmss(v uint32)

func (*SocketOptionTcpInfo) SetTcpiAto 

func (x *SocketOptionTcpInfo) SetTcpiAto(v uint32)

func (*SocketOptionTcpInfo) SetTcpiBackoff 

func (x *SocketOptionTcpInfo) SetTcpiBackoff(v uint32)

func (*SocketOptionTcpInfo) SetTcpiCaState 

func (x *SocketOptionTcpInfo) SetTcpiCaState(v uint32)

func (*SocketOptionTcpInfo) SetTcpiFackets 

func (x *SocketOptionTcpInfo) SetTcpiFackets(v uint32)

func (*SocketOptionTcpInfo) SetTcpiLastAckRecv 

func (x *SocketOptionTcpInfo) SetTcpiLastAckRecv(v uint32)

func (*SocketOptionTcpInfo) SetTcpiLastAckSent 

func (x *SocketOptionTcpInfo) SetTcpiLastAckSent(v uint32)

func (*SocketOptionTcpInfo) SetTcpiLastDataRecv 

func (x *SocketOptionTcpInfo) SetTcpiLastDataRecv(v uint32)

func (*SocketOptionTcpInfo) SetTcpiLastDataSent 

func (x *SocketOptionTcpInfo) SetTcpiLastDataSent(v uint32)

func (*SocketOptionTcpInfo) SetTcpiLost 

func (x *SocketOptionTcpInfo) SetTcpiLost(v uint32)

func (*SocketOptionTcpInfo) SetTcpiOptions 

func (x *SocketOptionTcpInfo) SetTcpiOptions(v uint32)

func (*SocketOptionTcpInfo) SetTcpiPmtu 

func (x *SocketOptionTcpInfo) SetTcpiPmtu(v uint32)

func (*SocketOptionTcpInfo) SetTcpiProbes 

func (x *SocketOptionTcpInfo) SetTcpiProbes(v uint32)

func (*SocketOptionTcpInfo) SetTcpiRcvMss 

func (x *SocketOptionTcpInfo) SetTcpiRcvMss(v uint32)

func (*SocketOptionTcpInfo) SetTcpiRcvSsthresh 

func (x *SocketOptionTcpInfo) SetTcpiRcvSsthresh(v uint32)

func (*SocketOptionTcpInfo) SetTcpiRcvWscale 

func (x *SocketOptionTcpInfo) SetTcpiRcvWscale(v uint32)

func (*SocketOptionTcpInfo) SetTcpiReordering 

func (x *SocketOptionTcpInfo) SetTcpiReordering(v uint32)

func (*SocketOptionTcpInfo) SetTcpiRetrans 

func (x *SocketOptionTcpInfo) SetTcpiRetrans(v uint32)

func (*SocketOptionTcpInfo) SetTcpiRetransmits 

func (x *SocketOptionTcpInfo) SetTcpiRetransmits(v uint32)

func (*SocketOptionTcpInfo) SetTcpiRto 

func (x *SocketOptionTcpInfo) SetTcpiRto(v uint32)

func (*SocketOptionTcpInfo) SetTcpiRtt 

func (x *SocketOptionTcpInfo) SetTcpiRtt(v uint32)

func (*SocketOptionTcpInfo) SetTcpiRttvar 

func (x *SocketOptionTcpInfo) SetTcpiRttvar(v uint32)

func (*SocketOptionTcpInfo) SetTcpiSacked 

func (x *SocketOptionTcpInfo) SetTcpiSacked(v uint32)

func (*SocketOptionTcpInfo) SetTcpiSndCwnd 

func (x *SocketOptionTcpInfo) SetTcpiSndCwnd(v uint32)

func (*SocketOptionTcpInfo) SetTcpiSndMss 

func (x *SocketOptionTcpInfo) SetTcpiSndMss(v uint32)

func (*SocketOptionTcpInfo) SetTcpiSndSsthresh 

func (x *SocketOptionTcpInfo) SetTcpiSndSsthresh(v uint32)

func (*SocketOptionTcpInfo) SetTcpiSndWscale 

func (x *SocketOptionTcpInfo) SetTcpiSndWscale(v uint32)

func (*SocketOptionTcpInfo) SetTcpiState 

func (x *SocketOptionTcpInfo) SetTcpiState(v uint32)

func (*SocketOptionTcpInfo) SetTcpiUnacked 

func (x *SocketOptionTcpInfo) SetTcpiUnacked(v uint32)

func (*SocketOptionTcpInfo) String 

func (x *SocketOptionTcpInfo) String() string

type SocketOptionTcpInfo_builder 

type SocketOptionTcpInfo_builder struct {
	TcpiState        uint32
	TcpiCaState      uint32
	TcpiRetransmits  uint32
	TcpiProbes       uint32
	TcpiBackoff      uint32
	TcpiOptions      uint32
	TcpiSndWscale    uint32
	TcpiRcvWscale    uint32
	TcpiRto          uint32
	TcpiAto          uint32
	TcpiSndMss       uint32
	TcpiRcvMss       uint32
	TcpiUnacked      uint32
	TcpiSacked       uint32
	TcpiLost         uint32
	TcpiRetrans      uint32
	TcpiFackets      uint32
	TcpiLastDataSent uint32
	TcpiLastAckSent  uint32
	TcpiLastDataRecv uint32
	TcpiLastAckRecv  uint32
	TcpiPmtu         uint32
	TcpiRcvSsthresh  uint32
	TcpiRtt          uint32
	TcpiRttvar       uint32
	TcpiSndSsthresh  uint32
	TcpiSndCwnd      uint32
	TcpiAdvmss       uint32
	TcpiReordering   uint32
	// contains filtered or unexported fields
}

func (SocketOptionTcpInfo_builder) Build 

func (b0 SocketOptionTcpInfo_builder) Build() *SocketOptionTcpInfo

type SocketOptionTimeout 

type SocketOptionTimeout struct {
	Duration *durationpb.Duration `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

For use with SocketOption's additional field. This is primarily used for SO_RCVTIMEO and SO_SNDTIMEO

func (*SocketOptionTimeout) ClearDuration 

func (x *SocketOptionTimeout) ClearDuration()

func (*SocketOptionTimeout) GetDuration 

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

func (*SocketOptionTimeout) HasDuration 

func (x *SocketOptionTimeout) HasDuration() bool

func (*SocketOptionTimeout) ProtoMessage 

func (*SocketOptionTimeout) ProtoMessage()

func (*SocketOptionTimeout) ProtoReflect 

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

func (*SocketOptionTimeout) Reset 

func (x *SocketOptionTimeout) Reset()

func (*SocketOptionTimeout) SetDuration 

func (x *SocketOptionTimeout) SetDuration(v *durationpb.Duration)

func (*SocketOptionTimeout) String 

func (x *SocketOptionTimeout) String() string

type SocketOptionTimeout_builder 

type SocketOptionTimeout_builder struct {
	Duration *durationpb.Duration
	// contains filtered or unexported fields
}

func (SocketOptionTimeout_builder) Build 

func (b0 SocketOptionTimeout_builder) Build() *SocketOptionTimeout

type SocketOption_builder 

type SocketOption_builder struct {

	// The full name of the socket option.  Typically this will be the upper case
	// name, such as "SO_REUSEPORT".
	Name string
	// The human readable value of this socket option.  At least one of value or
	// additional will be set.
	Value string
	// Additional data associated with the socket option.  At least one of value
	// or additional will be set.
	Additional *anypb.Any
	// contains filtered or unexported fields
}

func (SocketOption_builder) Build 

func (b0 SocketOption_builder) Build() *SocketOption

type SocketRef 

type SocketRef struct {

	// The globally unique id for this socket.  Must be a positive number.
	SocketId int64 `protobuf:"varint,3,opt,name=socket_id,json=socketId,proto3" json:"socket_id,omitempty"`
	// An optional name associated with the socket.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

SocketRef is a reference to a Socket.

func (*SocketRef) GetName 

func (x *SocketRef) GetName() string

func (*SocketRef) GetSocketId 

func (x *SocketRef) GetSocketId() int64

func (*SocketRef) ProtoMessage 

func (*SocketRef) ProtoMessage()

func (*SocketRef) ProtoReflect 

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

func (*SocketRef) Reset 

func (x *SocketRef) Reset()

func (*SocketRef) SetName 

func (x *SocketRef) SetName(v string)

func (*SocketRef) SetSocketId 

func (x *SocketRef) SetSocketId(v int64)

func (*SocketRef) String 

func (x *SocketRef) String() string

type SocketRef_builder 

type SocketRef_builder struct {

	// The globally unique id for this socket.  Must be a positive number.
	SocketId int64
	// An optional name associated with the socket.
	Name string
	// contains filtered or unexported fields
}

func (SocketRef_builder) Build 

func (b0 SocketRef_builder) Build() *SocketRef

type Socket_builder 

type Socket_builder struct {

	// The identifier for the Socket.
	Ref *SocketRef
	// Data specific to this Socket.
	Data *SocketData
	// The locally bound address.
	Local *Address
	// The remote bound address.  May be absent.
	Remote *Address
	// Security details for this socket.  May be absent if not available, or
	// there is no security on the socket.
	Security *Security
	// Optional, represents the name of the remote endpoint, if different than
	// the original target name.
	RemoteName string
	// contains filtered or unexported fields
}

func (Socket_builder) Build 

func (b0 Socket_builder) Build() *Socket

type Subchannel 

type Subchannel struct {

	// The identifier for this channel.
	Ref *SubchannelRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// Data specific to this channel.
	Data *ChannelData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // At most one of 'channel_ref+subchannel_ref' and 'socket' is set.
	// There are no ordering guarantees on the order of channel refs.
	// There may not be cycles in the ref graph.
	// A channel ref may be present in more than one channel or subchannel.
	ChannelRef []*ChannelRef `protobuf:"bytes,3,rep,name=channel_ref,json=channelRef,proto3" json:"channel_ref,omitempty"`
	// At most one of 'channel_ref+subchannel_ref' and 'socket' is set.
	// There are no ordering guarantees on the order of subchannel refs.
	// There may not be cycles in the ref graph.
	// A sub channel ref may be present in more than one channel or subchannel.
	SubchannelRef []*SubchannelRef `protobuf:"bytes,4,rep,name=subchannel_ref,json=subchannelRef,proto3" json:"subchannel_ref,omitempty"`
	// There are no ordering guarantees on the order of sockets.
	SocketRef []*SocketRef `protobuf:"bytes,5,rep,name=socket_ref,json=socketRef,proto3" json:"socket_ref,omitempty"`
	// contains filtered or unexported fields
}

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

func (*Subchannel) ClearData 

func (x *Subchannel) ClearData()

func (*Subchannel) ClearRef 

func (x *Subchannel) ClearRef()

func (*Subchannel) GetChannelRef 

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

func (*Subchannel) GetData 

func (x *Subchannel) GetData() *ChannelData

func (*Subchannel) GetRef 

func (x *Subchannel) GetRef() *SubchannelRef

func (*Subchannel) GetSocketRef 

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

func (*Subchannel) GetSubchannelRef 

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

func (*Subchannel) HasData 

func (x *Subchannel) HasData() bool

func (*Subchannel) HasRef 

func (x *Subchannel) HasRef() bool

func (*Subchannel) ProtoMessage 

func (*Subchannel) ProtoMessage()

func (*Subchannel) ProtoReflect 

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

func (*Subchannel) Reset 

func (x *Subchannel) Reset()

func (*Subchannel) SetChannelRef 

func (x *Subchannel) SetChannelRef(v []*ChannelRef)

func (*Subchannel) SetData 

func (x *Subchannel) SetData(v *ChannelData)

func (*Subchannel) SetRef 

func (x *Subchannel) SetRef(v *SubchannelRef)

func (*Subchannel) SetSocketRef 

func (x *Subchannel) SetSocketRef(v []*SocketRef)

func (*Subchannel) SetSubchannelRef 

func (x *Subchannel) SetSubchannelRef(v []*SubchannelRef)

func (*Subchannel) String 

func (x *Subchannel) String() string

type SubchannelRef 

type SubchannelRef struct {

	// The globally unique id for this subchannel.  Must be a positive number.
	SubchannelId int64 `protobuf:"varint,7,opt,name=subchannel_id,json=subchannelId,proto3" json:"subchannel_id,omitempty"`
	// An optional name associated with the subchannel.
	Name string `protobuf:"bytes,8,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

SubchannelRef is a reference to a Subchannel.

func (*SubchannelRef) GetName 

func (x *SubchannelRef) GetName() string

func (*SubchannelRef) GetSubchannelId 

func (x *SubchannelRef) GetSubchannelId() int64

func (*SubchannelRef) ProtoMessage 

func (*SubchannelRef) ProtoMessage()

func (*SubchannelRef) ProtoReflect 

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

func (*SubchannelRef) Reset 

func (x *SubchannelRef) Reset()

func (*SubchannelRef) SetName 

func (x *SubchannelRef) SetName(v string)

func (*SubchannelRef) SetSubchannelId 

func (x *SubchannelRef) SetSubchannelId(v int64)

func (*SubchannelRef) String 

func (x *SubchannelRef) String() string

type SubchannelRef_builder 

type SubchannelRef_builder struct {

	// The globally unique id for this subchannel.  Must be a positive number.
	SubchannelId int64
	// An optional name associated with the subchannel.
	Name string
	// contains filtered or unexported fields
}

func (SubchannelRef_builder) Build 

func (b0 SubchannelRef_builder) Build() *SubchannelRef

type Subchannel_builder 

type Subchannel_builder struct {

	// The identifier for this channel.
	Ref *SubchannelRef
	// Data specific to this channel.
	Data *ChannelData
	// 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
	// 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
	// There are no ordering guarantees on the order of sockets.
	SocketRef []*SocketRef
	// contains filtered or unexported fields
}

func (Subchannel_builder) Build 

func (b0 Subchannel_builder) Build() *Subchannel

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.