MCPcopy Create free account

hub / github.com/IoT-Technology/Groza / functions

Functions191 in github.com/IoT-Technology/Groza

⨍ Functions 191◇ Types & classes 48
↓ 29 callersMethodput
(String key, byte[] value)
groza-queue/src/main/java/iot/technology/groza/server/queue/GaQueueMsgHeaders.java:11
↓ 16 callersMethodget
(String key)
groza-queue/src/main/java/iot/technology/groza/server/queue/GaQueueMsgHeaders.java:13
↓ 16 callersMethodgetKey
()
groza-data/src/main/java/iot/technology/groza/server/data/kv/KvEntry.java:11
↓ 4 callersMethodgetData
()
groza-queue/src/main/java/iot/technology/groza/server/queue/GaQueueMsg.java:15
↓ 3 callersMethodgetValue
()
groza-data/src/main/java/iot/technology/groza/server/data/kv/KvEntry.java:27
↓ 3 callersMethodparseProtoValues
(JsonObject valuesObject)
groza-transport-api/src/main/java/iot/technology/groza/server/transport/api/adaptor/JsonConverter.java:157
↓ 3 callersMethodtoProps
()
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaSettings.java:117
↓ 3 callersMethodtoString
()
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaConsumerStatsService.java:159
↓ 2 callersMethodbuildNumericKeyValueProto
(JsonPrimitive value, String key)
groza-transport-api/src/main/java/iot/technology/groza/server/transport/api/adaptor/JsonConverter.java:223
↓ 2 callersMethodcreateCoapServer
()
groza-transport-coap/src/main/iot.technology.groza.transport.coap/DefaultCoapServerService.java:58
↓ 2 callersMethodgeKey
()
groza-queue/src/main/java/iot/technology/groza/server/queue/GaQueueMsg.java:11
↓ 2 callersMethodgetHeaders
()
groza-queue/src/main/java/iot/technology/groza/server/queue/GaQueueMsg.java:13
↓ 2 callersMethodgetInstance
()
groza-queue/src/main/java/iot/technology/groza/server/queue/memory/InMemoryStorage.java:34
↓ 2 callersMethodisSimpleDouble
(String valueAsString)
groza-transport-api/src/main/java/iot/technology/groza/server/transport/api/adaptor/JsonConverter.java:249
↓ 2 callersMethodonFailure
(Throwable t)
groza-queue/src/main/java/iot/technology/groza/server/queue/GaQueueCallback.java:11
↓ 2 callersMethodonSuccess
(GaQueueMsgMetadata metadata)
groza-queue/src/main/java/iot/technology/groza/server/queue/GaQueueCallback.java:9
↓ 2 callersMethodparseNumericValue
(List<KvEntry> result, Entry<String, JsonElement> valueEntry, JsonPrimitive value)
groza-transport-api/src/main/java/iot/technology/groza/server/transport/api/adaptor/JsonConverter.java:198
↓ 2 callersMethodparseObject
(long systemTs, Map<Long, List<KvEntry>> result, PostTelemetryMsg.Builder builder, JsonObject jo)
groza-transport-api/src/main/java/iot/technology/groza/server/transport/api/adaptor/JsonConverter.java:67
↓ 2 callersMethodparseValues
(JsonObject valuesObject)
groza-transport-api/src/main/java/iot/technology/groza/server/transport/api/adaptor/JsonConverter.java:120
↓ 2 callersMethodparseWithTs
(Map<Long, List<KvEntry>> result, JsonObject jo)
groza-transport-api/src/main/java/iot/technology/groza/server/transport/api/adaptor/JsonConverter.java:105
↓ 2 callersMethodparseWithoutTs
(Map<Long, List<KvEntry>> result, long systemTs, JsonObject jo)
groza-transport-api/src/main/java/iot/technology/groza/server/transport/api/adaptor/JsonConverter.java:92
↓ 2 callersMethodpoll
(long durationInMillis)
groza-queue/src/main/java/iot/technology/groza/server/queue/GaQueueConsumer.java:23
↓ 2 callersMethodresolve
(ServiceType serviceType, String tenantId, String entityId)
groza-queue/src/main/java/iot/technology/groza/server/queue/discovery/PartitionService.java:14
↓ 2 callersMethodtoAdminProps
()
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaSettings.java:83
↓ 2 callersMethodtoConsumerProps
()
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaSettings.java:91
↓ 2 callersMethodtoString
()
groza-data/src/main/java/iot/technology/groza/server/data/kv/BasicKvEntry.java:63
↓ 2 callersMethodunsubscribe
()
groza-queue/src/main/java/iot/technology/groza/server/queue/GaQueueConsumer.java:21
↓ 1 callersMethodconvertToTelemetry
(JsonElement jsonElement, long systemTs, Map<Long, List<KvEntry>> result, PostTelemetryMsg.Builde
groza-transport-api/src/main/java/iot/technology/groza/server/transport/api/adaptor/JsonConverter.java:50
↓ 1 callersMethodcreateTopic
(NewTopic topic)
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaAdmin.java:78
↓ 1 callersMethodcreateTopicIfNotExist
(TopicPartitionInfo tpi)
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaProducerTemplate.java:89
↓ 1 callersMethodcreateTopicIfNotExists
(String topic)
groza-queue/src/main/java/iot/technology/groza/server/queue/GaQueueAdmin.java:8
↓ 1 callersMethoddecode
(GaQueueMsg msg)
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaDecoder.java:12
↓ 1 callersMethoddecode
(R record)
groza-queue/src/main/java/iot/technology/groza/server/queue/common/AbstractGaQueueConsumerTemplate.java:137
↓ 1 callersMethoddestroy
()
groza-queue/src/main/java/iot/technology/groza/server/queue/GaQueueAdmin.java:10
↓ 1 callersMethoddoCommit
()
groza-queue/src/main/java/iot/technology/groza/server/queue/common/AbstractGaQueueConsumerTemplate.java:141
↓ 1 callersMethoddoPoll
(long durationInMillis)
groza-queue/src/main/java/iot/technology/groza/server/queue/common/AbstractGaQueueConsumerTemplate.java:135
↓ 1 callersMethoddoSubscribe
(List<String> topicNames)
groza-queue/src/main/java/iot/technology/groza/server/queue/common/AbstractGaQueueConsumerTemplate.java:139
↓ 1 callersMethoddoUnsubscribe
()
groza-queue/src/main/java/iot/technology/groza/server/queue/common/AbstractGaQueueConsumerTemplate.java:143
↓ 1 callersMethodforName
(String name)
groza-queue/src/main/java/iot/technology/groza/server/queue/common/GaThreadFactory.java:15
↓ 1 callersMethodgetTimeout
()
groza-transport-coap/src/main/iot.technology.groza.transport.coap/CoapServerService.java:12
↓ 1 callersMethodgetTopicsStatsWithLag
(Map<TopicPartition, OffsetAndMetadata> groupOffsets,
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaConsumerStatsService.java:104
↓ 1 callersMethodisStatsPrintRequired
()
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaConsumerStatsService.java:97
↓ 1 callersMethodput
(String key, byte[] value)
groza-queue/src/main/java/iot/technology/groza/server/queue/common/DefaultGaQueueMsgHeaders.java:16
↓ 1 callersMethodregisterClientGroup
(String groupId)
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaConsumerStatsService.java:125
↓ 1 callersMethodsend
(TopicPartitionInfo tpi, T msg, GaQueueCallback callback)
groza-queue/src/main/java/iot/technology/groza/server/queue/GaQueueProducer.java:16
↓ 1 callersMethodstartLogScheduling
()
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaConsumerStatsService.java:65
↓ 1 callersMethodsubscribe
()
groza-queue/src/main/java/iot/technology/groza/server/queue/GaQueueConsumer.java:17
↓ 1 callersMethodtoPath
(List<String> list)
groza-transport-coap/src/main/iot.technology.groza.transport.coap/GaCoapServerMessageDeliverer.java:36
↓ 1 callersMethodtoProducerProps
()
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaSettings.java:104
↓ 1 callersMethodtoString
()
groza-data/src/main/java/iot/technology/groza/server/data/kv/DoubleDataEntry.java:58
↓ 1 callersMethodtoString
()
groza-data/src/main/java/iot/technology/groza/server/data/kv/LongDataEntry.java:53
↓ 1 callersMethodtoString
()
groza-data/src/main/java/iot/technology/groza/server/data/kv/BooleanDataEntry.java:36
↓ 1 callersMethodunregisterClientGroup
(String groupId)
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaConsumerStatsService.java:131
MethodAbstractGaQueueConsumerTemplate
(String topic)
groza-queue/src/main/java/iot/technology/groza/server/queue/common/AbstractGaQueueConsumerTemplate.java:32
MethodAdaptorException
()
groza-transport-api/src/main/java/iot/technology/groza/server/transport/api/AdaptorException.java:10
MethodBasicKvEntry
(String key)
groza-data/src/main/java/iot/technology/groza/server/data/kv/BasicKvEntry.java:14
MethodBooleanDataEntry
(String key, Boolean value)
groza-data/src/main/java/iot/technology/groza/server/data/kv/BooleanDataEntry.java:11
MethodDefaultGaQueueMsg
(GaQueueMsg msg)
groza-queue/src/main/java/iot/technology/groza/server/queue/common/DefaultGaQueueMsg.java:19
MethodDoubleDataEntry
(String key, Double value)
groza-data/src/main/java/iot/technology/groza/server/data/kv/DoubleDataEntry.java:13
MethodGaCoapServerMessageDeliverer
(Resource root)
groza-transport-coap/src/main/iot.technology.groza.transport.coap/GaCoapServerMessageDeliverer.java:17
MethodGaKafkaAdmin
(GaKafkaSettings settings, Map<String, String> topicConfigs)
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaAdmin.java:28
MethodGaKafkaConsumerTemplate
(GaKafkaSettings settings, GaKafkaDecoder<T> decoder, String clientId, Str
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaConsumerTemplate.java:30
MethodGaKafkaProducerTemplate
(GaKafkaSettings settings, String defaultTopic, String clientId, GaQueueAdmin admin)
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaProducerTemplate.java:40
MethodGaProtoQueueMsg
(UUID key, T value)
groza-queue/src/main/java/iot/technology/groza/server/queue/common/GaProtoQueueMsg.java:20
MethodGaThreadFactory
(String name)
groza-queue/src/main/java/iot/technology/groza/server/queue/common/GaThreadFactory.java:19
MethodInMemoryGaQueueConsumer
(String topic)
groza-queue/src/main/java/iot/technology/groza/server/queue/memory/InMemoryGaQueueConsumer.java:25
MethodInMemoryGaQueueProducer
(String defaultTopic)
groza-queue/src/main/java/iot/technology/groza/server/queue/memory/InMemoryGaQueueProducer.java:18
MethodInMemoryStorage
()
groza-queue/src/main/java/iot/technology/groza/server/queue/memory/InMemoryStorage.java:22
MethodJsonDataEntry
(String key, String value)
groza-data/src/main/java/iot/technology/groza/server/data/kv/JsonDataEntry.java:12
MethodKafkaGaQueueMsg
(ConsumerRecord<String, byte[]> record)
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/KafkaGaQueueMsg.java:18
MethodLongDataEntry
(String key, Long value)
groza-data/src/main/java/iot/technology/groza/server/data/kv/LongDataEntry.java:13
MethodStringDataEntry
(String key, String value)
groza-data/src/main/java/iot/technology/groza/server/data/kv/StringDataEntry.java:15
MethodTopicPartitionInfo
(String topic, String tenantId, Integer partition, boolean myPartition)
groza-message/src/main/java/iot/technology/groza/server/msg/queue/TopicPartitionInfo.java:36
Methodcleanup
Used primarily for testing.
groza-queue/src/main/java/iot/technology/groza/server/queue/memory/InMemoryStorage.java:75
Methodcommit
()
groza-queue/src/main/java/iot/technology/groza/server/queue/GaQueueConsumer.java:25
Methodcommit
()
groza-queue/src/main/java/iot/technology/groza/server/queue/memory/InMemoryGaQueueConsumer.java:83
Methodcommit
()
groza-queue/src/main/java/iot/technology/groza/server/queue/common/AbstractGaQueueConsumerTemplate.java:125
MethodconvertToAttributesProto
(JsonElement jsonObject)
groza-transport-api/src/main/java/iot/technology/groza/server/transport/api/adaptor/JsonConverter.java:35
MethodconvertToPostAttributes
(String sessionId, Request inbound, Descriptors.Descriptor attrib
groza-transport-coap/src/main/iot.technology.groza.transport.coap/adaptors/CoapTransportAdaptor.java:17
MethodconvertToPostTelemetry
(String sessionId, Request inbound, Descriptors.Descriptor telemet
groza-transport-coap/src/main/iot.technology.groza.transport.coap/adaptors/CoapTransportAdaptor.java:14
MethodconvertToTelemetryProto
(JsonElement jsonElement, long ts)
groza-transport-api/src/main/java/iot/technology/groza/server/transport/api/adaptor/JsonConverter.java:29
MethodcreateResources
()
groza-transport-coap/src/main/iot.technology.groza.transport.coap/CoapTransportService.java:30
MethodcreateTopicIfNotExists
(String topic)
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaAdmin.java:49
Methoddecode
(ConsumerRecord<String, byte[]> record)
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaConsumerTemplate.java:62
Methoddestroy
()
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaConsumerStatsService.java:137
Methoddestroy
()
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaAdmin.java:71
MethoddoCommit
()
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaConsumerTemplate.java:77
MethoddoPoll
(long durationInMillis)
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaConsumerTemplate.java:50
MethoddoSubscribe
(List<String> topicNames)
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaConsumerTemplate.java:67
MethoddoUnsubscribe
()
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaConsumerTemplate.java:82
Methodencode
(T value)
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/GaKafkaEncoder.java:8
Methodequals
(Object o)
groza-data/src/main/java/iot/technology/groza/server/data/kv/JsonDataEntry.java:49
Methodequals
(Object o)
groza-data/src/main/java/iot/technology/groza/server/data/kv/DoubleDataEntry.java:38
Methodequals
(Object o)
groza-data/src/main/java/iot/technology/groza/server/data/kv/BasicKvEntry.java:48
Methodequals
(Object o)
groza-data/src/main/java/iot/technology/groza/server/data/kv/StringDataEntry.java:34
Methodequals
(Object o)
groza-data/src/main/java/iot/technology/groza/server/data/kv/LongDataEntry.java:33
Methodequals
(Object o)
groza-data/src/main/java/iot/technology/groza/server/data/kv/BooleanDataEntry.java:43
Methodequals
(Object o)
groza-message/src/main/java/iot/technology/groza/server/msg/queue/TopicPartitionInfo.java:68
MethodfindResource
(Exchange exchange)
groza-transport-coap/src/main/iot.technology.groza.transport.coap/GaCoapServerMessageDeliverer.java:21
MethodgeKey
()
groza-queue/src/main/java/iot/technology/groza/server/queue/kafka/KafkaGaQueueMsg.java:29
next →1–100 of 191, ranked by callers