push

Documentation

Index

• func GetContent(msg *sdkws.MsgData) string
• func NewOfflinePusher(config *config.GlobalConfig, cache cache.MsgModel) offlinepush.OfflinePusher
• func Start(config *config.GlobalConfig, client discoveryregistry.SvcDiscoveryRegistry, ...) error
• type Consumer
  • func NewConsumer(config *config.GlobalConfig, pusher *Pusher) (*Consumer, error)
  • func (c *Consumer) Start()
• type ConsumerHandler
  • func NewConsumerHandler(config *config.GlobalConfig, pusher *Pusher) (*ConsumerHandler, error)
  • func (ConsumerHandler) Cleanup(_ sarama.ConsumerGroupSession) error
  • func (c *ConsumerHandler) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (ConsumerHandler) Setup(_ sarama.ConsumerGroupSession) error
• type Pusher
  • func NewPusher(config *config.GlobalConfig, discov discoveryregistry.SvcDiscoveryRegistry, ...) *Pusher
  • func (p *Pusher) DeleteMemberAndSetConversationSeq(ctx context.Context, groupID string, userIDs []string) error
  • func (p *Pusher) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.MsgData, pushToUserIDs []string) (wsResults []*msggateway.SingleMsgToUserResults, err error)
  • func (p *Pusher) GetOfflinePushOpts(msg *sdkws.MsgData) (opts *offlinepush.Opts, err error)
  • func (p *Pusher) Push2SuperGroup(ctx context.Context, groupID string, msg *sdkws.MsgData) (err error)
  • func (p *Pusher) Push2User(ctx context.Context, userIDs []string, msg *sdkws.MsgData) error
  • func (p *Pusher) UnmarshalNotificationElem(bytes []byte, t any) error

Functions

func GetContent

func GetContent(msg *sdkws.MsgData) string

func NewOfflinePusher

func NewOfflinePusher(config *config.GlobalConfig, cache cache.MsgModel) offlinepush.OfflinePusher

func Start

func Start(config *config.GlobalConfig, client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error

Types

type Consumer

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

func NewConsumer

func NewConsumer(config *config.GlobalConfig, pusher *Pusher) (*Consumer, error)

func (*Consumer) Start

func (c *Consumer) Start()

type ConsumerHandler

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

func NewConsumerHandler

func NewConsumerHandler(config *config.GlobalConfig, pusher *Pusher) (*ConsumerHandler, error)

func (ConsumerHandler) Cleanup

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

func (*ConsumerHandler) ConsumeClaim

func (c *ConsumerHandler) ConsumeClaim(sess sarama.ConsumerGroupSession,
	claim sarama.ConsumerGroupClaim,
) error

func (ConsumerHandler) Setup

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

type Pusher

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

func NewPusher

func NewPusher(config *config.GlobalConfig, discov discoveryregistry.SvcDiscoveryRegistry, offlinePusher offlinepush.OfflinePusher, database controller.PushDatabase,
	groupLocalCache *localcache.GroupLocalCache, conversationLocalCache *localcache.ConversationLocalCache,
	conversationRpcClient *rpcclient.ConversationRpcClient, groupRpcClient *rpcclient.GroupRpcClient, msgRpcClient *rpcclient.MessageRpcClient,
) *Pusher

func (*Pusher) DeleteMemberAndSetConversationSeq

func (p *Pusher) DeleteMemberAndSetConversationSeq(ctx context.Context, groupID string, userIDs []string) error

func (*Pusher) GetConnsAndOnlinePush

func (p *Pusher) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.MsgData, pushToUserIDs []string) (wsResults []*msggateway.SingleMsgToUserResults, err error)

func (*Pusher) GetOfflinePushOpts

func (p *Pusher) GetOfflinePushOpts(msg *sdkws.MsgData) (opts *offlinepush.Opts, err error)

func (*Pusher) Push2SuperGroup

func (p *Pusher) Push2SuperGroup(ctx context.Context, groupID string, msg *sdkws.MsgData) (err error)

func (*Pusher) Push2User

func (p *Pusher) Push2User(ctx context.Context, userIDs []string, msg *sdkws.MsgData) error

func (*Pusher) UnmarshalNotificationElem

func (p *Pusher) UnmarshalNotificationElem(bytes []byte, t any) error