ui/ru.sydis.ui.core.kafka/Producer

Producer

object ~~Producer~~

Deprecated

Deprecated since 0.0.16

Replace with

Properties

var gateway: String

var manId: ProtoManId

Functions

suspend fun createDP(idType: Long, nameDP: String): ProtoMessageWrapper

suspend fun createType(systemId: Int, name: String, struct: String): ProtoMessageWrapper

suspend fun deleteDP(idDP: Long): ProtoMessageWrapper

suspend fun deleteType(systemId: Int, idType: Long): ProtoMessageWrapper

suspend fun dpConnect(dpIds: List<ProtoDpId>, answer: Boolean = false): SubsData

suspend fun dpDisconnect(subscriptionId: String): ProtoMessageWrapper

dpDisconnectAll

suspend fun dpDisconnectAll(): ProtoMessageWrapper

suspend fun dpExists(nameDP: String): ProtoMessageWrapper

suspend fun getDP(idSys: Int, idDp: Long, idAttr: Int, dpType: Long): ProtoMessageWrapper

getDPIdentifire

suspend fun getDPIdentifire(dpId: ProtoDpId): ProtoMessageWrapper

suspend fun getDPNames(idDPType: Long): ProtoMessageWrapper

suspend fun getElement(idType: Long, idDP: Long): ProtoMessageWrapper

suspend fun getId(dp: String): ProtoMessageWrapper

suspend fun getId(listDp: List<String>): ProtoMessageWrapper

suspend fun getInfo(dpId: ProtoDpId): ProtoMessageWrapper

getListByIdentify

suspend fun getListByIdentify(dpids: List<ProtoDpId>): ProtoMessageWrapper

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

suspend fun getType(name: String, systemId: Int = 1): ProtoMessageWrapper

fun init(id: ProtoManId)

fun isInitialized(): Boolean

suspend fun queryDpNames(query: String): ProtoMessageWrapper

suspend fun renameDP(idDP: Long, nameDP: String): ProtoMessageWrapper

suspend fun requestSystems(): ProtoMessageWrapper

suspend fun requestTree(systemId: Int): ProtoMessageWrapper

setDPByIdentify

suspend fun setDPByIdentify(dpsSetByIdentify: List<DPSetByIdentify>): ProtoMessageWrapper

suspend fun setDPByIdentify(dpId: ProtoDpId, value: Any, typeVar: ProtoVarType = dpId.eltype): ProtoMessageWrapper

suspend fun typeExists(name: String): ProtoMessageWrapper

suspend fun updateType(systemId: Int, idType: Long, nameType: String, struct: String): ProtoMessageWrapper

suspend fun waitForUpdates(subscriptionId: String, timeoutMillis: Long): ProtoMessageWrapper?