redis

Documentation

Index

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

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.