Module nstream.adapter.dynamodb

Package nstream.adapter.dynamodb

Class DynamoDbIngressSettings

java.lang.Object

nstream.adapter.dynamodb.DynamoDbIngressSettings

All Implemented Interfaces:

nstream.adapter.common.AdapterSettings, swim.codec.Debug

@Tag("dynamoDbIngressSettings")
public class DynamoDbIngressSettings
extends Object
implements nstream.adapter.common.AdapterSettings

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

See Also:

• DynamoDbIngestingAgent
• DynamoDbIngestingPatch

Constructor Summary

Constructors

Constructor	Description
DynamoDbIngressSettings()
DynamoDbIngressSettings(long firstFetchDelayMillis, long fetchIntervalMillis, String clientProvisionName, String table, swim.structure.Value relaySchema)

Method Summary

Modifier and Type	Method	Description
String	clientProvisionName()	Name of DynamoDB client provision to be used for ingestion.
<T> swim.codec.Output<T>	debug(swim.codec.Output<T> output)
static DynamoDbIngressSettings	defaultSettings()
long	fetchIntervalMillis()	Interval between fetches/polls in milliseconds.
long	firstFetchDelayMillis()	Initial delay on agent load before starting ingestion.
static swim.structure.Form<DynamoDbIngressSettings>	form()
swim.structure.Value	relaySchema()	Relay schema definition.
String	table()	The DynamoDB table name to be scanned.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

DynamoDbIngressSettings

public DynamoDbIngressSettings(long firstFetchDelayMillis,
 long fetchIntervalMillis,
 String clientProvisionName,
 String table,
 swim.structure.Value relaySchema)

DynamoDbIngressSettings

public DynamoDbIngressSettings()

Method Details

firstFetchDelayMillis

public long firstFetchDelayMillis()

Initial delay on agent load before starting ingestion.

Returns:

the delay in ms

fetchIntervalMillis

public long fetchIntervalMillis()

Interval between fetches/polls in milliseconds.

Returns:

the interval in ms

clientProvisionName

public String clientProvisionName()

Name of DynamoDB client provision to be used for ingestion.

Returns:

the client provision name

table

public String table()

The DynamoDB table name to be scanned.

Returns:

the table name

relaySchema

public swim.structure.Value relaySchema()

Relay schema definition.

Returns:

the relay schema

debug

public <T> swim.codec.Output<T> debug(swim.codec.Output<T> output)

Specified by:

debug in interface swim.codec.Debug

toString

public String toString()

Overrides:

toString in class Object

form

public static swim.structure.Form<DynamoDbIngressSettings> form()

defaultSettings

public static DynamoDbIngressSettings defaultSettings()