memstore

Documentation

Index

• func CreateMemoryStorage(minLatencyMs, maxLatencyMs int) storage.Storage
• func NewMemoryApplicationStorage(deviceStorage storage.DeviceStorage) storage.ApplicationStorage
• func NewMemoryDataStorage(devStorage storage.DeviceStorage, minLatencyMs, maxLatencyMs int) storage.DataStorage
• func NewMemoryDeviceStorage(minLatencyMs, maxLatencyMs int) storage.DeviceStorage
• func NewMemoryGatewayStorage() storage.GatewayStorage
• func NewMemoryKeySequenceStorage(minLatencyMs, maxLatencyMs int) storage.KeySequenceStorage
• func NewMemoryOutput() storage.AppOutputStorage
• func NewMemoryTokenStorage() storage.TokenStorage
• func NewMemoryUserManagement() storage.UserManagement
• type MemoryOutput
  • func (m *MemoryOutput) Delete(output model.AppOutput) error
  • func (m *MemoryOutput) GetByApplication(appEUI protocol.EUI) (<-chan model.AppOutput, error)
  • func (m *MemoryOutput) ListAll() (<-chan model.AppOutput, error)
  • func (m *MemoryOutput) Put(newOutput model.AppOutput) error
  • func (m *MemoryOutput) Update(output model.AppOutput) error

Functions

func CreateMemoryStorage

func CreateMemoryStorage(minLatencyMs, maxLatencyMs int) storage.Storage

CreateMemoryStorage creates a new storage backed by in-memory storage

func NewMemoryApplicationStorage

func NewMemoryApplicationStorage(deviceStorage storage.DeviceStorage) storage.ApplicationStorage

NewMemoryApplicationStorage returns a new instance of MemoryApplicationStorage

func NewMemoryDataStorage

func NewMemoryDataStorage(devStorage storage.DeviceStorage, minLatencyMs, maxLatencyMs int) storage.DataStorage

NewMemoryDataStorage makes a new MemoryDataStorage instance

func NewMemoryDeviceStorage

func NewMemoryDeviceStorage(minLatencyMs, maxLatencyMs int) storage.DeviceStorage

NewMemoryDeviceStorage creates a new MemoryDeviceStorage instance

func NewMemoryGatewayStorage

func NewMemoryGatewayStorage() storage.GatewayStorage

NewMemoryGatewayStorage returns a memory-backed gateway storage

func NewMemoryKeySequenceStorage

func NewMemoryKeySequenceStorage(minLatencyMs, maxLatencyMs int) storage.KeySequenceStorage

NewMemoryKeySequenceStorage returns a memory-backed KeySequenceStorage.

func NewMemoryOutput

func NewMemoryOutput() storage.AppOutputStorage

NewMemoryOutput creates a new memory output

func NewMemoryTokenStorage

func NewMemoryTokenStorage() storage.TokenStorage

NewMemoryTokenStorage creates a new storage.TokenStorage implementation that stores everything in memory.

func NewMemoryUserManagement

func NewMemoryUserManagement() storage.UserManagement

NewMemoryUserManagement returns a memory-backed UserManagement type

Types

type MemoryOutput

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

MemoryOutput is a memory-backed output storage

func (*MemoryOutput) Delete

func (m *MemoryOutput) Delete(output model.AppOutput) error

Delete removes the output. Outputs are also removed automatically when an application is removed

func (*MemoryOutput) GetByApplication

func (m *MemoryOutput) GetByApplication(appEUI protocol.EUI) (<-chan model.AppOutput, error)

GetByApplication returns outputs for a single application

func (*MemoryOutput) ListAll

func (m *MemoryOutput) ListAll() (<-chan model.AppOutput, error)

ListAll lists all of the outputs

func (*MemoryOutput) Put

func (m *MemoryOutput) Put(newOutput model.AppOutput) error

Put stores a new output

func (*MemoryOutput) Update

func (m *MemoryOutput) Update(output model.AppOutput) error

Update updates the configuration for the output.