Versions in this module Expand all Collapse all v1 v1.0.1 Apr 30, 2024 Changes in this version + type Blocker interface + Block func(C <-chan struct{}) error + type Message struct + Size uint64 + Text []byte + Type int64 + type Queue struct + func (q *Queue) Copy(mType int64) (*Message, error) + func (q *Queue) Destroy() + func (q *Queue) ID() ipc.ID + func (q *Queue) Lock() + func (q *Queue) Object() *ipc.Object + func (q *Queue) Receive(ctx context.Context, b Blocker, mType int64, maxSize int64, ...) (*Message, error) + func (q *Queue) Send(ctx context.Context, m Message, b Blocker, wait bool, pid int32) error + func (q *Queue) Set(ctx context.Context, ds *linux.MsqidDS) error + func (q *Queue) Stat(ctx context.Context) (*linux.MsqidDS, error) + func (q *Queue) StatAny(ctx context.Context) (*linux.MsqidDS, error) + func (q *Queue) Unlock() + type Registry struct + func NewRegistry(userNS *auth.UserNamespace) *Registry + func (r *Registry) FindByID(id ipc.ID) (*Queue, error) + func (r *Registry) FindOrCreate(ctx context.Context, key ipc.Key, mode linux.FileMode, ...) (*Queue, error) + func (r *Registry) IPCInfo(ctx context.Context) *linux.MsgInfo + func (r *Registry) MsgInfo(ctx context.Context) *linux.MsgInfo + func (r *Registry) Remove(id ipc.ID, creds *auth.Credentials) error
Go to main page