providers

Documentation

Index

• Variables
• func DeviceTypeUsesHandledProtocol(dt models.DeviceType, handledProtocols map[string]bool) (result bool)
• 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.PermDevice, err error)
  • func (this *DeviceProvider) GetNextDevice() (device model.PermDevice, 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.PermHub, err error)
  • func (this *HubProvider) GetNextHub() (hub model.PermHub, err error)
  • func (this *HubProvider) HubMatchesProtocol(hub model.PermHub) (result bool, err error)
• type Item
• type TokenGenerator

Variables

var EmptyBatch = errors.New("empty batch")

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 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.PermDevice, err error)

func (*DeviceProvider) GetNextDevice

func (this *DeviceProvider) GetNextDevice() (device model.PermDevice, 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.PermHub, err error)

func (*HubProvider) GetNextHub

func (this *HubProvider) GetNextHub() (hub model.PermHub, err error)

func (*HubProvider) HubMatchesProtocol

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

type Item

type Item struct {
	Key   string
	Value []byte
}

type TokenGenerator

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