observer

Documentation

Index

• type Ledger
• type Observer
  • func New(providers *Providers) *Observer
  • func (o *Observer) Start()
  • func (o *Observer) Stop()
• type OperationFilter
• type OperationStore
• type Providers

Types

type Ledger

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

Ledger interface to access ledger txn.

type Observer

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

func New(providers *Providers) *Observer

New returns a new observer.

func (*Observer) Start

func (o *Observer) Start()

Start starts observer routines.

func (*Observer) Stop

func (o *Observer) Stop()

Stop stops the observer.

type OperationFilter

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

OperationFilter filters out operations before they are persisted.

type OperationStore

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

OperationStore interface to access operation store.

type Providers

type Providers struct {
	Ledger                 Ledger
	ProtocolClientProvider protocol.ClientProvider
}

Providers contains all of the providers required by the TxnProcessor.