protocol

package module

Go to main page

Versions in this module

v0

v0.3.7

Aug 1, 2024

Changes in this version

type Protocol

+ func (p *Protocol) HeartbeatLastReceived() int64

+ func (p *Protocol) HeartbeatLastSend() int64

+ func (p *Protocol) Tag() string

v0.3.6

Aug 1, 2024

v0.3.5

Jul 31, 2024

v0.3.4

Jul 31, 2024

v0.3.3

Jul 31, 2024

v0.3.2

Jul 31, 2024

v0.3.1

Jul 31, 2024

v0.3.0

Jul 31, 2024

Changes in this version

+ var ErrDataSizeExceedsLimit = errors.New("body size exceeds limit")

+ var ErrEncryptorIsNil = errors.New("encryptor is nil")

+ var ErrReaderIsNil = errors.New("reader is nil")

+ var ErrWriterIsKilled = errors.New("writer is killed")

+ var ErrWriterIsNil = errors.New("writer is nil")

+ type HeartbeatTimeoutCallback func(p *Protocol) bool

+ type KillCallback func()

type Protocol

+ func (p *Protocol) Wait()

+ type ReadCallback func(data []byte)

+ type ReadPrepare func()

+ type WritePrepare func()

v0.2.2

Mar 11, 2024

v0.2.1

Mar 11, 2024

v0.2.0

Mar 11, 2024

v0.1.1

Mar 11, 2024

v0.1.0

Feb 27, 2024

Changes in this version

+ const FlagSuffix

+ var ErrorTimeout = errors.New("timeout")

type Protocol

+ func (p *Protocol) Connect(activeHeartbeatSignalSender bool)

+ func (p *Protocol) GetHeartbeatInterval() uint8

+ func (p *Protocol) GetHeartbeatTimeout() uint8

+ func (p *Protocol) GetRunningRoutine() int32

+ func (p *Protocol) GetTag() string

+ func (p *Protocol) SetHeartbeatInterval(interval uint8)

+ func (p *Protocol) SetHeartbeatTimeout(timeout uint8)

+ func (p *Protocol) SetTag(tag string)

+ func (p *Protocol) WaitKilled(timeout int) error

v0.0.6

Feb 3, 2024

Changes in this version

+ const FlagAll

+ const FlagDate

+ const FlagDev

+ const FlagFunc

+ const FlagLongFile

+ const FlagPrefix

+ const FlagProd

+ const FlagShortFile

+ const FlagStd

+ const FlagTime

+ const MaskAll

+ const MaskDEBUG

+ const MaskDev

+ const MaskERROR

+ const MaskFATAL

+ const MaskINFO

+ const MaskProd

+ const MaskStd

+ const MaskTRACE

+ const MaskUNKNOWN

+ const MaskWARNING

+ func SetLogFlag(f uint32)

+ func SetLogMask(mask uint32)

+ func SetLogProd(isProd bool)

v0.0.5

Jan 23, 2024

v0.0.3

Jan 22, 2024

Changes in this version

+ const VERSION

+ var ErrorBrokenData = errors.New("data crc32 checksum does not match")

+ var ErrorBrokenHead = errors.New("head crc32 checksum does not match")

+ var ErrorDataSizeExceedsLimit = errors.New("data size exceeds limit")

+ var ErrorHeartbeatCallbackIsNil = errors.New("heartbeat callback is nil")

+ var ErrorHeartbeatIsKilled = errors.New("heartbeat is killed")

+ var ErrorPackageEncrypted = errors.New("package is encrypted")

+ var ErrorPackageIncomplete = errors.New("package incomplete")

+ var ErrorReadCallbackIsNil = errors.New("read callback is nil")

+ var ErrorReaderIsKilled = errors.New("reader is killed")

+ var ErrorReaderIsNil = errors.New("reader is nil")

+ var ErrorUnsupportedVersion = errors.New("unsupported version")

+ var ErrorWriterIsKilled = errors.New("writer is killed")

+ var ErrorWriterIsNil = errors.New("writer is nil")

+ var ErrorWriterQueueIsNil = errors.New("writer queue is nil")

+ var ErrorWrongPrefix = errors.New("prefix does not match")

+ func CalculateTheNumberOfPackages(size int64) int64

+ func GetDataMaxSize() int

+ type Protocol struct

+ func New(r io.Reader, w io.Writer) *Protocol

+ func (p *Protocol) GetHeartbeatLastReceived() int64

+ func (p *Protocol) GetHeartbeatLastSend() int64

+ func (p *Protocol) Heartbeat(sendInterval int, receiveTimeout int, failedCallback func() bool) error

+ func (p *Protocol) Kill()

+ func (p *Protocol) Reader(callback func(data []byte)) error

+ func (p *Protocol) Write(data []byte) error

+ func (p *Protocol) Writer(writeQueueSize int) error

v0.0.2

Jan 15, 2024

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