queue

Documentation

Index

• func UnregisterQueue(entityID string) error
• type ActionQueue
  • func GetQueue(entityID string) *ActionQueue
  • func RegisterNewQueue(entityID string) (*ActionQueue, error)
  • func (this *ActionQueue) Count() int
  • func (this *ActionQueue) Delete(actionUUID string)
  • func (this *ActionQueue) Peek() Action
  • func (this *ActionQueue) Peeking() bool
  • func (this *ActionQueue) Put(action Action)

Functions

func UnregisterQueue

func UnregisterQueue(entityID string) error

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) Count

func (this *ActionQueue) Count() int

locked

func (*ActionQueue) Delete

func (this *ActionQueue) Delete(actionUUID string)

locked, idempotent

func (*ActionQueue) Peek

func (this *ActionQueue) Peek() Action

locked, however old call loses(return nil); new one wins. (for concurrent http get)

func (*ActionQueue) Peeking

func (this *ActionQueue) Peeking() bool

locked

func (*ActionQueue) Put

func (this *ActionQueue) Put(action Action)

locked