handler

Documentation

Index

• Constants
• type Base
• type BaseResponse
• type Payload
• type Reader
• type ReaderPlugin
  • func (r *ReaderPlugin) GetConn() (*websocket.Conn, error)
  • func (r *ReaderPlugin) Put(websocketConn *websocket.Conn, channel chan []interface{}) error
• type Writer
• type WriterPlugin
  • func (w *WriterPlugin) GetApplication() *gin.Engine

Constants

const (
	BaseURL = "/"
)

Types

type Base

type Base struct {
	Port uint `json:"port"`
}

type BaseResponse

type BaseResponse struct {
	// Code http status code
	Code int `json:"code"`
	// Msg responce message
	Msg string `json:"msg"`
	// Data response data
	Data interface{} `json:"data"`
}

type Payload

type Payload struct {
	// Value one row value
	Value []interface{} `json:"value"`
}

type Reader

type Reader interface {
	Read(channel chan []interface{})
}

type ReaderPlugin

type ReaderPlugin struct {
	Base
	Reader
}

func (*ReaderPlugin) GetConn

func (r *ReaderPlugin) GetConn() (*websocket.Conn, error)

GetConn get websocket connect to Push data to writer

func (*ReaderPlugin) Put

func (r *ReaderPlugin) Put(websocketConn *websocket.Conn, channel chan []interface{}) error

Push data to writer and get result

type Writer

type Writer interface {
	Write([]interface{}) BaseResponse
}

Writer Operator interface class for writing data.

type WriterPlugin

type WriterPlugin struct {
	Base `json:",inline"`
	Mode string `json:"mode"`
	Writer
}

func (*WriterPlugin) GetApplication

func (w *WriterPlugin) GetApplication() *gin.Engine