delivery

type Callback func(block *types.AugmentedBlockHeader) (bool, error)

type DeliverStream interface {
	// Receive returns
	//    - *types.BlockHeader if IncludeTxIDs is set to false in the delivery config
	//    - *types.AugmentedBlockHeader if IncludeTxIDs is set to true in the delivery config
	//    - nil if service has been stopped either by the caller or due to an error
	Receive() interface{}
	// Stop stops the delivery service
	Stop()
	// Error returns any accumulated error
	Error() error
}

type Network interface {
	SessionManager() driver.SessionManager
	IdentityManager() driver.IdentityManager
	Name() string
}

type Vault interface {
	// GetLastTxID returns the last transaction id committed
	GetLastTxID() (string, error)
}