server

Documentation

Overview

Package server implements a server for Chat service.

Index

• func StartServer(port string)
• type Connection
• type Server
  • func (s *Server) BroadcastMessage(_ context.Context, msg *pb.Message) (*pb.Close, error)
  • func (s *Server) CreateStream(pconn *pb.Connect, stream pb.Broadcast_CreateStreamServer) error

Functions

func StartServer

func StartServer(port string)

StartServer starts the server

Types

type Connection

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

Connection stores the streams for active userss

type Server

type Server struct {
	pb.UnimplementedBroadcastServer
	Connection map[string]*Connection
}

func (*Server) BroadcastMessage

func (s *Server) BroadcastMessage(_ context.Context, msg *pb.Message) (*pb.Close, error)

func (*Server) CreateStream

func (s *Server) CreateStream(pconn *pb.Connect, stream pb.Broadcast_CreateStreamServer) error