client

Documentation

Index

• type BroadcastStream
  • func (bs *BroadcastStream) JoinChat(username string) error
  • func (bs *BroadcastStream) LeaveChat(username string) error
  • func (bs *BroadcastStream) MessageListener(p *tea.Program) error
  • func (bs *BroadcastStream) SendMessage(username string, message string) error
• type ChatClient
  • func NewChatClient(conn *grpc.ClientConn) *ChatClient
  • func (cc *ChatClient) Stream(ctx context.Context) (*BroadcastStream, error)
• type MessageRecvEvent

Types

type BroadcastStream

type BroadcastStream struct {
	pb.Chat_BroadcastClient
	// contains filtered or unexported fields
}

func (*BroadcastStream) JoinChat

func (bs *BroadcastStream) JoinChat(username string) error

func (*BroadcastStream) LeaveChat

func (bs *BroadcastStream) LeaveChat(username string) error

func (*BroadcastStream) MessageListener

func (bs *BroadcastStream) MessageListener(p *tea.Program) error

func (*BroadcastStream) SendMessage

func (bs *BroadcastStream) SendMessage(username string, message string) error

type ChatClient

type ChatClient struct {
	pb.ChatClient
}

func NewChatClient

func NewChatClient(conn *grpc.ClientConn) *ChatClient

func (*ChatClient) Stream

func (cc *ChatClient) Stream(ctx context.Context) (*BroadcastStream, error)

type MessageRecvEvent

type MessageRecvEvent struct {
	Timestamp uint64
	Username  string
	Message   string
}