Documentation
¶
Index ¶
- func NewProtocol(transport io.WriteCloser, timeoutRequest time.Duration) *protocol
- func NewRequest(handler responseHandler, onTimeout func(), timeoutRequest time.Duration) *requestWithTimeout
- func WithManager(nonce []byte, blockchain *blockchain.Blockchain, p2pPort uint16, ...) error
- type Manager
- func (this *Manager) OnClose(connection interface{})
- func (this *Manager) OnData(connection interface{}, data []byte) error
- func (m *Manager) OnNewConnection(ctx context.Context, c *network.Connection) error
- func (this *Manager) OnOpen(address string, transport io.WriteCloser, isOutgoing bool, ...) (interface{}, error)
- type PascalConnection
- func (this *PascalConnection) BlocksGet(from, to uint32) []safebox.SerializedBlock
- func (this *PascalConnection) BroadcastBlock(block *safebox.SerializedBlock)
- func (this *PascalConnection) BroadcastTx(operation tx.CommonOperation)
- func (p *PascalConnection) GetRemoteNonce() []byte
- func (p *PascalConnection) OnClose()
- func (this *PascalConnection) OnData(data []byte) error
- func (p *PascalConnection) OnOpen() error
- func (p *PascalConnection) PeriodicPing(ctx context.Context)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewProtocol ¶
func NewProtocol(transport io.WriteCloser, timeoutRequest time.Duration) *protocol
func NewRequest ¶
func WithManager ¶
func WithManager( nonce []byte, blockchain *blockchain.Blockchain, p2pPort uint16, peers *network.PeersList, peerUpdates chan<- network.PeerInfo, blocksUpdates <-chan safebox.SerializedBlock, txPoolUpdates <-chan tx.CommonOperation, timeoutRequest time.Duration, callback func(m *Manager) error, ) error
Types ¶
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
func (*Manager) OnNewConnection ¶
func (*Manager) OnOpen ¶
func (this *Manager) OnOpen( address string, transport io.WriteCloser, isOutgoing bool, onStateUpdated func(), postHandshake func(*PascalConnection) error, ) (interface{}, error)
type PascalConnection ¶
type PascalConnection struct {
// contains filtered or unexported fields
}
func (*PascalConnection) BlocksGet ¶
func (this *PascalConnection) BlocksGet(from, to uint32) []safebox.SerializedBlock
func (*PascalConnection) BroadcastBlock ¶
func (this *PascalConnection) BroadcastBlock(block *safebox.SerializedBlock)
func (*PascalConnection) BroadcastTx ¶
func (this *PascalConnection) BroadcastTx(operation tx.CommonOperation)
func (*PascalConnection) GetRemoteNonce ¶
func (p *PascalConnection) GetRemoteNonce() []byte
func (*PascalConnection) OnClose ¶
func (p *PascalConnection) OnClose()
func (*PascalConnection) OnData ¶
func (this *PascalConnection) OnData(data []byte) error
func (*PascalConnection) OnOpen ¶
func (p *PascalConnection) OnOpen() error
func (*PascalConnection) PeriodicPing ¶
func (p *PascalConnection) PeriodicPing(ctx context.Context)
Source Files
Click to show internal directories.
Click to hide internal directories.