message_handlers

Documentation

Index

• Variables

Variables

var Indexer = NewMiddleware("indexer", func(h MessageHandler) MessageHandler {
	fn := func(c Connection, m *Message, e error) {
		if !Config().Indices.Disable && e == nil {
			if chItr, found := c.Metadata()["channel"]; found {
				ch := chItr.(*Channel)
				id := uuid.NewV1().String()
				p, err := NewPoint(id, ch, c, m)
				if err == nil {
					if meta, found := c.Metadata()["metadata"]; found && meta != nil {
						p.Metadata(meta.(map[string]string))
					}

					_, err := IndexClient.Index().
						Index(TimedIndexName(ch, p.Timestamp)).
						Type(p.IndexType()).
						Id(id).
						BodyJson(p).
						Do()
					if err != nil {
						Logger.Error(fmt.Sprintf("error indexing point, %s", err.Error()))
					}
				} else {
					Logger.Error(fmt.Sprintf("error creating point, %s", err.Error()))
				}
			}
		}

		h(c, m, e)
	}
	return MessageHandler(fn)
})

var SupportedMessageHandlers = map[string]*Middleware{"indexer": Indexer}