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
}

SocketBabbleProxy ...

func NewSocketBabbleProxy

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

NewSocketBabbleProxy ...

func (*SocketBabbleProxy) SubmitTx

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

SubmitTx ...

type SocketBabbleProxyClient

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

SocketBabbleProxyClient ...

func NewSocketBabbleProxyClient

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

NewSocketBabbleProxyClient ...

func (*SocketBabbleProxyClient) SubmitTx

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

SubmitTx ...

type SocketBabbleProxyServer

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

SocketBabbleProxyServer ...

func NewSocketBabbleProxyServer

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

NewSocketBabbleProxyServer ...

func (*SocketBabbleProxyServer) CommitBlock

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

CommitBlock ...

func (*SocketBabbleProxyServer) GetSnapshot

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

GetSnapshot ...

func (*SocketBabbleProxyServer) Restore

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

Restore ...