monitor

Documentation

Index

• Variables
• type ItemValue
• type ValueQueue
  • func NewValueQueue() *ValueQueue
  • func (this *ValueQueue) Add(item string, value maps.Map)
  • func (this *ValueQueue) Loop() error
  • func (this *ValueQueue) Start()

Variables

var SharedValueQueue = NewValueQueue()

Types

type ItemValue

type ItemValue struct {
	Item      string
	ValueJSON []byte
	CreatedAt int64
}

ItemValue 数据值定义

type ValueQueue

type ValueQueue struct {
	// contains filtered or unexported fields
}

ValueQueue 数据记录队列

func NewValueQueue

func NewValueQueue() *ValueQueue

func (*ValueQueue) Add

func (this *ValueQueue) Add(item string, value maps.Map)

Add 添加数据

func (*ValueQueue) Loop

func (this *ValueQueue) Loop() error

Loop 单次循环

func (*ValueQueue) Start

func (this *ValueQueue) Start()

Start 启动队列