Versions in this module Expand all Collapse all v0 v0.0.11 Feb 5, 2024 v0.0.8 Dec 7, 2023 Changes in this version + const PromLabelDC + const PromLabelSVC + func DealMessage(ctx context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) + func NewRouter() *gin.Engine + type HSParam struct + DC string + Index uint64 + Stale bool + SvcName string + Tags []string + Wait time.Duration + type MsgWorker struct + ExitChan chan struct{} + ExitedFlag chan struct{} + func NewMsgWorker() *MsgWorker + func (w *MsgWorker) Start() + func (w *MsgWorker) Stop() + type WebAPIServer struct + Server *http.Server + func NewWebServer(ginHandler *gin.Engine) *WebAPIServer + func (worker *WebAPIServer) Start() + func (worker *WebAPIServer) Stop()
Go to main page