server

Documentation

Index

• type ChatServer
  • func (s *ChatServer) Channel(in *pb.ConnectRequest, stream pb.Chat_ChannelServer) error
  • func (s *ChatServer) Say(ctx context.Context, in *pb.Text) (*pb.Confirm, error)
  • func (s *ChatServer) Users(ctx context.Context, in *pb.Empty) (*pb.UserList, error)
  • func (s *ChatServer) Version(ctx context.Context, in *pb.Empty) (*pb.Confirm, error)
• type Connection
  • func NewConnection(username string, stream *pb.Chat_ChannelServer) *Connection
  • func (connect *Connection) AddStream(stream *pb.Chat_ChannelServer)
  • func (connect *Connection) Clean()
  • func (connect *Connection) DeleteStream(server *pb.Chat_ChannelServer)
  • func (connect *Connection) NStreams() int
• type Stream
  • func (stream *Stream) Send(msg *pb.Text) error

Types

type ChatServer

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

func (*ChatServer) Channel

func (s *ChatServer) Channel(in *pb.ConnectRequest, stream pb.Chat_ChannelServer) error

func (*ChatServer) Say

func (s *ChatServer) Say(ctx context.Context, in *pb.Text) (*pb.Confirm, error)

func (*ChatServer) Users

func (s *ChatServer) Users(ctx context.Context, in *pb.Empty) (*pb.UserList, error)

func (*ChatServer) Version

func (s *ChatServer) Version(ctx context.Context, in *pb.Empty) (*pb.Confirm, error)

type Connection

type Connection struct {
	User    pb.User
	Streams []*Stream
	Deleted bool
}

func NewConnection

func NewConnection(username string, stream *pb.Chat_ChannelServer) *Connection

func (*Connection) AddStream

func (connect *Connection) AddStream(stream *pb.Chat_ChannelServer)

func (*Connection) Clean

func (connect *Connection) Clean()

func (*Connection) DeleteStream

func (connect *Connection) DeleteStream(server *pb.Chat_ChannelServer)

func (*Connection) NStreams

func (connect *Connection) NStreams() int

type Stream

type Stream struct {
	Server  *pb.Chat_ChannelServer
	Deleted bool
}

func (*Stream) Send

func (stream *Stream) Send(msg *pb.Text) error