service

Documentation

Index

• type Pusher
  • func (p *Pusher) GroupCast(ctx context.Context, m *record.PushMsg) error
  • func (p *Pusher) UniCast(ctx context.Context, m *record.PushMsg) error
  • func (p *Pusher) UniCastDevices(ctx context.Context, m *record.PushMsg) error
• type Service
  • func New(c *config.Config) *Service
  • func (s *Service) DealConn(ctx context.Context, m *logic.BizMsg) error
  • func (s *Service) DealPush(ctx context.Context, m *record.PushMsg) error
  • func (s *Service) JoinGroups(ctx context.Context, uid, key string) error
  • func (s *Service) ListenMQ()
  • func (s *Service) PushClient(ctx context.Context, key, from, mid, target string, tp int32, frameType string, ...) error
  • func (s *Service) PushUser(ctx context.Context, key, from, mid, target string, tp int32, frameType string, ...) error
  • func (s *Service) Shutdown(ctx context.Context)
  • func (s *Service) UniCastSignalEndpointLogin(ctx context.Context, uid string, actionProto *xproto.SignalEndpointLogin) error
  • func (s *Service) UniCastSignalReceived(ctx context.Context, item *logH.ConnSeqItem) error

Types

type Pusher

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

func (*Pusher) GroupCast

func (p *Pusher) GroupCast(ctx context.Context, m *record.PushMsg) error

func (*Pusher) UniCast

func (p *Pusher) UniCast(ctx context.Context, m *record.PushMsg) error

func (*Pusher) UniCastDevices

func (p *Pusher) UniCastDevices(ctx context.Context, m *record.PushMsg) error

type Service

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

func New

func New(c *config.Config) *Service

func (*Service) DealConn

func (s *Service) DealConn(ctx context.Context, m *logic.BizMsg) error

func (*Service) DealPush

func (s *Service) DealPush(ctx context.Context, m *record.PushMsg) error

func (*Service) JoinGroups

func (s *Service) JoinGroups(ctx context.Context, uid, key string) error

func (*Service) ListenMQ

func (s *Service) ListenMQ()

func (*Service) PushClient

func (s *Service) PushClient(ctx context.Context, key, from, mid, target string, tp int32, frameType string, body []byte) error

just socket push

func (*Service) PushUser

func (s *Service) PushUser(ctx context.Context, key, from, mid, target string, tp int32, frameType string, body []byte) error

just socket push

func (*Service) Shutdown

func (s *Service) Shutdown(ctx context.Context)

func (*Service) UniCastSignalEndpointLogin

func (s *Service) UniCastSignalEndpointLogin(ctx context.Context, uid string, actionProto *xproto.SignalEndpointLogin) error

func (*Service) UniCastSignalReceived

func (s *Service) UniCastSignalReceived(ctx context.Context, item *logH.ConnSeqItem) error

just socket push