app

Documentation

Index

• type SocketAppProxy
  • func NewSocketAppProxy(clientAddr string, bindAddr string, timeout time.Duration, ...) (*SocketAppProxy, error)
  • func (p *SocketAppProxy) CommitBlock(block hashgraph.Block) (proxy.CommitResponse, error)
  • func (p *SocketAppProxy) GetSnapshot(blockIndex int) ([]byte, error)
  • func (p *SocketAppProxy) Restore(snapshot []byte) error
  • func (p *SocketAppProxy) SubmitCh() chan []byte
• type SocketAppProxyClient
  • func NewSocketAppProxyClient(clientAddr string, timeout time.Duration, logger *logrus.Logger) *SocketAppProxyClient
  • func (p *SocketAppProxyClient) CommitBlock(block hashgraph.Block) (proxy.CommitResponse, error)
  • func (p *SocketAppProxyClient) GetSnapshot(blockIndex int) ([]byte, error)
  • func (p *SocketAppProxyClient) Restore(snapshot []byte) error
• type SocketAppProxyServer
  • func NewSocketAppProxyServer(bindAddress string, logger *logrus.Logger) (*SocketAppProxyServer, error)
  • func (p *SocketAppProxyServer) SubmitTx(tx []byte, ack *bool) error

Types

type SocketAppProxy

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

SocketAppProxy ...

func NewSocketAppProxy

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

NewSocketAppProxy ...

func (*SocketAppProxy) CommitBlock

func (p *SocketAppProxy) CommitBlock(block hashgraph.Block) (proxy.CommitResponse, error)

CommitBlock ...

func (*SocketAppProxy) GetSnapshot

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

GetSnapshot ...

func (*SocketAppProxy) Restore

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

Restore ...

func (*SocketAppProxy) SubmitCh

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

SubmitCh ...

type SocketAppProxyClient

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

SocketAppProxyClient ...

func NewSocketAppProxyClient

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

NewSocketAppProxyClient ...

func (*SocketAppProxyClient) CommitBlock

func (p *SocketAppProxyClient) CommitBlock(block hashgraph.Block) (proxy.CommitResponse, error)

CommitBlock ...

func (*SocketAppProxyClient) GetSnapshot

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

GetSnapshot ...

func (*SocketAppProxyClient) Restore

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

Restore ...

type SocketAppProxyServer

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

SocketAppProxyServer ...

func NewSocketAppProxyServer

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

NewSocketAppProxyServer ...

func (*SocketAppProxyServer) SubmitTx

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

SubmitTx ...