observer

package

v1.0.1 Latest Latest Go to latest Published: Oct 29, 2025 License: Apache-2.0 Imports: 5 Imported by: 4

Details

This section is empty.

This section is empty.

This section is empty.

type Ledger interface {
	RegisterForSidetreeTxn() <-chan []txn.SidetreeTxn
}

Ledger interface to access ledger txn.

type Observer struct {
	*Providers
	// contains filtered or unexported fields
}

Observer receives transactions over a channel and processes them by storing them to an operation store.

func New(providers *Providers) *Observer

New returns a new observer.

func (o *Observer) Start()

Start starts observer routines.

func (o *Observer) Stop()

Stop stops the observer.

type OperationFilter interface {
	Filter(uniqueSuffix string, ops []*operation.AnchoredOperation) ([]*operation.AnchoredOperation, error)
}

OperationFilter filters out operations before they are persisted.

type OperationStore interface {
	Put(ops []*operation.AnchoredOperation) error
}

OperationStore interface to access operation store.

type Providers struct {
	Ledger                 Ledger
	ProtocolClientProvider protocol.ClientProvider
}

Providers contains all of the providers required by the TxnProcessor.