notifier

Documentation

Index

• type Notifier
  • func NewNotifier() *Notifier
  • func (db *Notifier) Commit()
  • func (db *Notifier) Discard()
  • func (db *Notifier) EnqueueEvent(operation driver.Operation, payload map[driver.ColumnKey]string)
  • func (db *Notifier) Subscribe(callback driver.TriggerCallback) error
  • func (db *Notifier) UnsubscribeAll() error
• type UnversionedPersistenceNotifier
  • func NewUnversioned[P driver.UnversionedPersistence](persistence P) *UnversionedPersistenceNotifier[P]
  • func (db *UnversionedPersistenceNotifier[P]) BeginUpdate() error
  • func (db *UnversionedPersistenceNotifier[P]) Close() error
  • func (db *UnversionedPersistenceNotifier[P]) Commit() error
  • func (db *UnversionedPersistenceNotifier[P]) DeleteState(ns driver2.Namespace, key driver2.PKey) error
  • func (db *UnversionedPersistenceNotifier[P]) DeleteStates(namespace driver2.Namespace, keys ...driver2.PKey) map[driver2.PKey]error
  • func (db *UnversionedPersistenceNotifier[P]) Discard() error
  • func (db *UnversionedPersistenceNotifier[P]) GetState(namespace driver2.Namespace, key driver2.PKey) (driver2.RawValue, error)
  • func (db *UnversionedPersistenceNotifier[P]) GetStateRangeScanIterator(namespace driver2.Namespace, startKey, endKey driver2.PKey) (driver.UnversionedResultsIterator, error)
  • func (db *UnversionedPersistenceNotifier[P]) GetStateSetIterator(ns driver2.Namespace, keys ...driver2.PKey) (driver.UnversionedResultsIterator, error)
  • func (db *UnversionedPersistenceNotifier[P]) SetState(ns driver2.Namespace, key driver2.PKey, val driver2.RawValue) error
  • func (db *UnversionedPersistenceNotifier[P]) SetStates(ns driver2.Namespace, kvs map[driver2.PKey]driver2.RawValue) map[driver2.PKey]error
  • func (db *UnversionedPersistenceNotifier[P]) Stats() any
  • func (db *UnversionedPersistenceNotifier[P]) Subscribe(callback driver.TriggerCallback) error
  • func (db *UnversionedPersistenceNotifier[P]) UnsubscribeAll() error
• type VersionedPersistenceNotifier
  • func NewVersioned[P driver.VersionedPersistence](persistence P) *VersionedPersistenceNotifier[P]
  • func (db *VersionedPersistenceNotifier[P]) BeginUpdate() error
  • func (db *VersionedPersistenceNotifier[P]) Close() error
  • func (db *VersionedPersistenceNotifier[P]) Commit() error
  • func (db *VersionedPersistenceNotifier[P]) DeleteState(ns driver2.Namespace, key driver2.PKey) error
  • func (db *VersionedPersistenceNotifier[P]) DeleteStates(namespace driver2.Namespace, keys ...driver2.PKey) map[driver2.PKey]error
  • func (db *VersionedPersistenceNotifier[P]) Discard() error
  • func (db *VersionedPersistenceNotifier[P]) GetState(namespace driver2.Namespace, key driver2.PKey) (driver.VersionedValue, error)
  • func (db *VersionedPersistenceNotifier[P]) GetStateMetadata(namespace driver2.Namespace, key driver2.PKey) (driver2.Metadata, driver2.RawVersion, error)
  • func (db *VersionedPersistenceNotifier[P]) GetStateRangeScanIterator(namespace driver2.Namespace, startKey, endKey driver2.PKey) (driver.VersionedResultsIterator, error)
  • func (db *VersionedPersistenceNotifier[P]) GetStateSetIterator(ns driver2.Namespace, keys ...driver2.PKey) (driver.VersionedResultsIterator, error)
  • func (db *VersionedPersistenceNotifier[P]) SetState(namespace driver2.Namespace, key driver2.PKey, value driver.VersionedValue) error
  • func (db *VersionedPersistenceNotifier[P]) SetStateMetadata(namespace driver2.Namespace, key driver2.PKey, metadata driver2.Metadata, ...) error
  • func (db *VersionedPersistenceNotifier[P]) SetStateMetadatas(ns driver2.Namespace, kvs map[driver2.PKey]driver2.VersionedMetadataValue) map[driver2.PKey]error
  • func (db *VersionedPersistenceNotifier[P]) SetStates(ns driver2.Namespace, kvs map[driver2.PKey]driver.VersionedValue) map[driver2.PKey]error
  • func (db *VersionedPersistenceNotifier[P]) Stats() any
  • func (db *VersionedPersistenceNotifier[P]) Subscribe(callback driver.TriggerCallback) error
  • func (db *VersionedPersistenceNotifier[P]) UnsubscribeAll() error

Types

type Notifier

type Notifier struct {
	// contains filtered or unexported fields
}

func NewNotifier

func NewNotifier() *Notifier

func (*Notifier) Commit

func (db *Notifier) Commit()

func (*Notifier) Discard

func (db *Notifier) Discard()

func (*Notifier) EnqueueEvent

func (db *Notifier) EnqueueEvent(operation driver.Operation, payload map[driver.ColumnKey]string)

func (*Notifier) Subscribe

func (db *Notifier) Subscribe(callback driver.TriggerCallback) error

func (*Notifier) UnsubscribeAll

func (db *Notifier) UnsubscribeAll() error

type UnversionedPersistenceNotifier

type UnversionedPersistenceNotifier[P driver.UnversionedPersistence] struct {
	Persistence P
	*Notifier
}

func NewUnversioned

func NewUnversioned[P driver.UnversionedPersistence](persistence P) *UnversionedPersistenceNotifier[P]

func (*UnversionedPersistenceNotifier[P]) BeginUpdate

func (db *UnversionedPersistenceNotifier[P]) BeginUpdate() error

func (*UnversionedPersistenceNotifier[P]) Close

func (db *UnversionedPersistenceNotifier[P]) Close() error

func (*UnversionedPersistenceNotifier[P]) Commit

func (db *UnversionedPersistenceNotifier[P]) Commit() error

func (*UnversionedPersistenceNotifier[P]) DeleteState

func (db *UnversionedPersistenceNotifier[P]) DeleteState(ns driver2.Namespace, key driver2.PKey) error

func (*UnversionedPersistenceNotifier[P]) DeleteStates

func (db *UnversionedPersistenceNotifier[P]) DeleteStates(namespace driver2.Namespace, keys ...driver2.PKey) map[driver2.PKey]error

func (*UnversionedPersistenceNotifier[P]) Discard

func (db *UnversionedPersistenceNotifier[P]) Discard() error

func (*UnversionedPersistenceNotifier[P]) GetState

func (db *UnversionedPersistenceNotifier[P]) GetState(namespace driver2.Namespace, key driver2.PKey) (driver2.RawValue, error)

func (*UnversionedPersistenceNotifier[P]) GetStateRangeScanIterator

func (db *UnversionedPersistenceNotifier[P]) GetStateRangeScanIterator(namespace driver2.Namespace, startKey, endKey driver2.PKey) (driver.UnversionedResultsIterator, error)

func (*UnversionedPersistenceNotifier[P]) GetStateSetIterator

func (db *UnversionedPersistenceNotifier[P]) GetStateSetIterator(ns driver2.Namespace, keys ...driver2.PKey) (driver.UnversionedResultsIterator, error)

func (*UnversionedPersistenceNotifier[P]) SetState

func (db *UnversionedPersistenceNotifier[P]) SetState(ns driver2.Namespace, key driver2.PKey, val driver2.RawValue) error

func (*UnversionedPersistenceNotifier[P]) SetStates

func (db *UnversionedPersistenceNotifier[P]) SetStates(ns driver2.Namespace, kvs map[driver2.PKey]driver2.RawValue) map[driver2.PKey]error

func (*UnversionedPersistenceNotifier[P]) Stats

func (db *UnversionedPersistenceNotifier[P]) Stats() any

func (*UnversionedPersistenceNotifier[P]) Subscribe

func (db *UnversionedPersistenceNotifier[P]) Subscribe(callback driver.TriggerCallback) error

func (*UnversionedPersistenceNotifier[P]) UnsubscribeAll

func (db *UnversionedPersistenceNotifier[P]) UnsubscribeAll() error

type VersionedPersistenceNotifier

type VersionedPersistenceNotifier[P driver.VersionedPersistence] struct {
	Persistence P
	*Notifier
}

func NewVersioned

func NewVersioned[P driver.VersionedPersistence](persistence P) *VersionedPersistenceNotifier[P]

func (*VersionedPersistenceNotifier[P]) BeginUpdate

func (db *VersionedPersistenceNotifier[P]) BeginUpdate() error

func (*VersionedPersistenceNotifier[P]) Close

func (db *VersionedPersistenceNotifier[P]) Close() error

func (*VersionedPersistenceNotifier[P]) Commit

func (db *VersionedPersistenceNotifier[P]) Commit() error

func (*VersionedPersistenceNotifier[P]) DeleteState

func (db *VersionedPersistenceNotifier[P]) DeleteState(ns driver2.Namespace, key driver2.PKey) error

func (*VersionedPersistenceNotifier[P]) DeleteStates

func (db *VersionedPersistenceNotifier[P]) DeleteStates(namespace driver2.Namespace, keys ...driver2.PKey) map[driver2.PKey]error

func (*VersionedPersistenceNotifier[P]) Discard

func (db *VersionedPersistenceNotifier[P]) Discard() error

func (*VersionedPersistenceNotifier[P]) GetState

func (db *VersionedPersistenceNotifier[P]) GetState(namespace driver2.Namespace, key driver2.PKey) (driver.VersionedValue, error)

func (*VersionedPersistenceNotifier[P]) GetStateMetadata

func (db *VersionedPersistenceNotifier[P]) GetStateMetadata(namespace driver2.Namespace, key driver2.PKey) (driver2.Metadata, driver2.RawVersion, error)

func (*VersionedPersistenceNotifier[P]) GetStateRangeScanIterator

func (db *VersionedPersistenceNotifier[P]) GetStateRangeScanIterator(namespace driver2.Namespace, startKey, endKey driver2.PKey) (driver.VersionedResultsIterator, error)

func (*VersionedPersistenceNotifier[P]) GetStateSetIterator

func (db *VersionedPersistenceNotifier[P]) GetStateSetIterator(ns driver2.Namespace, keys ...driver2.PKey) (driver.VersionedResultsIterator, error)

func (*VersionedPersistenceNotifier[P]) SetState

func (db *VersionedPersistenceNotifier[P]) SetState(namespace driver2.Namespace, key driver2.PKey, value driver.VersionedValue) error

func (*VersionedPersistenceNotifier[P]) SetStateMetadata

func (db *VersionedPersistenceNotifier[P]) SetStateMetadata(namespace driver2.Namespace, key driver2.PKey, metadata driver2.Metadata, version driver2.RawVersion) error

func (*VersionedPersistenceNotifier[P]) SetStateMetadatas

func (db *VersionedPersistenceNotifier[P]) SetStateMetadatas(ns driver2.Namespace, kvs map[driver2.PKey]driver2.VersionedMetadataValue) map[driver2.PKey]error

func (*VersionedPersistenceNotifier[P]) SetStates

func (db *VersionedPersistenceNotifier[P]) SetStates(ns driver2.Namespace, kvs map[driver2.PKey]driver.VersionedValue) map[driver2.PKey]error

func (*VersionedPersistenceNotifier[P]) Stats

func (db *VersionedPersistenceNotifier[P]) Stats() any

func (*VersionedPersistenceNotifier[P]) Subscribe

func (db *VersionedPersistenceNotifier[P]) Subscribe(callback driver.TriggerCallback) error

func (*VersionedPersistenceNotifier[P]) UnsubscribeAll

func (db *VersionedPersistenceNotifier[P]) UnsubscribeAll() error