Documentation ¶
Index ¶
- Variables
- type LocalMessageQueue
- func (queue *LocalMessageQueue) Chan() chan interface{}
- func (queue *LocalMessageQueue) Pop(ms time.Duration) (interface{}, error)
- func (queue *LocalMessageQueue) PopAsBytes(ms time.Duration) ([]byte, error)
- func (queue *LocalMessageQueue) PopAsFloat32(ms time.Duration) (float32, error)
- func (queue *LocalMessageQueue) PopAsFloat64(ms time.Duration) (float64, error)
- func (queue *LocalMessageQueue) PopAsInt(ms time.Duration) (int, error)
- func (queue *LocalMessageQueue) PopAsInt32(ms time.Duration) (int32, error)
- func (queue *LocalMessageQueue) PopAsInt64(ms time.Duration) (int64, error)
- func (queue *LocalMessageQueue) PopAsString(ms time.Duration) (string, error)
- func (queue *LocalMessageQueue) Push(item interface{}) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type LocalMessageQueue ¶
type LocalMessageQueue struct {
// contains filtered or unexported fields
}
local message queue to buffer message
func NewLocalMessageQueue ¶
func NewLocalMessageQueue(bufferSize uint32) *LocalMessageQueue
new local message queue function
func (*LocalMessageQueue) Chan ¶
func (queue *LocalMessageQueue) Chan() chan interface{}
get message channel
func (*LocalMessageQueue) Pop ¶
func (queue *LocalMessageQueue) Pop(ms time.Duration) (interface{}, error)
pop message from queue
func (*LocalMessageQueue) PopAsBytes ¶
func (queue *LocalMessageQueue) PopAsBytes(ms time.Duration) ([]byte, error)
pop message from queue as []byte
func (*LocalMessageQueue) PopAsFloat32 ¶
func (queue *LocalMessageQueue) PopAsFloat32(ms time.Duration) (float32, error)
pop message from queue as float32
func (*LocalMessageQueue) PopAsFloat64 ¶
func (queue *LocalMessageQueue) PopAsFloat64(ms time.Duration) (float64, error)
pop message from queue as float64
func (*LocalMessageQueue) PopAsInt ¶
func (queue *LocalMessageQueue) PopAsInt(ms time.Duration) (int, error)
pop message from queue as int
func (*LocalMessageQueue) PopAsInt32 ¶
func (queue *LocalMessageQueue) PopAsInt32(ms time.Duration) (int32, error)
pop message from queue as int32
func (*LocalMessageQueue) PopAsInt64 ¶
func (queue *LocalMessageQueue) PopAsInt64(ms time.Duration) (int64, error)
pop message from queue as int64
func (*LocalMessageQueue) PopAsString ¶
func (queue *LocalMessageQueue) PopAsString(ms time.Duration) (string, error)
pop message from queue as string
func (*LocalMessageQueue) Push ¶
func (queue *LocalMessageQueue) Push(item interface{}) error
push message to queue
Click to show internal directories.
Click to hide internal directories.