baetyl_bacnet

Documentation

Index

• type Bacnet
  • func NewBacnet(ctx dm.Context, cfg *Config) (*Bacnet, error)
  • func (bac *Bacnet) Close() error
  • func (bac *Bacnet) DeltaCallback(info *dm.DeviceInfo, delta v1.Delta) error
  • func (bac *Bacnet) PropertyGetCallback(info *dm.DeviceInfo, properties []string) error
• type Config
• type Job
• type Property
• type Slave
  • func NewSlave(info *dm.DeviceInfo, cfg SlaveConfig) (*Slave, error)
• type SlaveConfig
• type Worker
  • func NewWorker(job Job, slave *Slave, ctx dm.Context, log *log.Logger) *Worker
  • func (w *Worker) Execute() error

Types

type Bacnet

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

func NewBacnet

func NewBacnet(ctx dm.Context, cfg *Config) (*Bacnet, error)

func (*Bacnet) Close

func (bac *Bacnet) Close() error

func (*Bacnet) DeltaCallback

func (bac *Bacnet) DeltaCallback(info *dm.DeviceInfo, delta v1.Delta) error

func (*Bacnet) PropertyGetCallback

func (bac *Bacnet) PropertyGetCallback(info *dm.DeviceInfo, properties []string) error

type Config

type Config struct {
	Slaves []SlaveConfig `yaml:"slaves" json:"slaves"`
	Jobs   []Job         `yaml:"jobs" json:"jobs"`
}

type Job

type Job struct {
	Device        string              `yaml:"device" json:"device"`
	DeviceId      uint32              `yaml:"deviceId" json:"deviceId"`
	AddressOffset uint                `yaml:"addressOffset" json:"addressOffset"`
	Properties    map[string]Property `yaml:"properties" json:"properties"`
	Interval      time.Duration       `yaml:"interval" json:"interval" default:"15s"`
}

type Property

type Property struct {
	Id                   string `yaml:"id" json:"id"`
	Name                 string `yaml:"name" json:"name"`
	Type                 string `yaml:"type" json:"type"`
	Mode                 string `yaml:"mode" json:"mode"`
	BacnetType           uint   `yaml:"bacnetType" json:"bacnetType"`
	BacnetAddress        uint   `yaml:"bacnetAddress" json:"bacnetAddress"`
	ApplicationTagNumber byte   `yaml:"applicationTagNumber" json:"applicationTagNumber"`
}

type Slave

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

func NewSlave

func NewSlave(info *dm.DeviceInfo, cfg SlaveConfig) (*Slave, error)

type SlaveConfig

type SlaveConfig struct {
	Device   string        `yaml:"device" json:"device"`
	DeviceId uint32        `yaml:"deviceId" json:"deviceId"`
	Interval time.Duration `yaml:"interval,omitempty" json:"interval,omitempty"`
	Address  string        `yaml:"address" json:"address"`
	Port     int           `yaml:"port" json:"port"`
}

type Worker

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

func NewWorker

func NewWorker(job Job, slave *Slave, ctx dm.Context, log *log.Logger) *Worker

func (*Worker) Execute

func (w *Worker) Execute() error