commRedisStatus

README

功能说明

commRedisStatus的用途，为A进程将自己的工作参数，通过redis缓存，生产者和消费者的方式，高效的告知给其他进程的机制

Documentation

Index

• Constants
• Variables
• func BuildServiceKey(serviceType, serviceName string) string
• func GetDataList(timeout int64) []map[string]interface{}
• func Instance()
• func IsActive(modelType string, modelName string, timeout int) bool
• func Scheduler()

Constants

const (
	ModelTypeChannel = "channel"
	ModelTypeDevice  = "device"
	ModelNameDevice  = "device"
)

Variables

var (
	Producer *redisStatusProducerService
	Consumer *redisStatusConsumerService
)

Functions

func BuildServiceKey

func BuildServiceKey(serviceType, serviceName string) string

func GetDataList

func GetDataList(timeout int64) []map[string]interface{}

func Instance

func Instance()

func IsActive

func IsActive(modelType string, modelName string, timeout int) bool

func Scheduler

func Scheduler()

Scheduler 创建一个线程