observer

package

v0.1.0 Latest Latest Go to latest Published: May 4, 2021 License: Apache-2.0 Imports: 9 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type AnchorGraph interface {
	Read(cid string) (*verifiable.Credential, error)
	GetDidAnchors(cid, suffix string) ([]graph.Anchor, error)
}

AnchorGraph interface to access anchors.

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 {
	TxnProvider            TxnProvider
	ProtocolClientProvider protocol.ClientProvider
	AnchorGraph
}

Providers contains all of the providers required by the TxnProcessor.

type TxnProvider interface {
	RegisterForAnchor() <-chan []string
	RegisterForDID() <-chan []string
}

TxnProvider interface to access orb txn.