redis

Documentation

Index

• type ApplicationPackagesRegistry
  • func (r *ApplicationPackagesRegistry) EndDeviceTransaction(ctx context.Context, ids ttnpb.EndDeviceIdentifiers, fPort uint32, ...) error
  • func (r ApplicationPackagesRegistry) GetAssociation(ctx context.Context, ids *ttnpb.ApplicationPackageAssociationIdentifiers, ...) (*ttnpb.ApplicationPackageAssociation, error)
  • func (r ApplicationPackagesRegistry) GetDefaultAssociation(ctx context.Context, ...) (*ttnpb.ApplicationPackageDefaultAssociation, error)
  • func (r *ApplicationPackagesRegistry) Init(ctx context.Context) error
  • func (r ApplicationPackagesRegistry) ListAssociations(ctx context.Context, ids *ttnpb.EndDeviceIdentifiers, paths []string) ([]*ttnpb.ApplicationPackageAssociation, error)
  • func (r ApplicationPackagesRegistry) ListDefaultAssociations(ctx context.Context, ids *ttnpb.ApplicationIdentifiers, paths []string) ([]*ttnpb.ApplicationPackageDefaultAssociation, error)
  • func (r ApplicationPackagesRegistry) Range(ctx context.Context, paths []string, ...) error
  • func (r ApplicationPackagesRegistry) SetAssociation(ctx context.Context, ids *ttnpb.ApplicationPackageAssociationIdentifiers, ...) (*ttnpb.ApplicationPackageAssociation, error)
  • func (r ApplicationPackagesRegistry) SetDefaultAssociation(ctx context.Context, ...) (*ttnpb.ApplicationPackageDefaultAssociation, error)
  • func (r ApplicationPackagesRegistry) WithPagination(ctx context.Context, limit, page uint32, total *int64) context.Context

Types

type ApplicationPackagesRegistry

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

ApplicationPackagesRegistry is a Redis application packages registry.

func (*ApplicationPackagesRegistry) EndDeviceTransaction

func (r *ApplicationPackagesRegistry) EndDeviceTransaction(ctx context.Context, ids ttnpb.EndDeviceIdentifiers, fPort uint32, packageName string, fn func(ctx context.Context) error) error

EndDeviceTransaction implements applicationpackages.TransactionRegistry.

func (ApplicationPackagesRegistry) GetAssociation

func (r ApplicationPackagesRegistry) GetAssociation(ctx context.Context, ids *ttnpb.ApplicationPackageAssociationIdentifiers, paths []string) (*ttnpb.ApplicationPackageAssociation, error)

GetAssociation implements applicationpackages.AssociationRegistry.

func (ApplicationPackagesRegistry) GetDefaultAssociation

func (r ApplicationPackagesRegistry) GetDefaultAssociation(ctx context.Context, ids *ttnpb.ApplicationPackageDefaultAssociationIdentifiers, paths []string) (*ttnpb.ApplicationPackageDefaultAssociation, error)

GetDefaultAssociation implements applicationpackages.AssociationRegistry.

func (*ApplicationPackagesRegistry) Init

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

Init initializes the ApplicationPackagesRegistry.

func (ApplicationPackagesRegistry) ListAssociations

func (r ApplicationPackagesRegistry) ListAssociations(ctx context.Context, ids *ttnpb.EndDeviceIdentifiers, paths []string) ([]*ttnpb.ApplicationPackageAssociation, error)

ListAssociations implements applicationpackages.AssociationRegistry.

func (ApplicationPackagesRegistry) ListDefaultAssociations

func (r ApplicationPackagesRegistry) ListDefaultAssociations(ctx context.Context, ids *ttnpb.ApplicationIdentifiers, paths []string) ([]*ttnpb.ApplicationPackageDefaultAssociation, error)

ListDefaultAssociations implements applicationpackages.AssociationRegistry.

func (ApplicationPackagesRegistry) Range

func (r ApplicationPackagesRegistry) Range(
	ctx context.Context, paths []string,
	devFunc func(context.Context, ttnpb.EndDeviceIdentifiers, *ttnpb.ApplicationPackageAssociation) bool,
	appFunc func(context.Context, ttnpb.ApplicationIdentifiers, *ttnpb.ApplicationPackageDefaultAssociation) bool,
) error

Range ranges over the application packages and calls the appropriate callback function, until false is returned.

func (ApplicationPackagesRegistry) SetAssociation

func (r ApplicationPackagesRegistry) SetAssociation(ctx context.Context, ids *ttnpb.ApplicationPackageAssociationIdentifiers, gets []string, f func(*ttnpb.ApplicationPackageAssociation) (*ttnpb.ApplicationPackageAssociation, []string, error)) (*ttnpb.ApplicationPackageAssociation, error)

SetAssociation implements applicationpackages.AssociationRegistry.

func (ApplicationPackagesRegistry) SetDefaultAssociation

func (r ApplicationPackagesRegistry) SetDefaultAssociation(ctx context.Context, ids *ttnpb.ApplicationPackageDefaultAssociationIdentifiers, gets []string, f func(*ttnpb.ApplicationPackageDefaultAssociation) (*ttnpb.ApplicationPackageDefaultAssociation, []string, error)) (*ttnpb.ApplicationPackageDefaultAssociation, error)

SetDefaultAssociation implements applicationpackages.AssociationRegistry.

func (ApplicationPackagesRegistry) WithPagination

func (r ApplicationPackagesRegistry) WithPagination(ctx context.Context, limit, page uint32, total *int64) context.Context

WithPagination implements applicationpackages.AssociationRegistry.