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

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/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