This commit is contained in:
Jaremy Creechley 2023-09-25 21:07:42 -07:00
parent 2861eba890
commit 7710dd7c26
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
2 changed files with 9 additions and 4 deletions

View File

@ -34,11 +34,16 @@ method put*(self: Datastore, batch: seq[BatchEntry]): Future[?!void] {.base, loc
method close*(self: Datastore): Future[?!void] {.base, locks: "unknown", raises: [].} = method close*(self: Datastore): Future[?!void] {.base, locks: "unknown", raises: [].} =
raiseAssert("Not implemented!") raiseAssert("Not implemented!")
method query*( method query*(self: Datastore,
self: Datastore, query: Query
query: Query): Future[?!QueryIter] {.base, gcsafe, raises: [].} = ): Future[?!QueryIter] {.base, gcsafe, raises: [].} =
raiseAssert("Not implemented!") raiseAssert("Not implemented!")
method queryIter*(self: Datastore,
query: Query
): ?!(iterator(): ?!QueryResponse) {.base, gcsafe, raises: [].} =
raiseAssert("Not implemented!")
proc contains*(self: Datastore, key: Key): Future[bool] {.async, raises: [].} = proc contains*(self: Datastore, key: Key): Future[bool] {.async, raises: [].} =
return (await self.has(key)) |? false return (await self.has(key)) |? false

View File

@ -59,7 +59,7 @@ method put*(self: SQLiteDatastore,
method close*(self: SQLiteDatastore): Future[?!void] {.async.} = method close*(self: SQLiteDatastore): Future[?!void] {.async.} =
self.db.close() self.db.close()
method query*( method queryIter*(
self: SQLiteDatastore, self: SQLiteDatastore,
query: Query query: Query
): ?!(iterator(): ?!QueryResponse) = ): ?!(iterator(): ?!QueryResponse) =