babble

Documentation

Index

• type SocketBabbleProxy
  • func NewSocketBabbleProxy(nodeAddr string, bindAddr string, handler proxy.ProxyHandler, ...) (*SocketBabbleProxy, error)
  • func (p *SocketBabbleProxy) SubmitTx(tx []byte) error
• type SocketBabbleProxyClient
  • func NewSocketBabbleProxyClient(nodeAddr string, timeout time.Duration) *SocketBabbleProxyClient
  • func (p *SocketBabbleProxyClient) SubmitTx(tx []byte) (*bool, error)
• type SocketBabbleProxyServer
  • func NewSocketBabbleProxyServer(bindAddress string, handler proxy.ProxyHandler, timeout time.Duration, ...) (*SocketBabbleProxyServer, error)
  • func (p *SocketBabbleProxyServer) CommitBlock(block hashgraph.Block, response *proxy.CommitResponse) (err error)
  • func (p *SocketBabbleProxyServer) GetSnapshot(blockIndex int, snapshot *[]byte) (err error)
  • func (p *SocketBabbleProxyServer) Restore(snapshot []byte, stateHash *[]byte) (err error)

Types

type SocketBabbleProxy

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

func NewSocketBabbleProxy

func NewSocketBabbleProxy(
	nodeAddr string,
	bindAddr string,
	handler proxy.ProxyHandler,
	timeout time.Duration,
	logger *logrus.Logger,
) (*SocketBabbleProxy, error)

func (*SocketBabbleProxy) SubmitTx

func (p *SocketBabbleProxy) SubmitTx(tx []byte) error

type SocketBabbleProxyClient

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

func NewSocketBabbleProxyClient

func NewSocketBabbleProxyClient(nodeAddr string, timeout time.Duration) *SocketBabbleProxyClient

func (*SocketBabbleProxyClient) SubmitTx

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

type SocketBabbleProxyServer

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

func NewSocketBabbleProxyServer

func NewSocketBabbleProxyServer(
	bindAddress string,
	handler proxy.ProxyHandler,
	timeout time.Duration,
	logger *logrus.Logger,
) (*SocketBabbleProxyServer, error)

func (*SocketBabbleProxyServer) CommitBlock

func (p *SocketBabbleProxyServer) CommitBlock(block hashgraph.Block, response *proxy.CommitResponse) (err error)

func (*SocketBabbleProxyServer) GetSnapshot

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

func (*SocketBabbleProxyServer) Restore

func (p *SocketBabbleProxyServer) Restore(snapshot []byte, stateHash *[]byte) (err error)