bacnet

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

type Client interface {
	io.Closer
	IsRunning() bool
	ClientRun()
	WhoIs(wh *WhoIsOpts) ([]btypes.Device, error)
	WhatIsNetworkNumber() []*btypes.Address
	IAm(dest btypes.Address, iam btypes.IAm) error
	WhoIsRouterToNetwork() (resp *[]btypes.Address)
	Objects(dev btypes.Device) (btypes.Device, error)
	ReadProperty(dest btypes.Device, rp btypes.PropertyData) (btypes.PropertyData, error)
	ReadMultiProperty(dev btypes.Device, rp btypes.MultiplePropertyData) (btypes.MultiplePropertyData, error)
	ReadPropertyWithTimeout(dest btypes.Device, rp btypes.PropertyData, timeout time.Duration) (btypes.PropertyData, error)
	ReadMultiPropertyWithTimeout(dev btypes.Device, rp btypes.MultiplePropertyData, timeout time.Duration) (btypes.MultiplePropertyData, error)
	WriteProperty(dest btypes.Device, wp btypes.PropertyData) error
	WriteMultiProperty(dev btypes.Device, wp btypes.MultiplePropertyData) error
}

type ClientBuilder struct {
	DataLink   datalink.DataLink
	Interface  string
	Ip         string
	Port       int
	SubnetCIDR int
	MaxPDU     uint16
}

type DeviceConfig struct {
	DeviceID int
	IP       string
	Port     int
}

type DeviceContext struct {
	Device              btypes.Device
	Scheduler           *PointScheduler
	Config              DeviceConfig
	DeviceKey           string
	LastDiscovery       time.Time
	State               int
	ConsecutiveFailures int
	IsolationUntil      time.Time
	IsolationCount      int
	LastValues          map[string]model.Value
	CacheMu             sync.RWMutex
	ReadMu              sync.Mutex
	// contains filtered or unexported fields
}

type ObjectResult struct {
	Type         string `json:"type"`
	Instance     int    `json:"instance"`
	Name         string `json:"name,omitempty"`
	Description  string `json:"description,omitempty"`
	Units        string `json:"units,omitempty"`
	PresentValue any    `json:"present_value,omitempty"`
	StatusFlags  string `json:"status_flags,omitempty"`
	Reliability  string `json:"reliability,omitempty"`
	DiffStatus   string `json:"diff_status"` // new, existing, removed
}

type PointRuntime struct {
	Point         model.Point
	FailCount     int
	LastSuccess   time.Time
	State         string // OK, SKIPPED
	CooldownUntil time.Time
}

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

type PointWriteRequest struct {
	Point    model.Point
	Value    any
	Priority *uint8
}

type ScanResult struct {
	DeviceID     int    `json:"device_id"`
	IP           string `json:"ip"`
	Port         int    `json:"port"`
	Network      uint16 `json:"network_number"`
	VendorID     uint32 `json:"vendor_id"`
	VendorName   string `json:"vendor_name"`
	ModelName    string `json:"model_name"`
	ObjectName   string `json:"object_name"`
	MaxAPDU      uint32 `json:"max_apdu"`
	Segmentation uint32 `json:"segmentation"`
	Status       string `json:"status"`
	DiffStatus   string `json:"diff_status,omitempty"` // new, existing
}

type SetBroadcastType struct {
	Set     bool
	BacFunc btypes.BacFunc
}

type WhoIsOpts struct {
	Low             int             `json:"low"`
	High            int             `json:"high"`
	GlobalBroadcast bool            `json:"global_broadcast"`
	NetworkNumber   uint16          `json:"network_number"`
	Destination     *btypes.Address `json:"-"`
}