push

package

v3.7.0 Latest Latest Go to latest Published: Apr 20, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/openimsdk/open-im-server

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
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)
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

Constants ¶

View Source

const (
	KUBERNETES = "k8s"
	ZOOKEEPER  = "zookeeper"
)

Variables ¶

This section is empty.

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 ¶ added in v3.7.0

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

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 ¶ added in v3.7.0

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

func (*ConsumerHandler) Push2SuperGroup ¶ added in v3.7.0

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

func (*ConsumerHandler) Push2User ¶ added in v3.7.0

func (c *ConsumerHandler) Push2User(ctx context.Context, userIDs []string, msg *sdkws.MsgData) 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 ¶ added in v3.7.0

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

func NewDefaultAllNode ¶ added in v3.7.0

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

func (*DefaultAllNode) GetConnsAndOnlinePush ¶ added in v3.7.0

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

func (*DefaultAllNode) GetOnlinePushFailedUserIDs ¶ added in v3.7.0

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

type K8sStaticConsistentHash ¶ added in v3.7.0

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

func NewK8sStaticConsistentHash ¶ added in v3.7.0

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

func (*K8sStaticConsistentHash) GetConnsAndOnlinePush ¶ added in v3.7.0

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

func (*K8sStaticConsistentHash) GetOnlinePushFailedUserIDs ¶ added in v3.7.0

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

type OnlinePusher ¶ added in v3.7.0

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 ¶ added in v3.7.0

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
offlinepush
dummy
fcm
getui
jpush
jpush/body
options

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL