im

Documentation

Index

• type Hub
  • func NewHub() *Hub
• type Im
  • func (i *Im) Connect(c *context.Context, req *phello.ConnectReq, rsp *phello.ConnectRsp) (err error)
  • func (i *Im) Count(c *context.Context, req *phello.CountReq, rsp *phello.CountRsp) (err error)
  • func (i *Im) SendMessage(c *context.Context, req chan *phello.SendMessageReq, errIn chan error) (chan *phello.SendMessageRsp, chan error)

Types

type Hub

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

func NewHub

func NewHub() *Hub

type Im

type Im struct {
	H *Hub
	// contains filtered or unexported fields
}

func (*Im) Connect

func (i *Im) Connect(c *context.Context, req *phello.ConnectReq, rsp *phello.ConnectRsp) (err error)

func (*Im) Count

func (i *Im) Count(c *context.Context, req *phello.CountReq, rsp *phello.CountRsp) (err error)

func (*Im) SendMessage

func (i *Im) SendMessage(
	c *context.Context,
	req chan *phello.SendMessageReq,
	errIn chan error,
) (chan *phello.SendMessageRsp, chan error)