PsrRowsStorage implements RowsStorage
Read onlyYes
FinalYes
Tags
Interfaces
Methods
- __construct() : mixed
- append() : void
- An empty batch still makes has() answer true for the key.
- close() : void
- Finishes the key's pending writes so another process can read it; a no-op for a key with none.
- get() : Generator<string|int, Rows>
- Yields the key's rows back in batches - batch shape is storage-defined, consumers must not assume any particular batch size.
- has() : bool
- remove() : void
- rows() : Cardinality
- schema() : Schema|null
- The schema every batch of the key fits; null for a missing key.
Methods
__construct()
public
__construct(CacheInterface $cache, Serializer $serializer[, string $prefix = 'flow.rows' ][, int|DateInterval|null $ttl = null ]) : mixed
Parameters
- $cache : CacheInterface
- $serializer : Serializer
- $prefix : string = 'flow.rows'
- $ttl : int|DateInterval|null = null
append()
An empty batch still makes has() answer true for the key.
public
append(string $key, Rows $rows) : void
Parameters
- $key : string
- $rows : Rows
close()
Finishes the key's pending writes so another process can read it; a no-op for a key with none.
public
close(string $key) : void
Parameters
- $key : string
get()
Yields the key's rows back in batches - batch shape is storage-defined, consumers must not assume any particular batch size.
public
get(string $key) : Generator<string|int, Rows>
Parameters
- $key : string
Return values
Generator<string|int, Rows>has()
public
has(string $key) : bool
Parameters
- $key : string
Return values
boolremove()
public
remove(string $key) : void
Parameters
- $key : string
rows()
public
rows(string $key) : Cardinality
Parameters
- $key : string
Return values
Cardinalityschema()
The schema every batch of the key fits; null for a missing key.
public
schema(string $key) : Schema|null
Parameters
- $key : string