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

package grpc_channelz_v1

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

Index

Package Files

channelz.pb.go

Variables

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

func RegisterChannelzServer Uses

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

type Address Uses

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

Address represents the address used to create the socket.

func (*Address) Descriptor Uses

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

func (*Address) GetAddress Uses

func (m *Address) GetAddress() isAddress_Address

func (*Address) GetOtherAddress Uses

func (m *Address) GetOtherAddress() *Address_OtherAddress

func (*Address) GetTcpipAddress Uses

func (m *Address) GetTcpipAddress() *Address_TcpIpAddress

func (*Address) GetUdsAddress Uses

func (m *Address) GetUdsAddress() *Address_UdsAddress

func (*Address) ProtoMessage Uses

func (*Address) ProtoMessage()

func (*Address) Reset Uses

func (m *Address) Reset()

func (*Address) String Uses

func (m *Address) String() string

func (*Address) XXX_DiscardUnknown Uses

func (m *Address) XXX_DiscardUnknown()

func (*Address) XXX_Marshal Uses

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

func (*Address) XXX_Merge Uses

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

func (*Address) XXX_OneofFuncs Uses

func (*Address) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Address) XXX_Size Uses

func (m *Address) XXX_Size() int

func (*Address) XXX_Unmarshal Uses

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

type Address_OtherAddress Uses

type Address_OtherAddress struct {
    // The human readable version of the value.  This value should be set.
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // The actual address message.
    Value                *any.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

An address type not included above.

func (*Address_OtherAddress) Descriptor Uses

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

func (*Address_OtherAddress) GetName Uses

func (m *Address_OtherAddress) GetName() string

func (*Address_OtherAddress) GetValue Uses

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

func (*Address_OtherAddress) ProtoMessage Uses

func (*Address_OtherAddress) ProtoMessage()

func (*Address_OtherAddress) Reset Uses

func (m *Address_OtherAddress) Reset()

func (*Address_OtherAddress) String Uses

func (m *Address_OtherAddress) String() string

func (*Address_OtherAddress) XXX_DiscardUnknown Uses

func (m *Address_OtherAddress) XXX_DiscardUnknown()

func (*Address_OtherAddress) XXX_Marshal Uses

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

func (*Address_OtherAddress) XXX_Merge Uses

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

func (*Address_OtherAddress) XXX_Size Uses

func (m *Address_OtherAddress) XXX_Size() int

func (*Address_OtherAddress) XXX_Unmarshal Uses

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

type Address_OtherAddress_ Uses

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

type Address_TcpIpAddress Uses

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

func (*Address_TcpIpAddress) Descriptor Uses

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

func (*Address_TcpIpAddress) GetIpAddress Uses

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

func (*Address_TcpIpAddress) GetPort Uses

func (m *Address_TcpIpAddress) GetPort() int32

func (*Address_TcpIpAddress) ProtoMessage Uses

func (*Address_TcpIpAddress) ProtoMessage()

func (*Address_TcpIpAddress) Reset Uses

func (m *Address_TcpIpAddress) Reset()

func (*Address_TcpIpAddress) String Uses

func (m *Address_TcpIpAddress) String() string

func (*Address_TcpIpAddress) XXX_DiscardUnknown Uses

func (m *Address_TcpIpAddress) XXX_DiscardUnknown()

func (*Address_TcpIpAddress) XXX_Marshal Uses

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

func (*Address_TcpIpAddress) XXX_Merge Uses

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

func (*Address_TcpIpAddress) XXX_Size Uses

func (m *Address_TcpIpAddress) XXX_Size() int

func (*Address_TcpIpAddress) XXX_Unmarshal Uses

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

type Address_TcpipAddress Uses

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

type Address_UdsAddress Uses

type Address_UdsAddress struct {
    Filename             string   `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A Unix Domain Socket address.

func (*Address_UdsAddress) Descriptor Uses

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

func (*Address_UdsAddress) GetFilename Uses

func (m *Address_UdsAddress) GetFilename() string

func (*Address_UdsAddress) ProtoMessage Uses

func (*Address_UdsAddress) ProtoMessage()

func (*Address_UdsAddress) Reset Uses

func (m *Address_UdsAddress) Reset()

func (*Address_UdsAddress) String Uses

func (m *Address_UdsAddress) String() string

func (*Address_UdsAddress) XXX_DiscardUnknown Uses

func (m *Address_UdsAddress) XXX_DiscardUnknown()

func (*Address_UdsAddress) XXX_Marshal Uses

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

func (*Address_UdsAddress) XXX_Merge Uses

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

func (*Address_UdsAddress) XXX_Size Uses

func (m *Address_UdsAddress) XXX_Size() int

func (*Address_UdsAddress) XXX_Unmarshal Uses

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

type Address_UdsAddress_ Uses

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

type Channel Uses

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

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

func (*Channel) Descriptor Uses

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

func (*Channel) GetChannelRef Uses

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

func (*Channel) GetData Uses

func (m *Channel) GetData() *ChannelData

func (*Channel) GetRef Uses

func (m *Channel) GetRef() *ChannelRef

func (*Channel) GetSocketRef Uses

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

func (*Channel) GetSubchannelRef Uses

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

func (*Channel) ProtoMessage Uses

func (*Channel) ProtoMessage()

func (*Channel) Reset Uses

func (m *Channel) Reset()

func (*Channel) String Uses

func (m *Channel) String() string

func (*Channel) XXX_DiscardUnknown Uses

func (m *Channel) XXX_DiscardUnknown()

func (*Channel) XXX_Marshal Uses

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

func (*Channel) XXX_Merge Uses

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

func (*Channel) XXX_Size Uses

func (m *Channel) XXX_Size() int

func (*Channel) XXX_Unmarshal Uses

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

type ChannelConnectivityState Uses

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

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

func (*ChannelConnectivityState) Descriptor Uses

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

func (*ChannelConnectivityState) GetState Uses

func (m *ChannelConnectivityState) GetState() ChannelConnectivityState_State

func (*ChannelConnectivityState) ProtoMessage Uses

func (*ChannelConnectivityState) ProtoMessage()

func (*ChannelConnectivityState) Reset Uses

func (m *ChannelConnectivityState) Reset()

func (*ChannelConnectivityState) String Uses

func (m *ChannelConnectivityState) String() string

func (*ChannelConnectivityState) XXX_DiscardUnknown Uses

func (m *ChannelConnectivityState) XXX_DiscardUnknown()

func (*ChannelConnectivityState) XXX_Marshal Uses

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

func (*ChannelConnectivityState) XXX_Merge Uses

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

func (*ChannelConnectivityState) XXX_Size Uses

func (m *ChannelConnectivityState) XXX_Size() int

func (*ChannelConnectivityState) XXX_Unmarshal Uses

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

type ChannelConnectivityState_State Uses

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

func (ChannelConnectivityState_State) EnumDescriptor Uses

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

func (ChannelConnectivityState_State) String Uses

func (x ChannelConnectivityState_State) String() string

type ChannelData Uses

type ChannelData struct {
    // The connectivity state of the channel or subchannel.  Implementations
    // should always set this.
    State *ChannelConnectivityState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
    // The target this channel originally tried to connect to.  May be absent
    Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
    // A trace of recent events on the channel.  May be absent.
    Trace *ChannelTrace `protobuf:"bytes,3,opt,name=trace,proto3" json:"trace,omitempty"`
    // The number of calls started on the channel
    CallsStarted int64 `protobuf:"varint,4,opt,name=calls_started,json=callsStarted,proto3" json:"calls_started,omitempty"`
    // The number of calls that have completed with an OK status
    CallsSucceeded int64 `protobuf:"varint,5,opt,name=calls_succeeded,json=callsSucceeded,proto3" json:"calls_succeeded,omitempty"`
    // The number of calls that have completed with a non-OK status
    CallsFailed int64 `protobuf:"varint,6,opt,name=calls_failed,json=callsFailed,proto3" json:"calls_failed,omitempty"`
    // The last time a call was started on the channel.
    LastCallStartedTimestamp *timestamp.Timestamp `protobuf:"bytes,7,opt,name=last_call_started_timestamp,json=lastCallStartedTimestamp,proto3" json:"last_call_started_timestamp,omitempty"`
    XXX_NoUnkeyedLiteral     struct{}             `json:"-"`
    XXX_unrecognized         []byte               `json:"-"`
    XXX_sizecache            int32                `json:"-"`
}

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

func (*ChannelData) Descriptor Uses

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

func (*ChannelData) GetCallsFailed Uses

func (m *ChannelData) GetCallsFailed() int64

func (*ChannelData) GetCallsStarted Uses

func (m *ChannelData) GetCallsStarted() int64

func (*ChannelData) GetCallsSucceeded Uses

func (m *ChannelData) GetCallsSucceeded() int64

func (*ChannelData) GetLastCallStartedTimestamp Uses

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

func (*ChannelData) GetState Uses

func (m *ChannelData) GetState() *ChannelConnectivityState

func (*ChannelData) GetTarget Uses

func (m *ChannelData) GetTarget() string

func (*ChannelData) GetTrace Uses

func (m *ChannelData) GetTrace() *ChannelTrace

func (*ChannelData) ProtoMessage Uses

func (*ChannelData) ProtoMessage()

func (*ChannelData) Reset Uses

func (m *ChannelData) Reset()

func (*ChannelData) String Uses

func (m *ChannelData) String() string

func (*ChannelData) XXX_DiscardUnknown Uses

func (m *ChannelData) XXX_DiscardUnknown()

func (*ChannelData) XXX_Marshal Uses

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

func (*ChannelData) XXX_Merge Uses

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

func (*ChannelData) XXX_Size Uses

func (m *ChannelData) XXX_Size() int

func (*ChannelData) XXX_Unmarshal Uses

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

type ChannelRef Uses

type ChannelRef struct {
    // The globally unique id for this channel.  Must be a positive number.
    ChannelId int64 `protobuf:"varint,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
    // An optional name associated with the channel.
    Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

ChannelRef is a reference to a Channel.

func (*ChannelRef) Descriptor Uses

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

func (*ChannelRef) GetChannelId Uses

func (m *ChannelRef) GetChannelId() int64

func (*ChannelRef) GetName Uses

func (m *ChannelRef) GetName() string

func (*ChannelRef) ProtoMessage Uses

func (*ChannelRef) ProtoMessage()

func (*ChannelRef) Reset Uses

func (m *ChannelRef) Reset()

func (*ChannelRef) String Uses

func (m *ChannelRef) String() string

func (*ChannelRef) XXX_DiscardUnknown Uses

func (m *ChannelRef) XXX_DiscardUnknown()

func (*ChannelRef) XXX_Marshal Uses

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

func (*ChannelRef) XXX_Merge Uses

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

func (*ChannelRef) XXX_Size Uses

func (m *ChannelRef) XXX_Size() int

func (*ChannelRef) XXX_Unmarshal Uses

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

type ChannelTrace Uses

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

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

func (*ChannelTrace) Descriptor Uses

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

func (*ChannelTrace) GetCreationTimestamp Uses

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

func (*ChannelTrace) GetEvents Uses

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

func (*ChannelTrace) GetNumEventsLogged Uses

func (m *ChannelTrace) GetNumEventsLogged() int64

func (*ChannelTrace) ProtoMessage Uses

func (*ChannelTrace) ProtoMessage()

func (*ChannelTrace) Reset Uses

func (m *ChannelTrace) Reset()

func (*ChannelTrace) String Uses

func (m *ChannelTrace) String() string

func (*ChannelTrace) XXX_DiscardUnknown Uses

func (m *ChannelTrace) XXX_DiscardUnknown()

func (*ChannelTrace) XXX_Marshal Uses

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

func (*ChannelTrace) XXX_Merge Uses

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

func (*ChannelTrace) XXX_Size Uses

func (m *ChannelTrace) XXX_Size() int

func (*ChannelTrace) XXX_Unmarshal Uses

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

type ChannelTraceEvent Uses

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

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

func (*ChannelTraceEvent) Descriptor Uses

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

func (*ChannelTraceEvent) GetChannelRef Uses

func (m *ChannelTraceEvent) GetChannelRef() *ChannelRef

func (*ChannelTraceEvent) GetChildRef Uses

func (m *ChannelTraceEvent) GetChildRef() isChannelTraceEvent_ChildRef

func (*ChannelTraceEvent) GetDescription Uses

func (m *ChannelTraceEvent) GetDescription() string

func (*ChannelTraceEvent) GetSeverity Uses

func (m *ChannelTraceEvent) GetSeverity() ChannelTraceEvent_Severity

func (*ChannelTraceEvent) GetSubchannelRef Uses

func (m *ChannelTraceEvent) GetSubchannelRef() *SubchannelRef

func (*ChannelTraceEvent) GetTimestamp Uses

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

func (*ChannelTraceEvent) ProtoMessage Uses

func (*ChannelTraceEvent) ProtoMessage()

func (*ChannelTraceEvent) Reset Uses

func (m *ChannelTraceEvent) Reset()

func (*ChannelTraceEvent) String Uses

func (m *ChannelTraceEvent) String() string

func (*ChannelTraceEvent) XXX_DiscardUnknown Uses

func (m *ChannelTraceEvent) XXX_DiscardUnknown()

func (*ChannelTraceEvent) XXX_Marshal Uses

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

func (*ChannelTraceEvent) XXX_Merge Uses

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

func (*ChannelTraceEvent) XXX_OneofFuncs Uses

func (*ChannelTraceEvent) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ChannelTraceEvent) XXX_Size Uses

func (m *ChannelTraceEvent) XXX_Size() int

func (*ChannelTraceEvent) XXX_Unmarshal Uses

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

type ChannelTraceEvent_ChannelRef Uses

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

type ChannelTraceEvent_Severity Uses

type ChannelTraceEvent_Severity int32

The supported severity levels of trace events.

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

func (ChannelTraceEvent_Severity) EnumDescriptor Uses

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

func (ChannelTraceEvent_Severity) String Uses

func (x ChannelTraceEvent_Severity) String() string

type ChannelTraceEvent_SubchannelRef Uses

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

type ChannelzClient Uses

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

ChannelzClient is the client API for Channelz service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewChannelzClient Uses

func NewChannelzClient(cc *grpc.ClientConn) ChannelzClient

type ChannelzServer Uses

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

ChannelzServer is the server API for Channelz service.

type GetChannelRequest Uses

type GetChannelRequest struct {
    // channel_id is the identifier of the specific channel to get.
    ChannelId            int64    `protobuf:"varint,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetChannelRequest) Descriptor Uses

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

func (*GetChannelRequest) GetChannelId Uses

func (m *GetChannelRequest) GetChannelId() int64

func (*GetChannelRequest) ProtoMessage Uses

func (*GetChannelRequest) ProtoMessage()

func (*GetChannelRequest) Reset Uses

func (m *GetChannelRequest) Reset()

func (*GetChannelRequest) String Uses

func (m *GetChannelRequest) String() string

func (*GetChannelRequest) XXX_DiscardUnknown Uses

func (m *GetChannelRequest) XXX_DiscardUnknown()

func (*GetChannelRequest) XXX_Marshal Uses

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

func (*GetChannelRequest) XXX_Merge Uses

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

func (*GetChannelRequest) XXX_Size Uses

func (m *GetChannelRequest) XXX_Size() int

func (*GetChannelRequest) XXX_Unmarshal Uses

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

type GetChannelResponse Uses

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

func (*GetChannelResponse) Descriptor Uses

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

func (*GetChannelResponse) GetChannel Uses

func (m *GetChannelResponse) GetChannel() *Channel

func (*GetChannelResponse) ProtoMessage Uses

func (*GetChannelResponse) ProtoMessage()

func (*GetChannelResponse) Reset Uses

func (m *GetChannelResponse) Reset()

func (*GetChannelResponse) String Uses

func (m *GetChannelResponse) String() string

func (*GetChannelResponse) XXX_DiscardUnknown Uses

func (m *GetChannelResponse) XXX_DiscardUnknown()

func (*GetChannelResponse) XXX_Marshal Uses

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

func (*GetChannelResponse) XXX_Merge Uses

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

func (*GetChannelResponse) XXX_Size Uses

func (m *GetChannelResponse) XXX_Size() int

func (*GetChannelResponse) XXX_Unmarshal Uses

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

type GetServerRequest Uses

type GetServerRequest struct {
    // server_id is the identifier of the specific server to get.
    ServerId             int64    `protobuf:"varint,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetServerRequest) Descriptor Uses

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

func (*GetServerRequest) GetServerId Uses

func (m *GetServerRequest) GetServerId() int64

func (*GetServerRequest) ProtoMessage Uses

func (*GetServerRequest) ProtoMessage()

func (*GetServerRequest) Reset Uses

func (m *GetServerRequest) Reset()

func (*GetServerRequest) String Uses

func (m *GetServerRequest) String() string

func (*GetServerRequest) XXX_DiscardUnknown Uses

func (m *GetServerRequest) XXX_DiscardUnknown()

func (*GetServerRequest) XXX_Marshal Uses

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

func (*GetServerRequest) XXX_Merge Uses

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

func (*GetServerRequest) XXX_Size Uses

func (m *GetServerRequest) XXX_Size() int

func (*GetServerRequest) XXX_Unmarshal Uses

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

type GetServerResponse Uses

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

func (*GetServerResponse) Descriptor Uses

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

func (*GetServerResponse) GetServer Uses

func (m *GetServerResponse) GetServer() *Server

func (*GetServerResponse) ProtoMessage Uses

func (*GetServerResponse) ProtoMessage()

func (*GetServerResponse) Reset Uses

func (m *GetServerResponse) Reset()

func (*GetServerResponse) String Uses

func (m *GetServerResponse) String() string

func (*GetServerResponse) XXX_DiscardUnknown Uses

func (m *GetServerResponse) XXX_DiscardUnknown()

func (*GetServerResponse) XXX_Marshal Uses

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

func (*GetServerResponse) XXX_Merge Uses

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

func (*GetServerResponse) XXX_Size Uses

func (m *GetServerResponse) XXX_Size() int

func (*GetServerResponse) XXX_Unmarshal Uses

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

type GetServerSocketsRequest Uses

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

func (*GetServerSocketsRequest) Descriptor Uses

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

func (*GetServerSocketsRequest) GetMaxResults Uses

func (m *GetServerSocketsRequest) GetMaxResults() int64

func (*GetServerSocketsRequest) GetServerId Uses

func (m *GetServerSocketsRequest) GetServerId() int64

func (*GetServerSocketsRequest) GetStartSocketId Uses

func (m *GetServerSocketsRequest) GetStartSocketId() int64

func (*GetServerSocketsRequest) ProtoMessage Uses

func (*GetServerSocketsRequest) ProtoMessage()

func (*GetServerSocketsRequest) Reset Uses

func (m *GetServerSocketsRequest) Reset()

func (*GetServerSocketsRequest) String Uses

func (m *GetServerSocketsRequest) String() string

func (*GetServerSocketsRequest) XXX_DiscardUnknown Uses

func (m *GetServerSocketsRequest) XXX_DiscardUnknown()

func (*GetServerSocketsRequest) XXX_Marshal Uses

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

func (*GetServerSocketsRequest) XXX_Merge Uses

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

func (*GetServerSocketsRequest) XXX_Size Uses

func (m *GetServerSocketsRequest) XXX_Size() int

func (*GetServerSocketsRequest) XXX_Unmarshal Uses

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

type GetServerSocketsResponse Uses

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

func (*GetServerSocketsResponse) Descriptor Uses

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

func (*GetServerSocketsResponse) GetEnd Uses

func (m *GetServerSocketsResponse) GetEnd() bool

func (*GetServerSocketsResponse) GetSocketRef Uses

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

func (*GetServerSocketsResponse) ProtoMessage Uses

func (*GetServerSocketsResponse) ProtoMessage()

func (*GetServerSocketsResponse) Reset Uses

func (m *GetServerSocketsResponse) Reset()

func (*GetServerSocketsResponse) String Uses

func (m *GetServerSocketsResponse) String() string

func (*GetServerSocketsResponse) XXX_DiscardUnknown Uses

func (m *GetServerSocketsResponse) XXX_DiscardUnknown()

func (*GetServerSocketsResponse) XXX_Marshal Uses

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

func (*GetServerSocketsResponse) XXX_Merge Uses

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

func (*GetServerSocketsResponse) XXX_Size Uses

func (m *GetServerSocketsResponse) XXX_Size() int

func (*GetServerSocketsResponse) XXX_Unmarshal Uses

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

type GetServersRequest Uses

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

func (*GetServersRequest) Descriptor Uses

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

func (*GetServersRequest) GetMaxResults Uses

func (m *GetServersRequest) GetMaxResults() int64

func (*GetServersRequest) GetStartServerId Uses

func (m *GetServersRequest) GetStartServerId() int64

func (*GetServersRequest) ProtoMessage Uses

func (*GetServersRequest) ProtoMessage()

func (*GetServersRequest) Reset Uses

func (m *GetServersRequest) Reset()

func (*GetServersRequest) String Uses

func (m *GetServersRequest) String() string

func (*GetServersRequest) XXX_DiscardUnknown Uses

func (m *GetServersRequest) XXX_DiscardUnknown()

func (*GetServersRequest) XXX_Marshal Uses

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

func (*GetServersRequest) XXX_Merge Uses

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

func (*GetServersRequest) XXX_Size Uses

func (m *GetServersRequest) XXX_Size() int

func (*GetServersRequest) XXX_Unmarshal Uses

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

type GetServersResponse Uses

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

func (*GetServersResponse) Descriptor Uses

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

func (*GetServersResponse) GetEnd Uses

func (m *GetServersResponse) GetEnd() bool

func (*GetServersResponse) GetServer Uses

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

func (*GetServersResponse) ProtoMessage Uses

func (*GetServersResponse) ProtoMessage()

func (*GetServersResponse) Reset Uses

func (m *GetServersResponse) Reset()

func (*GetServersResponse) String Uses

func (m *GetServersResponse) String() string

func (*GetServersResponse) XXX_DiscardUnknown Uses

func (m *GetServersResponse) XXX_DiscardUnknown()

func (*GetServersResponse) XXX_Marshal Uses

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

func (*GetServersResponse) XXX_Merge Uses

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

func (*GetServersResponse) XXX_Size Uses

func (m *GetServersResponse) XXX_Size() int

func (*GetServersResponse) XXX_Unmarshal Uses

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

type GetSocketRequest Uses

type GetSocketRequest struct {
    // socket_id is the identifier of the specific socket to get.
    SocketId int64 `protobuf:"varint,1,opt,name=socket_id,json=socketId,proto3" json:"socket_id,omitempty"`
    // If true, the response will contain only high level information
    // that is inexpensive to obtain. Fields thay may be omitted are
    // documented.
    Summary              bool     `protobuf:"varint,2,opt,name=summary,proto3" json:"summary,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetSocketRequest) Descriptor Uses

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

func (*GetSocketRequest) GetSocketId Uses

func (m *GetSocketRequest) GetSocketId() int64

func (*GetSocketRequest) GetSummary Uses

func (m *GetSocketRequest) GetSummary() bool

func (*GetSocketRequest) ProtoMessage Uses

func (*GetSocketRequest) ProtoMessage()

func (*GetSocketRequest) Reset Uses

func (m *GetSocketRequest) Reset()

func (*GetSocketRequest) String Uses

func (m *GetSocketRequest) String() string

func (*GetSocketRequest) XXX_DiscardUnknown Uses

func (m *GetSocketRequest) XXX_DiscardUnknown()

func (*GetSocketRequest) XXX_Marshal Uses

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

func (*GetSocketRequest) XXX_Merge Uses

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

func (*GetSocketRequest) XXX_Size Uses

func (m *GetSocketRequest) XXX_Size() int

func (*GetSocketRequest) XXX_Unmarshal Uses

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

type GetSocketResponse Uses

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

func (*GetSocketResponse) Descriptor Uses

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

func (*GetSocketResponse) GetSocket Uses

func (m *GetSocketResponse) GetSocket() *Socket

func (*GetSocketResponse) ProtoMessage Uses

func (*GetSocketResponse) ProtoMessage()

func (*GetSocketResponse) Reset Uses

func (m *GetSocketResponse) Reset()

func (*GetSocketResponse) String Uses

func (m *GetSocketResponse) String() string

func (*GetSocketResponse) XXX_DiscardUnknown Uses

func (m *GetSocketResponse) XXX_DiscardUnknown()

func (*GetSocketResponse) XXX_Marshal Uses

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

func (*GetSocketResponse) XXX_Merge Uses

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

func (*GetSocketResponse) XXX_Size Uses

func (m *GetSocketResponse) XXX_Size() int

func (*GetSocketResponse) XXX_Unmarshal Uses

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

type GetSubchannelRequest Uses

type GetSubchannelRequest struct {
    // subchannel_id is the identifier of the specific subchannel to get.
    SubchannelId         int64    `protobuf:"varint,1,opt,name=subchannel_id,json=subchannelId,proto3" json:"subchannel_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetSubchannelRequest) Descriptor Uses

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

func (*GetSubchannelRequest) GetSubchannelId Uses

func (m *GetSubchannelRequest) GetSubchannelId() int64

func (*GetSubchannelRequest) ProtoMessage Uses

func (*GetSubchannelRequest) ProtoMessage()

func (*GetSubchannelRequest) Reset Uses

func (m *GetSubchannelRequest) Reset()

func (*GetSubchannelRequest) String Uses

func (m *GetSubchannelRequest) String() string

func (*GetSubchannelRequest) XXX_DiscardUnknown Uses

func (m *GetSubchannelRequest) XXX_DiscardUnknown()

func (*GetSubchannelRequest) XXX_Marshal Uses

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

func (*GetSubchannelRequest) XXX_Merge Uses

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

func (*GetSubchannelRequest) XXX_Size Uses

func (m *GetSubchannelRequest) XXX_Size() int

func (*GetSubchannelRequest) XXX_Unmarshal Uses

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

type GetSubchannelResponse Uses

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

func (*GetSubchannelResponse) Descriptor Uses

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

func (*GetSubchannelResponse) GetSubchannel Uses

func (m *GetSubchannelResponse) GetSubchannel() *Subchannel

func (*GetSubchannelResponse) ProtoMessage Uses

func (*GetSubchannelResponse) ProtoMessage()

func (*GetSubchannelResponse) Reset Uses

func (m *GetSubchannelResponse) Reset()

func (*GetSubchannelResponse) String Uses

func (m *GetSubchannelResponse) String() string

func (*GetSubchannelResponse) XXX_DiscardUnknown Uses

func (m *GetSubchannelResponse) XXX_DiscardUnknown()

func (*GetSubchannelResponse) XXX_Marshal Uses

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

func (*GetSubchannelResponse) XXX_Merge Uses

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

func (*GetSubchannelResponse) XXX_Size Uses

func (m *GetSubchannelResponse) XXX_Size() int

func (*GetSubchannelResponse) XXX_Unmarshal Uses

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

type GetTopChannelsRequest Uses

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

func (*GetTopChannelsRequest) Descriptor Uses

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

func (*GetTopChannelsRequest) GetMaxResults Uses

func (m *GetTopChannelsRequest) GetMaxResults() int64

func (*GetTopChannelsRequest) GetStartChannelId Uses

func (m *GetTopChannelsRequest) GetStartChannelId() int64

func (*GetTopChannelsRequest) ProtoMessage Uses

func (*GetTopChannelsRequest) ProtoMessage()

func (*GetTopChannelsRequest) Reset Uses

func (m *GetTopChannelsRequest) Reset()

func (*GetTopChannelsRequest) String Uses

func (m *GetTopChannelsRequest) String() string

func (*GetTopChannelsRequest) XXX_DiscardUnknown Uses

func (m *GetTopChannelsRequest) XXX_DiscardUnknown()

func (*GetTopChannelsRequest) XXX_Marshal Uses

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

func (*GetTopChannelsRequest) XXX_Merge Uses

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

func (*GetTopChannelsRequest) XXX_Size Uses

func (m *GetTopChannelsRequest) XXX_Size() int

func (*GetTopChannelsRequest) XXX_Unmarshal Uses

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

type GetTopChannelsResponse Uses

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

func (*GetTopChannelsResponse) Descriptor Uses

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

func (*GetTopChannelsResponse) GetChannel Uses

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

func (*GetTopChannelsResponse) GetEnd Uses

func (m *GetTopChannelsResponse) GetEnd() bool

func (*GetTopChannelsResponse) ProtoMessage Uses

func (*GetTopChannelsResponse) ProtoMessage()

func (*GetTopChannelsResponse) Reset Uses

func (m *GetTopChannelsResponse) Reset()

func (*GetTopChannelsResponse) String Uses

func (m *GetTopChannelsResponse) String() string

func (*GetTopChannelsResponse) XXX_DiscardUnknown Uses

func (m *GetTopChannelsResponse) XXX_DiscardUnknown()

func (*GetTopChannelsResponse) XXX_Marshal Uses

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

func (*GetTopChannelsResponse) XXX_Merge Uses

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

func (*GetTopChannelsResponse) XXX_Size Uses

func (m *GetTopChannelsResponse) XXX_Size() int

func (*GetTopChannelsResponse) XXX_Unmarshal Uses

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

type Security Uses

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

Security represents details about how secure the socket is.

func (*Security) Descriptor Uses

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

func (*Security) GetModel Uses

func (m *Security) GetModel() isSecurity_Model

func (*Security) GetOther Uses

func (m *Security) GetOther() *Security_OtherSecurity

func (*Security) GetTls Uses

func (m *Security) GetTls() *Security_Tls

func (*Security) ProtoMessage Uses

func (*Security) ProtoMessage()

func (*Security) Reset Uses

func (m *Security) Reset()

func (*Security) String Uses

func (m *Security) String() string

func (*Security) XXX_DiscardUnknown Uses

func (m *Security) XXX_DiscardUnknown()

func (*Security) XXX_Marshal Uses

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

func (*Security) XXX_Merge Uses

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

func (*Security) XXX_OneofFuncs Uses

func (*Security) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Security) XXX_Size Uses

func (m *Security) XXX_Size() int

func (*Security) XXX_Unmarshal Uses

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

type Security_Other Uses

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

type Security_OtherSecurity Uses

type Security_OtherSecurity struct {
    // The human readable version of the value.
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // The actual security details message.
    Value                *any.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*Security_OtherSecurity) Descriptor Uses

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

func (*Security_OtherSecurity) GetName Uses

func (m *Security_OtherSecurity) GetName() string

func (*Security_OtherSecurity) GetValue Uses

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

func (*Security_OtherSecurity) ProtoMessage Uses

func (*Security_OtherSecurity) ProtoMessage()

func (*Security_OtherSecurity) Reset Uses

func (m *Security_OtherSecurity) Reset()

func (*Security_OtherSecurity) String Uses

func (m *Security_OtherSecurity) String() string

func (*Security_OtherSecurity) XXX_DiscardUnknown Uses

func (m *Security_OtherSecurity) XXX_DiscardUnknown()

func (*Security_OtherSecurity) XXX_Marshal Uses

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

func (*Security_OtherSecurity) XXX_Merge Uses

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

func (*Security_OtherSecurity) XXX_Size Uses

func (m *Security_OtherSecurity) XXX_Size() int

func (*Security_OtherSecurity) XXX_Unmarshal Uses

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

type Security_Tls Uses

type Security_Tls struct {
    // Types that are valid to be assigned to CipherSuite:
    //	*Security_Tls_StandardName
    //	*Security_Tls_OtherName
    CipherSuite isSecurity_Tls_CipherSuite `protobuf_oneof:"cipher_suite"`
    // the certificate used by this endpoint.
    LocalCertificate []byte `protobuf:"bytes,3,opt,name=local_certificate,json=localCertificate,proto3" json:"local_certificate,omitempty"`
    // the certificate used by the remote endpoint.
    RemoteCertificate    []byte   `protobuf:"bytes,4,opt,name=remote_certificate,json=remoteCertificate,proto3" json:"remote_certificate,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*Security_Tls) Descriptor Uses

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

func (*Security_Tls) GetCipherSuite Uses

func (m *Security_Tls) GetCipherSuite() isSecurity_Tls_CipherSuite

func (*Security_Tls) GetLocalCertificate Uses

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

func (*Security_Tls) GetOtherName Uses

func (m *Security_Tls) GetOtherName() string

func (*Security_Tls) GetRemoteCertificate Uses

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

func (*Security_Tls) GetStandardName Uses

func (m *Security_Tls) GetStandardName() string

func (*Security_Tls) ProtoMessage Uses

func (*Security_Tls) ProtoMessage()

func (*Security_Tls) Reset Uses

func (m *Security_Tls) Reset()

func (*Security_Tls) String Uses

func (m *Security_Tls) String() string

func (*Security_Tls) XXX_DiscardUnknown Uses

func (m *Security_Tls) XXX_DiscardUnknown()

func (*Security_Tls) XXX_Marshal Uses

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

func (*Security_Tls) XXX_Merge Uses

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

func (*Security_Tls) XXX_OneofFuncs Uses

func (*Security_Tls) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Security_Tls) XXX_Size Uses

func (m *Security_Tls) XXX_Size() int

func (*Security_Tls) XXX_Unmarshal Uses

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

type Security_Tls_ Uses

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

type Security_Tls_OtherName Uses

type Security_Tls_OtherName struct {
    OtherName string `protobuf:"bytes,2,opt,name=other_name,json=otherName,proto3,oneof"`
}

type Security_Tls_StandardName Uses

type Security_Tls_StandardName struct {
    StandardName string `protobuf:"bytes,1,opt,name=standard_name,json=standardName,proto3,oneof"`
}

type Server Uses

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

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

func (*Server) Descriptor Uses

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

func (*Server) GetData Uses

func (m *Server) GetData() *ServerData

func (*Server) GetListenSocket Uses

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

func (*Server) GetRef Uses

func (m *Server) GetRef() *ServerRef

func (*Server) ProtoMessage Uses

func (*Server) ProtoMessage()

func (*Server) Reset Uses

func (m *Server) Reset()

func (*Server) String Uses

func (m *Server) String() string

func (*Server) XXX_DiscardUnknown Uses

func (m *Server) XXX_DiscardUnknown()

func (*Server) XXX_Marshal Uses

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

func (*Server) XXX_Merge Uses

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

func (*Server) XXX_Size Uses

func (m *Server) XXX_Size() int

func (*Server) XXX_Unmarshal Uses

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

type ServerData Uses

type ServerData struct {
    // A trace of recent events on the server.  May be absent.
    Trace *ChannelTrace `protobuf:"bytes,1,opt,name=trace,proto3" json:"trace,omitempty"`
    // The number of incoming calls started on the server
    CallsStarted int64 `protobuf:"varint,2,opt,name=calls_started,json=callsStarted,proto3" json:"calls_started,omitempty"`
    // The number of incoming calls that have completed with an OK status
    CallsSucceeded int64 `protobuf:"varint,3,opt,name=calls_succeeded,json=callsSucceeded,proto3" json:"calls_succeeded,omitempty"`
    // The number of incoming calls that have a completed with a non-OK status
    CallsFailed int64 `protobuf:"varint,4,opt,name=calls_failed,json=callsFailed,proto3" json:"calls_failed,omitempty"`
    // The last time a call was started on the server.
    LastCallStartedTimestamp *timestamp.Timestamp `protobuf:"bytes,5,opt,name=last_call_started_timestamp,json=lastCallStartedTimestamp,proto3" json:"last_call_started_timestamp,omitempty"`
    XXX_NoUnkeyedLiteral     struct{}             `json:"-"`
    XXX_unrecognized         []byte               `json:"-"`
    XXX_sizecache            int32                `json:"-"`
}

ServerData is data for a specific Server.

func (*ServerData) Descriptor Uses

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

func (*ServerData) GetCallsFailed Uses

func (m *ServerData) GetCallsFailed() int64

func (*ServerData) GetCallsStarted Uses

func (m *ServerData) GetCallsStarted() int64

func (*ServerData) GetCallsSucceeded Uses

func (m *ServerData) GetCallsSucceeded() int64

func (*ServerData) GetLastCallStartedTimestamp Uses

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

func (*ServerData) GetTrace Uses

func (m *ServerData) GetTrace() *ChannelTrace

func (*ServerData) ProtoMessage Uses

func (*ServerData) ProtoMessage()

func (*ServerData) Reset Uses

func (m *ServerData) Reset()

func (*ServerData) String Uses

func (m *ServerData) String() string

func (*ServerData) XXX_DiscardUnknown Uses

func (m *ServerData) XXX_DiscardUnknown()

func (*ServerData) XXX_Marshal Uses

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

func (*ServerData) XXX_Merge Uses

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

func (*ServerData) XXX_Size Uses

func (m *ServerData) XXX_Size() int

func (*ServerData) XXX_Unmarshal Uses

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

type ServerRef Uses

type ServerRef struct {
    // A globally unique identifier for this server.  Must be a positive number.
    ServerId int64 `protobuf:"varint,5,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
    // An optional name associated with the server.
    Name                 string   `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

ServerRef is a reference to a Server.

func (*ServerRef) Descriptor Uses

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

func (*ServerRef) GetName Uses

func (m *ServerRef) GetName() string

func (*ServerRef) GetServerId Uses

func (m *ServerRef) GetServerId() int64

func (*ServerRef) ProtoMessage Uses

func (*ServerRef) ProtoMessage()

func (*ServerRef) Reset Uses

func (m *ServerRef) Reset()

func (*ServerRef) String Uses

func (m *ServerRef) String() string

func (*ServerRef) XXX_DiscardUnknown Uses

func (m *ServerRef) XXX_DiscardUnknown()

func (*ServerRef) XXX_Marshal Uses

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

func (*ServerRef) XXX_Merge Uses

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

func (*ServerRef) XXX_Size Uses

func (m *ServerRef) XXX_Size() int

func (*ServerRef) XXX_Unmarshal Uses

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

type Socket Uses

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

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

func (*Socket) Descriptor Uses

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

func (*Socket) GetData Uses

func (m *Socket) GetData() *SocketData

func (*Socket) GetLocal Uses

func (m *Socket) GetLocal() *Address

func (*Socket) GetRef Uses

func (m *Socket) GetRef() *SocketRef

func (*Socket) GetRemote Uses

func (m *Socket) GetRemote() *Address

func (*Socket) GetRemoteName Uses

func (m *Socket) GetRemoteName() string

func (*Socket) GetSecurity Uses

func (m *Socket) GetSecurity() *Security

func (*Socket) ProtoMessage Uses

func (*Socket) ProtoMessage()

func (*Socket) Reset Uses

func (m *Socket) Reset()

func (*Socket) String Uses

func (m *Socket) String() string

func (*Socket) XXX_DiscardUnknown Uses

func (m *Socket) XXX_DiscardUnknown()

func (*Socket) XXX_Marshal Uses

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

func (*Socket) XXX_Merge Uses

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

func (*Socket) XXX_Size Uses

func (m *Socket) XXX_Size() int

func (*Socket) XXX_Unmarshal Uses

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

type SocketData Uses

type SocketData struct {
    // The number of streams that have been started.
    StreamsStarted int64 `protobuf:"varint,1,opt,name=streams_started,json=streamsStarted,proto3" json:"streams_started,omitempty"`
    // The number of streams that have ended successfully:
    // On client side, received frame with eos bit set;
    // On server side, sent frame with eos bit set.
    StreamsSucceeded int64 `protobuf:"varint,2,opt,name=streams_succeeded,json=streamsSucceeded,proto3" json:"streams_succeeded,omitempty"`
    // The number of streams that have ended unsuccessfully:
    // On client side, ended without receiving frame with eos bit set;
    // On server side, ended without sending frame with eos bit set.
    StreamsFailed int64 `protobuf:"varint,3,opt,name=streams_failed,json=streamsFailed,proto3" json:"streams_failed,omitempty"`
    // The number of grpc messages successfully sent on this socket.
    MessagesSent int64 `protobuf:"varint,4,opt,name=messages_sent,json=messagesSent,proto3" json:"messages_sent,omitempty"`
    // The number of grpc messages received on this socket.
    MessagesReceived int64 `protobuf:"varint,5,opt,name=messages_received,json=messagesReceived,proto3" json:"messages_received,omitempty"`
    // The number of keep alives sent.  This is typically implemented with HTTP/2
    // ping messages.
    KeepAlivesSent int64 `protobuf:"varint,6,opt,name=keep_alives_sent,json=keepAlivesSent,proto3" json:"keep_alives_sent,omitempty"`
    // The last time a stream was created by this endpoint.  Usually unset for
    // servers.
    LastLocalStreamCreatedTimestamp *timestamp.Timestamp `protobuf:"bytes,7,opt,name=last_local_stream_created_timestamp,json=lastLocalStreamCreatedTimestamp,proto3" json:"last_local_stream_created_timestamp,omitempty"`
    // The last time a stream was created by the remote endpoint.  Usually unset
    // for clients.
    LastRemoteStreamCreatedTimestamp *timestamp.Timestamp `protobuf:"bytes,8,opt,name=last_remote_stream_created_timestamp,json=lastRemoteStreamCreatedTimestamp,proto3" json:"last_remote_stream_created_timestamp,omitempty"`
    // The last time a message was sent by this endpoint.
    LastMessageSentTimestamp *timestamp.Timestamp `protobuf:"bytes,9,opt,name=last_message_sent_timestamp,json=lastMessageSentTimestamp,proto3" json:"last_message_sent_timestamp,omitempty"`
    // The last time a message was received by this endpoint.
    LastMessageReceivedTimestamp *timestamp.Timestamp `protobuf:"bytes,10,opt,name=last_message_received_timestamp,json=lastMessageReceivedTimestamp,proto3" json:"last_message_received_timestamp,omitempty"`
    // The amount of window, granted to the local endpoint by the remote endpoint.
    // This may be slightly out of date due to network latency.  This does NOT
    // include stream level or TCP level flow control info.
    LocalFlowControlWindow *wrappers.Int64Value `protobuf:"bytes,11,opt,name=local_flow_control_window,json=localFlowControlWindow,proto3" json:"local_flow_control_window,omitempty"`
    // The amount of window, granted to the remote endpoint by the local endpoint.
    // This may be slightly out of date due to network latency.  This does NOT
    // include stream level or TCP level flow control info.
    RemoteFlowControlWindow *wrappers.Int64Value `protobuf:"bytes,12,opt,name=remote_flow_control_window,json=remoteFlowControlWindow,proto3" json:"remote_flow_control_window,omitempty"`
    // Socket options set on this socket.  May be absent if 'summary' is set
    // on GetSocketRequest.
    Option               []*SocketOption `protobuf:"bytes,13,rep,name=option,proto3" json:"option,omitempty"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

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

func (*SocketData) Descriptor Uses

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

func (*SocketData) GetKeepAlivesSent Uses

func (m *SocketData) GetKeepAlivesSent() int64

func (*SocketData) GetLastLocalStreamCreatedTimestamp Uses

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

func (*SocketData) GetLastMessageReceivedTimestamp Uses

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

func (*SocketData) GetLastMessageSentTimestamp Uses

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

func (*SocketData) GetLastRemoteStreamCreatedTimestamp Uses

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

func (*SocketData) GetLocalFlowControlWindow Uses

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

func (*SocketData) GetMessagesReceived Uses

func (m *SocketData) GetMessagesReceived() int64

func (*SocketData) GetMessagesSent Uses

func (m *SocketData) GetMessagesSent() int64

func (*SocketData) GetOption Uses

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

func (*SocketData) GetRemoteFlowControlWindow Uses

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

func (*SocketData) GetStreamsFailed Uses

func (m *SocketData) GetStreamsFailed() int64

func (*SocketData) GetStreamsStarted Uses

func (m *SocketData) GetStreamsStarted() int64

func (*SocketData) GetStreamsSucceeded Uses

func (m *SocketData) GetStreamsSucceeded() int64

func (*SocketData) ProtoMessage Uses

func (*SocketData) ProtoMessage()

func (*SocketData) Reset Uses

func (m *SocketData) Reset()

func (*SocketData) String Uses

func (m *SocketData) String() string

func (*SocketData) XXX_DiscardUnknown Uses

func (m *SocketData) XXX_DiscardUnknown()

func (*SocketData) XXX_Marshal Uses

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

func (*SocketData) XXX_Merge Uses

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

func (*SocketData) XXX_Size Uses

func (m *SocketData) XXX_Size() int

func (*SocketData) XXX_Unmarshal Uses

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

type SocketOption Uses

type SocketOption struct {
    // The full name of the socket option.  Typically this will be the upper case
    // name, such as "SO_REUSEPORT".
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // The human readable value of this socket option.  At least one of value or
    // additional will be set.
    Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
    // Additional data associated with the socket option.  At least one of value
    // or additional will be set.
    Additional           *any.Any `protobuf:"bytes,3,opt,name=additional,proto3" json:"additional,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*SocketOption) Descriptor Uses

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

func (*SocketOption) GetAdditional Uses

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

func (*SocketOption) GetName Uses

func (m *SocketOption) GetName() string

func (*SocketOption) GetValue Uses

func (m *SocketOption) GetValue() string

func (*SocketOption) ProtoMessage Uses

func (*SocketOption) ProtoMessage()

func (*SocketOption) Reset Uses

func (m *SocketOption) Reset()

func (*SocketOption) String Uses

func (m *SocketOption) String() string

func (*SocketOption) XXX_DiscardUnknown Uses

func (m *SocketOption) XXX_DiscardUnknown()

func (*SocketOption) XXX_Marshal Uses

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

func (*SocketOption) XXX_Merge Uses

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

func (*SocketOption) XXX_Size Uses

func (m *SocketOption) XXX_Size() int

func (*SocketOption) XXX_Unmarshal Uses

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

type SocketOptionLinger Uses

type SocketOptionLinger struct {
    // active maps to `struct linger.l_onoff`
    Active bool `protobuf:"varint,1,opt,name=active,proto3" json:"active,omitempty"`
    // duration maps to `struct linger.l_linger`
    Duration             *duration.Duration `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"`
    XXX_NoUnkeyedLiteral struct{}           `json:"-"`
    XXX_unrecognized     []byte             `json:"-"`
    XXX_sizecache        int32              `json:"-"`
}

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

func (*SocketOptionLinger) Descriptor Uses

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

func (*SocketOptionLinger) GetActive Uses

func (m *SocketOptionLinger) GetActive() bool

func (*SocketOptionLinger) GetDuration Uses

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

func (*SocketOptionLinger) ProtoMessage Uses

func (*SocketOptionLinger) ProtoMessage()

func (*SocketOptionLinger) Reset Uses

func (m *SocketOptionLinger) Reset()

func (*SocketOptionLinger) String Uses

func (m *SocketOptionLinger) String() string

func (*SocketOptionLinger) XXX_DiscardUnknown Uses

func (m *SocketOptionLinger) XXX_DiscardUnknown()

func (*SocketOptionLinger) XXX_Marshal Uses

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

func (*SocketOptionLinger) XXX_Merge Uses

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

func (*SocketOptionLinger) XXX_Size Uses

func (m *SocketOptionLinger) XXX_Size() int

func (*SocketOptionLinger) XXX_Unmarshal Uses

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

type SocketOptionTcpInfo Uses

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

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

func (*SocketOptionTcpInfo) Descriptor Uses

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

func (*SocketOptionTcpInfo) GetTcpiAdvmss Uses

func (m *SocketOptionTcpInfo) GetTcpiAdvmss() uint32

func (*SocketOptionTcpInfo) GetTcpiAto Uses

func (m *SocketOptionTcpInfo) GetTcpiAto() uint32

func (*SocketOptionTcpInfo) GetTcpiBackoff Uses

func (m *SocketOptionTcpInfo) GetTcpiBackoff() uint32

func (*SocketOptionTcpInfo) GetTcpiCaState Uses

func (m *SocketOptionTcpInfo) GetTcpiCaState() uint32

func (*SocketOptionTcpInfo) GetTcpiFackets Uses

func (m *SocketOptionTcpInfo) GetTcpiFackets() uint32

func (*SocketOptionTcpInfo) GetTcpiLastAckRecv Uses

func (m *SocketOptionTcpInfo) GetTcpiLastAckRecv() uint32

func (*SocketOptionTcpInfo) GetTcpiLastAckSent Uses

func (m *SocketOptionTcpInfo) GetTcpiLastAckSent() uint32

func (*SocketOptionTcpInfo) GetTcpiLastDataRecv Uses

func (m *SocketOptionTcpInfo) GetTcpiLastDataRecv() uint32

func (*SocketOptionTcpInfo) GetTcpiLastDataSent Uses

func (m *SocketOptionTcpInfo) GetTcpiLastDataSent() uint32

func (*SocketOptionTcpInfo) GetTcpiLost Uses

func (m *SocketOptionTcpInfo) GetTcpiLost() uint32

func (*SocketOptionTcpInfo) GetTcpiOptions Uses

func (m *SocketOptionTcpInfo) GetTcpiOptions() uint32

func (*SocketOptionTcpInfo) GetTcpiPmtu Uses

func (m *SocketOptionTcpInfo) GetTcpiPmtu() uint32

func (*SocketOptionTcpInfo) GetTcpiProbes Uses

func (m *SocketOptionTcpInfo) GetTcpiProbes() uint32

func (*SocketOptionTcpInfo) GetTcpiRcvMss Uses

func (m *SocketOptionTcpInfo) GetTcpiRcvMss() uint32

func (*SocketOptionTcpInfo) GetTcpiRcvSsthresh Uses

func (m *SocketOptionTcpInfo) GetTcpiRcvSsthresh() uint32

func (*SocketOptionTcpInfo) GetTcpiRcvWscale Uses

func (m *SocketOptionTcpInfo) GetTcpiRcvWscale() uint32

func (*SocketOptionTcpInfo) GetTcpiReordering Uses

func (m *SocketOptionTcpInfo) GetTcpiReordering() uint32

func (*SocketOptionTcpInfo) GetTcpiRetrans Uses

func (m *SocketOptionTcpInfo) GetTcpiRetrans() uint32

func (*SocketOptionTcpInfo) GetTcpiRetransmits Uses

func (m *SocketOptionTcpInfo) GetTcpiRetransmits() uint32

func (*SocketOptionTcpInfo) GetTcpiRto Uses

func (m *SocketOptionTcpInfo) GetTcpiRto() uint32

func (*SocketOptionTcpInfo) GetTcpiRtt Uses

func (m *SocketOptionTcpInfo) GetTcpiRtt() uint32

func (*SocketOptionTcpInfo) GetTcpiRttvar Uses

func (m *SocketOptionTcpInfo) GetTcpiRttvar() uint32

func (*SocketOptionTcpInfo) GetTcpiSacked Uses

func (m *SocketOptionTcpInfo) GetTcpiSacked() uint32

func (*SocketOptionTcpInfo) GetTcpiSndCwnd Uses

func (m *SocketOptionTcpInfo) GetTcpiSndCwnd() uint32

func (*SocketOptionTcpInfo) GetTcpiSndMss Uses

func (m *SocketOptionTcpInfo) GetTcpiSndMss() uint32

func (*SocketOptionTcpInfo) GetTcpiSndSsthresh Uses

func (m *SocketOptionTcpInfo) GetTcpiSndSsthresh() uint32

func (*SocketOptionTcpInfo) GetTcpiSndWscale Uses

func (m *SocketOptionTcpInfo) GetTcpiSndWscale() uint32

func (*SocketOptionTcpInfo) GetTcpiState Uses

func (m *SocketOptionTcpInfo) GetTcpiState() uint32

func (*SocketOptionTcpInfo) GetTcpiUnacked Uses

func (m *SocketOptionTcpInfo) GetTcpiUnacked() uint32

func (*SocketOptionTcpInfo) ProtoMessage Uses

func (*SocketOptionTcpInfo) ProtoMessage()

func (*SocketOptionTcpInfo) Reset Uses

func (m *SocketOptionTcpInfo) Reset()

func (*SocketOptionTcpInfo) String Uses

func (m *SocketOptionTcpInfo) String() string

func (*SocketOptionTcpInfo) XXX_DiscardUnknown Uses

func (m *SocketOptionTcpInfo) XXX_DiscardUnknown()

func (*SocketOptionTcpInfo) XXX_Marshal Uses

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

func (*SocketOptionTcpInfo) XXX_Merge Uses

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

func (*SocketOptionTcpInfo) XXX_Size Uses

func (m *SocketOptionTcpInfo) XXX_Size() int

func (*SocketOptionTcpInfo) XXX_Unmarshal Uses

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

type SocketOptionTimeout Uses

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

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

func (*SocketOptionTimeout) Descriptor Uses

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

func (*SocketOptionTimeout) GetDuration Uses

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

func (*SocketOptionTimeout) ProtoMessage Uses

func (*SocketOptionTimeout) ProtoMessage()

func (*SocketOptionTimeout) Reset Uses

func (m *SocketOptionTimeout) Reset()

func (*SocketOptionTimeout) String Uses

func (m *SocketOptionTimeout) String() string

func (*SocketOptionTimeout) XXX_DiscardUnknown Uses

func (m *SocketOptionTimeout) XXX_DiscardUnknown()

func (*SocketOptionTimeout) XXX_Marshal Uses

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

func (*SocketOptionTimeout) XXX_Merge Uses

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

func (*SocketOptionTimeout) XXX_Size Uses

func (m *SocketOptionTimeout) XXX_Size() int

func (*SocketOptionTimeout) XXX_Unmarshal Uses

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

type SocketRef Uses

type SocketRef struct {
    // The globally unique id for this socket.  Must be a positive number.
    SocketId int64 `protobuf:"varint,3,opt,name=socket_id,json=socketId,proto3" json:"socket_id,omitempty"`
    // An optional name associated with the socket.
    Name                 string   `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

SocketRef is a reference to a Socket.

func (*SocketRef) Descriptor Uses

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

func (*SocketRef) GetName Uses

func (m *SocketRef) GetName() string

func (*SocketRef) GetSocketId Uses

func (m *SocketRef) GetSocketId() int64

func (*SocketRef) ProtoMessage Uses

func (*SocketRef) ProtoMessage()

func (*SocketRef) Reset Uses

func (m *SocketRef) Reset()

func (*SocketRef) String Uses

func (m *SocketRef) String() string

func (*SocketRef) XXX_DiscardUnknown Uses

func (m *SocketRef) XXX_DiscardUnknown()

func (*SocketRef) XXX_Marshal Uses

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

func (*SocketRef) XXX_Merge Uses

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

func (*SocketRef) XXX_Size Uses

func (m *SocketRef) XXX_Size() int

func (*SocketRef) XXX_Unmarshal Uses

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

type Subchannel Uses

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

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

func (*Subchannel) Descriptor Uses

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

func (*Subchannel) GetChannelRef Uses

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

func (*Subchannel) GetData Uses

func (m *Subchannel) GetData() *ChannelData

func (*Subchannel) GetRef Uses

func (m *Subchannel) GetRef() *SubchannelRef

func (*Subchannel) GetSocketRef Uses

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

func (*Subchannel) GetSubchannelRef Uses

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

func (*Subchannel) ProtoMessage Uses

func (*Subchannel) ProtoMessage()

func (*Subchannel) Reset Uses

func (m *Subchannel) Reset()

func (*Subchannel) String Uses

func (m *Subchannel) String() string

func (*Subchannel) XXX_DiscardUnknown Uses

func (m *Subchannel) XXX_DiscardUnknown()

func (*Subchannel) XXX_Marshal Uses

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

func (*Subchannel) XXX_Merge Uses

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

func (*Subchannel) XXX_Size Uses

func (m *Subchannel) XXX_Size() int

func (*Subchannel) XXX_Unmarshal Uses

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

type SubchannelRef Uses

type SubchannelRef struct {
    // The globally unique id for this subchannel.  Must be a positive number.
    SubchannelId int64 `protobuf:"varint,7,opt,name=subchannel_id,json=subchannelId,proto3" json:"subchannel_id,omitempty"`
    // An optional name associated with the subchannel.
    Name                 string   `protobuf:"bytes,8,opt,name=name,proto3" json:"name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

ChannelRef is a reference to a Subchannel.

func (*SubchannelRef) Descriptor Uses

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

func (*SubchannelRef) GetName Uses

func (m *SubchannelRef) GetName() string

func (*SubchannelRef) GetSubchannelId Uses

func (m *SubchannelRef) GetSubchannelId() int64

func (*SubchannelRef) ProtoMessage Uses

func (*SubchannelRef) ProtoMessage()

func (*SubchannelRef) Reset Uses

func (m *SubchannelRef) Reset()

func (*SubchannelRef) String Uses

func (m *SubchannelRef) String() string

func (*SubchannelRef) XXX_DiscardUnknown Uses

func (m *SubchannelRef) XXX_DiscardUnknown()

func (*SubchannelRef) XXX_Marshal Uses

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

func (*SubchannelRef) XXX_Merge Uses

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

func (*SubchannelRef) XXX_Size Uses

func (m *SubchannelRef) XXX_Size() int

func (*SubchannelRef) XXX_Unmarshal Uses

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

Package grpc_channelz_v1 imports 9 packages (graph) and is imported by 2 packages. Updated 2018-10-30. Refresh now. Tools for package owners.