push

Documentation

Index

• func GetContent(msg *sdkws.MsgData) string
• func Start(ctx context.Context, config *Config, client discovery.SvcDiscoveryRegistry, ...) error
• type Config
• type ConsumerHandler
  • func NewConsumerHandler(config *Config, offlinePusher offlinepush.OfflinePusher, ...) (*ConsumerHandler, error)
  • func (*ConsumerHandler) Cleanup(sarama.ConsumerGroupSession) error
  • func (c *ConsumerHandler) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (c *ConsumerHandler) DeleteMemberAndSetConversationSeq(ctx context.Context, groupID string, userIDs []string) error
  • func (c *ConsumerHandler) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.MsgData, pushToUserIDs []string) ([]*msggateway.SingleMsgToUserResults, error)
  • func (c *ConsumerHandler) Push2Group(ctx context.Context, groupID string, msg *sdkws.MsgData) (err error)
  • func (c *ConsumerHandler) Push2User(ctx context.Context, userIDs []string, msg *sdkws.MsgData) (err error)
  • func (*ConsumerHandler) Setup(sarama.ConsumerGroupSession) error
• type DefaultAllNode
  • func NewDefaultAllNode(disCov discovery.SvcDiscoveryRegistry, config *Config) *DefaultAllNode
  • func (d *DefaultAllNode) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.MsgData, pushToUserIDs []string) (wsResults []*msggateway.SingleMsgToUserResults, err error)
  • func (d *DefaultAllNode) GetOnlinePushFailedUserIDs(_ context.Context, msg *sdkws.MsgData, ...) []string
• type K8sStaticConsistentHash
  • func NewK8sStaticConsistentHash(disCov discovery.SvcDiscoveryRegistry, config *Config) *K8sStaticConsistentHash
  • func (k *K8sStaticConsistentHash) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.MsgData, pushToUserIDs []string) (wsResults []*msggateway.SingleMsgToUserResults, err error)
  • func (k *K8sStaticConsistentHash) GetOnlinePushFailedUserIDs(_ context.Context, _ *sdkws.MsgData, ...) []string
• type OnlinePusher
  • func NewOnlinePusher(disCov discovery.SvcDiscoveryRegistry, config *Config) OnlinePusher

Functions

func GetContent

func GetContent(msg *sdkws.MsgData) string

func Start

func Start(ctx context.Context, config *Config, client discovery.SvcDiscoveryRegistry, server *grpc.Server) error

Types

type Config

type Config struct {
	RpcConfig          config.Push
	RedisConfig        config.Redis
	MongodbConfig      config.Mongo
	KafkaConfig        config.Kafka
	NotificationConfig config.Notification
	Share              config.Share
	WebhooksConfig     config.Webhooks
	LocalCacheConfig   config.LocalCache
	Discovery          config.Discovery
	FcmConfigPath      string
}

type ConsumerHandler

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

func NewConsumerHandler

func NewConsumerHandler(config *Config, offlinePusher offlinepush.OfflinePusher, rdb redis.UniversalClient,
	client discovery.SvcDiscoveryRegistry) (*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) DeleteMemberAndSetConversationSeq

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

func (*ConsumerHandler) GetConnsAndOnlinePush

func (c *ConsumerHandler) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.MsgData, pushToUserIDs []string) ([]*msggateway.SingleMsgToUserResults, error)

func (*ConsumerHandler) Push2Group

func (c *ConsumerHandler) Push2Group(ctx context.Context, groupID string, msg *sdkws.MsgData) (err error)

func (*ConsumerHandler) Push2User

func (c *ConsumerHandler) Push2User(ctx context.Context, userIDs []string, msg *sdkws.MsgData) (err error)

Push2User Suitable for two types of conversations, one is SingleChatType and the other is NotificationChatType.

func (*ConsumerHandler) Setup

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

type DefaultAllNode

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

func NewDefaultAllNode

func NewDefaultAllNode(disCov discovery.SvcDiscoveryRegistry, config *Config) *DefaultAllNode

func (*DefaultAllNode) GetConnsAndOnlinePush

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

func (*DefaultAllNode) GetOnlinePushFailedUserIDs

func (d *DefaultAllNode) GetOnlinePushFailedUserIDs(_ context.Context, msg *sdkws.MsgData,
	wsResults []*msggateway.SingleMsgToUserResults, pushToUserIDs *[]string) []string

type K8sStaticConsistentHash

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

func NewK8sStaticConsistentHash

func NewK8sStaticConsistentHash(disCov discovery.SvcDiscoveryRegistry, config *Config) *K8sStaticConsistentHash

func (*K8sStaticConsistentHash) GetConnsAndOnlinePush

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

func (*K8sStaticConsistentHash) GetOnlinePushFailedUserIDs

func (k *K8sStaticConsistentHash) GetOnlinePushFailedUserIDs(_ context.Context, _ *sdkws.MsgData,
	wsResults []*msggateway.SingleMsgToUserResults, _ *[]string) []string

type OnlinePusher

type OnlinePusher interface {
	GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.MsgData,
		pushToUserIDs []string) (wsResults []*msggateway.SingleMsgToUserResults, err error)
	GetOnlinePushFailedUserIDs(ctx context.Context, msg *sdkws.MsgData, wsResults []*msggateway.SingleMsgToUserResults,
		pushToUserIDs *[]string) []string
}

func NewOnlinePusher

func NewOnlinePusher(disCov discovery.SvcDiscoveryRegistry, config *Config) OnlinePusher