processor

Documentation

Index

• Constants
• Variables
• func InitProcessor(r IDpReportProcessor) error
• func MatchDeviceType(devId string) (string, error)
• func MatchString(pattern string, s string) bool
• type DefaultDpReportProcessor
  • func (p *DefaultDpReportProcessor) DeviceType() string
  • func (p *DefaultDpReportProcessor) Process(topicDevId string, Data map[string]string) (bool, error)
• type IDpReportProcessor
  • func GetDpReportProcessor(protocolVersion string) IDpReportProcessor
• type MeshDpReportProcessor
  • func (p *MeshDpReportProcessor) DeviceType() string
  • func (p *MeshDpReportProcessor) Process(topicDevId string, Data map[string]string) (bool, error)

Constants

const DEVICETYPE_ANDROID string = "ANDROID" //android"),

const DEVICETYPE_GATEWAY string = "GATEWAY" //网关"),

const DEVICETYPE_IOS string = "IOS" //ios"),

const DEVICETYPE_MESH string = "MESH" //MESH网关"),

const DEVICETYPE_MOBILE string = "MOBILE" //手机"),

const DEVICETYPE_OTHER string = "OTHER" //OTHER"),

const DEVICETYPE_SERVER string = "SERVER" //服务器"),

const DeviceTypeDefault = "Default"

Variables

var DpReportProcessors map[string]IDpReportProcessor = make(map[string]IDpReportProcessor)

Functions

func InitProcessor

func InitProcessor(r IDpReportProcessor) error

InitProcessor 实现类自己主动注册进来

func MatchDeviceType

func MatchDeviceType(devId string) (string, error)

func MatchString

func MatchString(pattern string, s string) bool

Types

type DefaultDpReportProcessor

type DefaultDpReportProcessor struct {
}

func (*DefaultDpReportProcessor) DeviceType

func (p *DefaultDpReportProcessor) DeviceType() string

func (*DefaultDpReportProcessor) Process

func (p *DefaultDpReportProcessor) Process(topicDevId string, Data map[string]string) (bool, error)

type IDpReportProcessor

type IDpReportProcessor interface {
	DeviceType() string
	Process(topicDevId string, Data map[string]string) (bool, error)
}

func GetDpReportProcessor

func GetDpReportProcessor(protocolVersion string) IDpReportProcessor

type MeshDpReportProcessor

type MeshDpReportProcessor struct {
}

func (*MeshDpReportProcessor) DeviceType

func (p *MeshDpReportProcessor) DeviceType() string

func (*MeshDpReportProcessor) Process

func (p *MeshDpReportProcessor) Process(topicDevId string, Data map[string]string) (bool, error)