rtd

Documentation

Index

• type SM
  • func GetSM(topic string) (*SM, error)
  • func (s *SM) CacheDT(side int, a *gset.IntSet) error
  • func (s *SM) CacheGZ(side int, b *gset.IntSet) error
  • func (s *SM) CacheHD(m *gmap.TreeMap) error
  • func (s *SM) CacheHDPlus(m *gmap.TreeMap) error
  • func (s *SM) CacheKD(m *gmap.TreeMap) error
  • func (s *SM) CacheRTD(j *gjson.Json) error
  • func (s *SM) GetGeneraterTime() int64
  • func (s *SM) GetLdt() gset.IntSet

Types

type SM

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

状态机

func GetSM

func GetSM(topic string) (*SM, error)

新建sm缓存

func (*SM) CacheDT

func (s *SM) CacheDT(side int, a *gset.IntSet) error

更新 状态机缓存的断头锭数据

func (*SM) CacheGZ

func (s *SM) CacheGZ(side int, b *gset.IntSet) error

更新状态机缓存的 故障锭子的实时数据 移除断头产生时间早于一个小时的计数

func (*SM) CacheHD

func (s *SM) CacheHD(m *gmap.TreeMap) error

更新 状态机缓存的滑锭数据

func (*SM) CacheHDPlus

func (s *SM) CacheHDPlus(m *gmap.TreeMap) error

更新 状态机缓存的严重滑锭数据

func (*SM) CacheKD

func (s *SM) CacheKD(m *gmap.TreeMap) error

更新 状态机缓存的空锭数据

func (*SM) CacheRTD

func (s *SM) CacheRTD(j *gjson.Json) error

更新状态机缓存中的实时上报数据

func (*SM) GetGeneraterTime

func (s *SM) GetGeneraterTime() int64

func (*SM) GetLdt

func (s *SM) GetLdt() gset.IntSet

获取状态机的 左侧断头数据