state

type Memory struct {
	Now func() time.Time
	// contains filtered or unexported fields
}

type Reader interface {
	Get(context.Context, string) (Record, error)
	// List returns up to limit records in key order, strictly after after.
	List(ctx context.Context, prefix, after string, limit int) ([]Record, error)
}

type Record struct {
	Key       string
	Value     []byte
	ExpiresAt time.Time
}

type Store interface {
	Reader
	Update(ctx context.Context, keys []string, fn func(Tx) error) error
	// Prune deletes at most limit expired records. It never deletes immortal data.
	Prune(ctx context.Context, limit int) (int, error)
}

type Tx interface {
	Reader
	Now() time.Time
	Put(context.Context, Record) error
	Delete(context.Context, string) error
}