adaptors

Documentation

Overview

Package adaptors includes various server connector and data processors

Index

• Variables
• func Create(opts common.KVM) error
• func HandleMessage(msg common.MSG)
• func StopAll()
• type Adaptor
• type BYAdaptor
  • func (a *BYAdaptor) HandleMessage(msg common.MSG)
  • func (a *BYAdaptor) Init(opts common.KVM) error
  • func (a *BYAdaptor) Stop()
• type TBAdaptor
  • func (a *TBAdaptor) GET(path string, params req.Param) (*req.Resp, error)
  • func (a *TBAdaptor) HandleMessage(msg common.MSG)
  • func (a *TBAdaptor) Init(opts common.KVM) error
  • func (a *TBAdaptor) POST(path string, params req.Param) (*req.Resp, error)
  • func (a *TBAdaptor) Stop()

Variables

var MQ = make(chan common.MSG, 10)

MQ is the message queue which Adaptors push message to

var Running = make(map[string]Adaptor)

Running adaptors

Functions

func Create

func Create(opts common.KVM) error

Create adaptor instance

func HandleMessage

func HandleMessage(msg common.MSG)

HandleMessage handles messages from device

func StopAll

func StopAll()

StopAll stops all running adaptors

Types

type Adaptor

type Adaptor interface {
	HandleMessage(msg common.MSG)
	Stop()
}

Adaptor interface

type BYAdaptor

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

BYAdaptor defines the local adaptor

func (*BYAdaptor) HandleMessage

func (a *BYAdaptor) HandleMessage(msg common.MSG)

HandleMessage will be called when a device message is received

func (*BYAdaptor) Init

func (a *BYAdaptor) Init(opts common.KVM) error

Init the adaptors data

func (*BYAdaptor) Stop

func (a *BYAdaptor) Stop()

Stop the adaptor

type TBAdaptor

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

TBAdaptor defines the Thingsboard adaptor

func (*TBAdaptor) GET

func (a *TBAdaptor) GET(path string, params req.Param) (*req.Resp, error)

GET request

func (*TBAdaptor) HandleMessage

func (a *TBAdaptor) HandleMessage(msg common.MSG)

HandleMessage will be called when a device message is received

func (*TBAdaptor) Init

func (a *TBAdaptor) Init(opts common.KVM) error

Init the adaptors data

func (*TBAdaptor) POST

func (a *TBAdaptor) POST(path string, params req.Param) (*req.Resp, error)

POST request

func (*TBAdaptor) Stop

func (a *TBAdaptor) Stop()

Stop the adaptor