Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func UnregisterQueue ¶
intended for testing (`go test -count XXX` needs this)
Types ¶
type ActionQueue ¶
type ActionQueue struct {
EntityID string
// contains filtered or unexported fields
}
concurrent-safe, deletable queue
func GetQueue ¶
func GetQueue(entityID string) *ActionQueue
func RegisterNewQueue ¶
func RegisterNewQueue(entityID string) (*ActionQueue, error)
func (*ActionQueue) Peek ¶
func (this *ActionQueue) Peek() Action
locked, however old call loses(return nil); new one wins. (for concurrent http get)
Source Files
Click to show internal directories.
Click to hide internal directories.