pgkeyvalue

Documentation

Index

• type KeyValue
• type PGKeyValueStore
  • func New(ctx context.Context, db *pgxpool.Pool, tableName string) (*PGKeyValueStore, error)
  • func (c *PGKeyValueStore) Load(ctx context.Context, keys []string) (map[string][]byte, error)
  • func (c *PGKeyValueStore) PeriodicCleanup(ctx context.Context, interval time.Duration, lifespan time.Duration) error
  • func (c *PGKeyValueStore) Store(ctx context.Context, kvs map[string][]byte) error

Types

type KeyValue

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

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

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

func (*PGKeyValueStore) Load

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

func (*PGKeyValueStore) PeriodicCleanup

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

PeriodicCleanup starts a goroutine that automatically runs the cleanup job every interval until the provided context is cancelled.

func (*PGKeyValueStore) Store

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