grpc_channelz

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

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

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

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

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

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

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

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