Documentation ¶
Index ¶
Constants ¶
Variables ¶
View Source
var (
MemoryAllocationError = fmt.Errorf("Memory Allocation Error")
)
Functions ¶
This section is empty.
Types ¶
type MessageQueue ¶
type MessageQueue struct {
// contains filtered or unexported fields
}
Represents the message queue
func NewMessageQueue ¶
func NewMessageQueue(name string, oflag int, mode int, attr *MessageQueueAttribute) (*MessageQueue, error)
NewMessageQueue returns an instance of the message queue given a QueueConfig.
func (*MessageQueue) Notify ¶
func (mq *MessageQueue) Notify(sigNo syscall.Signal) error
FIXME Don't work because of signal portability. Notify set signal notification to handle new messages.
func (*MessageQueue) Receive ¶
func (mq *MessageQueue) Receive() ([]byte, uint, error)
Receive receives message from the message queue.
func (*MessageQueue) Send ¶
func (mq *MessageQueue) Send(data []byte, priority uint) error
Send sends message to the message queue.
func (*MessageQueue) Unlink ¶
func (mq *MessageQueue) Unlink() error
Unlink deletes the message queue.
type MessageQueueAttribute ¶
type MessageQueueAttribute struct { Flags int MaxMsg int MsgSize int // contains filtered or unexported fields }
Represents the message queue attribute
Click to show internal directories.
Click to hide internal directories.