cache

Documentation

Index

• Constants
• func DealMessage(ctx context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error)
• func NewRouter() *gin.Engine
• type HSParam
• type MsgWorker
  • func NewMsgWorker() *MsgWorker
  • func (w *MsgWorker) Start()
  • func (w *MsgWorker) Stop()
• type WebAPIServer
  • func NewWebServer(ginHandler *gin.Engine) *WebAPIServer
  • func (worker *WebAPIServer) Start()
  • func (worker *WebAPIServer) Stop()

Constants

const (
	PromLabelSVC = "service"
	PromLabelDC  = "dc"
)

Functions

func DealMessage

func DealMessage(ctx context.Context,
	msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error)

func NewRouter

func NewRouter() *gin.Engine

Types

type HSParam

type HSParam struct {
	SvcName string
	DC      string
	Index   uint64
	Wait    time.Duration
	Stale   bool
	Tags    []string
}

type MsgWorker

type MsgWorker struct {
	ExitedFlag chan struct{} // 已经退出的标识
	ExitChan   chan struct{}
}

func NewMsgWorker

func NewMsgWorker() *MsgWorker

func (*MsgWorker) Start

func (w *MsgWorker) Start()

func (*MsgWorker) Stop

func (w *MsgWorker) Stop()

type WebAPIServer

type WebAPIServer struct {
	Server *http.Server
}

func NewWebServer

func NewWebServer(ginHandler *gin.Engine) *WebAPIServer

func (*WebAPIServer) Start

func (worker *WebAPIServer) Start()

func (*WebAPIServer) Stop

func (worker *WebAPIServer) Stop()