MCPcopy Create free account

hub / github.com/aws-samples/amazon-dynamodb-implementing-priority-queuing / functions

Functions261 in github.com/aws-samples/amazon-dynamodb-implementing-priority-queuing

↓ 66 callersMethodget
Get the Shipment object/record from DynamoDB @param id @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:276
↓ 60 callersMethodtoJSON
Convert an Object to JSON (Object should be properly annotated)
src/main/java/com/awsblog/queueing/utils/Utils.java:23
↓ 51 callersMethodcheckIfNullObject
Check if the object is NULL @param o @return
src/main/java/com/awsblog/queueing/utils/Utils.java:86
↓ 27 callersMethodsetReturnValue
@param status the status to set
src/main/java/com/awsblog/queueing/model/ReturnResult.java:91
↓ 25 callersMethodbuild
Create a QueueSDK @return QueueSdkClient
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1187
↓ 25 callersMethodput
Put the new object into DynamoDB - replaces values, if there is already data with the same primary key @param shipment
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:292
↓ 24 callersMethodgetQueueStats
Get the queue depth statistics @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:154
↓ 23 callersMethodgetId
@return the id
src/main/java/com/awsblog/queueing/appdata/Shipment.java:52
↓ 20 callersMethodgetSystemInfo
@return the systemInfo
src/main/java/com/awsblog/queueing/appdata/Shipment.java:96
↓ 19 callersMethodtoString
toString
src/main/java/com/awsblog/queueing/model/DLQResult.java:68
↓ 14 callersMethodwithRegion
Specify AWS region If not used, default value is 'us-east-1'. @param region Proper AWS Region string @return Builder
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1221
↓ 13 callersMethodcheckIfNullOrEmptyString
Check if the string is Null or Empty @param strToValidate @return
src/main/java/com/awsblog/queueing/utils/Utils.java:76
↓ 10 callersMethodthrowIfNullOrEmptyString
Throw exception if this an empty String @param strToValidate @param exceptionMessage
src/main/java/com/awsblog/queueing/utils/Utils.java:146
↓ 9 callersMethodpeek
Peek the record from the queue @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:527
↓ 9 callersMethodsetStatus
@param status the status to set
src/main/java/com/awsblog/queueing/model/SystemInfo.java:186
↓ 8 callersMethodenqueue
enqueue() the record into the queue @param id @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:435
↓ 8 callersMethodgetAttributeType
@return the attributeType
src/main/java/com/awsblog/queueing/config/ConfigField.java:40
↓ 8 callersMethodgetSortKey
@return the sortKey
src/main/java/com/awsblog/queueing/config/ConfigIndex.java:81
↓ 8 callersMethodgetVersion
@return the version
src/main/java/com/awsblog/queueing/model/SystemInfo.java:84
↓ 8 callersMethodsetData
@param data the data to set
src/main/java/com/awsblog/queueing/appdata/Shipment.java:146
↓ 8 callersMethodsetData1
@param data1 the data1 to set
src/main/java/com/awsblog/queueing/appdata/ShipmentData.java:70
↓ 8 callersMethodsetData2
@param data2 the data2 to set
src/main/java/com/awsblog/queueing/appdata/ShipmentData.java:85
↓ 8 callersMethodsetData3
@param data3 the data3 to set
src/main/java/com/awsblog/queueing/appdata/ShipmentData.java:100
↓ 8 callersMethodsetItems
@param items the items to set
src/main/java/com/awsblog/queueing/appdata/ShipmentData.java:115
↓ 8 callersMethodupdateStatus
Method for changing the status of the record This call should not be used unless there are operational issues and there are live issues that needs to
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:353
↓ 8 callersMethodwithCredentialsProfileName
Specify local credential profile @param profile This is the name of the local AWS Credential profile @return Builder
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1233
↓ 7 callersMethodcheckIfNotNullAndNotEmptyString
Check if not NULL and not Empty string @param strToValidate @return
src/main/java/com/awsblog/queueing/utils/Utils.java:136
↓ 7 callersMethoddelete
Delete the shipment record from DynamoDB by shipment ID @param ID
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1019
↓ 7 callersMethodgetPeekedShipmentId
Get the peeked shipment id @return
src/main/java/com/awsblog/queueing/model/PeekResult.java:68
↓ 6 callersMethodgetLambdaDeploymentName
@return the lambdaDeploymentName
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:38
↓ 6 callersMethodgetLogicalName
@return the logicalName
src/main/java/com/awsblog/queueing/config/ConfigTable.java:28
↓ 6 callersMethodgetStatus
@return the status
src/main/java/com/awsblog/queueing/model/SystemInfo.java:177
↓ 6 callersMethodisSuccessful
Was it successful? @return
src/main/java/com/awsblog/queueing/model/ReturnResult.java:47
↓ 6 callersMethodsetLastUpdatedTimestamp
@param lastUpdatedTimestamp the lastUpdatedTimestamp to set
src/main/java/com/awsblog/queueing/model/ReturnResult.java:70
↓ 6 callersMethodsetStatus
@param status the status to set
src/main/java/com/awsblog/queueing/model/ReturnResult.java:105
↓ 6 callersMethodsetVersion
@param version the version to set
src/main/java/com/awsblog/queueing/model/ReturnResult.java:118
↓ 6 callersMethodwithCredentials
Provide the AWS Credentials @param awsCredentials User's provided AWSCredential @return Builder
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1271
↓ 5 callersMethodgetTableName
@return the tableName
src/main/java/com/awsblog/queueing/config/ConfigTable.java:40
↓ 5 callersMethodsetVersion
@param version the version to set
src/main/java/com/awsblog/queueing/model/SystemInfo.java:224
↓ 5 callersMethodthrowIfNullObject
Throw exception if the object is NULL @param o @param exceptionMessage
src/main/java/com/awsblog/queueing/utils/Utils.java:106
↓ 4 callersMethodcheckIfNotNullObject
Check if the object is NOT NULL @param o @return
src/main/java/com/awsblog/queueing/utils/Utils.java:96
↓ 4 callersMethodcreateTestData
Create the test data @param ID @return Shipment
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1032
↓ 4 callersMethodgetAttributeName
@return the attributeName
src/main/java/com/awsblog/queueing/config/ConfigField.java:26
↓ 4 callersMethodgetLambdas
@return the lambdas
src/main/java/com/awsblog/queueing/config/Configuration.java:163
↓ 4 callersMethodgetPartitionKey
@return the partitionKey
src/main/java/com/awsblog/queueing/config/ConfigTable.java:81
↓ 4 callersMethodgetReadCapacity
@return the readCapacity
src/main/java/com/awsblog/queueing/config/ConfigIndex.java:39
↓ 4 callersMethodgetWriteCapacity
@return the writeCapacity
src/main/java/com/awsblog/queueing/config/ConfigIndex.java:53
↓ 4 callersMethodthrowIfConditionIsTrue
Throw exception if the passed condition is TRUE @param condition @param exceptionMessage
src/main/java/com/awsblog/queueing/utils/Utils.java:156
↓ 3 callersMethodfromJSON
Create a Configuration object from JSON @param jsonPayload @return
src/main/java/com/awsblog/queueing/config/Configuration.java:47
↓ 3 callersMethodgetFileFromResourcesAsString
Retrieve the resource content as a String with provided resource name @param resourceFileName resource file name for the file content to be retrieved
src/main/java/com/awsblog/queueing/utils/FileUtils.java:116
↓ 3 callersMethodgetHashKey
@return the hashKey
src/main/java/com/awsblog/queueing/config/ConfigIndex.java:67
↓ 3 callersMethodgetId
@return the ID
src/main/java/com/awsblog/queueing/model/SystemInfo.java:215
↓ 3 callersMethodgetItems
@return the items
src/main/java/com/awsblog/queueing/appdata/ShipmentData.java:107
↓ 3 callersMethodgetLocalJarPath
@return the localJarPath
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:74
↓ 3 callersMethodgetPeekedShipmentObject
@return the peekedShipmentObject
src/main/java/com/awsblog/queueing/model/PeekResult.java:38
↓ 3 callersMethodgetS3CodeBucket
@return the s3CodeBucket
src/main/java/com/awsblog/queueing/config/Configuration.java:135
↓ 3 callersMethodgetTables
@return the tables
src/main/java/com/awsblog/queueing/config/Configuration.java:121
↓ 3 callersMethodgetTablesMap
@return the tablesMap
src/main/java/com/awsblog/queueing/config/Configuration.java:149
↓ 3 callersMethodremove
Acknowledge that the account is processed and that can be removed from the queue queued = 0 (and REMOVE), queue_selected = false @param id @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:709
↓ 3 callersMethodresetSystemInfo
Reset the data inside the Shipment's system info object
src/main/java/com/awsblog/queueing/appdata/Shipment.java:130
↓ 3 callersMethodsetId
@param id the id to set
src/main/java/com/awsblog/queueing/appdata/Shipment.java:61
↓ 3 callersMethodsetLastUpdatedTimestamp
@param lastUpdatedTimestamp the lastUpdatedTimestamp to set
src/main/java/com/awsblog/queueing/appdata/Shipment.java:123
↓ 3 callersMethodtoString
toString()
src/main/java/com/awsblog/queueing/utils/CommandLineUtils.java:133
↓ 2 callersMethodcheckIfNotNullAndNotEmptyCollection
Check if collection exists and it is not empty @param c @return
src/main/java/com/awsblog/queueing/utils/Utils.java:185
↓ 2 callersMethodcontainsOption
Check if the options map contains provided option key @param optionKey @return
src/main/java/com/awsblog/queueing/utils/CommandLineUtils.java:79
↓ 2 callersMethodfromReturnResult
Get the values from ReturnResult object @param result @return
src/main/java/com/awsblog/queueing/model/DequeueResult.java:43
↓ 2 callersMethodgetClassName
@return the className
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:26
↓ 2 callersMethodgetJarNameFromLocalPath
Get the JAR name @param localJarPath @return
src/main/java/com/awsblog/queueing/cdk/LambdaStack.java:105
↓ 2 callersMethodgetLastUpdatedTimestamp
@return the lastUpdatedTimestamp
src/main/java/com/awsblog/queueing/appdata/Shipment.java:115
↓ 2 callersMethodgetName
@return the name
src/main/java/com/awsblog/queueing/config/ConfigIndex.java:26
↓ 2 callersMethodgetOptionValue
Get the option's value from the Options Map @param optionKey @return options's value
src/main/java/com/awsblog/queueing/utils/CommandLineUtils.java:92
↓ 2 callersMethodgetShipment
@return the shipment
src/main/java/com/awsblog/queueing/model/EnqueueResult.java:36
↓ 2 callersMethodloadConfiguration
Load the Configuration from JSON definition @return
src/main/java/com/awsblog/queueing/config/Configuration.java:81
↓ 2 callersMethodnullOrEmpty
Check if NULL or EMPTY string @param strToValidate @return
src/main/java/com/awsblog/queueing/utils/Utils.java:66
↓ 2 callersMethodputImpl
Put/Replace the new object into DynamoDB @param shipment
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:312
↓ 2 callersMethodremoveLeadingDashes
Remove the leading dashes @param s @return
src/main/java/com/awsblog/queueing/utils/CommandLineUtils.java:105
↓ 2 callersMethodsetLastUpdatedTimestamp
@param lastUpdatedTimestamp the lastUpdatedTimestamp to set
src/main/java/com/awsblog/queueing/model/SystemInfo.java:77
↓ 1 callersMethodgetDLQStats
Retrieve DLQ information @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:222
↓ 1 callersMethodgetData
@return the data
src/main/java/com/awsblog/queueing/appdata/Shipment.java:138
↓ 1 callersMethodgetDescription
@return the description
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:86
↓ 1 callersMethodgetHandler
@return the handler
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:62
↓ 1 callersMethodgetIndexes
@return the indexes
src/main/java/com/awsblog/queueing/config/ConfigTable.java:109
↓ 1 callersMethodgetLambdaRuntime
Get the proper Lambda Runtime environment @param runtime @return
src/main/java/com/awsblog/queueing/cdk/LambdaStack.java:121
↓ 1 callersMethodgetLambdasMap
@return the lambdasMap
src/main/java/com/awsblog/queueing/config/Configuration.java:156
↓ 1 callersMethodgetLastUpdatedTimestamp
@return the lastUpdatedTimestamp
src/main/java/com/awsblog/queueing/model/SystemInfo.java:70
↓ 1 callersMethodgetMemoryInMegabytes
@return the memoryInMegabytes
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:98
↓ 1 callersMethodgetReturnValue
@return the status
src/main/java/com/awsblog/queueing/model/ReturnResult.java:84
↓ 1 callersMethodgetRuntime
@return the runtime
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:50
↓ 1 callersMethodgetTimeoutInSeconds
@return the timeoutInSeconds
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:125
↓ 1 callersMethodgetTotalRecordsInProcessing
@return the totalRecordsInProcessing
src/main/java/com/awsblog/queueing/model/QueueStats.java:54
↓ 1 callersMethodgetTotalRecordsInQueue
@return the totalRecordsInQueue
src/main/java/com/awsblog/queueing/model/QueueStats.java:42
↓ 1 callersMethodgetTotalRecordsNotStarted
@return the totalRecordsNotStarted
src/main/java/com/awsblog/queueing/model/QueueStats.java:66
↓ 1 callersMethodinitialize
Part of the fluid API chaining. Once all parameters are set with .with(...) methods, build() method needs to be called. No other client call can be us
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:88
↓ 1 callersMethodisInQueue
@return the inQueue
src/main/java/com/awsblog/queueing/model/SystemInfo.java:93
↓ 1 callersMethodlistExtendedIDs
Get the first 'size' items form the Shipment table @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:996
↓ 1 callersMethodlistIDs
Get the first 'size' items form the Shipment table @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:973
↓ 1 callersMethodmarkAsReadyForShipment
Mark the object as read for Show
src/main/java/com/awsblog/queueing/appdata/Shipment.java:81
↓ 1 callersMethodparse
Parse the command line arguments @param argv
src/main/java/com/awsblog/queueing/utils/CommandLineUtils.java:32
↓ 1 callersMethodrestore
Put back the record in the queue @param id @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:775
↓ 1 callersMethodsendToDLQ
Send the problematic record to DLQ @param id @return ReturnResult
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:844
next →1–100 of 261, ranked by callers