handlers

Documentation

Index

• Variables
• type Handler
  • func NewHandler(options HandlerOptions) *Handler
  • func (h *Handler) EntityResponseMessage(er *shared.EntityResponse) error
  • func (h *Handler) InitializedConversation(im *shared.InitializationResponse) error
  • func (h *Handler) InsightResponseMessage(ir *shared.InsightResponse) error
  • func (h *Handler) MessageResponseMessage(mr *shared.MessageResponse) error
  • func (h *Handler) RecognitionResultMessage(rr *shared.RecognitionResponse) error
  • func (h *Handler) SetClientPublisher(mp *interfacessdk.MessagePublisher)
  • func (h *Handler) TeardownConversation(tm *shared.TeardownResponse) error
  • func (h *Handler) TopicResponseMessage(tr *shared.TopicResponse) error
  • func (h *Handler) TrackerResponseMessage(tr *shared.TrackerResponse) error
  • func (h *Handler) UnhandledMessage(byMsg []byte) error
  • func (h *Handler) UserDefinedMessage(data []byte) error
• type HandlerOptions
• type StatisticType

Variables

var (
	// ErrUnhandledMessage runhandled message from symbl-proxy-dataminer
	ErrUnhandledMessage = errors.New("unhandled message from symbl-proxy-dataminer")
)

Types

type Handler

type Handler struct {
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(options HandlerOptions) *Handler

func (*Handler) EntityResponseMessage

func (h *Handler) EntityResponseMessage(er *shared.EntityResponse) error

func (*Handler) InitializedConversation

func (h *Handler) InitializedConversation(im *shared.InitializationResponse) error

func (*Handler) InsightResponseMessage

func (h *Handler) InsightResponseMessage(ir *shared.InsightResponse) error

func (*Handler) MessageResponseMessage

func (h *Handler) MessageResponseMessage(mr *shared.MessageResponse) error

func (*Handler) RecognitionResultMessage

func (h *Handler) RecognitionResultMessage(rr *shared.RecognitionResponse) error

func (*Handler) SetClientPublisher

func (h *Handler) SetClientPublisher(mp *interfacessdk.MessagePublisher)

func (*Handler) TeardownConversation

func (h *Handler) TeardownConversation(tm *shared.TeardownResponse) error

func (*Handler) TopicResponseMessage

func (h *Handler) TopicResponseMessage(tr *shared.TopicResponse) error

func (*Handler) TrackerResponseMessage

func (h *Handler) TrackerResponseMessage(tr *shared.TrackerResponse) error

func (*Handler) UnhandledMessage

func (h *Handler) UnhandledMessage(byMsg []byte) error

func (*Handler) UserDefinedMessage

func (h *Handler) UserDefinedMessage(data []byte) error

type HandlerOptions

type HandlerOptions struct {
	Session     *neo4j.SessionWithContext // retrieve insights
	SymblClient *symbl.RestClient
}

Handler for messages

type StatisticType

type StatisticType int

const (
	StatType1Month StatisticType = iota
	StatType1Week
	StatType2Days
	StatType1Day
	StatType4Hours
	StatType1Hour
	StatType30Mins
)