logic

Documentation

Overview

** description(""). ** copyright('open-im,www.open-im.io'). ** author("fg,Gordon@open-im.io"). ** time(2021/3/22 15:33).

** description(""). ** copyright('Open_IM,www.Open_IM.io'). ** author("fg,Gordon@tuoyun.net"). ** time(2021/5/13 10:33).

** description(""). ** copyright('open-im,www.open-im.io'). ** author("fg,Gordon@open-im.io"). ** time(2021/3/5 14:31).

Index

• func GetOfflinePushOpts(pushMsg *pbPush.PushMsgReq) (opts push.PushOpts, err error)
• func IOSAccountListPush(accounts []string, title, content, jsonCustomContent string)
• func Init(rpcPort int)
• func MsgToSuperGroupUser(pushMsg *pbPush.PushMsgReq)
• func MsgToUser(pushMsg *pbPush.PushMsgReq)
• func Run(promethuesPort int)
• type AtContent
• type OpenIMContent
• type PushConsumerHandler
  • func (PushConsumerHandler) Cleanup(_ sarama.ConsumerGroupSession) error
  • func (ms *PushConsumerHandler) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (ms *PushConsumerHandler) Init()
  • func (PushConsumerHandler) Setup(_ sarama.ConsumerGroupSession) error
• type RPCServer
  • func (r *RPCServer) DelUserPushToken(c context.Context, req *pbPush.DelUserPushTokenReq) (*pbPush.DelUserPushTokenResp, error)
  • func (r *RPCServer) Init(rpcPort int)
  • func (r *RPCServer) PushMsg(_ context.Context, pbData *pbPush.PushMsgReq) (*pbPush.PushMsgResp, error)

Functions

func GetOfflinePushOpts

func GetOfflinePushOpts(pushMsg *pbPush.PushMsgReq) (opts push.PushOpts, err error)

func IOSAccountListPush

func IOSAccountListPush(accounts []string, title, content, jsonCustomContent string)

func Init

func Init(rpcPort int)

func MsgToSuperGroupUser

func MsgToSuperGroupUser(pushMsg *pbPush.PushMsgReq)

func MsgToUser

func MsgToUser(pushMsg *pbPush.PushMsgReq)

func Run

func Run(promethuesPort int)

Types

type AtContent

type AtContent struct {
	Text       string   `json:"text"`
	AtUserList []string `json:"atUserList"`
	IsAtSelf   bool     `json:"isAtSelf"`
}

type OpenIMContent

type OpenIMContent struct {
	SessionType int    `json:"sessionType"`
	From        string `json:"from"`
	To          string `json:"to"`
	Seq         uint32 `json:"seq"`
}

type PushConsumerHandler

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

func (PushConsumerHandler) Cleanup

func (PushConsumerHandler) Cleanup(_ sarama.ConsumerGroupSession) error

func (*PushConsumerHandler) ConsumeClaim

func (ms *PushConsumerHandler) ConsumeClaim(sess sarama.ConsumerGroupSession,
	claim sarama.ConsumerGroupClaim) error

func (*PushConsumerHandler) Init

func (ms *PushConsumerHandler) Init()

func (PushConsumerHandler) Setup

func (PushConsumerHandler) Setup(_ sarama.ConsumerGroupSession) error

type RPCServer

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

func (*RPCServer) DelUserPushToken

func (r *RPCServer) DelUserPushToken(c context.Context, req *pbPush.DelUserPushTokenReq) (*pbPush.DelUserPushTokenResp, error)

func (*RPCServer) Init

func (r *RPCServer) Init(rpcPort int)

func (*RPCServer) PushMsg

func (r *RPCServer) PushMsg(_ context.Context, pbData *pbPush.PushMsgReq) (*pbPush.PushMsgResp, error)