observer

Documentation

Index

• func Start(ledger Ledger, dcas DCAS, operationStore OperationStore)
• type AnchorFile
• type BatchFile
• type DCAS
• type Ledger
• type OperationStore
• type SidetreeTxn
• type TxnProcessor
  • func NewTxnProcessor(dcas DCAS, opStore OperationStore) *TxnProcessor
  • func (p *TxnProcessor) Process(sidetreeTxn SidetreeTxn) error

Functions

func Start

func Start(ledger Ledger, dcas DCAS, operationStore OperationStore)

Start starts channel observer routines

Types

type AnchorFile

type AnchorFile struct {
	// BatchFileHash is encoded hash of the batch file
	BatchFileHash string `json:"batchFileHash"`
	// MerkleRoot is encoded root hash of the Merkle tree constructed from
	// the operations included in the batch file
	MerkleRoot string `json:"merkleRoot"`
}

AnchorFile defines the schema of a Anchor File and its related operations.

type BatchFile

type BatchFile struct {
	// Operations included in this batch file, each operation is an encoded string
	Operations []string `json:"operations"`
}

BatchFile defines the schema of a Batch File and its related operations.

type DCAS

type DCAS interface {
	Read(key string) ([]byte, error)
}

DCAS interface to access content addressable storage

type Ledger

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

Ledger interface to access ledger txn

type OperationStore

type OperationStore interface {
	Put(ops []batch.Operation) error
}

OperationStore interface to access operation store

type SidetreeTxn

type SidetreeTxn struct {
	TransactionTime   uint64
	TransactionNumber uint64
	AnchorAddress     string
}

SidetreeTxn defines info about sidetree transaction

type TxnProcessor

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

TxnProcessor processes Sidetree transactions by persisting them to an operation store

func NewTxnProcessor

func NewTxnProcessor(dcas DCAS, opStore OperationStore) *TxnProcessor

NewTxnProcessor returns a new document operation processor

func (*TxnProcessor) Process

func (p *TxnProcessor) Process(sidetreeTxn SidetreeTxn) error

Process persists all of the operations for the given anchor