datastore

Documentation

Index

• func NewDynamoDBDatastore(cfg aws.Config, tableName string, ...) *dynamoDBDatastore
• type Datastore
• type KeyConfig
• type RedisDatastore
  • func (r RedisDatastore) IncrKeys(ctx context.Context, keys []KeyConfig) ([]int, []error)

Functions

func NewDynamoDBDatastore

func NewDynamoDBDatastore(
	cfg aws.Config,
	tableName string,
	keyGetter func(identifier string) map[string]string,
	ttlAttr string,
	countAttr string,
) *dynamoDBDatastore

Types

type Datastore

type Datastore interface {
	// Responsible for incrementing keys. Returns the post increment counts.
	//
	// Should also add relevant expiry based on MaxLifespan of keys to ensure cleanup. Ideally the expiry should be set on the first increment of the key.
	IncrKeys(ctx context.Context, keys []KeyConfig) ([]int, []error)
}

type KeyConfig

type KeyConfig struct {
	Key         string
	MaxLifespan time.Duration
}

type RedisDatastore

type RedisDatastore struct {
	Client        *redis.Client
	ClusterClient *redis.ClusterClient
}

RedisDatastore represents a datastore backed by Redis.

func (RedisDatastore) IncrKeys

func (r RedisDatastore) IncrKeys(ctx context.Context, keys []KeyConfig) ([]int, []error)

IncrKeys increments the keys in Redis and sets an expiration time on the first increment.