app

package

v0.3.0 Latest Latest Go to latest Published: Sep 4, 2018 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

InmemProxy is used for testing

func NewInmemAppProxy(logger *logrus.Logger) *InmemAppProxy

func (p *InmemAppProxy) CommitBlock(block hashgraph.Block) (stateHash []byte, err error)

func (p *InmemAppProxy) GetCommittedTransactions() [][]byte

func (p *InmemAppProxy) GetSnapshot(blockIndex int) (snapshot []byte, err error)

func (p *InmemAppProxy) Restore(snapshot []byte) error

func (p *InmemAppProxy) SubmitCh() chan []byte

func (p *InmemAppProxy) SubmitTx(tx []byte)

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

func NewSocketAppProxy(clientAddr string, bindAddr string, timeout time.Duration, logger *logrus.Logger) *SocketAppProxy

func (p *SocketAppProxy) CommitBlock(block hashgraph.Block) ([]byte, error)

func (p *SocketAppProxy) GetSnapshot(blockIndex int) ([]byte, error)

func (p *SocketAppProxy) Restore(snapshot []byte) error

func (p *SocketAppProxy) SubmitCh() chan []byte

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

func NewSocketAppProxyClient(clientAddr string, timeout time.Duration, logger *logrus.Logger) *SocketAppProxyClient

func (p *SocketAppProxyClient) CommitBlock(block hashgraph.Block) ([]byte, error)

func (p *SocketAppProxyClient) GetSnapshot(blockIndex int) ([]byte, error)

func (p *SocketAppProxyClient) Restore(snapshot []byte) error

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

func NewSocketAppProxyServer(bindAddress string, logger *logrus.Logger) *SocketAppProxyServer

func (p *SocketAppProxyServer) SubmitTx(tx []byte, ack *bool) error