internal

package

v1.0.2 Latest Latest Go to latest Published: Dec 16, 2022 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Cyberax/gimlet

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func NewReadWriter(pipe *utils.Pipeline[[]byte], sender func([]byte) error) io.ReadWriteCloser
type AckReceiver
type ErrorCallbackFunc
type Receiver
- func NewReceiver(conn WsConn, onErrorCallback ErrorCallbackFunc, acks AckReceiver, ...) *Receiver
type Sender
- func NewSender(conn WsConn, onErrorCallback ErrorCallbackFunc, maxPps uint64, ...) *Sender
type WsConn

Constants ¶

View Source

const MaxResendNum = 1000

View Source

const PingTimeInterval = 30 * time.Second

Variables ¶

View Source

var ErrTooManyRetries = fmt.Errorf("too many unacknowledged retries")

Functions ¶

func NewReadWriter ¶

func NewReadWriter(pipe *utils.Pipeline[[]byte], sender func([]byte) error) io.ReadWriteCloser

Types ¶

type AckReceiver ¶

type AckReceiver func(messageType string, ackedMsgId uuid.UUID, ackedSequenceNumber int64)

type ErrorCallbackFunc ¶

type ErrorCallbackFunc func(err error)

type Receiver ¶

type Receiver struct {
	// contains filtered or unexported fields
}

func NewReceiver ¶

func NewReceiver(conn WsConn, onErrorCallback ErrorCallbackFunc,
	acks AckReceiver, logger *log.GimletLogger, stats *log.Stats) *Receiver

func (*Receiver) ControlReaderQueue ¶

func (r *Receiver) ControlReaderQueue() *utils.Pipeline[*mgsproto.ClientMessage]

func (*Receiver) DataReaderQueue ¶

func (r *Receiver) DataReaderQueue() *utils.Pipeline[[]byte]

func (*Receiver) Shutdown ¶

func (r *Receiver) Shutdown()

type Sender ¶

type Sender struct {
	// contains filtered or unexported fields
}

func NewSender ¶

func NewSender(conn WsConn, onErrorCallback ErrorCallbackFunc, maxPps uint64, resendTimeout time.Duration,
	log *log.GimletLogger, stats *log.Stats) *Sender

func (*Sender) AckReceived ¶

func (s *Sender) AckReceived(seqId int64)

func (*Sender) EnqueueAck ¶

func (s *Sender) EnqueueAck(messageType string, ackedMsgId uuid.UUID, ackedSequenceNumber int64)

func (*Sender) EnqueueChannelOpen ¶

func (s *Sender) EnqueueChannelOpen(token string)

func (*Sender) EnqueueControlFlag ¶

func (s *Sender) EnqueueControlFlag(flagType mgsproto.FlagMessage) error

func (*Sender) EnqueueData ¶

func (s *Sender) EnqueueData(data []byte) error

func (*Sender) SerializeAndEnqueueControl ¶

func (s *Sender) SerializeAndEnqueueControl(msgType mgsproto.PayloadType, data any) error

func (*Sender) Shutdown ¶

func (s *Sender) Shutdown()

Shutdown shuts down the sender. Intra-class callers needs to make sure it's not called while `Sender.mtx` is held.

type WsConn ¶

type WsConn interface {
	SetReadDeadline(t time.Time) error
	SetWriteDeadline(t time.Time) error
	ReadMessage() (messageType int, p []byte, err error)
	WriteMessage(messageType int, data []byte) error
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
utils

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL