segment

Documentation

Overview

Package segment provides functions to segment the binary of ISCP messages in Transport layer.

Index

• func SendTo(wr Sender, seqNum uint32, msgPayload []byte) (int, error)
• type ReadBuffer
• type ReadBuffers
  • func (t *ReadBuffers) Receive(bs []byte) ([]byte, bool, error)
  • func (b *ReadBuffers) RemoveExpired()
• type Sender

Functions

func SendTo

func SendTo(wr Sender, seqNum uint32, msgPayload []byte) (int, error)

Types

type ReadBuffer

type ReadBuffer struct {
	SegCount  int
	MsgSize   int
	Msgs      [][]byte
	ExpiredAt time.Time
}

type ReadBuffers

type ReadBuffers struct {
	sync.Mutex
	ReadBuffer       map[uint32]*ReadBuffer
	ReadBufferExpiry time.Duration
}

func (*ReadBuffers) Receive

func (t *ReadBuffers) Receive(bs []byte) ([]byte, bool, error)

func (*ReadBuffers) RemoveExpired

func (b *ReadBuffers) RemoveExpired()

type Sender

type Sender interface {
	SendMessage([]byte) error
}