server

Documentation

Index

• type Server
  • func New(log *logger.Logger, self *peers.Peer) *Server
  • func (s *Server) Greet(ctx context.Context, peer *greeter.Peer) (*greeter.Peer, error)
  • func (s *Server) Stream(srv chat.Chat_StreamServer) error
  • func (s *Server) Streams() <-chan *Stream
• type Stream

Types

type Server

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

Server used to receive a connection from another peer.

func New

func New(
	log *logger.Logger,
	self *peers.Peer,
) *Server

New is server constructor.

func (*Server) Greet

func (s *Server) Greet(ctx context.Context, peer *greeter.Peer) (*greeter.Peer, error)

Greet implements greeter.Greeter.

func (*Server) Stream

func (s *Server) Stream(srv chat.Chat_StreamServer) error

Stream implements chat.MessageServer.

func (*Server) Streams

func (s *Server) Streams() <-chan *Stream

Streams returns channel with new streams.

type Stream

type Stream struct {
	chat.Chat_StreamServer

	PeerID string
}

Stream implements messages.Stream