MCPcopy Create free account

hub / github.com/Accenture/mercury / functions

Functions2,050 in github.com/Accenture/mercury

↓ 16 callersMethodsend
Send an event to a target service in multiple servers @param to target route @param parameters for the event @throws IOException in case of invalid r
system/platform-core/src/main/java/org/platformlambda/core/system/PostOffice.java:231
↓ 16 callersMethodwriteValueAsString
(Object value)
system/platform-core/src/main/java/org/platformlambda/core/serializers/SimpleObjectMapper.java:38
↓ 15 callersMethodfilteredServiceName
(String name)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:656
↓ 15 callersMethodget
Retrieve a parameter value by key (Note that a parameter may be substituted by a system property, an environment variable or another configuration par
system/platform-core/src/main/java/org/platformlambda/core/util/ConfigReader.java:72
↓ 15 callersMethodgetFrom
()
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:135
↓ 15 callersMethodsetBroadcastLevel
DO NOT set this manually. The system will set it. @param level 0 to 2 @return event envelope
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:671
↓ 15 callersMethodvalidServiceName
Valid service name (routing path and project ID) must contain only 0-9, a-z, period, underscore and hyphen. @param str for routing path or project ID
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:642
↓ 14 callersMethodtouch
(final EventEnvelope event)
system/platform-core/src/main/java/org/platformlambda/core/system/PostOffice.java:374
↓ 13 callersMethodawaitRequest
* Make a non-blocking RPC call to a service * <p> * When service timeout, the response will be an envelope with status "408" and a timeout e
system/platform-core/src/main/kotlin/org/platformlambda/core/system/FastRPC.kt:48
↓ 13 callersMethodgetAnnotatedClasses
(Class<? extends Annotation> type, boolean includeBasePackage)
system/platform-core/src/main/java/org/platformlambda/core/util/SimpleClassScanner.java:47
↓ 13 callersMethodgetError
()
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:187
↓ 13 callersMethodgetInputStreamId
()
system/platform-core/src/main/java/org/platformlambda/core/system/ObjectStreamIO.java:97
↓ 13 callersMethodgetPublic
(byte[] publicKey)
system/platform-core/src/main/java/org/platformlambda/core/util/CryptoApi.java:113
↓ 13 callersMethodgetUrl
()
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:90
↓ 13 callersMethodhttpPost
(String host, String path, Map<String, String> headers, Map<String, Objec
system/rest-spring-2/src/test/java/org/platformlambda/common/TestBase.java:74
↓ 13 callersMethodsendResponse
(EventEnvelope input, EventEnvelope response)
system/platform-core/src/main/java/org/platformlambda/automation/http/AsyncHttpClient.java:439
↓ 13 callersMethodsetContentLength
(int contentLength)
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:241
↓ 13 callersMethodsetElement
Set a key-value @param compositePath using dot-bracket format @param value to be inserted @return this
system/platform-core/src/main/java/org/platformlambda/core/util/MultiLevelMap.java:199
↓ 13 callersMethodsetQueryParameter
(String key, Object value)
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:415
↓ 13 callersMethodstart
(String[] args)
system/platform-core/src/main/java/org/platformlambda/core/models/EntryPoint.java:23
↓ 13 callersMethodstr2date
(String str)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:715
↓ 12 callersMethodannotateTrace
User application may add key-values using this method <p> Please note that trace annotation feature is available inside a user function that implement
system/platform-core/src/main/java/org/platformlambda/core/system/PostOffice.java:169
↓ 12 callersMethodclose
()
system/platform-core/src/main/java/org/platformlambda/core/system/ObjectStreamWriter.java:69
↓ 12 callersMethodgetException
Get event exception if any @return exception cause
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:279
↓ 12 callersMethodgetPrivate
(byte[] privateKey)
system/platform-core/src/main/java/org/platformlambda/core/util/CryptoApi.java:121
↓ 12 callersMethodgetRoute
Get my route name for the currently running service. This is typically used in Role Based Access Control (RBAC) to restrict certain user roles to exec
system/platform-core/src/main/java/org/platformlambda/core/system/PostOffice.java:96
↓ 12 callersMethodgetTime
()
system/platform-core/src/main/java/org/platformlambda/core/models/FutureEvent.java:37
↓ 12 callersMethodisDigits
(String str)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:839
↓ 12 callersMethodstr2long
(String str)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:567
↓ 12 callersMethodstream2bytes
(InputStream stream)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:402
↓ 12 callersMethodzeroFill
(int seq, int max)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:197
↓ 11 callersMethodgetInstance
()
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/reporter/PresenceConnector.java:115
↓ 11 callersMethodisRequired
(Class<?> cls)
system/platform-core/src/main/java/org/platformlambda/core/util/Feature.java:31
↓ 11 callersMethodvalidateTopicName
(String route)
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/ConnectorConfig.java:134
↓ 10 callersMethodbytes2hex
(byte[] bytes)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:945
↓ 10 callersMethodconnectToCloud
This will connect the app instance to a network event stream system based on the "cloud.connector" parameter in the application.properties
system/platform-core/src/main/java/org/platformlambda/core/system/Platform.java:251
↓ 10 callersMethodelapsedTime
(long milliseconds)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:1022
↓ 10 callersMethodgetInstance
()
system/platform-core/src/main/java/org/platformlambda/automation/util/SimpleHttpUtility.java:68
↓ 10 callersMethodgetInstance
()
system/platform-core/src/main/java/org/platformlambda/core/system/ServerPersonality.java:33
↓ 10 callersMethodgetMap
()
system/platform-core/src/main/java/org/platformlambda/core/util/common/ConfigBase.java:30
↓ 10 callersMethodgetOrigin
(Node node)
system/rest-spring-2/src/main/java/org/platformlambda/spring/patch/OriginTrackedYamlLoader.java:122
↓ 10 callersMethodgetOutputStream
()
system/platform-core/src/main/java/org/platformlambda/automation/models/StreamHolder.java:39
↓ 10 callersMethodgetOutputStreamId
()
system/platform-core/src/main/java/org/platformlambda/core/system/ObjectStreamIO.java:101
↓ 10 callersMethodgetTag
Retrieve a tag value @param key for a tag @return event envelope
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:512
↓ 10 callersMethodinit
This will be set when your function starts @param manager name - this is the manager's route name of this function
system/platform-core/src/main/java/org/platformlambda/core/models/StreamFunction.java:31
↓ 10 callersMethodreservedExtension
()
connectors/core/cloud-connector/src/test/java/org/platformlambda/cloud/ConnectorTest.java:201
↓ 10 callersMethodtopicSubstitutionEnabled
()
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/ConnectorConfig.java:41
↓ 9 callersMethodenableFeature
This method is reserved for cloud connector. You should not call this method unless you are writing your own cloud connector. @param pubSub provider
system/platform-core/src/main/java/org/platformlambda/core/system/PubSub.java:118
↓ 9 callersMethodgetEventSystem
Internal API - The vertx event bus instance must be used exclusively by the platform-core <p> This is used for event delivery for the PostOffice <p> P
system/platform-core/src/main/java/org/platformlambda/core/system/Platform.java:151
↓ 9 callersMethodgetMap
Retrieve the underlying map of key-values @return map
system/platform-core/src/main/java/org/platformlambda/core/util/MultiLevelMap.java:50
↓ 9 callersMethodgetUrlDecodedPath
(String uri)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:1080
↓ 9 callersMethodisClosed
()
system/platform-core/src/main/java/org/platformlambda/core/util/ElasticQueue.java:213
↓ 9 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/EventEmitter.java:538
↓ 9 callersMethodwrite
(Object payload)
system/platform-core/src/main/java/org/platformlambda/core/system/ObjectStreamWriter.java:38
↓ 8 callersMethodaddTag
Add a tag without value to the extra field @param key without value @return event envelope
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:471
↓ 8 callersMethodclose
()
system/platform-core/src/main/java/org/platformlambda/automation/models/StreamHolder.java:55
↓ 8 callersMethodend
()
system/platform-core/src/main/java/org/platformlambda/automation/models/OutputStreamQueue.java:51
↓ 8 callersMethodgetAddress
()
system/platform-core/src/test/java/org/platformlambda/core/models/PoJo.java:55
↓ 8 callersMethodgetBody
Restore body to PoJo if class type information is available @return original body
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:135
↓ 8 callersMethodgetConnections
()
connectors/core/service-monitor/src/main/java/org/platformlambda/ws/MonitorService.java:101
↓ 8 callersMethodgetExtra
()
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:155
↓ 8 callersMethodgetFlatMap
Hierarchical data of a map to be converted into properties like "this.is.a.key" @param src map @return flat map
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:277
↓ 8 callersMethodgetId
()
system/platform-core/src/main/java/org/platformlambda/core/system/EventEmitter.java:139
↓ 8 callersMethodgetInstance
()
system/platform-core/src/main/java/org/platformlambda/core/websocket/common/MultipartPayload.java:61
↓ 8 callersMethodgetInstance
()
system/platform-core/src/main/java/org/platformlambda/core/util/SimpleClassScanner.java:43
↓ 8 callersMethodgetJob
(String id)
extensions/simple-scheduler/src/main/java/org/platformlambda/quartz/MainScheduler.java:66
↓ 8 callersMethodgetManager
()
system/platform-core/src/main/java/org/platformlambda/core/models/TargetRoute.java:37
↓ 8 callersMethodgetTopicSubstitution
()
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/ConnectorConfig.java:96
↓ 8 callersMethodgetVersion
()
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:187
↓ 8 callersMethodhttpPost
(String host, String path, Map<String, String> headers, Map<String,
connectors/core/service-monitor/src/test/java/org/platformlambda/mock/TestBase.java:70
↓ 8 callersMethodisZero
(BigDecimal number)
system/platform-core/src/main/java/org/platformlambda/core/serializers/SimpleMapper.java:384
↓ 8 callersMethodreservedFilename
(String name)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:683
↓ 8 callersMethodsendError
(EventEnvelope input, int status, String error)
system/platform-core/src/main/java/org/platformlambda/core/services/EventApiService.java:153
↓ 8 callersMethodsetParametricType
For Java object with generic types, you may tell EventEnvelope to transport the parameterized Class(es) so that the object can be deserialized correct
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:723
↓ 8 callersMethodsubstituteRouteIfAny
(String to)
system/platform-core/src/main/java/org/platformlambda/core/system/EventEmitter.java:639
↓ 8 callersMethodwaitForProvider
This method may be used during application startup. @param provider route name of a service that you want to check if it is ready @param seconds to w
system/platform-core/src/main/java/org/platformlambda/core/system/Platform.java:705
↓ 7 callersMethodclear
()
system/platform-core/src/main/java/org/platformlambda/core/util/SimpleCache.java:128
↓ 7 callersMethodcreateCache
Create a simple cache with expiry timer @param name cache label @param expiryMs timer @return simple cache object
system/platform-core/src/main/java/org/platformlambda/core/util/SimpleCache.java:71
↓ 7 callersMethodcreateTopic
Create a topic before publishing @param topic for a store-n-forward pub/sub channel @return true when topic is successfully created @throws IOExcepti
system/platform-core/src/main/java/org/platformlambda/core/system/PubSub.java:201
↓ 7 callersMethodgenerateRsaKey
Generate RSA keypair @return keypair
system/platform-core/src/main/java/org/platformlambda/core/util/CryptoApi.java:71
↓ 7 callersMethodgetBroadcastLevel
()
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:171
↓ 7 callersMethodgetClient
(String domain, Properties properties)
connectors/adapters/hazelcast/hazelcast-connector/src/main/java/org/platformlambda/hazelcast/HazelcastConnector.java:111
↓ 7 callersMethodgetExecutionTime
()
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:163
↓ 7 callersMethodgetInstance
()
system/platform-core/src/main/java/org/platformlambda/automation/config/RoutingEntry.java:85
↓ 7 callersMethodgetPackages
(boolean includeBasePackage)
system/platform-core/src/main/java/org/platformlambda/core/util/SimpleClassScanner.java:65
↓ 7 callersMethodgetSafeDisplayUri
(String uri)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:1091
↓ 7 callersMethodgetTimestamp
()
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:329
↓ 7 callersMethodoutgoing
(String dest, EventEnvelope event)
system/platform-core/src/main/java/org/platformlambda/core/websocket/common/MultipartPayload.java:114
↓ 7 callersMethodremoveTag
Remove a tag from the extra field @param key for a tag @return event envelope
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:497
↓ 7 callersMethodsendRequestToService
(HttpServerRequest request, HttpRequestEvent requestEvent)
system/platform-core/src/main/java/org/platformlambda/automation/services/ServiceGateway.java:700
↓ 7 callersMethodsetHttpRequest
(AsyncHttpRequest request)
system/platform-core/src/main/java/org/platformlambda/automation/models/HttpRequestEvent.java:79
↓ 7 callersMethodsetStreamRoute
(String streamRoute)
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:202
↓ 7 callersMethodsubscribe
Subscribe to a topic For Kafka, the parameters must include a client ID, a group ID and an optional READ offset. If read offset is not given, the lis
system/platform-core/src/main/java/org/platformlambda/core/system/PubSub.java:303
↓ 7 callersMethodtoMap
(Object obj)
system/platform-core/src/main/java/org/platformlambda/core/models/CustomSerializer.java:25
↓ 6 callersMethodbroadcast
Broadcast an event to multiple servers holding the target route <p> This method is only relevant when running in a minimalist service mesh @param to
system/platform-core/src/main/java/org/platformlambda/core/system/PostOffice.java:186
↓ 6 callersMethodbytesToBase64
(byte[] b)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:883
↓ 6 callersMethodclose
()
system/platform-core/src/main/java/org/platformlambda/core/websocket/client/PersistentWsClient.java:240
↓ 6 callersMethodcloseContext
(String requestId)
system/platform-core/src/main/java/org/platformlambda/automation/services/ServiceGateway.java:164
↓ 6 callersMethoddropDangerousSegment
(String uri, String pattern)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:1102
↓ 6 callersMethodescapeXml
(String value, TagType type)
system/platform-core/src/main/java/org/platformlambda/core/serializers/SimpleXmlWriter.java:133
← previousnext →101–200 of 2,050, ranked by callers