dmiserver

Documentation

Index

• Constants
• func CreateMessageStateUpdate(in *pb.ReportDeviceStatesRequest) ([]byte, error)
• func CreateMessageTwinUpdate(twin *pb.Twin) ([]byte, error)
• func StartDMIServer(cache *DMICache)
• type DMICache
• type DeviceStateUpdate
• type DeviceTwinUpdate

Constants

const (
	Limit = 1000
	Burst = 100
)

const (
	SockPath = "/etc/kubeedge/dmi.sock"
)

Functions

func CreateMessageStateUpdate

func CreateMessageStateUpdate(in *pb.ReportDeviceStatesRequest) ([]byte, error)

CreateMessageStateUpdate create state update message.

func CreateMessageTwinUpdate

func CreateMessageTwinUpdate(twin *pb.Twin) ([]byte, error)

CreateMessageTwinUpdate create twin update message.

func StartDMIServer

func StartDMIServer(cache *DMICache)

Types

type DMICache

type DMICache struct {
	MapperMu        *sync.Mutex
	DeviceMu        *sync.Mutex
	DeviceModelMu   *sync.Mutex
	MapperList      map[string]*pb.MapperInfo
	DeviceModelList map[string]*v1beta1.DeviceModel
	DeviceList      map[string]*v1beta1.Device
}

type DeviceStateUpdate

type DeviceStateUpdate struct {
	types.BaseMessage
	State string
}

DeviceStateUpdate the structure of device state update.

type DeviceTwinUpdate

type DeviceTwinUpdate struct {
	types.BaseMessage
	Twin map[string]*types.MsgTwin `json:"twin"`
}

DeviceTwinUpdate the structure of device twin update.