peer

Documentation

Index

• Variables
• 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.

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.