Documentation
¶
Index ¶
Constants ¶
View Source
const (
PendingQueueCapacity = 256
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExampleReplayer ¶
type ExampleReplayer struct {
Retransmit bool // need re-transmit
Ack int64 // ack number
// contains filtered or unexported fields
}
func NewExampleReplayer ¶
func NewExampleReplayer(id int) *ExampleReplayer
func (*ExampleReplayer) GetAcked ¶
func (er *ExampleReplayer) GetAcked() int64
func (*ExampleReplayer) Sync ¶
func (er *ExampleReplayer) Sync(message *tunnel.TMessage, completion func()) int64
* Receiver message and do the following steps: * 1. if we need re-transmit, this log will be discard * 2. validate the checksum * 3. decompress * 4. put message into channel * Generally speaking, do not modify this function.
type MessageWithCallback ¶
type MessageWithCallback struct {
// contains filtered or unexported fields
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.