service

Documentation

Index

• Constants
• Variables
• func AddAction(ws *restful.WebService, kind *resource.Kind, httpMethod string, action string, ...) *restful.WebService
• func AddAlertDataWS(ws *restful.WebService) *restful.WebService
• func AddControlWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService
• func AddDeviceDataWS(ws *restful.WebService) *restful.WebService
• func AddDeviceListWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService
• func AddDeviceSummaryWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService
• func AddLog(ws *restful.WebService, kind *resource.Kind, function restful.RouteFunction) *restful.WebService
• func AddLogWS(ws *restful.WebService) *restful.WebService
• func AddNodeWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService
• func AddPipeTaskListWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService
• func AddPipeTaskStateListWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService
• func AddPipelineListWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService
• func AddProductListWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService
• func AddProtocolListWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService
• func AddResourceListWS(kind *resource.Kind, cli api.DatahubApi, ws *restful.WebService) *restful.WebService
• func AddResourceSummaryWS(kind *resource.Kind, cli api.DatahubApi, ws *restful.WebService) *restful.WebService
• func AddResourceWS(kind *resource.Kind, cli api.DatahubApi, ws *restful.WebService) *restful.WebService
• func GetSwagger(request *restful.Request, response *restful.Response)
• func GetSwaggerUI(request *restful.Request, response *restful.Response)
• func GetSwaggerUIResouces(req *restful.Request, resp *restful.Response)
• func NewControlAPI(root string, cli api.DatahubApi) *restful.WebService
• func NewDataAPI(root string, cli api.DatahubApi) *restful.WebService
• func NewEdgeSwaggerAPI(root string) *restful.WebService
• func NewLogAPI(root string, cli api.DatahubApi) *restful.WebService
• func NewResourceAPI(root string, cli api.DatahubApi) *restful.WebService
• func WriteError(rsp *restful.Response, v stderr.StdError)
• func WriteResult(rsp *restful.Response, v interface{})
• type DeviceSummary
• type LogData

Constants

const (
	SocketIoNS   = "/"
	SocketIoRoom = "default"

	SocketEventNotif = "notif"
	SocketEventState = "state"
	SocketEventAlert = "alert"
)

Variables

var SwaggerUIRoot = "public/swagger-ui"

var WsApi = &wsApi{}

Functions

func AddAction

func AddAction(ws *restful.WebService, kind *resource.Kind, httpMethod string, action string, function restful.RouteFunction, queries ...string) *restful.WebService

func AddAlertDataWS

func AddAlertDataWS(ws *restful.WebService) *restful.WebService

func AddControlWS

func AddControlWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService

func AddDeviceDataWS

func AddDeviceDataWS(ws *restful.WebService) *restful.WebService

func AddDeviceListWS

func AddDeviceListWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService

func AddDeviceSummaryWS

func AddDeviceSummaryWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService

func AddLog

func AddLog(ws *restful.WebService, kind *resource.Kind, function restful.RouteFunction) *restful.WebService

func AddLogWS

func AddLogWS(ws *restful.WebService) *restful.WebService

func AddNodeWS

func AddNodeWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService

func AddPipeTaskListWS

func AddPipeTaskListWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService

func AddPipeTaskStateListWS

func AddPipeTaskStateListWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService

func AddPipelineListWS

func AddPipelineListWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService

func AddProductListWS

func AddProductListWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService

func AddProtocolListWS

func AddProtocolListWS(cli api.DatahubApi, ws *restful.WebService) *restful.WebService

func AddResourceListWS

func AddResourceListWS(kind *resource.Kind, cli api.DatahubApi, ws *restful.WebService) *restful.WebService

func AddResourceSummaryWS

func AddResourceSummaryWS(kind *resource.Kind, cli api.DatahubApi, ws *restful.WebService) *restful.WebService

func AddResourceWS

func AddResourceWS(kind *resource.Kind, cli api.DatahubApi, ws *restful.WebService) *restful.WebService

func GetSwagger

func GetSwagger(request *restful.Request, response *restful.Response)

func GetSwaggerUI

func GetSwaggerUI(request *restful.Request, response *restful.Response)

func GetSwaggerUIResouces

func GetSwaggerUIResouces(req *restful.Request, resp *restful.Response)

func NewControlAPI

func NewControlAPI(root string, cli api.DatahubApi) *restful.WebService

func NewDataAPI

func NewDataAPI(root string, cli api.DatahubApi) *restful.WebService

func NewEdgeSwaggerAPI

func NewEdgeSwaggerAPI(root string) *restful.WebService

func NewLogAPI

func NewLogAPI(root string, cli api.DatahubApi) *restful.WebService

func NewResourceAPI

func NewResourceAPI(root string, cli api.DatahubApi) *restful.WebService

func WriteError

func WriteError(rsp *restful.Response, v stderr.StdError)

func WriteResult

func WriteResult(rsp *restful.Response, v interface{})

Types

type DeviceSummary

type DeviceSummary struct {
	resource.Device
	ProductName  string `json:"product_name,omitempty"`  // auxiliary fields, updated according to product_id
	ProtocolId   string `json:"protocol_id,omitempty"`   // same as above
	ProtocolName string `json:"protocol_name,omitempty"` // same as above
}

type LogData

type LogData struct {
	Content string `json:"content,omitempty"`
	Offset  string `json:"offset,omitempty"`
	Size    string `json:"size,omitempty"`
	Total   string `json:"total,omitempty"`
}