logic

type BrokerChecker struct {
	RunningFlag *wm.AtomicBool // 是否运行 true:运行 false:停止
	ExitedFlag  chan struct{}  //  已经退出的标识
	ExitChan    chan struct{}
	// contains filtered or unexported fields
}

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

type LogicServer struct{}

type PumpDialogueLoopWorker struct {
	//RunningFlag bool // is running? true:running false:stoped
	ExitedFlag chan struct{}
	ExitChan   chan struct{}
	// contains filtered or unexported fields
}

type PumpSignalLoopWorker struct {
	RunningFlag *wm.AtomicBool // is running? true:running false:stoped
	ExitedFlag  chan struct{}  //  已经退出的标识
	ExitChan    chan struct{}
}