peer

Documentation

Index

• Variables
• func TLSServerName(nodeName, clusterName string) string
• type Service
  • func NewService(notifier manager.Notifier, options ...serviceoption.Option) *Service
  • func (s *Service) Close() error
  • func (s *Service) Notify(_ *peerpb.NotifyRequest, stream peerpb.Peer_NotifyServer) error

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

func TLSServerName(nodeName, clusterName string) string

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

func (s *Service) Close() error

Close frees resources associated to the 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.