deviceshifusocket

Documentation

Index

• Constants
• type DeviceShifu
  • func New(deviceShifuMetadata *deviceshifubase.DeviceShifuMetaData) (*DeviceShifu, error)
  • func (ds *DeviceShifu) Start(stopCh <-chan struct{}) error
  • func (ds *DeviceShifu) Stop() error
• type HandlerMetaData
• type RequestBody
• type ReturnBody

Constants

const (
	DefaultBufferLength = 1024
)

Types

type DeviceShifu

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

DeviceShifu deviceshifu and socketConnection for Socket

func New

func New(deviceShifuMetadata *deviceshifubase.DeviceShifuMetaData) (*DeviceShifu, error)

New new socket deviceshifu

func (*DeviceShifu) Start

func (ds *DeviceShifu) Start(stopCh <-chan struct{}) error

Start start socket telemetry

func (*DeviceShifu) Stop

func (ds *DeviceShifu) Stop() error

Stop stop http server

type HandlerMetaData

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

HandlerMetaData MetaData for Socket Handler

type RequestBody

type RequestBody struct {
	Command string `json:"command"`
	Timeout int    `json:"timeout"`
}

RequestBody Socket Request Body

type ReturnBody

type ReturnBody struct {
	Message string `json:"message"`
	Status  int    `json:"status"`
}

ReturnBody Socket Reply Body