replayer

Documentation

Index

• Constants
• type ExampleReplayer
  • func NewExampleReplayer(id int) *ExampleReplayer
  • func (er *ExampleReplayer) GetAcked() int64
  • func (er *ExampleReplayer) Sync(message *tunnel.TMessage, completion func()) int64
• type MessageWithCallback

Constants

const (
	PendingQueueCapacity = 256
)

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
}