Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Accenture/mercury
/ functions
Functions
2,050 in github.com/Accenture/mercury
⨍
Functions
2,050
◇
Types & classes
398
↓ 4 callers
Method
setNonNullValue
(Map<String, String> map, String key, String value)
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:641
↓ 4 callers
Method
setPrivate
(boolean isPrivateFunction)
system/platform-core/src/main/java/org/platformlambda/core/system/ServiceDef.java:167
↓ 4 callers
Method
setQueryString
(String queryString)
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:304
↓ 4 callers
Method
setRoundTrip
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 callers
Method
setType
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 callers
Method
shutdown
()
connectors/adapters/kafka/kafka-connector/src/main/java/org/platformlambda/kafka/services/EventConsumer.java:324
↓ 4 callers
Method
start
()
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/ServiceLifeCycle.java:44
↓ 4 callers
Method
startAdmin
()
connectors/adapters/kafka/kafka-connector/src/main/java/org/platformlambda/kafka/services/TopicManager.java:69
↓ 4 callers
Method
str2file
(File f, String s)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:454
↓ 4 callers
Method
stream2bytes
(AsyncObjectStreamReader in, ByteArrayOutputStream out)
system/platform-core/src/test/java/org/platformlambda/automation/RestEndpointTest.java:262
↓ 4 callers
Method
submit
(String type, HttpServletRequest request, HttpServletResponse response)
system/rest-spring-2/src/main/java/org/platformlambda/servlets/ServletBase.java:54
↓ 4 callers
Method
subscribe
(String topic, String memberRoute)
system/platform-core/src/main/java/org/platformlambda/core/system/LocalPubSub.java:87
↓ 4 callers
Method
subscribe
(String topic, LambdaFunction listener, String... parameters)
system/platform-core/src/main/java/org/platformlambda/core/models/PubSubProvider.java:46
↓ 4 callers
Method
topicExists
(String topic)
system/platform-core/src/main/java/org/platformlambda/core/system/LocalPubSub.java:79
↓ 4 callers
Method
typedNumber
(JsonPrimitive p)
system/platform-core/src/main/java/org/platformlambda/core/serializers/SimpleMapper.java:359
↓ 4 callers
Method
uriPathSecurity
(String uri, String expected)
system/platform-core/src/test/java/org/platformlambda/automation/RestEndpointTest.java:145
↓ 3 callers
Method
addRoute
(String origin, String route, String personality)
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/services/ServiceRegistry.java:375
↓ 3 callers
Method
cancelFutureEvent
Cancel a future event @param id of the scheduled event
system/platform-core/src/main/java/org/platformlambda/core/system/EventEmitter.java:568
↓ 3 callers
Method
cleanUp
()
system/platform-core/src/main/java/org/platformlambda/core/util/SimpleCache.java:132
↓ 3 callers
Method
cleanup
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 callers
Method
closeProducer
()
connectors/adapters/kafka/kafka-connector/src/main/java/org/platformlambda/kafka/services/PubSubManager.java:261
↓ 3 callers
Method
createCookie
(String key, String value)
system/platform-core/src/test/java/org/platformlambda/core/SimpleCookieTest.java:34
↓ 3 callers
Method
createTopic
(String topic)
system/platform-core/src/main/java/org/platformlambda/core/system/LocalPubSub.java:52
↓ 3 callers
Method
createTopics
(ConfigReader config, Properties baseProp)
connectors/adapters/kafka/kafka-connector/src/main/java/org/platformlambda/kafka/adapter/KafkaAdapter.java:99
↓ 3 callers
Method
destinationExists
(String origin)
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/services/ServiceRegistry.java:137
↓ 3 callers
Method
doApps
(String[] args, boolean main)
system/platform-core/src/main/java/org/platformlambda/core/system/AppStarter.java:130
↓ 3 callers
Method
enforceKeysAsText
(Map raw)
system/platform-core/src/main/java/org/platformlambda/core/util/ConfigReader.java:324
↓ 3 callers
Method
extraToKeyValues
()
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:435
↓ 3 callers
Method
featureEnabled
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 callers
Method
file2bytes
(File f)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:471
↓ 3 callers
Method
findActualQueryKey
(String key)
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:604
↓ 3 callers
Method
getData
()
system/rest-spring-2/src/main/java/org/platformlambda/spring/patch/OriginTrackedYamlLoader.java:84
↓ 3 callers
Method
getDatabase
()
system/platform-core/src/main/java/org/platformlambda/core/util/ElasticQueue.java:267
↓ 3 callers
Method
getDate
()
system/platform-core/src/test/java/org/platformlambda/core/models/PoJo.java:63
↓ 3 callers
Method
getDateOnly
(Date date)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:348
↓ 3 callers
Method
getDateUuid
()
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:213
↓ 3 callers
Method
getId
()
connectors/adapters/kafka/kafka-standalone/src/test/java/org/platformlambda/core/util/models/ObjectWithGenericType.java:34
↓ 3 callers
Method
getKafkaProperties
(String location)
connectors/adapters/kafka/kafka-connector/src/main/java/org/platformlambda/kafka/KafkaConnector.java:60
↓ 3 callers
Method
getLongNumber
()
system/platform-core/src/test/java/org/platformlambda/core/models/PoJo.java:87
↓ 3 callers
Method
getName
()
connectors/adapters/kafka/kafka-standalone/src/test/java/org/platformlambda/core/util/models/PoJo.java:35
↓ 3 callers
Method
getName
()
connectors/adapters/kafka/kafka-presence/src/test/java/org/platformlambda/core/util/models/PoJo.java:35
↓ 3 callers
Method
getName
()
system/platform-core/src/main/java/org/platformlambda/core/util/SimpleCache.java:120
↓ 3 callers
Method
getQueryParameter
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 callers
Method
getQueryParameters
()
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:337
↓ 3 callers
Method
getQueryString
()
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:300
↓ 3 callers
Method
getRootCause
(Throwable exception)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:859
↓ 3 callers
Method
getRoute
()
system/platform-core/src/main/java/org/platformlambda/core/system/ServiceQueue.java:97
↓ 3 callers
Method
getStreamInfo
()
system/platform-core/src/main/java/org/platformlambda/core/system/ObjectStreamIO.java:109
↓ 3 callers
Method
getTrace
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 callers
Method
getTrace
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 callers
Method
getTraceId
()
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:143
↓ 3 callers
Method
getTracePath
()
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:147
↓ 3 callers
Method
getValidatedRoute
(String route)
system/platform-core/src/main/java/org/platformlambda/core/system/Platform.java:582
↓ 3 callers
Method
incoming
(EventEnvelope message)
system/platform-core/src/main/java/org/platformlambda/core/websocket/common/MultipartPayload.java:65
↓ 3 callers
Method
indentBlock
(StringBuilder buffer, int indent)
system/platform-core/src/main/java/org/platformlambda/core/serializers/SimpleXmlWriter.java:127
↓ 3 callers
Method
initialize
()
system/platform-core/src/main/java/org/platformlambda/core/models/CloudSetup.java:23
↓ 3 callers
Method
invalidFilterParameters
(List<String> items)
system/platform-core/src/main/java/org/platformlambda/automation/config/RoutingEntry.java:267
↓ 3 callers
Method
isBinary
()
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:179
↓ 3 callers
Method
isCloudSelected
()
system/platform-core/src/main/java/org/platformlambda/core/system/Platform.java:243
↓ 3 callers
Method
isListOfMap
(List<Object> list)
system/platform-core/src/main/java/org/platformlambda/automation/config/RoutingEntry.java:364
↓ 3 callers
Method
isPrimitive
(Object obj)
system/platform-core/src/main/java/org/platformlambda/core/serializers/SimpleObjectMapper.java:131
↓ 3 callers
Method
isPrimitive
(Object obj)
system/platform-core/src/main/java/org/platformlambda/core/serializers/PayloadMapper.java:162
↓ 3 callers
Method
isSuccess
()
system/platform-core/src/main/java/org/platformlambda/core/models/ProcessStatus.java:58
↓ 3 callers
Method
isTrackable
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 callers
Method
listen
(String queue, LambdaFunction listener, String... parameters)
system/platform-core/src/main/java/org/platformlambda/core/models/PubSubProvider.java:52
↓ 3 callers
Method
matchedElement
(List<String> elements, String path)
system/platform-core/src/main/java/org/platformlambda/automation/services/ServiceGateway.java:250
↓ 3 callers
Method
mergeConfig
(Map<String, Object> consolidated, String filename)
system/platform-core/src/main/java/org/platformlambda/core/util/AppConfigReader.java:107
↓ 3 callers
Method
nextInt
(int bound)
system/platform-core/src/main/java/org/platformlambda/core/util/CryptoApi.java:521
↓ 3 callers
Method
normalizeMap
(Map<String, Object> map)
system/platform-core/src/main/java/org/platformlambda/core/util/ConfigReader.java:315
↓ 3 callers
Method
partitionCount
(String topic)
system/platform-core/src/main/java/org/platformlambda/core/models/PubSubProvider.java:60
↓ 3 callers
Method
peek
()
system/platform-core/src/main/java/org/platformlambda/core/util/ElasticQueue.java:296
↓ 3 callers
Method
publish
(String topic, Map<String, String> headers, Object body)
system/platform-core/src/main/java/org/platformlambda/core/models/PubSubProvider.java:42
↓ 3 callers
Method
read
()
system/platform-core/src/main/java/org/platformlambda/automation/models/OutputStreamQueue.java:31
↓ 3 callers
Method
readJsonString
(String fromValue, Class<T> toValueType)
system/platform-core/src/main/java/org/platformlambda/core/serializers/SimpleObjectMapper.java:102
↓ 3 callers
Method
registerKotlinPrivate
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 callers
Method
removeElement
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 callers
Method
removeRoutesFromOrigin
(String origin)
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/services/ServiceRegistry.java:407
↓ 3 callers
Method
runAsSpringBootApp
()
system/platform-core/src/main/java/org/platformlambda/core/system/AppStarter.java:115
↓ 3 callers
Method
runMainApp
()
system/platform-core/src/main/java/org/platformlambda/core/system/AppStarter.java:119
↓ 3 callers
Method
search
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 callers
Method
sendError
(HttpRequestEvent evt, int status, String message, String path)
system/platform-core/src/main/java/org/platformlambda/automation/services/AuthInterceptor.java:116
↓ 3 callers
Method
sendLater
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 callers
Method
sendMyRoutes
(boolean exchange)
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/services/ServiceRegistry.java:348
↓ 3 callers
Method
sendResponse
(EventEnvelope input, Object result)
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/services/CloudHealthCheck.java:168
↓ 3 callers
Method
sendResponse
(String type, String requestId, HttpServerRequest request, int status, String message)
system/platform-core/src/main/java/org/platformlambda/automation/util/SimpleHttpUtility.java:158
↓ 3 callers
Method
setConcurrency
(int instances)
system/platform-core/src/main/java/org/platformlambda/core/system/ServiceDef.java:162
↓ 3 callers
Method
setContent
(T content)
connectors/adapters/kafka/kafka-standalone/src/test/java/org/platformlambda/core/util/models/ObjectWithGenericType.java:30
↓ 3 callers
Method
setCookie
(String key, String value)
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:272
↓ 3 callers
Method
setDisplayUrl
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 callers
Method
setExecutionTime
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 callers
Method
setId
(int id)
connectors/adapters/kafka/kafka-standalone/src/test/java/org/platformlambda/core/util/models/ObjectWithGenericType.java:38
↓ 3 callers
Method
setManager
(ServiceQueue manager)
system/platform-core/src/main/java/org/platformlambda/core/system/ServiceDef.java:176
↓ 3 callers
Method
setRemoteIp
(String ip)
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:105
↓ 3 callers
Method
setSecure
(boolean https)
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:318
↓ 3 callers
Method
setServiceName
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 callers
Method
stopAdmin
()
connectors/adapters/kafka/kafka-connector/src/main/java/org/platformlambda/kafka/services/TopicManager.java:81
↓ 3 callers
Method
toMap
()
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:1018
↓ 3 callers
Method
toMap
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 callers
Method
toPoJo
(Object obj, Class<T> toValueType)
system/platform-core/src/main/java/org/platformlambda/core/models/CustomSerializer.java:27
↓ 3 callers
Method
topicPartitions
(String topic)
connectors/adapters/kafka/kafka-connector/src/main/java/org/platformlambda/kafka/services/TopicManager.java:135
← previous
next →
301–400 of 2,050, ranked by callers