redis

Documentation

Index

• Constants
• type ApplicationUplinkRegistry
  • func (r *ApplicationUplinkRegistry) Clear(ctx context.Context, ids *ttnpb.EndDeviceIdentifiers) error
  • func (r *ApplicationUplinkRegistry) Push(ctx context.Context, ids *ttnpb.EndDeviceIdentifiers, ...) error
  • func (r *ApplicationUplinkRegistry) Range(ctx context.Context, ids *ttnpb.EndDeviceIdentifiers, paths []string, ...) error
• type DeviceRegistry
  • func (r *DeviceRegistry) Get(ctx context.Context, ids *ttnpb.EndDeviceIdentifiers, paths []string) (*ttnpb.EndDevice, error)
  • func (r *DeviceRegistry) Init(ctx context.Context) error
  • func (r *DeviceRegistry) Range(ctx context.Context, paths []string, ...) error
  • func (r *DeviceRegistry) Set(ctx context.Context, ids *ttnpb.EndDeviceIdentifiers, gets []string, ...) (*ttnpb.EndDevice, error)
• type LinkRegistry
  • func (r *LinkRegistry) Get(ctx context.Context, ids *ttnpb.ApplicationIdentifiers, paths []string) (*ttnpb.ApplicationLink, error)
  • func (r *LinkRegistry) Init(ctx context.Context) error
  • func (r *LinkRegistry) Range(ctx context.Context, paths []string, ...) error
  • func (r *LinkRegistry) Set(ctx context.Context, ids *ttnpb.ApplicationIdentifiers, gets []string, ...) (*ttnpb.ApplicationLink, error)

Constants

const SchemaVersion = 1

SchemaVersion is the Application Server database schema version. Bump when a migration is required.

Types

type ApplicationUplinkRegistry

type ApplicationUplinkRegistry struct {
	Redis *ttnredis.Client
	Limit int64
}

ApplicationUplinkRegistry is a store for uplink messages.

func (*ApplicationUplinkRegistry) Clear

func (r *ApplicationUplinkRegistry) Clear(ctx context.Context, ids *ttnpb.EndDeviceIdentifiers) error

Clear empties the application uplink storage by the end device identifiers.

func (*ApplicationUplinkRegistry) Push

func (r *ApplicationUplinkRegistry) Push(ctx context.Context, ids *ttnpb.EndDeviceIdentifiers, up *ttnpb.ApplicationUplink) error

Push pushes the provided uplink message to the storage.

func (*ApplicationUplinkRegistry) Range

func (r *ApplicationUplinkRegistry) Range(ctx context.Context, ids *ttnpb.EndDeviceIdentifiers, paths []string, f func(context.Context, *ttnpb.ApplicationUplink) bool) error

Range ranges the uplink messagess and calls the callback function, until false is returned.

type DeviceRegistry

type DeviceRegistry struct {
	Redis   *ttnredis.Client
	LockTTL time.Duration
}

DeviceRegistry is a Redis device registry.

func (*DeviceRegistry) Get

func (r *DeviceRegistry) Get(ctx context.Context, ids *ttnpb.EndDeviceIdentifiers, paths []string) (*ttnpb.EndDevice, error)

Get returns the end device by its identifiers.

func (*DeviceRegistry) Init

func (r *DeviceRegistry) Init(ctx context.Context) error

Init initializes the DeviceRegistry.

func (*DeviceRegistry) Range

func (r *DeviceRegistry) Range(ctx context.Context, paths []string, f func(context.Context, *ttnpb.EndDeviceIdentifiers, *ttnpb.EndDevice) bool) error

Range ranges over the end devices and calls the callback function, until false is returned.

func (*DeviceRegistry) Set

func (r *DeviceRegistry) Set(ctx context.Context, ids *ttnpb.EndDeviceIdentifiers, gets []string, f func(*ttnpb.EndDevice) (*ttnpb.EndDevice, []string, error)) (*ttnpb.EndDevice, error)

Set creates, updates or deletes the end device by its identifiers.

type LinkRegistry

type LinkRegistry struct {
	Redis   *ttnredis.Client
	LockTTL time.Duration
}

LinkRegistry is a store for application links.

func (*LinkRegistry) Get

func (r *LinkRegistry) Get(ctx context.Context, ids *ttnpb.ApplicationIdentifiers, paths []string) (*ttnpb.ApplicationLink, error)

Get returns the link by the application identifiers.

func (*LinkRegistry) Init

func (r *LinkRegistry) Init(ctx context.Context) error

Init initializes the LinkRegistry.

func (*LinkRegistry) Range

func (r *LinkRegistry) Range(ctx context.Context, paths []string, f func(context.Context, *ttnpb.ApplicationIdentifiers, *ttnpb.ApplicationLink) bool) error

Range ranges the links and calls the callback function, until false is returned.

func (*LinkRegistry) Set

func (r *LinkRegistry) Set(ctx context.Context, ids *ttnpb.ApplicationIdentifiers, gets []string, f func(*ttnpb.ApplicationLink) (*ttnpb.ApplicationLink, []string, error)) (*ttnpb.ApplicationLink, error)

Set creates, updates or deletes the link by the application identifiers.