Versions in this module Expand all Collapse all v0 v0.2.3 Feb 15, 2025 v0.2.2 Feb 15, 2025 Changes in this version + const FlagAll + const FlagDate + const FlagDev + const FlagFunc + const FlagLongFile + const FlagPrefix + const FlagProd + const FlagShortFile + const FlagStd + const FlagSuffix + const FlagTime + const MaskAll + const MaskDEBUG + const MaskDev + const MaskERROR + const MaskFATAL + const MaskINFO + const MaskProd + const MaskStd + const MaskTRACE + const MaskUNKNOWN + const MaskWARNING + const VERSION + var ErrorDataSizeExceedsLimit = errors.New("data size exceeds limit") + var ErrorHeartbeatCallbackIsNil = errors.New("heartbeat callback is nil") + var ErrorHeartbeatIsKilled = errors.New("heartbeat is killed") + 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 ErrorTimeout = errors.New("timeout") + var ErrorWriterIsKilled = errors.New("writer is killed") + var ErrorWriterIsNil = errors.New("writer is nil") + var ErrorWriterQueueIsNil = errors.New("writer queue is nil") + func CalculateTheNumberOfPackages(size int64) int64 + func GetDataMaxSize() int + func SetLogFlag(f uint32) + func SetLogMask(mask uint32) + func SetLogProd(isProd bool) + type Protocol struct + func New(tag string, r io.Reader, w io.Writer, writeQueueSize int, ...) *Protocol + func (p *Protocol) Connect(activeHeartbeatSignalSender bool) + func (p *Protocol) GetHeartbeatInterval() uint8 + func (p *Protocol) GetHeartbeatLastReceived() int64 + func (p *Protocol) GetHeartbeatLastSend() int64 + func (p *Protocol) GetHeartbeatTimeout() uint8 + func (p *Protocol) GetRunningRoutine() int32 + func (p *Protocol) GetTag() string + func (p *Protocol) Kill() + 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 + func (p *Protocol) Write(data []byte) error
Go to main page