providers

Documentation

Index

• Variables
• func DeviceTypeUsesHandledProtocol(dt models.DeviceType, handledProtocols map[string]bool) (result bool)
• type Batch
  • func NewBatch[T any](getter func(offset int64) ([]T, error), checker func(T) (bool, error)) *Batch[T]
  • func (this *Batch[T]) GetNext() (result T, resets int, err error)
• type Cache
  • func NewCache(expiration time.Duration) *Cache
  • func (this *Cache) Reset()
  • func (this *Cache) Use(key string, getter func() (interface{}, error), result interface{}) (err error)
  • func (this *Cache) UseWithExpiration(key string, expiration time.Duration, getter func() (interface{}, error), ...) (err error)
• type DeviceProvider
  • func NewDeviceProvider(config configuration.Config, tokengen TokenGenerator, ...) (result *DeviceProvider, err error)
  • func (this *DeviceProvider) GetDevice(id string) (result model.ExtendedDevice, err error)
  • func (this *DeviceProvider) GetNextDevice() (device model.ExtendedDevice, resets int, err error)
• type DeviceTypeProvider
  • func NewDeviceTypeProvider(config configuration.Config, tokengen TokenGenerator) (*DeviceTypeProvider, error)
  • func (this *DeviceTypeProvider) GetDeviceType(id string) (result model.DeviceType, err error)
• type DeviceTypeProviderInterface
• type HubProvider
  • func NewHubProvider(config configuration.Config, tokengen TokenGenerator, ...) (result *HubProvider, err error)
  • func (this *HubProvider) GetHub(id string) (result model.ExtendedHub, err error)
  • func (this *HubProvider) GetNextHub() (hub model.ExtendedHub, resets int, err error)
  • func (this *HubProvider) HubMatchesProtocol(hub model.ExtendedHub) (result bool, err error)
• type Item
• type TokenGenerator

Variables

var BatchNoMatchAfterMultipleResets = errors.New("no matching element found after multiple resets")

var BatchNotInWindowErr = errors.New("no matching element in batch window")

var ErrNotFound = errors.New("key not found in cache")

Functions

func DeviceTypeUsesHandledProtocol

func DeviceTypeUsesHandledProtocol(dt models.DeviceType, handledProtocols map[string]bool) (result bool)

Types

type Batch

type Batch[T any] struct {
	// contains filtered or unexported fields
}

func NewBatch

func NewBatch[T any](getter func(offset int64) ([]T, error), checker func(T) (bool, error)) *Batch[T]

func (*Batch[T]) GetNext

func (this *Batch[T]) GetNext() (result T, resets int, err error)

type Cache

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

func NewCache

func NewCache(expiration time.Duration) *Cache

func (*Cache) Reset

func (this *Cache) Reset()

func (*Cache) Use

func (this *Cache) Use(key string, getter func() (interface{}, error), result interface{}) (err error)

func (*Cache) UseWithExpiration

func (this *Cache) UseWithExpiration(key string, expiration time.Duration, getter func() (interface{}, error), result interface{}) (err error)

type DeviceProvider

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

func NewDeviceProvider

func NewDeviceProvider(config configuration.Config, tokengen TokenGenerator, devicetypes DeviceTypeProviderInterface) (result *DeviceProvider, err error)

func (*DeviceProvider) GetDevice

func (this *DeviceProvider) GetDevice(id string) (result model.ExtendedDevice, err error)

func (*DeviceProvider) GetNextDevice

func (this *DeviceProvider) GetNextDevice() (device model.ExtendedDevice, resets int, err error)

type DeviceTypeProvider

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

func NewDeviceTypeProvider

func NewDeviceTypeProvider(config configuration.Config, tokengen TokenGenerator) (*DeviceTypeProvider, error)

func (*DeviceTypeProvider) GetDeviceType

func (this *DeviceTypeProvider) GetDeviceType(id string) (result model.DeviceType, err error)

type DeviceTypeProviderInterface

type DeviceTypeProviderInterface interface {
	GetDeviceType(deviceTypeId string) (dt models.DeviceType, err error)
}

type HubProvider

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

func NewHubProvider

func NewHubProvider(config configuration.Config, tokengen TokenGenerator, devicetypes DeviceTypeProviderInterface) (result *HubProvider, err error)

func (*HubProvider) GetHub

func (this *HubProvider) GetHub(id string) (result model.ExtendedHub, err error)

func (*HubProvider) GetNextHub

func (this *HubProvider) GetNextHub() (hub model.ExtendedHub, resets int, err error)

func (*HubProvider) HubMatchesProtocol

func (this *HubProvider) HubMatchesProtocol(hub model.ExtendedHub) (result bool, err error)

type Item

type Item struct {
	Key   string
	Value []byte
}

type TokenGenerator

type TokenGenerator interface {
	Access() (token string, err error)
}