Documentation ¶
Index ¶
Constants ¶
View Source
const ( ActionIndex = "INDEX" ActionUpdate = "UPDATE" ActionDelete = "DELETE" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IndexerHandler ¶
type IndexerHandler struct { C *nsq.Consumer // contains filtered or unexported fields }
MessageHandler is a custom NSQ message handler.
func NewIndexerHandler ¶
func (*IndexerHandler) HandleMessage ¶
func (h *IndexerHandler) HandleMessage(msg *nsq.Message) error
HandleMessage is called when a new message is received.
type IndexerHandlerMSG ¶
Click to show internal directories.
Click to hide internal directories.