grpc_channelz

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Nov 24, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ChannelzServerName = "grpc.channelz.v1.Channelz"
)

Variables

View Source 
var DefaultChannelzClients = NewChannelzClients()

Functions

This section is empty.

Types

type ChannelzClients 

type ChannelzClients interface {
	WithServiceName(serviceName string) ChannelzClients
	// 发送到一个节点
	Unicast() ChannelzClientsUnicast
	Multicast(count int) ChannelzClientsMulticast
	// 广播给所有节点
	Broadcast() ChannelzClientsMulticast

	// 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, address string, in *grpc_channelz_v1.GetTopChannelsRequest, opts ...grpc.CallOption) (*grpc_channelz_v1.GetTopChannelsResponse, error)
	// Gets all servers that exist in the process.
	GetServers(ctx context.Context, address string, in *grpc_channelz_v1.GetServersRequest, opts ...grpc.CallOption) (*grpc_channelz_v1.GetServersResponse, error)
	// Returns a single Server, or else a NOT_FOUND code.
	GetServer(ctx context.Context, address string, in *grpc_channelz_v1.GetServerRequest, opts ...grpc.CallOption) (*grpc_channelz_v1.GetServerResponse, error)
	// Gets all server sockets that exist in the process.
	GetServerSockets(ctx context.Context, address string, in *grpc_channelz_v1.GetServerSocketsRequest, opts ...grpc.CallOption) (*grpc_channelz_v1.GetServerSocketsResponse, error)
	// Returns a single Channel, or else a NOT_FOUND code.
	GetChannel(ctx context.Context, address string, in *grpc_channelz_v1.GetChannelRequest, opts ...grpc.CallOption) (*grpc_channelz_v1.GetChannelResponse, error)
	// Returns a single Subchannel, or else a NOT_FOUND code.
	GetSubchannel(ctx context.Context, address string, in *grpc_channelz_v1.GetSubchannelRequest, opts ...grpc.CallOption) (*grpc_channelz_v1.GetSubchannelResponse, error)
	// Returns a single Socket or else a NOT_FOUND code.
	GetSocket(ctx context.Context, address string, in *grpc_channelz_v1.GetSocketRequest, opts ...grpc.CallOption) (*grpc_channelz_v1.GetSocketResponse, error)
}

ChannelzClient is the client API for Channelz service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewChannelzClients 

func NewChannelzClients() ChannelzClients

type ChannelzClientsMulticast 

type ChannelzClientsMulticast interface {
	WhereRegex(regex string) ChannelzClientsMulticast
	WherePrefix(prefix bool) ChannelzClientsMulticast
	Local() ChannelzClientsMulticast
	// 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 *grpc_channelz_v1.GetTopChannelsRequest, opts ...grpc.CallOption) (*GetTopChannelsResponse_MulticastResult, error)
	// Gets all servers that exist in the process.
	GetServers(ctx context.Context, in *grpc_channelz_v1.GetServersRequest, opts ...grpc.CallOption) (*GetServersResponse_MulticastResult, error)
	// Returns a single Server, or else a NOT_FOUND code.
	GetServer(ctx context.Context, in *grpc_channelz_v1.GetServerRequest, opts ...grpc.CallOption) (*GetServerResponse_MulticastResult, error)
	// Gets all server sockets that exist in the process.
	GetServerSockets(ctx context.Context, in *grpc_channelz_v1.GetServerSocketsRequest, opts ...grpc.CallOption) (*GetServerSocketsResponse_MulticastResult, error)
	// Returns a single Channel, or else a NOT_FOUND code.
	GetChannel(ctx context.Context, in *grpc_channelz_v1.GetChannelRequest, opts ...grpc.CallOption) (*GetChannelResponse_MulticastResult, error)
	// Returns a single Subchannel, or else a NOT_FOUND code.
	GetSubchannel(ctx context.Context, in *grpc_channelz_v1.GetSubchannelRequest, opts ...grpc.CallOption) (*GetSubchannelResponse_MulticastResult, error)
	// Returns a single Socket or else a NOT_FOUND code.
	GetSocket(ctx context.Context, in *grpc_channelz_v1.GetSocketRequest, opts ...grpc.CallOption) (*GetSocketResponse_MulticastResult, error)
}

type ChannelzClientsUnicast 

type ChannelzClientsUnicast interface {
	Where(serviceName string) ChannelzClientsUnicast
	WherePeer(peer *gira.Peer) ChannelzClientsUnicast
	WherePeerFullName(appFullName string) ChannelzClientsUnicast
	WhereAddress(address string) ChannelzClientsUnicast
	WhereUser(userId string) ChannelzClientsUnicast
	Local() ChannelzClientsUnicast

	// 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 *grpc_channelz_v1.GetTopChannelsRequest, opts ...grpc.CallOption) (*grpc_channelz_v1.GetTopChannelsResponse, error)
	// Gets all servers that exist in the process.
	GetServers(ctx context.Context, in *grpc_channelz_v1.GetServersRequest, opts ...grpc.CallOption) (*grpc_channelz_v1.GetServersResponse, error)
	// Returns a single Server, or else a NOT_FOUND code.
	GetServer(ctx context.Context, in *grpc_channelz_v1.GetServerRequest, opts ...grpc.CallOption) (*grpc_channelz_v1.GetServerResponse, error)
	// Gets all server sockets that exist in the process.
	GetServerSockets(ctx context.Context, in *grpc_channelz_v1.GetServerSocketsRequest, opts ...grpc.CallOption) (*grpc_channelz_v1.GetServerSocketsResponse, error)
	// Returns a single Channel, or else a NOT_FOUND code.
	GetChannel(ctx context.Context, in *grpc_channelz_v1.GetChannelRequest, opts ...grpc.CallOption) (*grpc_channelz_v1.GetChannelResponse, error)
	// Returns a single Subchannel, or else a NOT_FOUND code.
	GetSubchannel(ctx context.Context, in *grpc_channelz_v1.GetSubchannelRequest, opts ...grpc.CallOption) (*grpc_channelz_v1.GetSubchannelResponse, error)
	// Returns a single Socket or else a NOT_FOUND code.
	GetSocket(ctx context.Context, in *grpc_channelz_v1.GetSocketRequest, opts ...grpc.CallOption) (*grpc_channelz_v1.GetSocketResponse, error)
}

type GetChannelResponse_MulticastResult 

type GetChannelResponse_MulticastResult struct {
	// contains filtered or unexported fields
}

func (*GetChannelResponse_MulticastResult) Error 

func (r *GetChannelResponse_MulticastResult) Error() error

func (*GetChannelResponse_MulticastResult) ErrorCount 

func (r *GetChannelResponse_MulticastResult) ErrorCount() int

func (*GetChannelResponse_MulticastResult) ErrorPeer 

func (r *GetChannelResponse_MulticastResult) ErrorPeer(index int) *gira.Peer

func (*GetChannelResponse_MulticastResult) Errors 

func (r *GetChannelResponse_MulticastResult) Errors(index int) error

func (*GetChannelResponse_MulticastResult) PeerCount 

func (r *GetChannelResponse_MulticastResult) PeerCount() int

func (*GetChannelResponse_MulticastResult) Response 

func (r *GetChannelResponse_MulticastResult) Response(index int) *grpc_channelz_v1.GetChannelResponse

func (*GetChannelResponse_MulticastResult) SuccessCount 

func (r *GetChannelResponse_MulticastResult) SuccessCount() int

func (*GetChannelResponse_MulticastResult) SuccessPeer 

func (r *GetChannelResponse_MulticastResult) SuccessPeer(index int) *gira.Peer

type GetServerResponse_MulticastResult 

type GetServerResponse_MulticastResult struct {
	// contains filtered or unexported fields
}

func (*GetServerResponse_MulticastResult) Error 

func (r *GetServerResponse_MulticastResult) Error() error

func (*GetServerResponse_MulticastResult) ErrorCount 

func (r *GetServerResponse_MulticastResult) ErrorCount() int

func (*GetServerResponse_MulticastResult) ErrorPeer 

func (r *GetServerResponse_MulticastResult) ErrorPeer(index int) *gira.Peer

func (*GetServerResponse_MulticastResult) Errors 

func (r *GetServerResponse_MulticastResult) Errors(index int) error

func (*GetServerResponse_MulticastResult) PeerCount 

func (r *GetServerResponse_MulticastResult) PeerCount() int

func (*GetServerResponse_MulticastResult) Response 

func (r *GetServerResponse_MulticastResult) Response(index int) *grpc_channelz_v1.GetServerResponse

func (*GetServerResponse_MulticastResult) SuccessCount 

func (r *GetServerResponse_MulticastResult) SuccessCount() int

func (*GetServerResponse_MulticastResult) SuccessPeer 

func (r *GetServerResponse_MulticastResult) SuccessPeer(index int) *gira.Peer

type GetServerSocketsResponse_MulticastResult 

type GetServerSocketsResponse_MulticastResult struct {
	// contains filtered or unexported fields
}

func (*GetServerSocketsResponse_MulticastResult) Error 

func (r *GetServerSocketsResponse_MulticastResult) Error() error

func (*GetServerSocketsResponse_MulticastResult) ErrorCount 

func (r *GetServerSocketsResponse_MulticastResult) ErrorCount() int

func (*GetServerSocketsResponse_MulticastResult) ErrorPeer 

func (r *GetServerSocketsResponse_MulticastResult) ErrorPeer(index int) *gira.Peer

func (*GetServerSocketsResponse_MulticastResult) Errors 

func (r *GetServerSocketsResponse_MulticastResult) Errors(index int) error

func (*GetServerSocketsResponse_MulticastResult) PeerCount 

func (r *GetServerSocketsResponse_MulticastResult) PeerCount() int

func (*GetServerSocketsResponse_MulticastResult) Response 

func (r *GetServerSocketsResponse_MulticastResult) Response(index int) *grpc_channelz_v1.GetServerSocketsResponse

func (*GetServerSocketsResponse_MulticastResult) SuccessCount 

func (r *GetServerSocketsResponse_MulticastResult) SuccessCount() int

func (*GetServerSocketsResponse_MulticastResult) SuccessPeer 

func (r *GetServerSocketsResponse_MulticastResult) SuccessPeer(index int) *gira.Peer

type GetServersResponse_MulticastResult 

type GetServersResponse_MulticastResult struct {
	// contains filtered or unexported fields
}

func (*GetServersResponse_MulticastResult) Error 

func (r *GetServersResponse_MulticastResult) Error() error

func (*GetServersResponse_MulticastResult) ErrorCount 

func (r *GetServersResponse_MulticastResult) ErrorCount() int

func (*GetServersResponse_MulticastResult) ErrorPeer 

func (r *GetServersResponse_MulticastResult) ErrorPeer(index int) *gira.Peer

func (*GetServersResponse_MulticastResult) Errors 

func (r *GetServersResponse_MulticastResult) Errors(index int) error

func (*GetServersResponse_MulticastResult) PeerCount 

func (r *GetServersResponse_MulticastResult) PeerCount() int

func (*GetServersResponse_MulticastResult) Response 

func (r *GetServersResponse_MulticastResult) Response(index int) *grpc_channelz_v1.GetServersResponse

func (*GetServersResponse_MulticastResult) SuccessCount 

func (r *GetServersResponse_MulticastResult) SuccessCount() int

func (*GetServersResponse_MulticastResult) SuccessPeer 

func (r *GetServersResponse_MulticastResult) SuccessPeer(index int) *gira.Peer

type GetSocketResponse_MulticastResult 

type GetSocketResponse_MulticastResult struct {
	// contains filtered or unexported fields
}

func (*GetSocketResponse_MulticastResult) Error 

func (r *GetSocketResponse_MulticastResult) Error() error

func (*GetSocketResponse_MulticastResult) ErrorCount 

func (r *GetSocketResponse_MulticastResult) ErrorCount() int

func (*GetSocketResponse_MulticastResult) ErrorPeer 

func (r *GetSocketResponse_MulticastResult) ErrorPeer(index int) *gira.Peer

func (*GetSocketResponse_MulticastResult) Errors 

func (r *GetSocketResponse_MulticastResult) Errors(index int) error

func (*GetSocketResponse_MulticastResult) PeerCount 

func (r *GetSocketResponse_MulticastResult) PeerCount() int

func (*GetSocketResponse_MulticastResult) Response 

func (r *GetSocketResponse_MulticastResult) Response(index int) *grpc_channelz_v1.GetSocketResponse

func (*GetSocketResponse_MulticastResult) SuccessCount 

func (r *GetSocketResponse_MulticastResult) SuccessCount() int

func (*GetSocketResponse_MulticastResult) SuccessPeer 

func (r *GetSocketResponse_MulticastResult) SuccessPeer(index int) *gira.Peer

type GetSubchannelResponse_MulticastResult 

type GetSubchannelResponse_MulticastResult struct {
	// contains filtered or unexported fields
}

func (*GetSubchannelResponse_MulticastResult) Error 

func (r *GetSubchannelResponse_MulticastResult) Error() error

func (*GetSubchannelResponse_MulticastResult) ErrorCount 

func (r *GetSubchannelResponse_MulticastResult) ErrorCount() int

func (*GetSubchannelResponse_MulticastResult) ErrorPeer 

func (r *GetSubchannelResponse_MulticastResult) ErrorPeer(index int) *gira.Peer

func (*GetSubchannelResponse_MulticastResult) Errors 

func (r *GetSubchannelResponse_MulticastResult) Errors(index int) error

func (*GetSubchannelResponse_MulticastResult) PeerCount 

func (r *GetSubchannelResponse_MulticastResult) PeerCount() int

func (*GetSubchannelResponse_MulticastResult) Response 

func (r *GetSubchannelResponse_MulticastResult) Response(index int) *grpc_channelz_v1.GetSubchannelResponse

func (*GetSubchannelResponse_MulticastResult) SuccessCount 

func (r *GetSubchannelResponse_MulticastResult) SuccessCount() int

func (*GetSubchannelResponse_MulticastResult) SuccessPeer 

func (r *GetSubchannelResponse_MulticastResult) SuccessPeer(index int) *gira.Peer

type GetTopChannelsResponse_MulticastResult 

type GetTopChannelsResponse_MulticastResult struct {
	// contains filtered or unexported fields
}

func (*GetTopChannelsResponse_MulticastResult) Error 

func (r *GetTopChannelsResponse_MulticastResult) Error() error

func (*GetTopChannelsResponse_MulticastResult) ErrorCount 

func (r *GetTopChannelsResponse_MulticastResult) ErrorCount() int

func (*GetTopChannelsResponse_MulticastResult) ErrorPeer 

func (r *GetTopChannelsResponse_MulticastResult) ErrorPeer(index int) *gira.Peer

func (*GetTopChannelsResponse_MulticastResult) Errors 

func (r *GetTopChannelsResponse_MulticastResult) Errors(index int) error

func (*GetTopChannelsResponse_MulticastResult) PeerCount 

func (r *GetTopChannelsResponse_MulticastResult) PeerCount() int

func (*GetTopChannelsResponse_MulticastResult) Response 

func (r *GetTopChannelsResponse_MulticastResult) Response(index int) *grpc_channelz_v1.GetTopChannelsResponse

func (*GetTopChannelsResponse_MulticastResult) SuccessCount 

func (r *GetTopChannelsResponse_MulticastResult) SuccessCount() int

func (*GetTopChannelsResponse_MulticastResult) SuccessPeer 

func (r *GetTopChannelsResponse_MulticastResult) SuccessPeer(index int) *gira.Peer

Source Files

View all Source files

Jump to

Keyboard shortcuts

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