proxy

Documentation

Index

• type AppProxy
• type BabbleProxy
• type DummySocketClient
  • func NewDummySocketClient(clientAddr string, nodeAddr string, logger *logrus.Logger) (*DummySocketClient, error)
  • func (c *DummySocketClient) Run()
  • func (c *DummySocketClient) SubmitTx(tx []byte) error
• type State
  • func (a *State) CommitBlock(block hashgraph.Block) ([]byte, error)
  • func (a *State) GetSnapshot(blockIndex int) ([]byte, error)
  • func (a *State) Restore(snapshot []byte) ([]byte, error)

Types

type AppProxy

type AppProxy interface {
	SubmitCh() chan []byte
	CommitBlock(block hashgraph.Block) ([]byte, error)
	GetSnapshot(blockIndex int) ([]byte, error)
	Restore(snapshot []byte) error
}

type BabbleProxy

type BabbleProxy interface {
	CommitCh() chan hashgraph.Block
	SnapshotRequestCh() chan int
	RestoreCh() chan []byte
	SubmitTx(tx []byte) error
}

type DummySocketClient

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

func NewDummySocketClient

func NewDummySocketClient(clientAddr string, nodeAddr string, logger *logrus.Logger) (*DummySocketClient, error)

func (*DummySocketClient) Run

func (c *DummySocketClient) Run()

func (*DummySocketClient) SubmitTx

func (c *DummySocketClient) SubmitTx(tx []byte) error

type State

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

func (*State) CommitBlock

func (a *State) CommitBlock(block hashgraph.Block) ([]byte, error)

func (*State) GetSnapshot

func (a *State) GetSnapshot(blockIndex int) ([]byte, error)

func (*State) Restore

func (a *State) Restore(snapshot []byte) ([]byte, error)