txnprocessor

Documentation

Index

• type OperationStore
• type Option
  • func WithUnpublishedOperationStore(store unpublishedOperationStore, opTypes []operation.Type) Option
• type Providers
• type TxnProcessor
  • func New(providers *Providers, opts ...Option) *TxnProcessor
  • func (p *TxnProcessor) Process(sidetreeTxn txn.SidetreeTxn, suffixes ...string) (int, error)

Types

type OperationStore

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

OperationStore interface to access operation store.

type Option

type Option func(opts *TxnProcessor)

Option is an option for transaction processor.

func WithUnpublishedOperationStore

func WithUnpublishedOperationStore(store unpublishedOperationStore, opTypes []operation.Type) Option

WithUnpublishedOperationStore is unpublished operation store option.

type Providers

type Providers struct {
	OpStore                   OperationStore
	OperationProtocolProvider protocol.OperationProvider
}

Providers contains the providers required by the TxnProcessor.

type TxnProcessor

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

TxnProcessor processes Sidetree transactions by persisting them to an operation store.

func New

func New(providers *Providers, opts ...Option) *TxnProcessor

New returns a new document operation processor.

func (*TxnProcessor) Process

func (p *TxnProcessor) Process(sidetreeTxn txn.SidetreeTxn, suffixes ...string) (int, error)

Process persists all the operations for the given anchor.