Documentation ¶
Index ¶
- func InQueue() chan InteractQueueData
- func OutQueue() chan InteractQueueData
- func ReceiveData(data InteractQueueData)
- func SendData(data InteractQueueData)
- func StartDataCacheQueue()
- type DataCacheQueue
- func (q *DataCacheQueue) GetDeviceQueue() chan QueueData
- func (q *DataCacheQueue) GetInQueue() chan QueueData
- func (q *DataCacheQueue) GetOutQueue() chan QueueData
- func (q *DataCacheQueue) GetQueue() chan QueueData
- func (q *DataCacheQueue) GetSize() int
- func (q *DataCacheQueue) Push(d QueueData) error
- func (q *DataCacheQueue) PushDeviceQueue(Device *typex.Device, data string) error
- func (q *DataCacheQueue) PushInQueue(in *typex.InEnd, data string) error
- func (q *DataCacheQueue) PushOutQueue(out *typex.OutEnd, data string) error
- func (q *DataCacheQueue) PushQueue(qd QueueData) error
- type InteractQueue
- type InteractQueueData
- type QueueData
- type XQueue
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func OutQueue ¶
func OutQueue() chan InteractQueueData
func ReceiveData ¶
func ReceiveData(data InteractQueueData)
Types ¶
type DataCacheQueue ¶
type DataCacheQueue struct { Queue chan QueueData OutQueue chan QueueData InQueue chan QueueData DeviceQueue chan QueueData // contains filtered or unexported fields }
* * DataCacheQueue *
func (*DataCacheQueue) GetDeviceQueue ¶ added in v0.6.5
func (q *DataCacheQueue) GetDeviceQueue() chan QueueData
* *GetDeviceQueue *
func (*DataCacheQueue) GetInQueue ¶ added in v0.6.5
func (q *DataCacheQueue) GetInQueue() chan QueueData
* * GetQueue *
func (*DataCacheQueue) GetOutQueue ¶ added in v0.6.5
func (q *DataCacheQueue) GetOutQueue() chan QueueData
* * GetQueue *
func (*DataCacheQueue) GetSize ¶
func (q *DataCacheQueue) GetSize() int
func (*DataCacheQueue) PushDeviceQueue ¶
func (q *DataCacheQueue) PushDeviceQueue(Device *typex.Device, data string) error
* * PushDeviceQueue *
func (*DataCacheQueue) PushInQueue ¶
func (q *DataCacheQueue) PushInQueue(in *typex.InEnd, data string) error
* *PushInQueue *
func (*DataCacheQueue) PushOutQueue ¶
func (q *DataCacheQueue) PushOutQueue(out *typex.OutEnd, data string) error
* * PushOutQueue *
type InteractQueue ¶
type InteractQueue struct {
// contains filtered or unexported fields
}
func InitInteractQueue ¶
func InitInteractQueue(rulex typex.RuleX, maxQueueSize int) *InteractQueue
type InteractQueueData ¶
type InteractQueueData struct { Topic string `json:"topic"` ComponentId string `json:"componentId"` Data map[string]interface{} `json:"data"` }
* * 前后端交互数据 *
func (InteractQueueData) String ¶
func (v InteractQueueData) String() string
type QueueData ¶
type XQueue ¶
type XQueue interface { GetQueue() chan QueueData GetInQueue() chan QueueData GetOutQueue() chan QueueData GetDeviceQueue() chan QueueData GetSize() int Push(QueueData) error PushQueue(QueueData) error PushInQueue(in *typex.InEnd, data string) error PushOutQueue(in *typex.OutEnd, data string) error PushDeviceQueue(in *typex.Device, data string) error }
* * XQueue *
var DefaultDataCacheQueue XQueue
Click to show internal directories.
Click to hide internal directories.