internal

Documentation

Index

• func LoadValidator(validator *types.Validator) error
• func LoadValidators() error
• func Push(pid, id string, ctx map[string]interface{})
• func SubscribeOffline()
• func SubscribeProperty(client mqtt.Client)
• type Device
  • func (d *Device) Push(pid, id string, ctx map[string]interface{})
• type Product
  • func (p *Product) Push(pid, id string, ctx map[string]interface{})
• type Validator

Functions

func LoadValidator

func LoadValidator(validator *types.Validator) error

func LoadValidators

func LoadValidators() error

func Push

func Push(pid, id string, ctx map[string]interface{})

func SubscribeOffline

func SubscribeOffline()

func SubscribeProperty

func SubscribeProperty(client mqtt.Client)

Types

type Device

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

func (*Device) Push

func (d *Device) Push(pid, id string, ctx map[string]interface{})

type Product

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

func (*Product) Push

func (p *Product) Push(pid, id string, ctx map[string]interface{})

type Validator

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