logic

package

v0.0.0-...-4702bed Latest Latest Go to latest Published: Apr 13, 2023 License: Apache-2.0 Imports: 27 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/erbaner/be

Links

Open Source Insights

Documentation ¶

Overview ¶

** description(""). ** copyright('tuoyun,www.tuoyun.net'). ** author("fg,Gordon@tuoyun.net"). ** time(2021/5/11 15:37).

Index ¶

Constants
func GetOnlineTopicStatus() int
func Init()
func Run(promethuesPort int)
func SetOnlineTopicStatus(status int)
func UnMarshallSetReactionMsgContent(content []byte) (notification *base_info.ReactionMessageModifierNotification, err error)
type Cmd2Value
type ModifyMsgConsumerHandler
type MsgChannelValue
type OnlineHistoryMongoConsumerHandler
type OnlineHistoryRedisConsumerHandler
type PersistentConsumerHandler
type TriggerChannelValue

Constants ¶

View Source

const AggregationMessages = 4

View Source

const ChannelNum = 100

View Source

const ConsumerMsgs = 3

View Source

const MongoMessages = 5

View Source

const Msg = 2

View Source

const OnlineTopicBusy = 1

View Source

const OnlineTopicVacancy = 0

Variables ¶

This section is empty.

Functions ¶

func GetOnlineTopicStatus ¶

func GetOnlineTopicStatus() int

func Init ¶

func Init()

func Run ¶

func Run(promethuesPort int)

func SetOnlineTopicStatus ¶

func SetOnlineTopicStatus(status int)

func UnMarshallSetReactionMsgContent ¶

func UnMarshallSetReactionMsgContent(content []byte) (notification *base_info.ReactionMessageModifierNotification, err error)

Types ¶

type Cmd2Value ¶

type Cmd2Value struct {
	Cmd   int
	Value interface{}
}

type ModifyMsgConsumerHandler ¶

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

func (ModifyMsgConsumerHandler) Cleanup ¶

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

func (*ModifyMsgConsumerHandler) ConsumeClaim ¶

func (mmc *ModifyMsgConsumerHandler) ConsumeClaim(sess sarama.ConsumerGroupSession,
	claim sarama.ConsumerGroupClaim) error

func (*ModifyMsgConsumerHandler) Init ¶

func (mmc *ModifyMsgConsumerHandler) Init()

func (*ModifyMsgConsumerHandler) ModifyMsg ¶

func (mmc *ModifyMsgConsumerHandler) ModifyMsg(cMsg *sarama.ConsumerMessage, msgKey string, _ sarama.ConsumerGroupSession)

func (ModifyMsgConsumerHandler) Setup ¶

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

type MsgChannelValue ¶

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

type OnlineHistoryMongoConsumerHandler ¶

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

func (OnlineHistoryMongoConsumerHandler) Cleanup ¶

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

func (*OnlineHistoryMongoConsumerHandler) ConsumeClaim ¶

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

func (*OnlineHistoryMongoConsumerHandler) Init ¶

func (och *OnlineHistoryMongoConsumerHandler) Init()

func (OnlineHistoryMongoConsumerHandler) Setup ¶

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

type OnlineHistoryRedisConsumerHandler ¶

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

func (OnlineHistoryRedisConsumerHandler) Cleanup ¶

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

func (*OnlineHistoryRedisConsumerHandler) ConsumeClaim ¶

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

func (*OnlineHistoryRedisConsumerHandler) Init ¶

func (och *OnlineHistoryRedisConsumerHandler) Init(cmdCh chan Cmd2Value)

func (*OnlineHistoryRedisConsumerHandler) MessagesDistributionHandle ¶

func (och *OnlineHistoryRedisConsumerHandler) MessagesDistributionHandle()

func (*OnlineHistoryRedisConsumerHandler) Run ¶

func (och *OnlineHistoryRedisConsumerHandler) Run(channelID int)

func (*OnlineHistoryRedisConsumerHandler) SendMessageToMongoCH ¶

func (och *OnlineHistoryRedisConsumerHandler) SendMessageToMongoCH(aggregationID string, triggerID string, messages []*pbMsg.MsgDataToMQ, lastSeq uint64)

func (OnlineHistoryRedisConsumerHandler) Setup ¶

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

type PersistentConsumerHandler ¶

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

func (PersistentConsumerHandler) Cleanup ¶

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

func (*PersistentConsumerHandler) ConsumeClaim ¶

func (pc *PersistentConsumerHandler) ConsumeClaim(sess sarama.ConsumerGroupSession,
	claim sarama.ConsumerGroupClaim) error

func (*PersistentConsumerHandler) Init ¶

func (pc *PersistentConsumerHandler) Init()

func (PersistentConsumerHandler) Setup ¶

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

type TriggerChannelValue ¶

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

Source Files ¶

View all Source files

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