redis

Documentation

Index

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

Types

type WebhookRegistry

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

WebhookRegistry is a Redis webhook registry.

func (WebhookRegistry) Get

func (r WebhookRegistry) Get(ctx context.Context, ids *ttnpb.ApplicationWebhookIdentifiers, paths []string) (*ttnpb.ApplicationWebhook, error)

Get implements WebhookRegistry.

func (*WebhookRegistry) Init

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

Init initializes the WebhookRegistry.

func (WebhookRegistry) List

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

List implements WebhookRegistry.

func (WebhookRegistry) Range

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

Range implements WebhookRegistry.

func (WebhookRegistry) Set

func (r WebhookRegistry) Set(ctx context.Context, ids *ttnpb.ApplicationWebhookIdentifiers, gets []string, f func(*ttnpb.ApplicationWebhook) (*ttnpb.ApplicationWebhook, []string, error)) (*ttnpb.ApplicationWebhook, error)

Set implements WebhookRegistry.