mq

package

Go to main page

Versions in this module

v0

v0.6.1

May 7, 2019

v0.6.0

Oct 29, 2018

v0.5.0

Dec 29, 2016

v0.4.0

Dec 18, 2016

Changes in this version

+ const O_NONBLOCK — js/wasm

+ func Destroy(name string) error — js/wasm

+ func IsTemporary(err error) bool — js/wasm

+ type Blocker interface — js/wasm

+ SetBlocking func(bool) error

+ type Buffered interface — js/wasm

+ Cap func() int

+ type Messenger interface — js/wasm

+ Receive func(data []byte) (int, error)

+ Send func(data []byte) error

+ func New(name string, flag int, perm os.FileMode) (Messenger, error)

+ func Open(name string, flags int) (Messenger, error)

+ type PriorityMessenger interface — js/wasm

+ ReceivePriority func(data []byte) (int, int, error)

+ SendPriority func(data []byte, prio int) error

+ type TimedMessenger interface — js/wasm

+ ReceiveTimeout func(data []byte, timeout time.Duration) (int, error)

+ SendTimeout func(data []byte, timeout time.Duration) error

v0.3.0

Oct 12, 2016

Changes in this version

+ func FastMqAttrs(name string) (int, int, error)

type FastMq

+ func (mq *FastMq) Empty() bool

+ func (mq *FastMq) Full() bool

+ func (mq *FastMq) ReceiveTimeout(data []byte, timeout time.Duration) error

+ func (mq *FastMq) SendTimeout(data []byte, timeout time.Duration) error

v0.2.0

Jun 22, 2016

Changes in this version

+ const DefaultFastMqMaxSize

+ const DefaultFastMqMessageSize

+ const O_NONBLOCK — windows/amd64

+ func Destroy(name string) error — windows/amd64

+ func DestroyFastMq(name string) error

+ func IsTemporary(err error) bool — darwin/amd64, linux/amd64, windows/amd64

+ type Blocker interface — darwin/amd64, linux/amd64, windows/amd64

+ SetBlocking func(bool) error

+ type Buffered interface — darwin/amd64, linux/amd64, windows/amd64

+ Cap func() (int, error)

+ type FastMq struct

+ func CreateFastMq(name string, flag int, perm os.FileMode, maxQueueSize, maxMsgSize int) (*FastMq, error)

+ func OpenFastMq(name string, flag int) (*FastMq, error)

+ func (mq *FastMq) Cap() (int, error)

+ func (mq *FastMq) Close() error

+ func (mq *FastMq) Destroy() error

+ func (mq *FastMq) Receive(data []byte) error

+ func (mq *FastMq) ReceivePriority(data []byte) (int, error)

+ func (mq *FastMq) ReceivePriorityTimeout(data []byte, timeout time.Duration) (int, error)

+ func (mq *FastMq) Send(data []byte) error

+ func (mq *FastMq) SendPriority(data []byte, prio int) error

+ func (mq *FastMq) SendPriorityTimeout(data []byte, prio int, timeout time.Duration) error

+ func (mq *FastMq) SetBlocking(block bool) error

+ type Messenger interface — windows/amd64

+ Receive func(data []byte) error

+ Send func(data []byte) error

+ func New(name string, flag int, perm os.FileMode) (Messenger, error)

+ func Open(name string, flags int) (Messenger, error)

+ type PriorityMessenger interface — darwin/amd64, linux/amd64, windows/amd64

+ ReceivePriority func(data []byte) (int, error)

+ SendPriority func(data []byte, prio int) error

+ type TimedMessenger interface — windows/amd64

+ ReceiveTimeout func(data []byte, timeout time.Duration) error

+ SendTimeout func(data []byte, timeout time.Duration) error

v0.1.0

May 23, 2016

Changes in this version

+ const DefaultLinuxMqMaxSize — linux/amd64

+ const DefaultLinuxMqMessageSize — linux/amd64

+ const O_NONBLOCK — darwin/amd64, linux/amd64

+ func Destroy(name string) error — darwin/amd64, linux/amd64

+ func DestroyLinuxMessageQueue(name string) error — linux/amd64

+ func DestroySystemVMessageQueue(name string) error — darwin/amd64, linux/amd64

+ func SetLinuxMqBlocking(name string, block bool) error — linux/amd64

+ type LinuxMessageQueue struct — linux/amd64

+ func CreateLinuxMessageQueue(name string, perm os.FileMode, maxQueueSize, maxMsgSize int) (*LinuxMessageQueue, error)

+ func OpenLinuxMessageQueue(name string, flags int) (*LinuxMessageQueue, error)

+ func (mq *LinuxMessageQueue) Cap() (int, error)

+ func (mq *LinuxMessageQueue) Close() error

+ func (mq *LinuxMessageQueue) Destroy() error

+ func (mq *LinuxMessageQueue) ID() int

+ func (mq *LinuxMessageQueue) Notify(ch chan<- int) error

+ func (mq *LinuxMessageQueue) NotifyCancel() error

+ func (mq *LinuxMessageQueue) Receive(data []byte) error

+ func (mq *LinuxMessageQueue) ReceivePriority(data []byte) (int, error)

+ func (mq *LinuxMessageQueue) ReceiveTimeout(data []byte, timeout time.Duration) error

+ func (mq *LinuxMessageQueue) ReceiveTimeoutPriority(data []byte, timeout time.Duration) (int, error)

+ func (mq *LinuxMessageQueue) Send(data []byte) error

+ func (mq *LinuxMessageQueue) SendPriority(data []byte, prio int) error

+ func (mq *LinuxMessageQueue) SendTimeout(data []byte, timeout time.Duration) error

+ func (mq *LinuxMessageQueue) SendTimeoutPriority(data []byte, prio int, timeout time.Duration) error

+ func (mq *LinuxMessageQueue) SetBlocking(block bool) error

+ type Messenger interface — darwin/amd64, linux/amd64

+ Receive func(data []byte) error

+ Send func(data []byte) error

+ func New(name string, perm os.FileMode) (Messenger, error)

+ func Open(name string, flags int) (Messenger, error)

+ type SystemVMessageQueue struct — darwin/amd64, linux/amd64

+ func CreateSystemVMessageQueue(name string, perm os.FileMode) (*SystemVMessageQueue, error)

+ func OpenSystemVMessageQueue(name string, flags int) (*SystemVMessageQueue, error)

+ func (mq *SystemVMessageQueue) Close() error

+ func (mq *SystemVMessageQueue) Destroy() error

+ func (mq *SystemVMessageQueue) Receive(data []byte) error

+ func (mq *SystemVMessageQueue) Send(data []byte) error

+ func (mq *SystemVMessageQueue) SetBlocking(block bool) error

+ type TimedMessenger interface — darwin/amd64, linux/amd64

+ ReceiveTimeout func(data []byte, timeout time.Duration) error

+ SendTimeout func(data []byte, timeout time.Duration) error

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