Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ErrStreamSendBlocked = errors.New("server stream send was blocked for too long")
ErrStreamSendBlocked is returned by Notify when the send operation is blocked for too long, likely indicating a problem with the transport.
Functions ¶
func TLSServerName ¶
TLSServerName constructs a server name to be used as the TLS server name. The server name is of the following form:
<nodeName>.<clusterName>.<hubble-grpc-svc-name>.<domain>
For example, with nodeName=moseisley and clusterName=tatooine, the following server name is returned:
moseisley.tatooine.hubble-grpc.cilium.io
When nodeName is not provided, an empty string is returned. All Dot (.) in nodeName are replaced by Hyphen (-). When clusterName is not provided, it defaults to the default cluster name. All Dot (.) in clusterName are replaced by Hypen (-).
Types ¶
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service implements the peerpb.PeerServer gRPC service.
func NewService ¶
func NewService(notifier manager.Notifier, options ...serviceoption.Option) *Service
NewService creates a new Service.
func (*Service) Notify ¶
func (s *Service) Notify(_ *peerpb.NotifyRequest, stream peerpb.Peer_NotifyServer) error
Notify implements peerpb.Peer_PeerServer.Notify. If the client is not able to process change notifications fast enough, the server will terminate the connection.
Source Files
Directories