redis

Documentation

Index

• type DeviceRegistry
  • func (r *DeviceRegistry) Get(ctx context.Context, ids ttnpb.EndDeviceIdentifiers, paths []string) (*ttnpb.EndDevice, 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) Range(ctx context.Context, paths []string, ...) error
  • func (r *LinkRegistry) Set(ctx context.Context, ids ttnpb.ApplicationIdentifiers, gets []string, ...) (*ttnpb.ApplicationLink, error)

Types

type DeviceRegistry

type DeviceRegistry struct {
	Redis *ttnredis.Client
}

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) 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
}

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) 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.