ice104

package
v0.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 14, 2026 License: GPL-2.0, GPL-3.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewICE104Driver

func NewICE104Driver() driver.Driver

Types

type ICE104Decoder

type ICE104Decoder struct{}

func NewICE104Decoder

func NewICE104Decoder() *ICE104Decoder

func (*ICE104Decoder) DecodeInformationObject

func (d *ICE104Decoder) DecodeInformationObject(typeID byte, payload []byte, sq bool, count int) ([]cachedPoint, error)

func (*ICE104Decoder) ParseAddress

func (d *ICE104Decoder) ParseAddress(addr string) (uint32, error)

func (*ICE104Decoder) PointKey

func (d *ICE104Decoder) PointKey(typeID byte, ioa uint32) string

func (*ICE104Decoder) PointMeta

func (d *ICE104Decoder) PointMeta(p model.Point) (typeID byte, ioa uint32, err error)

func (*ICE104Decoder) ToModelValue

func (d *ICE104Decoder) ToModelValue(p model.Point, cp cachedPoint) model.Value

type ICE104Driver

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

func (*ICE104Driver) Connect

func (d *ICE104Driver) Connect(ctx context.Context) error

func (*ICE104Driver) Disconnect

func (d *ICE104Driver) Disconnect() error

func (*ICE104Driver) GetConnectionMetrics

func (d *ICE104Driver) GetConnectionMetrics() (connectionSeconds int64, reconnectCount int64, localAddr string, remoteAddr string, lastDisconnectTime time.Time)

func (*ICE104Driver) Health

func (d *ICE104Driver) Health() driver.HealthStatus

func (*ICE104Driver) Init

func (d *ICE104Driver) Init(cfg model.DriverConfig) error

func (*ICE104Driver) ReadPoints

func (d *ICE104Driver) ReadPoints(ctx context.Context, points []model.Point) (map[string]model.Value, error)

func (*ICE104Driver) SetDeviceConfig

func (d *ICE104Driver) SetDeviceConfig(config map[string]any) error

func (*ICE104Driver) SetSlaveID

func (d *ICE104Driver) SetSlaveID(_ uint8) error

func (*ICE104Driver) WritePoint

func (d *ICE104Driver) WritePoint(ctx context.Context, point model.Point, value any) error

type ICE104Scheduler

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

func NewICE104Scheduler

func NewICE104Scheduler(transport *ICE104Transport, decoder *ICE104Decoder, cfg map[string]any) *ICE104Scheduler

func (*ICE104Scheduler) ReadPoints

func (s *ICE104Scheduler) ReadPoints(ctx context.Context, points []model.Point) (map[string]model.Value, error)

func (*ICE104Scheduler) WritePoint

func (s *ICE104Scheduler) WritePoint(ctx context.Context, point model.Point, value any) error

type ICE104Transport

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

func NewICE104Transport

func NewICE104Transport(cfg map[string]any) *ICE104Transport

func (*ICE104Transport) Connect

func (t *ICE104Transport) Connect(ctx context.Context) error

func (*ICE104Transport) Disconnect

func (t *ICE104Transport) Disconnect() error

func (*ICE104Transport) GetCached

func (t *ICE104Transport) GetCached(key string) (cachedPoint, bool)

func (*ICE104Transport) GetConnectionMetrics

func (t *ICE104Transport) GetConnectionMetrics() (connectionSeconds int64, reconnectCount int64, localAddr string, remoteAddr string, lastDisconnectTime time.Time)

func (*ICE104Transport) IsConnected

func (t *ICE104Transport) IsConnected() bool

func (*ICE104Transport) SendGeneralCall

func (t *ICE104Transport) SendGeneralCall(ctx context.Context) error

func (*ICE104Transport) SendSingleCommand

func (t *ICE104Transport) SendSingleCommand(ctx context.Context, ioa uint32, execute bool) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL