Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Buffer ¶
func Buffer(name string, inbox <-chan interface{}, closing <-chan struct{}) <-chan interface{}
Buffer creates a memory based buffer of messages that grows exponentially as necessary.
func GetIPAddrDebugString ¶
func GetIPAddrDebugString() string
GetIPAddrDebugString gives a machine itentifiying string
Types ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
A Queue is a go-routine safe FIFO (first in first out) data stucture.
func (*Queue) Peek ¶
func (q *Queue) Peek() interface{}
Peek returns a read value at the front of the queue.
i.e. the oldest value in the queue. Note: this function does NOT mutate the queue.
Source Files
Click to show internal directories.
Click to hide internal directories.