delivery

Documentation

Index

• Variables
• func New(sp view2.ServiceProvider, network Network, callback Callback, vault Vault, ...) (*delivery, error)
• type Callback
• type DeliverStream
• type Network
• type Vault

Variables

var (
	ErrComm = errors.New("communication issue")
)

Functions

func New

func New(
	sp view2.ServiceProvider,
	network Network,
	callback Callback,
	vault Vault,
	waitForEventTimeout time.Duration,
) (*delivery, error)

Types

type Callback

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

type DeliverStream

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

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

type Vault

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

Vault models a key-value store that can be updated by committing rwsets