observer

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

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

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

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

type Option func(opts *options)

type Outbox interface {
	Post(ctx context.Context, activity *vocab.ActivityType, exclude ...*url.URL) (*url.URL, error)
}

type Providers struct {
	ProtocolClientProvider protocol.ClientProvider
	AnchorGraph
	DidAnchors           didAnchors
	PubSub               pubSub
	Metrics              metricsProvider
	Outbox               outboxProvider
	HostMetaLinkResolver resourceResolver
	CASResolver          casResolver
	DocLoader            documentLoader
	Pkf                  verifiable.PublicKeyFetcher
	AnchorLinkStore      anchorLinkStore
	MonitoringSvc        monitoringSvc
	AnchorLinksetBuilder anchorLinksetBuilder
}

type PubSub struct {
	*lifecycle.Lifecycle
	// contains filtered or unexported fields
}

type Publisher interface {
	PublishAnchor(ctx context.Context, anchorInfo *anchorinfo.AnchorInfo) error
	PublishDID(ctx context.Context, did string) error
}