queuedproto

package module

Go to main page

Versions in this module

v0

v0.0.13

Jul 21, 2026

Changes in this version

+ const MaxIProtoLen

v0.0.12

Jun 26, 2026

Changes in this version

+ type Cmd uint32

+ func (i Cmd) String() string

type ReqAddData

+ func (req ReqAddData) QueueID() uint16

type ReqAddItem

+ func (req ReqAddItem) QueueID() uint16

type ReqDeleteItems

+ func (req ReqDeleteItems) QueueID() uint16

type ReqFullUpdate

+ func (req ReqFullUpdate) QueueID() uint16

type ReqGetActive

+ func (req ReqGetActive) QueueID() uint16

type ReqGetItems

+ func (req ReqGetItems) QueueID() uint16

type ReqQueueStat

+ func (req ReqQueueStat) QueueID() uint16

type ReqUpdateItems

+ func (req ReqUpdateItems) QueueID() uint16

v0.0.11

Apr 3, 2026

v0.0.10

Sep 11, 2025

v0.0.9

Apr 30, 2025

Changes in this version

+ const CmdAddData

+ const CmdAddItem

+ const CmdDeleteItems

+ const CmdFullUpdate

+ const CmdGetActive

+ const CmdGetItems

+ const CmdGetQueueStat

+ const CmdUpdateItems

+ const FlagEnableAddons

+ const FlagEnableExtensions

+ const FlagEncodeInUTF8

+ const FlagIgnoreWrongItem

+ const RcBadRequestLength

+ const RcInsufficientActiveCount

+ const RcItemLocked

+ const RcLogicError

+ const RcMemAllocationFailed

+ const RcNoActiveItems

+ const RcOK

+ const RcReqAlreadyProcessed

+ const RcUnknownQueueType

+ const RcWrongID

+ const RcWrongItem

+ const RcWrongRequest

+ const RcWrongVersion

+ const SkipTimeUpdate

+ const TimestampAbsolute

+ const TimestampRelativeMinus

+ const TimestampRelativePlus

+ const VersionMask

+ var ErrBadRequestLength = fmt.Errorf("%w: bad request length", ErrQueued)

+ var ErrItemLocked = fmt.Errorf("%w: item locked", ErrQueued)

+ var ErrLogic = fmt.Errorf("%w: logic error", ErrQueued)

+ var ErrMemAllocationFailed = fmt.Errorf("%w: queued memory allocation failure", ErrQueued)

+ var ErrQueued = errors.New("queued error")

+ var ErrReqAlreadyProcessed = fmt.Errorf("%w: request has been already processed (duplicate ReqID)", ErrQueued)

+ var ErrUnknownQueueType = fmt.Errorf("%w: unknown queue type", ErrQueued)

+ var ErrWrongItem = fmt.Errorf("%w: wrong item", ErrQueued)

+ var ErrWrongRequest = fmt.Errorf("%w: wrong request", ErrQueued)

+ var ErrWrongVersion = fmt.Errorf("%w: wrong version", ErrQueued)

+ func ErrorByRetCode(rc uint8) error

+ func IsSoftError(err error) bool

+ type EventID struct

+ ID uint64

+ Shard uint

+ func (eid EventID) MarshalText() ([]byte, error)

+ func (eid EventID) String() string

+ func (recvEventID EventID) MarshalIProto(buf []byte) ([]byte, error)

+ func (recv_EventID *EventID) UnmarshalIProto(buf []byte) ([]byte, error)

+ type ItemList struct

+ Items []QueueItem

+ func (recvItemList ItemList) MarshalIProto(buf []byte) ([]byte, error)

+ func (recv_ItemList *ItemList) UnmarshalIProto(buf []byte) ([]byte, error)

+ type PerlAddonData struct

+ Data []byte

+ ID uint16

+ type PerlAddons struct

+ List []PerlAddonData

+ func (recvPerlAddons PerlAddons) MarshalIProto(buf []byte) ([]byte, error)

+ func (recv_PerlAddons *PerlAddons) UnmarshalIProto(buf []byte) ([]byte, error)

+ type PerlData struct

+ Addons PerlAddons

+ Data []byte

+ Extensions PerlExtensions

+ Version uint8

+ func (pd *PerlData) UnmarshalIProto(buf []byte) ([]byte, error)

+ func (pd PerlData) MarshalIProto(buf []byte) ([]byte, error)

+ type PerlExtensions struct

+ Data []byte

+ Flags uint32

+ func (recvPerlExtensions PerlExtensions) MarshalIProto(buf []byte) ([]byte, error)

+ func (recv_PerlExtensions *PerlExtensions) UnmarshalIProto(buf []byte) ([]byte, error)

+ type QueueItem struct

+ Data []byte

+ EventID EventID

+ type ReqAddData struct

+ Data []byte

+ ID uint64

+ StorageType uint16

+ func (ReqAddData) Cmd() uint32

+ func (recvReqAddData ReqAddData) MarshalIProto(buf []byte) ([]byte, error)

+ func (recv_ReqAddData *ReqAddData) UnmarshalIProto(buf []byte) ([]byte, error)

+ type ReqAddItem struct

+ Data []byte

+ Flags uint32

+ ID uint64

+ Pid uint32

+ ReqID uint32

+ StorageType uint16

+ UnixTime uint32

+ func (ReqAddItem) Cmd() uint32

+ func (req *ReqAddItem) UnmarshalIProto(buf []byte) ([]byte, error)

+ func (req ReqAddItem) MarshalIProto(buf []byte) ([]byte, error)

+ type ReqDeleteItems struct

+ IDs []uint64

+ StorageType uint16

+ func (ReqDeleteItems) Cmd() uint32

+ func (recvReqDeleteItems ReqDeleteItems) MarshalIProto(buf []byte) ([]byte, error)

+ func (recv_ReqDeleteItems *ReqDeleteItems) UnmarshalIProto(buf []byte) ([]byte, error)

+ type ReqFullUpdate struct

+ Items []UpdQueueItem

+ StorageType uint16

+ UnixTime uint32

+ func (ReqFullUpdate) Cmd() uint32

+ func (recvReqFullUpdate ReqFullUpdate) MarshalIProto(buf []byte) ([]byte, error)

+ func (recv_ReqFullUpdate *ReqFullUpdate) UnmarshalIProto(buf []byte) ([]byte, error)

+ type ReqGetActive struct

+ Count uint32

+ StorageType uint16

+ func (ReqGetActive) Cmd() uint32

+ func (recvReqGetActive ReqGetActive) MarshalIProto(buf []byte) ([]byte, error)

+ func (recv_ReqGetActive *ReqGetActive) UnmarshalIProto(buf []byte) ([]byte, error)

+ type ReqGetItems struct

+ IDs []uint64

+ StorageType uint16

+ func (ReqGetItems) Cmd() uint32

+ func (recvReqGetItems ReqGetItems) MarshalIProto(buf []byte) ([]byte, error)

+ func (recv_ReqGetItems *ReqGetItems) UnmarshalIProto(buf []byte) ([]byte, error)

+ type ReqQueueStat struct

+ StorageType uint16

+ Version uint8

+ func (ReqQueueStat) Cmd() uint32

+ func (recvReqQueueStat ReqQueueStat) MarshalIProto(buf []byte) ([]byte, error)

+ func (recv_ReqQueueStat *ReqQueueStat) UnmarshalIProto(buf []byte) ([]byte, error)

+ type ReqUpdateItems struct

+ IDs []uint64

+ StorageType uint16

+ TimestampType uint8

+ UnixTime uint32

+ func (ReqUpdateItems) Cmd() uint32

+ func (recvReqUpdateItems ReqUpdateItems) MarshalIProto(buf []byte) ([]byte, error)

+ func (recv_ReqUpdateItems *ReqUpdateItems) UnmarshalIProto(buf []byte) ([]byte, error)

+ type Request interface

+ Cmd func() uint32

+ type RespQueueStat struct

+ ActiveCount uint32

+ ItemsCount uint32

+ LockedCount uint32

+ func (i RespQueueStat) String() string

+ func (recvRespQueueStat RespQueueStat) MarshalIProto(buf []byte) ([]byte, error)

+ func (recv_RespQueueStat *RespQueueStat) UnmarshalIProto(buf []byte) ([]byte, error)

+ type UpdQueueItem struct

+ Data []byte

+ EventID EventID

+ func (uqi *UpdQueueItem) UnmarshalIProto(buf []byte) ([]byte, error)

+ func (uqi UpdQueueItem) MarshalIProto(buf []byte) ([]byte, error)

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