redis

package

v3.30.0 Latest Latest Go to latest Published: Apr 5, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/TheThingsNetwork/lorawan-stack

Links

Open Source Insights

Documentation ¶

Overview ¶

Package redis provides interfaces to Redis.

Constants ¶

View Source

const SchemaVersion = 1

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

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DeviceRegistry ¶

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

DeviceRegistry is a Redis device registry.

func (*DeviceRegistry) BatchDelete ¶ added in v3.27.0

func (r *DeviceRegistry) BatchDelete(
	ctx context.Context,
	appIDs *ttnpb.ApplicationIdentifiers,
	deviceIDs []string,
) ([]*ttnpb.EndDeviceIdentifiers, error)

BatchDelete implements 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 ¶ added in v3.15.2

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

Init initializes the DeviceRegistry.

func (*DeviceRegistry) Range ¶ added in v3.15.2

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 ¶ added in v3.15.2

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.

Source Files ¶

View all Source files

registry.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL