tools

package
v3.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 20, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Start added in v3.7.0 

func Start(ctx context.Context, config *CronTaskConfig) error

Types

type CronTaskConfig added in v3.7.0 

type CronTaskConfig struct {
	CronTask        config.CronTask
	RedisConfig     config.Redis
	MongodbConfig   config.Mongo
	ZookeeperConfig config.ZooKeeper
	Share           config.Share
	KafkaConfig     config.Kafka
}

type MsgTool 

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

func InitMsgTool 

func InitMsgTool(ctx context.Context, config *CronTaskConfig) (*MsgTool, error)

func NewMsgTool 

func NewMsgTool(msgDatabase controller.CommonMsgDatabase, userDatabase controller.UserDatabase,
	groupDatabase controller.GroupDatabase, conversationDatabase controller.ConversationDatabase,
	msgNotificationSender *msg.MsgNotificationSender, config *CronTaskConfig,
) *MsgTool

func (*MsgTool) AllConversationClearMsgAndFixSeq 

func (c *MsgTool) AllConversationClearMsgAndFixSeq()

func (*MsgTool) ClearConversationsMsg 

func (c *MsgTool) ClearConversationsMsg(ctx context.Context, conversationIDs []string)

func (*MsgTool) ConversationsDestructMsgs 

func (c *MsgTool) ConversationsDestructMsgs()

func (*MsgTool) FixAllSeq 

func (c *MsgTool) FixAllSeq(ctx context.Context) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.