ship

Documentation

Index

• type Connection
  • func NewConnection(address string, port int) *Connection
  • func (c *Connection) Close()
  • func (c *Connection) Open() error
  • func (c *Connection) ReadResult(msg []byte) (string, map[string]interface{}, error)
  • func (c *Connection) SendAckBlocksRequest(request *types.GetBlocksAckRequest) error
  • func (c *Connection) SendBlocksRequest(request *types.GetBlocksRequest) error
  • func (c *Connection) SendRequest(typeName string, body map[string]interface{}) error
  • func (c *Connection) SendStatusRequest() error

Types

type Connection

type Connection struct {
	Abi *chain.Abi

	Error  chan error
	Ready  chan *chain.Abi
	Blocks chan *types.GetBlocksResult
	Status chan *types.GetStatusResult
	// contains filtered or unexported fields
}

func NewConnection

func NewConnection(address string, port int) *Connection

func (*Connection) Close

func (c *Connection) Close()

func (*Connection) Open

func (c *Connection) Open() error

func (*Connection) ReadResult

func (c *Connection) ReadResult(msg []byte) (string, map[string]interface{}, error)

func (*Connection) SendAckBlocksRequest

func (c *Connection) SendAckBlocksRequest(request *types.GetBlocksAckRequest) error

func (*Connection) SendBlocksRequest

func (c *Connection) SendBlocksRequest(request *types.GetBlocksRequest) error

func (*Connection) SendRequest

func (c *Connection) SendRequest(typeName string, body map[string]interface{}) error

func (*Connection) SendStatusRequest

func (c *Connection) SendStatusRequest() error