Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ErrCorruptData ¶
type ErrCorruptData struct {
}
func (*ErrCorruptData) Error ¶
func (e *ErrCorruptData) Error() string
type ErrTransportFailed ¶
type ErrTransportFailed struct {
Data *TransportData
}
func (*ErrTransportFailed) Error ¶
func (e *ErrTransportFailed) Error() string
type Transport ¶
type Transport interface {
RegisterListener(listener TransportListener, listenerNodeAddress primitives.NodeAddress)
Send(ctx context.Context, data *TransportData) error
}
type TransportData ¶
type TransportData struct {
SenderNodeAddress primitives.NodeAddress
RecipientMode gossipmessages.RecipientsListMode
RecipientNodeAddresses []primitives.NodeAddress
Payloads [][]byte // the first payload is normally gossipmessages.Header
}
func (*TransportData) TotalSize ¶ added in v0.7.11
func (d *TransportData) TotalSize() (res int)
type TransportListener ¶
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package memory provides an in-memory implementation of the Gossip Transport adapter, meant for usage in fast tests that should not use the TCP-based adapter, such as acceptance tests or sociable unit tests, or in other in-process network use cases
|
Package memory provides an in-memory implementation of the Gossip Transport adapter, meant for usage in fast tests that should not use the TCP-based adapter, such as acceptance tests or sociable unit tests, or in other in-process network use cases |
|
Package testkit extends the in-process transport adapter with Tampering capabilities, intended to be used by system-wide acceptance tests
|
Package testkit extends the in-process transport adapter with Tampering capabilities, intended to be used by system-wide acceptance tests |
Click to show internal directories.
Click to hide internal directories.