notifier

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 2, 2025 License: Apache-2.0 Imports: 6 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 struct {
	Persistence driver.KeyValueStore
	*Notifier
}

func NewUnversioned 

func NewUnversioned(persistence driver.KeyValueStore) *UnversionedPersistenceNotifier

func (*UnversionedPersistenceNotifier) BeginUpdate 

func (db *UnversionedPersistenceNotifier) BeginUpdate() error

func (*UnversionedPersistenceNotifier) Close 

func (db *UnversionedPersistenceNotifier) Close() error

func (*UnversionedPersistenceNotifier) Commit 

func (db *UnversionedPersistenceNotifier) Commit() error

func (*UnversionedPersistenceNotifier) DeleteState 

func (db *UnversionedPersistenceNotifier) DeleteState(ctx context.Context, ns driver2.Namespace, key driver2.PKey) error

func (*UnversionedPersistenceNotifier) DeleteStates 

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

func (*UnversionedPersistenceNotifier) Discard 

func (db *UnversionedPersistenceNotifier) Discard() error

func (*UnversionedPersistenceNotifier) GetState 

func (db *UnversionedPersistenceNotifier) GetState(ctx context.Context, namespace driver2.Namespace, key driver2.PKey) (driver2.RawValue, error)

func (*UnversionedPersistenceNotifier) GetStateRangeScanIterator 

func (db *UnversionedPersistenceNotifier) GetStateRangeScanIterator(ctx context.Context, namespace driver2.Namespace, startKey, endKey driver2.PKey) (iterators.Iterator[*driver.UnversionedRead], error)

func (*UnversionedPersistenceNotifier) GetStateSetIterator 

func (db *UnversionedPersistenceNotifier) GetStateSetIterator(ctx context.Context, ns driver2.Namespace, keys ...driver2.PKey) (iterators.Iterator[*driver.UnversionedRead], error)

func (*UnversionedPersistenceNotifier) SetState 

func (db *UnversionedPersistenceNotifier) SetState(ctx context.Context, ns driver2.Namespace, key driver2.PKey, val driver2.RawValue) error

func (*UnversionedPersistenceNotifier) SetStates 

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

func (*UnversionedPersistenceNotifier) Stats 

func (db *UnversionedPersistenceNotifier) Stats() any

func (*UnversionedPersistenceNotifier) Subscribe 

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

func (*UnversionedPersistenceNotifier) UnsubscribeAll 

func (db *UnversionedPersistenceNotifier) UnsubscribeAll() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.