parse

Documentation

Index

• Variables
• func BuildProtocol(device *v1alpha2.Device) (common.Protocol, error)
• func BuildProtocolFromGrpc(device *dmiapi.Device) (common.Protocol, error)
• func ConvGrpcToTwins(twins []*dmiapi.Twin, srcTwins []common.Twin) ([]common.Twin, error)
• func ConvMsgTwinToGrpc(msgTwin map[string]*common.MsgTwin) []*dmiapi.Twin
• func ConvTwinsToGrpc(twins []common.Twin) ([]*dmiapi.Twin, error)
• func Parse(path string, devices map[string]*common.DeviceInstance, ...) error
• func ParseByUsingRegister(cfg *config.Config, devices map[string]*common.DeviceInstance, ...) error
• func ParseDevice(device *v1alpha2.Device, commonModel *common.DeviceModel) (*common.DeviceInstance, error)
• func ParseDeviceFromGrpc(device *dmiapi.Device, commonModel *common.DeviceModel) (*common.DeviceInstance, error)
• func ParseDeviceModel(model *v1alpha2.DeviceModel) common.DeviceModel
• func ParseDeviceModelFromGrpc(model *dmiapi.DeviceModel) common.DeviceModel
• type DeviceData
• type TwinResultResponse

Variables

var ErrEmptyData error = errors.New("device or device model list is empty")

Functions

func BuildProtocol

func BuildProtocol(device *v1alpha2.Device) (common.Protocol, error)

func BuildProtocolFromGrpc

func BuildProtocolFromGrpc(device *dmiapi.Device) (common.Protocol, error)

func ConvGrpcToTwins

func ConvGrpcToTwins(twins []*dmiapi.Twin, srcTwins []common.Twin) ([]common.Twin, error)

func ConvMsgTwinToGrpc

func ConvMsgTwinToGrpc(msgTwin map[string]*common.MsgTwin) []*dmiapi.Twin

func ConvTwinsToGrpc

func ConvTwinsToGrpc(twins []common.Twin) ([]*dmiapi.Twin, error)

func Parse

func Parse(path string,
	devices map[string]*common.DeviceInstance,
	dms map[string]common.DeviceModel,
	protocols map[string]common.Protocol) error

Parse the configmap.

func ParseByUsingRegister

func ParseByUsingRegister(cfg *config.Config,
	devices map[string]*common.DeviceInstance,
	dms map[string]common.DeviceModel,
	protocols map[string]common.Protocol) error

func ParseDevice

func ParseDevice(device *v1alpha2.Device, commonModel *common.DeviceModel) (*common.DeviceInstance, error)

func ParseDeviceFromGrpc

func ParseDeviceFromGrpc(device *dmiapi.Device, commonModel *common.DeviceModel) (*common.DeviceInstance, error)

func ParseDeviceModel

func ParseDeviceModel(model *v1alpha2.DeviceModel) common.DeviceModel

func ParseDeviceModelFromGrpc

func ParseDeviceModelFromGrpc(model *dmiapi.DeviceModel) common.DeviceModel

Types

type DeviceData

type DeviceData struct {
	Device      *v1alpha2.Device      `json:"device"`
	DeviceModel *v1alpha2.DeviceModel `json:"device_model"`
}

type TwinResultResponse

type TwinResultResponse struct {
	PropertyName string `json:"property_name"`
	Payload      []byte `json:"payload"`
}