redis

Documentation

Index

• type PubSubRegistry
  • func (r PubSubRegistry) Get(ctx context.Context, ids *ttnpb.ApplicationPubSubIdentifiers, paths []string) (*ttnpb.ApplicationPubSub, error)
  • func (r *PubSubRegistry) Init(ctx context.Context) error
  • func (r PubSubRegistry) List(ctx context.Context, ids *ttnpb.ApplicationIdentifiers, paths []string) ([]*ttnpb.ApplicationPubSub, error)
  • func (r PubSubRegistry) Range(ctx context.Context, paths []string, ...) error
  • func (r PubSubRegistry) Set(ctx context.Context, ids *ttnpb.ApplicationPubSubIdentifiers, gets []string, ...) (*ttnpb.ApplicationPubSub, error)

Types

type PubSubRegistry

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

PubSubRegistry is a Redis pub/sub registry.

func (PubSubRegistry) Get

func (r PubSubRegistry) Get(ctx context.Context, ids *ttnpb.ApplicationPubSubIdentifiers, paths []string) (*ttnpb.ApplicationPubSub, error)

Get implements pubsub.Registry.

func (*PubSubRegistry) Init

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

Init initializes the PubSubRegistry.

func (PubSubRegistry) List

func (r PubSubRegistry) List(ctx context.Context, ids *ttnpb.ApplicationIdentifiers, paths []string) ([]*ttnpb.ApplicationPubSub, error)

List implements pubsub.Registry.

func (PubSubRegistry) Range

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

Range implements pubsub.Registry.

func (PubSubRegistry) Set

func (r PubSubRegistry) Set(ctx context.Context, ids *ttnpb.ApplicationPubSubIdentifiers, gets []string, f func(*ttnpb.ApplicationPubSub) (*ttnpb.ApplicationPubSub, []string, error)) (*ttnpb.ApplicationPubSub, error)

Set implements pubsub.Registry.