Index

A C D F I L N P R S T U W
All Classes and Interfaces|All Packages

A

assignClient(DynamoDbClient) - Method in class nstream.adapter.dynamodb.DynamoDbIngestingAgent

Assign the DynamoDbClient to be used for ingestion.

assignClient(DynamoDbClient) - Method in class nstream.adapter.dynamodb.DynamoDbPublishingAgent

Assign the DynamoDbClient to be used for publication.

C

cancel() - Method in class nstream.adapter.dynamodb.DynamoDbIngestingAgent

Cancel the poll timer and therefore ingestion.

client - Variable in class nstream.adapter.dynamodb.DynamoDbIngestingAgent

client - Variable in class nstream.adapter.dynamodb.DynamoDbPublishingAgent

ClientProvision - Class in nstream.adapter.dynamodb

ClientProvision() - Constructor for class nstream.adapter.dynamodb.ClientProvision

clientProvisionName() - Method in class nstream.adapter.dynamodb.DynamoDbEgressSettings

Name of dynamo client provision to be used for publication.

clientProvisionName() - Method in class nstream.adapter.dynamodb.DynamoDbIngressSettings

Name of DynamoDB client provision to be used for ingestion.

D

debug(Output<T>) - Method in class nstream.adapter.dynamodb.DynamoDbEgressSettings

debug(Output<T>) - Method in class nstream.adapter.dynamodb.DynamoDbIngressSettings

defaultSettings() - Static method in class nstream.adapter.dynamodb.DynamoDbEgressSettings

defaultSettings() - Static method in class nstream.adapter.dynamodb.DynamoDbIngressSettings

didFailIngest(Map<String, AttributeValue>, Exception) - Method in class nstream.adapter.dynamodb.DynamoDbIngestingAgent

didStart() - Method in class nstream.adapter.dynamodb.DynamoDbPublishingAgent

Stage publication on agent start.

DynamoDbAdapterUtils - Class in nstream.adapter.dynamodb

Provides static utility methods used by the DynamoDB connector.

DynamoDbEgressSettings - Class in nstream.adapter.dynamodb

Provides a concrete class to parse and store agent configuration used for DynamoDB egress by DynamoDbPublishingAgent.

DynamoDbEgressSettings() - Constructor for class nstream.adapter.dynamodb.DynamoDbEgressSettings

DynamoDbEgressSettings(String, String) - Constructor for class nstream.adapter.dynamodb.DynamoDbEgressSettings

DynamoDbIngestingAgent - Class in nstream.adapter.dynamodb

An abstract Web Agent that can scan a DynamoDB database table.

DynamoDbIngestingAgent() - Constructor for class nstream.adapter.dynamodb.DynamoDbIngestingAgent

DynamoDbIngestingPatch - Class in nstream.adapter.dynamodb

A concrete but extendable implementation of DynamoDbIngestingAgent that uses configuration to query and relay DynamoDB items.

DynamoDbIngestingPatch() - Constructor for class nstream.adapter.dynamodb.DynamoDbIngestingPatch

DynamoDbIngressSettings - Class in nstream.adapter.dynamodb

Provides a concrete class to parse and store agent configuration used for DynamoDB ingress by various ingesting agents and patches.

DynamoDbIngressSettings() - Constructor for class nstream.adapter.dynamodb.DynamoDbIngressSettings

DynamoDbIngressSettings(long, long, String, String, Value) - Constructor for class nstream.adapter.dynamodb.DynamoDbIngressSettings

DynamoDbPublishingAgent - Class in nstream.adapter.dynamodb

An abstract Web Agent that can publish items to a DynamoDB table.

DynamoDbPublishingAgent() - Constructor for class nstream.adapter.dynamodb.DynamoDbPublishingAgent

F

fetchAndIngest() - Method in class nstream.adapter.dynamodb.DynamoDbIngestingAgent

Loop through the ScanRequest results provided by the abstract DynamoDbIngestingAgent.scanRequest() method, ingesting each document asynchronously.

fetchIntervalMillis() - Method in class nstream.adapter.dynamodb.DynamoDbIngressSettings

Interval between fetches/polls in milliseconds.

firstFetchDelayMillis() - Method in class nstream.adapter.dynamodb.DynamoDbIngressSettings

Initial delay on agent load before starting ingestion.

form() - Static method in class nstream.adapter.dynamodb.DynamoDbEgressSettings

form() - Static method in class nstream.adapter.dynamodb.DynamoDbIngressSettings

I

ingest(Map<String, AttributeValue>) - Method in class nstream.adapter.dynamodb.DynamoDbIngestingPatch

ingest(Value) - Method in class nstream.adapter.dynamodb.DynamoDbIngestingPatch

Ingest an item after it has been structured into a Value object.

L

loadValue(Log, Properties) - Method in class nstream.adapter.dynamodb.ClientProvision

N

nstream.adapter.dynamodb - module nstream.adapter.dynamodb

Templates for consuming from and producing to DynamoDB with Swim.

nstream.adapter.dynamodb - package nstream.adapter.dynamodb

P

parseEgressSettings(Value) - Method in class nstream.adapter.dynamodb.DynamoDbPublishingAgent

parseIngressSettings(Value) - Method in class nstream.adapter.dynamodb.DynamoDbIngestingAgent

pollTimer - Variable in class nstream.adapter.dynamodb.DynamoDbIngestingAgent

R

relaySchema() - Method in class nstream.adapter.dynamodb.DynamoDbIngressSettings

Relay schema definition.

S

scanRequest() - Method in class nstream.adapter.dynamodb.DynamoDbIngestingAgent

The configurable ScanRequest to be executed, looped through and ingested.

scanRequest() - Method in class nstream.adapter.dynamodb.DynamoDbIngestingPatch

stagePublication() - Method in class nstream.adapter.dynamodb.DynamoDbPublishingAgent

stageReception() - Method in class nstream.adapter.dynamodb.DynamoDbIngestingAgent

structureItem(Map<String, AttributeValue>) - Static method in class nstream.adapter.dynamodb.DynamoDbAdapterUtils

T

table() - Method in class nstream.adapter.dynamodb.DynamoDbEgressSettings

DynamoDB table name to publish to.

table() - Method in class nstream.adapter.dynamodb.DynamoDbIngressSettings

The DynamoDB table name to be scanned.

toString() - Method in class nstream.adapter.dynamodb.DynamoDbEgressSettings

toString() - Method in class nstream.adapter.dynamodb.DynamoDbIngressSettings

U

unloadValue(Log) - Method in class nstream.adapter.dynamodb.ClientProvision

W

willStop() - Method in class nstream.adapter.dynamodb.DynamoDbPublishingAgent

Close any open resources on agent close.

A C D F I L N P R S T U W
All Classes and Interfaces|All Packages