observer

Documentation

Index

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

Types

type AnchorGraph

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

AnchorGraph interface to access anchors.

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

Providers contains all of the providers required by the TxnProcessor.

type TxnProvider

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

TxnProvider interface to access orb txn.