Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrDuplicateEntry = errors.New("entry with given id already exists")
Functions ¶
This section is empty.
Types ¶
type Collector ¶
type Collector struct {
// contains filtered or unexported fields
}
func NewCollector ¶
func NewCollectorFromClient ¶
type DebugPublisher ¶
type InfluxPublisher ¶
type InfluxPublisher struct {
// contains filtered or unexported fields
}
func NewInfluxPublisher ¶
func NewInfluxPublisher(addr, username, password, dbName, pointName string) (*InfluxPublisher, error)
func NewInfluxPublisherFromClient ¶
func NewInfluxPublisherFromClient(client influx.Client, dbName, pointName string) *InfluxPublisher
func (*InfluxPublisher) Close ¶
func (ip *InfluxPublisher) Close() error
func (*InfluxPublisher) PublishBlockVars ¶
func (*InfluxPublisher) PublishMarkers ¶
type Poller ¶
type Poller struct {
// contains filtered or unexported fields
}
func NewPoller ¶
func NewPoller(storage *PrestClient) *Poller
type PrestClient ¶
type PrestClient struct {
// contains filtered or unexported fields
}
func NewPrestClient ¶
func NewPrestClient(host string) (s *PrestClient, err error)
func (*PrestClient) GetBlockVars ¶
func (c *PrestClient) GetBlockVars(cid int) (BlockVars, error)
func (*PrestClient) GetChangedS7Devices ¶
func (c *PrestClient) GetChangedS7Devices(t uint64) ([]S7Device, error)
func (*PrestClient) GetMarkers ¶
func (c *PrestClient) GetMarkers(cid int) (Markers, error)
Source Files ¶
Click to show internal directories.
Click to hide internal directories.