Versions in this module Expand all Collapse all v0 v0.0.2 Jan 21, 2025 Changes in this version type MQ + func (mq *MQ) ClearNotify() error v0.0.1 Jan 20, 2025 Changes in this version + const AttributeBlocking + const AttributeNonBlocking + var NotifyNone int + var NotifySignal int + func DefaultMessageSize() (int, error) + func DefaultQueueSize() (int, error) + func MaxMessageSize() (int, error) + func MaxQueueSize() (int, error) + func MaxQueues() (int, error) + func RawClose(mqd int) error + func RawNotify(mq int, notify *Notify) error + func RawOpen(name string, oflag OpenFlag, mode int, attr *Attributes) (int, error) + func RawSendReceive[P uint | *uint](mqd int, dl deadline.Deadline, buf []byte, priority P) (int, error) + func RawUnlink(name string) error + func ValidateName(name string) (string, error) + type AttributeFlag OpenFlag + func (af AttributeFlag) String() string + type Attributes struct + Flags AttributeFlag + MaxMessageSize int + MaxQueueSize int + NumCurrMessages int + func RawGetSetAttributes(mqd int, newAttr *Attributes) (attr Attributes, err error) + type ErrBadFileDescriptor struct + func (e ErrBadFileDescriptor) Errno() unix.Errno + func (e ErrBadFileDescriptor) Error() string + type ErrGetSetAttrInvalidFlags struct + func (ErrGetSetAttrInvalidFlags) Errno() unix.Errno + func (ErrGetSetAttrInvalidFlags) Error() string + type ErrNameContainedMultipleSlash struct + func (ErrNameContainedMultipleSlash) Errno() unix.Errno + func (ErrNameContainedMultipleSlash) Error() string + type ErrNameEmpty struct + func (ErrNameEmpty) Errno() unix.Errno + func (ErrNameEmpty) Error() string + type ErrNameInvalid struct + func (ErrNameInvalid) Errno() unix.Errno + func (ErrNameInvalid) Error() string + type ErrNameTooLong struct + func (err ErrNameTooLong) Errno() unix.Errno + func (err ErrNameTooLong) Error() string + type ErrNoMemory struct + func (err ErrNoMemory) Errno() unix.Errno + func (err ErrNoMemory) Error() string + type ErrNotifyBusy struct + func (ErrNotifyBusy) Errno() unix.Errno + func (ErrNotifyBusy) Error() string + type ErrNotifyInvalid struct + func (ErrNotifyInvalid) Errno() unix.Errno + func (ErrNotifyInvalid) Error() string + type ErrOpenBadAccess struct + func (ErrOpenBadAccess) Errno() unix.Errno + func (ErrOpenBadAccess) Error() string + type ErrOpenExists struct + func (ErrOpenExists) Errno() unix.Errno + func (ErrOpenExists) Error() string + type ErrOpenInvalid struct + func (ErrOpenInvalid) Errno() unix.Errno + func (ErrOpenInvalid) Error() string + type ErrOpenNoEntry struct + func (ErrOpenNoEntry) Errno() unix.Errno + func (ErrOpenNoEntry) Error() string + type ErrOpenNoSpace struct + func (ErrOpenNoSpace) Errno() unix.Errno + func (ErrOpenNoSpace) Error() string + type ErrOpenProcessLimitReached struct + func (ErrOpenProcessLimitReached) Errno() unix.Errno + func (ErrOpenProcessLimitReached) Error() string + type ErrOpenSystemLimitReached struct + func (ErrOpenSystemLimitReached) Errno() unix.Errno + func (ErrOpenSystemLimitReached) Error() string + type ErrReceiveInvalidFileDescriptor struct + func (ErrReceiveInvalidFileDescriptor) Errno() unix.Errno + func (ErrReceiveInvalidFileDescriptor) Error() string + type ErrRecvEmptyQueue struct + func (ErrRecvEmptyQueue) Errno() unix.Errno + func (ErrRecvEmptyQueue) Error() string + type ErrRecvInvalidMessageSize struct + func (ErrRecvInvalidMessageSize) Errno() unix.Errno + func (ErrRecvInvalidMessageSize) Error() string + type ErrSendFullQueue struct + func (ErrSendFullQueue) Errno() unix.Errno + func (ErrSendFullQueue) Error() string + type ErrSendInvalidFileDescriptor struct + func (ErrSendInvalidFileDescriptor) Errno() unix.Errno + func (ErrSendInvalidFileDescriptor) Error() string + type ErrSendInvalidMessageSize struct + func (ErrSendInvalidMessageSize) Errno() unix.Errno + func (ErrSendInvalidMessageSize) Error() string + type ErrSendRecvInterrupted struct + func (ErrSendRecvInterrupted) Errno() unix.Errno + func (ErrSendRecvInterrupted) Error() string + type ErrSendRecvInvalidTimeout struct + func (ErrSendRecvInvalidTimeout) Errno() unix.Errno + func (ErrSendRecvInvalidTimeout) Error() string + type ErrSendRecvTimeout struct + func (ErrSendRecvTimeout) Errno() unix.Errno + func (ErrSendRecvTimeout) Error() string + type ErrUnlinkNoMessageQueue struct + func (ErrUnlinkNoMessageQueue) Errno() unix.Errno + func (ErrUnlinkNoMessageQueue) Error() string + type ErrUnlinkNoPermission struct + func (ErrUnlinkNoPermission) Errno() unix.Errno + func (ErrUnlinkNoPermission) Error() string + type MQ struct + func New(name string, opts ...MQOption) (mq *MQ, err error) + func (mq *MQ) Close() error + func (mq *MQ) GetAttr() (oldValue Attributes, _ error) + func (mq *MQ) Mode() int + func (mq *MQ) Mqd() int + func (mq *MQ) Name() string + func (mq *MQ) Notify(sig unix.Signal) error + func (mq *MQ) Oflag() OpenFlag + func (mq *MQ) Receive(dl deadline.Deadline) (data []byte, priority uint, _ error) + func (mq *MQ) Send(dl deadline.Deadline, data []byte, priority uint) error + func (mq *MQ) SetBlocking(blocking bool) (Attributes, error) + func (mq *MQ) Unlink() error + type MQOption interface + func OptionCreateArgs(mode, maxMessageSize, maxQueueSize int) MQOption + func OptionOflag(oflag OpenFlag) MQOption + type Notify struct + Notify int + Signo unix.Signal + type OpenFlag int + const DefaultCreateFlags + const DefaultOpenFlags + const OpenCloseOnExec + const OpenCreate + const OpenExclusive + const OpenNonBlocking + const OpenReadOnly + const OpenReadWrite + const OpenWriteOnly + func (f OpenFlag) String() string
Go to main page