stream

Documentation

Index

• type Handler
  • func NewHandler(logger *logrus.Entry) *Handler
  • func (h *Handler) Connect(c *gin.Context)
  • func (h *Handler) RegisterMessageHandler(msgType MessageType, handler MessageHandler)
• type Message
• type MessageHandler
• type MessageType

Types

type Handler

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

Stream handler.

func NewHandler

func NewHandler(logger *logrus.Entry) *Handler

func (*Handler) Connect

func (h *Handler) Connect(c *gin.Context)

func (*Handler) RegisterMessageHandler

func (h *Handler) RegisterMessageHandler(msgType MessageType, handler MessageHandler)

type Message

type Message []byte

type MessageHandler

type MessageHandler interface {
	Handle(ctx context.Context, msg Message, reply chan<- Message) error
}

type MessageType

type MessageType string