Versions in this module Expand all Collapse all v0 v0.1.58 Dec 5, 2020 Changes in this version + type EventClient interface + Add func(ctx context.Context, event *models.Event) (string, error) + AddBytes func(ctx context.Context, event []byte) (string, error) + Delete func(ctx context.Context, id string) error + DeleteForDevice func(ctx context.Context, deviceID string) error + DeleteOld func(ctx context.Context, age int) error + Event func(ctx context.Context, id string) (models.Event, error) + EventCount func(ctx context.Context) (int, error) + EventCountForDevice func(ctx context.Context, deviceId string) (int, error) + Events func(ctx context.Context) ([]models.Event, error) + EventsForDevice func(ctx context.Context, deviceID string, limit int) ([]models.Event, error) + EventsForDeviceAndValueDescriptor func(ctx context.Context, deviceId string, vd string, limit int) ([]models.Event, error) + EventsForInterval func(ctx context.Context, start int, end int, limit int) ([]models.Event, error) + MarkPushed func(ctx context.Context, id string) error + MarkPushedByChecksum func(ctx context.Context, checksum string) error + MarshalEvent func(e models.Event) ([]byte, error) + func NewEventClient(urlClient interfaces.URLClient) EventClient + type ReadingClient interface + Add func(ctx context.Context, reading *models.Reading) (string, error) + Delete func(ctx context.Context, id string) error + Reading func(ctx context.Context, id string) (models.Reading, error) + ReadingCount func(ctx context.Context) (int, error) + Readings func(ctx context.Context) ([]models.Reading, error) + ReadingsForDevice func(ctx context.Context, deviceId string, limit int) ([]models.Reading, error) + ReadingsForInterval func(ctx context.Context, start int, end int, limit int) ([]models.Reading, error) + ReadingsForLabel func(ctx context.Context, label string, limit int) ([]models.Reading, error) + ReadingsForName func(ctx context.Context, name string, limit int) ([]models.Reading, error) + ReadingsForNameAndDevice func(ctx context.Context, name string, deviceId string, limit int) ([]models.Reading, error) + ReadingsForType func(ctx context.Context, readingType string, limit int) ([]models.Reading, error) + ReadingsForUOMLabel func(ctx context.Context, uomLabel string, limit int) ([]models.Reading, error) + func NewReadingClient(urlClient interfaces.URLClient) ReadingClient + type ValueDescriptorClient interface + Add func(ctx context.Context, vdr *models.ValueDescriptor) (string, error) + Delete func(ctx context.Context, id string) error + DeleteByName func(ctx context.Context, name string) error + Update func(ctx context.Context, vdr *models.ValueDescriptor) error + ValueDescriptor func(ctx context.Context, id string) (models.ValueDescriptor, error) + ValueDescriptorForName func(ctx context.Context, name string) (models.ValueDescriptor, error) + ValueDescriptors func(ctx context.Context) ([]models.ValueDescriptor, error) + ValueDescriptorsByLabel func(ctx context.Context, label string) ([]models.ValueDescriptor, error) + ValueDescriptorsByUomLabel func(ctx context.Context, uomLabel string) ([]models.ValueDescriptor, error) + ValueDescriptorsForDevice func(ctx context.Context, deviceId string) ([]models.ValueDescriptor, error) + ValueDescriptorsForDeviceByName func(ctx context.Context, deviceName string) ([]models.ValueDescriptor, error) + ValueDescriptorsUsage func(ctx context.Context, names []string) (map[string]bool, error) + func NewValueDescriptorClient(urlClient interfaces.URLClient) ValueDescriptorClient