Documentation
¶
Index ¶
- type QueuePair
- type SendRecvQueues
- func (q *SendRecvQueues) Create(name string) error
- func (q *SendRecvQueues) Delete(name string, shutdown bool) error
- func (q *SendRecvQueues) HasQueuePair(name string) bool
- func (q *SendRecvQueues) Len() int
- func (q *SendRecvQueues) Names() []string
- func (q *SendRecvQueues) RecvQ(name string) workqueue.RateLimitingInterface
- func (q *SendRecvQueues) SendQ(name string) workqueue.RateLimitingInterface
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SendRecvQueues ¶
type SendRecvQueues struct {
// contains filtered or unexported fields
}
func NewSendRecvQueues ¶
func NewSendRecvQueues() *SendRecvQueues
func (*SendRecvQueues) Create ¶
func (q *SendRecvQueues) Create(name string) error
Create creates and initializes a queue pair with name, and adds it to the list of available queues. The given name must be unique, if a queue pair with the same name already exists, Create will return an error.
func (*SendRecvQueues) Delete ¶
func (q *SendRecvQueues) Delete(name string, shutdown bool) error
Delete will delete the named queue pair from the list of available queue. pairs. If shutdown is true, the Shutdown function will be called on both send and receive queues. If the named queue does not exist, Delete will return an error.
func (*SendRecvQueues) HasQueuePair ¶
func (q *SendRecvQueues) HasQueuePair(name string) bool
HasQueuePair retruns true if a queue pair with name currently exists
func (*SendRecvQueues) Len ¶
func (q *SendRecvQueues) Len() int
Len returns the number of queue pairs held by q
func (*SendRecvQueues) Names ¶
func (q *SendRecvQueues) Names() []string
Names returns the names of all currently existing queues.
func (*SendRecvQueues) RecvQ ¶
func (q *SendRecvQueues) RecvQ(name string) workqueue.RateLimitingInterface
RecvQ will return the receive queue from the queue pair named name. If no such queue pair exists, returns nil
func (*SendRecvQueues) SendQ ¶
func (q *SendRecvQueues) SendQ(name string) workqueue.RateLimitingInterface
RecvQ will return the send queue from the queue pair named name. If no such queue pair exists, returns nil
Source Files
Directories