ui/ru.sydis.ui.core.kafka/DpManager

DpManager

class DpManager

Constructors

DpManager

constructor()

Functions

connect

fun connect(dpList: List<String>, answer: Boolean = true, callback: (dpList: List<String>, values: List<Any?>) -> Unit)

connectByIdentify

fun connectByIdentify(dpList: List<ProtoDpId>, answer: Boolean = true, callback: (dpList: List<ProtoDpId>, values: List<Any?>) -> Unit)

disconnect

fun disconnect()

dpCreate

suspend fun dpCreate(idType: Long, nameDP: String): Int

dpDelete

suspend fun dpDelete(idDP: Long): Int

dpPeriod

suspend fun dpPeriod(dps: List<ProtoDpId>, periodFrom: Long, periodTo: Long, count: Int, nmax: Long = 0, dpNames: List<String> = listOf()): List<ResponseHDBData>

dpPeriodRaw

suspend fun dpPeriodRaw(dps: List<ProtoDpId>, periodFrom: Long, periodTo: Long, count: Int, nmax: Long): List<ProtoMessageWrapper>

dpRename

suspend fun dpRename(idDP: Long, nameDP: String): Int

get

fun get(dp: String): Any?

fun <T> get(input: List<T>): List<Any?>

fun get(dpId: ProtoDpId): Any?

getDPElements

fun getDPElements(idType: Long, idDP: Long): DPElementsData?

getDpNames

fun getDpNames(idDPType: Long): DPNamesData?

getDpTypes

fun getDpTypes(sysId: Int): DPTypesData

fun getDpTypes(sysId: Int, cb: (DPTypesData) -> Unit)

getId

fun getId(dp: String): ProtoDpIdConf?

fun getId(dpList: List<String>): List<ProtoDpIdConf>?

getInfo

fun getInfo(dp: ProtoDpId): String

getSystems

fun getSystems(): List<SysData>

set

fun <T> set(input: List<T>): Int

fun set(dp: String, value: Any): Int

fun set(dpId: ProtoDpId, value: Any, typeVar: ProtoVarType = dpId.eltype): Int

setWait

fun setWait(dp: String, value: Any): Int

setWaitByIdentify

fun setWaitByIdentify(dpId: ProtoDpId, value: Any, typeVar: ProtoVarType = dpId.eltype): Int

stopDpConnect

fun stopDpConnect()