Documentation ¶
Index ¶
- Constants
- type Driver
- type DynKVItem
- type EntriesIterator
- type Store
- func (s *Store) Check()
- func (s *Store) Close()
- func (s *Store) Delete(ctx context.Context, partitionKey, key []byte) error
- func (s *Store) DropTable() error
- func (s *Store) Get(ctx context.Context, partitionKey, key []byte) (*kv.ValueWithPredicate, error)
- func (s *Store) Scan(ctx context.Context, partitionKey []byte, options kv.ScanOptions) (kv.EntriesIterator, error)
- func (s *Store) Set(ctx context.Context, partitionKey, key, value []byte) error
- func (s *Store) SetIf(ctx context.Context, partitionKey, key, value []byte, ...) error
- func (s *Store) StartPeriodicCheck()
- func (s *Store) StopPeriodicCheck()
Constants ¶
View Source
const ( DriverName = "dynamodb" PartitionKey = "PartitionKey" ItemKey = "ItemKey" ItemValue = "ItemValue" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EntriesIterator ¶
type EntriesIterator struct {
// contains filtered or unexported fields
}
func (*EntriesIterator) Close ¶
func (e *EntriesIterator) Close()
func (*EntriesIterator) Entry ¶
func (e *EntriesIterator) Entry() *kv.Entry
func (*EntriesIterator) Err ¶
func (e *EntriesIterator) Err() error
func (*EntriesIterator) Next ¶
func (e *EntriesIterator) Next() bool
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
func (*Store) Scan ¶
func (s *Store) Scan(ctx context.Context, partitionKey []byte, options kv.ScanOptions) (kv.EntriesIterator, error)
func (*Store) StartPeriodicCheck ¶ added in v0.94.0
func (s *Store) StartPeriodicCheck()
StartPeriodicCheck performs one check and continues every 'interval' in the background
func (*Store) StopPeriodicCheck ¶ added in v0.94.0
func (s *Store) StopPeriodicCheck()
Click to show internal directories.
Click to hide internal directories.