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
}

func NewSocketAppProxy

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

func (*SocketAppProxy) CommitBlock

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

func (*SocketAppProxy) GetSnapshot

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

func (*SocketAppProxy) Restore

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

func (*SocketAppProxy) SubmitCh

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

type SocketAppProxyClient

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

func NewSocketAppProxyClient

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

func (*SocketAppProxyClient) CommitBlock

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

func (*SocketAppProxyClient) GetSnapshot

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

func (*SocketAppProxyClient) Restore

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

type SocketAppProxyServer

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

func NewSocketAppProxyServer

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

func (*SocketAppProxyServer) SubmitTx

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