msgtransfer

package
v3.6.0 Latest Latest
Warning

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

 Go to latest Published: Mar 7, 2024 License: Apache-2.0 Imports: 38 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ConsumerMsgs   = 3
	SourceMessages = 4
	MongoMessages  = 5
	ChannelNum     = 100
)

Variables

This section is empty.

Functions

func StartTransfer 

func StartTransfer(config *config.GlobalConfig, prometheusPort int) error

Types

type Cmd2Value 

type Cmd2Value struct {
	Cmd   int
	Value any
}

type ContextMsg 

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

type MsgChannelValue 

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

type MsgTransfer 

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

func NewMsgTransfer 

func NewMsgTransfer(
	config *config.GlobalConfig,
	msgDatabase controller.CommonMsgDatabase,
	conversationRpcClient *rpcclient.ConversationRpcClient,
	groupRpcClient *rpcclient.GroupRpcClient,
) (*MsgTransfer, error)

func (*MsgTransfer) Start 

func (m *MsgTransfer) Start(prometheusPort int, config *config.GlobalConfig) error

type OnlineHistoryMongoConsumerHandler 

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

func NewOnlineHistoryMongoConsumerHandler 

func NewOnlineHistoryMongoConsumerHandler(config *config.GlobalConfig, database controller.CommonMsgDatabase) (*OnlineHistoryMongoConsumerHandler, error)

func (OnlineHistoryMongoConsumerHandler) Cleanup 

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

func (*OnlineHistoryMongoConsumerHandler) ConsumeClaim 

func (mc *OnlineHistoryMongoConsumerHandler) ConsumeClaim(
	sess sarama.ConsumerGroupSession,
	claim sarama.ConsumerGroupClaim,
) error

func (OnlineHistoryMongoConsumerHandler) Setup 

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

type OnlineHistoryRedisConsumerHandler 

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

func NewOnlineHistoryRedisConsumerHandler 

func NewOnlineHistoryRedisConsumerHandler(
	config *config.GlobalConfig,
	database controller.CommonMsgDatabase,
	conversationRpcClient *rpcclient.ConversationRpcClient,
	groupRpcClient *rpcclient.GroupRpcClient,
) (*OnlineHistoryRedisConsumerHandler, error)

func (*OnlineHistoryRedisConsumerHandler) Cleanup 

func (och *OnlineHistoryRedisConsumerHandler) Cleanup(_ sarama.ConsumerGroupSession) error

func (*OnlineHistoryRedisConsumerHandler) ConsumeClaim 

func (och *OnlineHistoryRedisConsumerHandler) ConsumeClaim(
	sess sarama.ConsumerGroupSession,
	claim sarama.ConsumerGroupClaim,
) error

func (*OnlineHistoryRedisConsumerHandler) MessagesDistributionHandle 

func (och *OnlineHistoryRedisConsumerHandler) MessagesDistributionHandle()

func (*OnlineHistoryRedisConsumerHandler) Run 

func (och *OnlineHistoryRedisConsumerHandler) Run(channelID int)

func (*OnlineHistoryRedisConsumerHandler) Setup 

func (och *OnlineHistoryRedisConsumerHandler) Setup(_ sarama.ConsumerGroupSession) error

type TriggerChannelValue 

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

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.