MCPcopy Create free account

hub / github.com/Accenture/mercury / functions

Functions2,050 in github.com/Accenture/mercury

↓ 4 callersMethodsetNonNullValue
(Map<String, String> map, String key, String value)
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:641
↓ 4 callersMethodsetPrivate
(boolean isPrivateFunction)
system/platform-core/src/main/java/org/platformlambda/core/system/ServiceDef.java:167
↓ 4 callersMethodsetQueryString
(String queryString)
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:304
↓ 4 callersMethodsetRoundTrip
DO NOT set this manually. The system will set it. @param milliseconds spent @return event envelope
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:660
↓ 4 callersMethodsetType
REST indicates that the deployed application is user facing <p> APP signals that the deployed application holds business logic <p> RESOURCES is a reso
system/platform-core/src/main/java/org/platformlambda/core/system/ServerPersonality.java:50
↓ 4 callersMethodshutdown
()
connectors/adapters/kafka/kafka-connector/src/main/java/org/platformlambda/kafka/services/EventConsumer.java:324
↓ 4 callersMethodstart
()
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/ServiceLifeCycle.java:44
↓ 4 callersMethodstartAdmin
()
connectors/adapters/kafka/kafka-connector/src/main/java/org/platformlambda/kafka/services/TopicManager.java:69
↓ 4 callersMethodstr2file
(File f, String s)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:454
↓ 4 callersMethodstream2bytes
(AsyncObjectStreamReader in, ByteArrayOutputStream out)
system/platform-core/src/test/java/org/platformlambda/automation/RestEndpointTest.java:262
↓ 4 callersMethodsubmit
(String type, HttpServletRequest request, HttpServletResponse response)
system/rest-spring-2/src/main/java/org/platformlambda/servlets/ServletBase.java:54
↓ 4 callersMethodsubscribe
(String topic, String memberRoute)
system/platform-core/src/main/java/org/platformlambda/core/system/LocalPubSub.java:87
↓ 4 callersMethodsubscribe
(String topic, LambdaFunction listener, String... parameters)
system/platform-core/src/main/java/org/platformlambda/core/models/PubSubProvider.java:46
↓ 4 callersMethodtopicExists
(String topic)
system/platform-core/src/main/java/org/platformlambda/core/system/LocalPubSub.java:79
↓ 4 callersMethodtypedNumber
(JsonPrimitive p)
system/platform-core/src/main/java/org/platformlambda/core/serializers/SimpleMapper.java:359
↓ 4 callersMethoduriPathSecurity
(String uri, String expected)
system/platform-core/src/test/java/org/platformlambda/automation/RestEndpointTest.java:145
↓ 3 callersMethodaddRoute
(String origin, String route, String personality)
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/services/ServiceRegistry.java:375
↓ 3 callersMethodcancelFutureEvent
Cancel a future event @param id of the scheduled event
system/platform-core/src/main/java/org/platformlambda/core/system/EventEmitter.java:568
↓ 3 callersMethodcleanUp
()
system/platform-core/src/main/java/org/platformlambda/core/util/SimpleCache.java:132
↓ 3 callersMethodcleanup
Tell the pub/sub provider to perform clean up. e.g. closing connection, etc.
system/platform-core/src/main/java/org/platformlambda/core/system/PubSub.java:429
↓ 3 callersMethodcloseProducer
()
connectors/adapters/kafka/kafka-connector/src/main/java/org/platformlambda/kafka/services/PubSubManager.java:261
↓ 3 callersMethodcreateCookie
(String key, String value)
system/platform-core/src/test/java/org/platformlambda/core/SimpleCookieTest.java:34
↓ 3 callersMethodcreateTopic
(String topic)
system/platform-core/src/main/java/org/platformlambda/core/system/LocalPubSub.java:52
↓ 3 callersMethodcreateTopics
(ConfigReader config, Properties baseProp)
connectors/adapters/kafka/kafka-connector/src/main/java/org/platformlambda/kafka/adapter/KafkaAdapter.java:99
↓ 3 callersMethoddestinationExists
(String origin)
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/services/ServiceRegistry.java:137
↓ 3 callersMethoddoApps
(String[] args, boolean main)
system/platform-core/src/main/java/org/platformlambda/core/system/AppStarter.java:130
↓ 3 callersMethodenforceKeysAsText
(Map raw)
system/platform-core/src/main/java/org/platformlambda/core/util/ConfigReader.java:324
↓ 3 callersMethodextraToKeyValues
()
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:435
↓ 3 callersMethodfeatureEnabled
Check if pub/sub feature is enabled. @return true or false
system/platform-core/src/main/java/org/platformlambda/core/system/PubSub.java:133
↓ 3 callersMethodfile2bytes
(File f)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:471
↓ 3 callersMethodfindActualQueryKey
(String key)
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:604
↓ 3 callersMethodgetData
()
system/rest-spring-2/src/main/java/org/platformlambda/spring/patch/OriginTrackedYamlLoader.java:84
↓ 3 callersMethodgetDatabase
()
system/platform-core/src/main/java/org/platformlambda/core/util/ElasticQueue.java:267
↓ 3 callersMethodgetDate
()
system/platform-core/src/test/java/org/platformlambda/core/models/PoJo.java:63
↓ 3 callersMethodgetDateOnly
(Date date)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:348
↓ 3 callersMethodgetDateUuid
()
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:213
↓ 3 callersMethodgetId
()
connectors/adapters/kafka/kafka-standalone/src/test/java/org/platformlambda/core/util/models/ObjectWithGenericType.java:34
↓ 3 callersMethodgetKafkaProperties
(String location)
connectors/adapters/kafka/kafka-connector/src/main/java/org/platformlambda/kafka/KafkaConnector.java:60
↓ 3 callersMethodgetLongNumber
()
system/platform-core/src/test/java/org/platformlambda/core/models/PoJo.java:87
↓ 3 callersMethodgetName
()
connectors/adapters/kafka/kafka-standalone/src/test/java/org/platformlambda/core/util/models/PoJo.java:35
↓ 3 callersMethodgetName
()
connectors/adapters/kafka/kafka-presence/src/test/java/org/platformlambda/core/util/models/PoJo.java:35
↓ 3 callersMethodgetName
()
system/platform-core/src/main/java/org/platformlambda/core/util/SimpleCache.java:120
↓ 3 callersMethodgetQueryParameter
Use this when you know it is a single value item. @param key of the parameter @return value of the parameter
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:379
↓ 3 callersMethodgetQueryParameters
()
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:337
↓ 3 callersMethodgetQueryString
()
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:300
↓ 3 callersMethodgetRootCause
(Throwable exception)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:859
↓ 3 callersMethodgetRoute
()
system/platform-core/src/main/java/org/platformlambda/core/system/ServiceQueue.java:97
↓ 3 callersMethodgetStreamInfo
()
system/platform-core/src/main/java/org/platformlambda/core/system/ObjectStreamIO.java:109
↓ 3 callersMethodgetTrace
User application may obtain the complete trace object for trace ID, path, start time and annotations. @return trace info
system/platform-core/src/main/java/org/platformlambda/core/system/PostOffice.java:123
↓ 3 callersMethodgetTrace
IMPORTANT: This method is reserved by the system. User application MUST NOT access this. @param route name @param instance for the worker serving this
system/platform-core/src/main/java/org/platformlambda/core/system/EventEmitter.java:350
↓ 3 callersMethodgetTraceId
()
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:143
↓ 3 callersMethodgetTracePath
()
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:147
↓ 3 callersMethodgetValidatedRoute
(String route)
system/platform-core/src/main/java/org/platformlambda/core/system/Platform.java:582
↓ 3 callersMethodincoming
(EventEnvelope message)
system/platform-core/src/main/java/org/platformlambda/core/websocket/common/MultipartPayload.java:65
↓ 3 callersMethodindentBlock
(StringBuilder buffer, int indent)
system/platform-core/src/main/java/org/platformlambda/core/serializers/SimpleXmlWriter.java:127
↓ 3 callersMethodinitialize
()
system/platform-core/src/main/java/org/platformlambda/core/models/CloudSetup.java:23
↓ 3 callersMethodinvalidFilterParameters
(List<String> items)
system/platform-core/src/main/java/org/platformlambda/automation/config/RoutingEntry.java:267
↓ 3 callersMethodisBinary
()
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:179
↓ 3 callersMethodisCloudSelected
()
system/platform-core/src/main/java/org/platformlambda/core/system/Platform.java:243
↓ 3 callersMethodisListOfMap
(List<Object> list)
system/platform-core/src/main/java/org/platformlambda/automation/config/RoutingEntry.java:364
↓ 3 callersMethodisPrimitive
(Object obj)
system/platform-core/src/main/java/org/platformlambda/core/serializers/SimpleObjectMapper.java:131
↓ 3 callersMethodisPrimitive
(Object obj)
system/platform-core/src/main/java/org/platformlambda/core/serializers/PayloadMapper.java:162
↓ 3 callersMethodisSuccess
()
system/platform-core/src/main/java/org/platformlambda/core/models/ProcessStatus.java:58
↓ 3 callersMethodisTrackable
Check if the route is trackable @param route name of a function @return true or false
system/platform-core/src/main/java/org/platformlambda/core/system/Platform.java:453
↓ 3 callersMethodlisten
(String queue, LambdaFunction listener, String... parameters)
system/platform-core/src/main/java/org/platformlambda/core/models/PubSubProvider.java:52
↓ 3 callersMethodmatchedElement
(List<String> elements, String path)
system/platform-core/src/main/java/org/platformlambda/automation/services/ServiceGateway.java:250
↓ 3 callersMethodmergeConfig
(Map<String, Object> consolidated, String filename)
system/platform-core/src/main/java/org/platformlambda/core/util/AppConfigReader.java:107
↓ 3 callersMethodnextInt
(int bound)
system/platform-core/src/main/java/org/platformlambda/core/util/CryptoApi.java:521
↓ 3 callersMethodnormalizeMap
(Map<String, Object> map)
system/platform-core/src/main/java/org/platformlambda/core/util/ConfigReader.java:315
↓ 3 callersMethodpartitionCount
(String topic)
system/platform-core/src/main/java/org/platformlambda/core/models/PubSubProvider.java:60
↓ 3 callersMethodpeek
()
system/platform-core/src/main/java/org/platformlambda/core/util/ElasticQueue.java:296
↓ 3 callersMethodpublish
(String topic, Map<String, String> headers, Object body)
system/platform-core/src/main/java/org/platformlambda/core/models/PubSubProvider.java:42
↓ 3 callersMethodread
()
system/platform-core/src/main/java/org/platformlambda/automation/models/OutputStreamQueue.java:31
↓ 3 callersMethodreadJsonString
(String fromValue, Class<T> toValueType)
system/platform-core/src/main/java/org/platformlambda/core/serializers/SimpleObjectMapper.java:102
↓ 3 callersMethodregisterKotlinPrivate
Register a private non-blocking lambda function with one or more concurrent instances. Private function is only visible within a single execution unit
system/platform-core/src/main/java/org/platformlambda/core/system/Platform.java:386
↓ 3 callersMethodremoveElement
Remove a key-value @param compositePath using dot-bracket format @return this
system/platform-core/src/main/java/org/platformlambda/core/util/MultiLevelMap.java:211
↓ 3 callersMethodremoveRoutesFromOrigin
(String origin)
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/services/ServiceRegistry.java:407
↓ 3 callersMethodrunAsSpringBootApp
()
system/platform-core/src/main/java/org/platformlambda/core/system/AppStarter.java:115
↓ 3 callersMethodrunMainApp
()
system/platform-core/src/main/java/org/platformlambda/core/system/AppStarter.java:119
↓ 3 callersMethodsearch
Search for all application instances that contain the service route @param route for a service @return list of application instance IDs (aka originId
system/platform-core/src/main/java/org/platformlambda/core/system/EventEmitter.java:1106
↓ 3 callersMethodsendError
(HttpRequestEvent evt, int status, String message, String path)
system/platform-core/src/main/java/org/platformlambda/automation/services/AuthInterceptor.java:116
↓ 3 callersMethodsendLater
Schedule a future event @param event envelope @param future time @return eventId of the scheduled delivery
system/platform-core/src/main/java/org/platformlambda/core/system/PostOffice.java:282
↓ 3 callersMethodsendMyRoutes
(boolean exchange)
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/services/ServiceRegistry.java:348
↓ 3 callersMethodsendResponse
(EventEnvelope input, Object result)
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/services/CloudHealthCheck.java:168
↓ 3 callersMethodsendResponse
(String type, String requestId, HttpServerRequest request, int status, String message)
system/platform-core/src/main/java/org/platformlambda/automation/util/SimpleHttpUtility.java:158
↓ 3 callersMethodsetConcurrency
(int instances)
system/platform-core/src/main/java/org/platformlambda/core/system/ServiceDef.java:162
↓ 3 callersMethodsetContent
(T content)
connectors/adapters/kafka/kafka-standalone/src/test/java/org/platformlambda/core/util/models/ObjectWithGenericType.java:30
↓ 3 callersMethodsetCookie
(String key, String value)
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:272
↓ 3 callersMethodsetDisplayUrl
The URL must be set by the corresponding cloud connector implementation class <p> @param displayUrl for the connector
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/ConnectorConfig.java:63
↓ 3 callersMethodsetExecutionTime
DO NOT set this manually. The system will set it. @param milliseconds spent @return event envelope
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:649
↓ 3 callersMethodsetId
(int id)
connectors/adapters/kafka/kafka-standalone/src/test/java/org/platformlambda/core/util/models/ObjectWithGenericType.java:38
↓ 3 callersMethodsetManager
(ServiceQueue manager)
system/platform-core/src/main/java/org/platformlambda/core/system/ServiceDef.java:176
↓ 3 callersMethodsetRemoteIp
(String ip)
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:105
↓ 3 callersMethodsetSecure
(boolean https)
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:318
↓ 3 callersMethodsetServiceName
The service name must be set by the corresponding cloud connector implementation class <p> @param serviceName for the connector
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/ConnectorConfig.java:54
↓ 3 callersMethodstopAdmin
()
connectors/adapters/kafka/kafka-connector/src/main/java/org/platformlambda/kafka/services/TopicManager.java:81
↓ 3 callersMethodtoMap
()
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:1018
↓ 3 callersMethodtoMap
The set methods and toMap method are used for manually construct an HTTP request object that are typically used for Unit Test or for a service to emul
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:454
↓ 3 callersMethodtoPoJo
(Object obj, Class<T> toValueType)
system/platform-core/src/main/java/org/platformlambda/core/models/CustomSerializer.java:27
↓ 3 callersMethodtopicPartitions
(String topic)
connectors/adapters/kafka/kafka-connector/src/main/java/org/platformlambda/kafka/services/TopicManager.java:135
← previousnext →301–400 of 2,050, ranked by callers