collector

type BlockVar struct {
	ID         int64   `json:"id"`
	S7DeviceID int64   `json:"s7_device_id"`
	DataBlock  int     `json:"data_block"`
	Addr       float32 `json:"addr"`
	Name       string  `json:"name"`
	Type       string  `json:"s7_type"`
	Unit       string  `json:"unit"`
}

type BlockVars []BlockVar

type Client interface {
	AGReadDB(dbNumber int, start int, size int, buffer []byte) (err error)
	AGReadMB(start int, size int, buffer []byte) (err error)
	Close() error
}

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

type DebugPublisher struct {
	W io.Writer
}

type Duration time.Duration

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

type Marker struct {
	ID         int64   `json:"id"`
	S7DeviceID int64   `json:"s7_device_id"`
	Addr       float32 `json:"addr"`
	Name       string  `json:"name"`
}

type Markers []Marker

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

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

type Publisher interface {
	PublishBlockVars(buf []byte, dataBlock int, vars BlockVars, t time.Time) error
	PublishMarkers(buf []byte, markers Markers, t time.Time) error
}

type S7Device struct {
	ID           int64    `json:"id"`
	IP           string   `json:"ip"`
	Rack         int      `json:"rack"`
	Slot         int      `json:"slot"`
	Active       bool     `json:"active"`
	PollInterval Duration `json:"poll_interval"`
	UpdatedAt    uint64   `json:"updated_at"`
	SeriesName   string   `json:"series_name"`
}