pgkeyvalue

type KeyValue ¶

type KeyValue struct {
	Key      string    `db:"key"`
	Value    []byte    `db:"value"`
	Inserted time.Time `db:"inserted"`
}

type KeyValueStore ¶ added in v0.4.44

type KeyValueStore interface {
	Store(ctx *armadacontext.Context, kvs map[string][]byte) error
	Load(ctx *armadacontext.Context, keys []string) (map[string][]byte, error)
}

type PGKeyValueStore ¶

type PGKeyValueStore struct {
	// contains filtered or unexported fields
}

PGKeyValueStore is a time-limited key-value store backed by postgres with a local LRU cache. The store is write-only, i.e., writing to an existing key will return an error (of type *armadaerrors.ErrAlreadyExists). Keys can only be deleted by running the cleanup function. Deleting keys does not cause caches to update, i.e., nodes may have an inconsistent view if keys are deleted.

func New(ctx *armadacontext.Context, db *pgxpool.Pool, tableName string) (*PGKeyValueStore, error)

func (c *PGKeyValueStore) Load(ctx *armadacontext.Context, keys []string) (map[string][]byte, error)

func (c *PGKeyValueStore) PeriodicCleanup(ctx *armadacontext.Context, interval time.Duration, lifespan time.Duration) error

func (c *PGKeyValueStore) Store(ctx *armadacontext.Context, kvs map[string][]byte) error