config

package

Go to main page

Versions in this module

v1

v1.5.1

Mar 28, 2023

v1.5.0

Oct 22, 2021

v1.4.0

Oct 15, 2021

v1.3.0

Jun 1, 2021

Changes in this version

+ const DefaultEnableLeaseStealing

+ const DefaultLeaseStealingClaimTimeoutMillis

+ const DefaultLeaseStealingIntervalMillis

+ const DefaultLeaseSyncingIntervalMillis

type KinesisClientLibConfiguration

+ EnableLeaseStealing bool

+ LeaseStealingClaimTimeoutMillis int

+ LeaseStealingIntervalMillis int

+ LeaseSyncingTimeIntervalMillis int

+ func (c *KinesisClientLibConfiguration) WithLeaseStealing(enableLeaseStealing bool) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithLeaseStealingIntervalMillis(leaseStealingIntervalMillis int) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithLeaseSyncingIntervalMillis(leaseSyncingIntervalMillis int) *KinesisClientLibConfiguration

v1.2.0

Apr 29, 2021

Changes in this version

type KinesisClientLibConfiguration

+ EnableEnhancedFanOutConsumer bool

+ EnhancedFanOutConsumerARN string

+ EnhancedFanOutConsumerName string

+ func (c *KinesisClientLibConfiguration) WithEnhancedFanOutConsumer(enable bool) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithEnhancedFanOutConsumerARN(consumerARN string) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithEnhancedFanOutConsumerName(consumerName string) *KinesisClientLibConfiguration

v1.1.0

Jan 26, 2021

Changes in this version

+ const DefaultCleanupLeasesUponShardsCompletion

+ const DefaultDontCallProcessRecordsForEmptyRecordList

+ const DefaultFailoverTimeMillis

+ const DefaultIdletimeBetweenReadsMillis

+ const DefaultInitialLeaseTableReadCapacity

+ const DefaultInitialLeaseTableWriteCapacity

+ const DefaultInitialPositionInStream

+ const DefaultLeaseRefreshPeriodMillis

+ const DefaultMaxLeasesForWorker

+ const DefaultMaxLeasesToStealAtOneTime

+ const DefaultMaxRecords

+ const DefaultParentShardPollIntervalMillis

+ const DefaultShardSyncIntervalMillis

+ const DefaultShutdownGraceMillis

+ const DefaultSkipShardSyncAtStartupIfLeasesExist

+ const DefaultTaskBackoffTimeMillis

+ const DefaultValidateSequenceNumberBeforeCheckpointing

type KinesisClientLibConfiguration

+ LeaseRefreshPeriodMillis int

+ MonitoringService metrics.MonitoringService

+ func (c *KinesisClientLibConfiguration) WithLeaseRefreshPeriodMillis(leaseRefreshPeriodMillis int) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithMonitoringService(mService metrics.MonitoringService) *KinesisClientLibConfiguration

v1.0.0

Nov 15, 2019

Changes in this version

+ const AT_TIMESTAMP

+ const DEFAULT_CLEANUP_LEASES_UPON_SHARDS_COMPLETION

+ const DEFAULT_DONT_CALL_PROCESS_RECORDS_FOR_EMPTY_RECORD_LIST

+ const DEFAULT_FAILOVER_TIME_MILLIS

+ const DEFAULT_IDLETIME_BETWEEN_READS_MILLIS

+ const DEFAULT_INITIAL_LEASE_TABLE_READ_CAPACITY

+ const DEFAULT_INITIAL_LEASE_TABLE_WRITE_CAPACITY

+ const DEFAULT_INITIAL_POSITION_IN_STREAM

+ const DEFAULT_LIST_SHARDS_BACKOFF_TIME_IN_MILLIS

+ const DEFAULT_MAX_LEASES_FOR_WORKER

+ const DEFAULT_MAX_LEASES_TO_STEAL_AT_ONE_TIME

+ const DEFAULT_MAX_LEASE_RENEWAL_THREADS

+ const DEFAULT_MAX_LIST_SHARDS_RETRY_ATTEMPTS

+ const DEFAULT_MAX_RECORDS

+ const DEFAULT_METRICS_BUFFER_TIME_MILLIS

+ const DEFAULT_METRICS_MAX_QUEUE_SIZE

+ const DEFAULT_PARENT_SHARD_POLL_INTERVAL_MILLIS

+ const DEFAULT_SHARD_SYNC_INTERVAL_MILLIS

+ const DEFAULT_SHUTDOWN_GRACE_MILLIS

+ const DEFAULT_SKIP_SHARD_SYNC_AT_STARTUP_IF_LEASES_EXIST

+ const DEFAULT_TASK_BACKOFF_TIME_MILLIS

+ const DEFAULT_VALIDATE_SEQUENCE_NUMBER_BEFORE_CHECKPOINTING

+ const LATEST

+ const TRIM_HORIZON

+ func InitalPositionInStreamToShardIteratorType(pos InitialPositionInStream) *string

+ type InitialPositionInStream int

+ type InitialPositionInStreamExtended struct

+ Position InitialPositionInStream

+ Timestamp *time.Time

+ type KinesisClientLibConfiguration struct

+ ApplicationName string

+ CallProcessRecordsEvenForEmptyRecordList bool

+ CleanupTerminatedShardsBeforeExpiry bool

+ CloudWatchCredentials *creds.Credentials

+ DynamoDBCredentials *creds.Credentials

+ DynamoDBEndpoint string

+ FailoverTimeMillis int

+ IdleTimeBetweenReadsInMillis int

+ InitialLeaseTableReadCapacity int

+ InitialLeaseTableWriteCapacity int

+ InitialPositionInStream InitialPositionInStream

+ InitialPositionInStreamExtended InitialPositionInStreamExtended

+ KinesisCredentials *creds.Credentials

+ KinesisEndpoint string

+ Logger logger.Logger

+ MaxLeasesForWorker int

+ MaxLeasesToStealAtOneTime int

+ MaxRecords int

+ MetricsBufferTimeMillis int

+ MetricsMaxQueueSize int

+ ParentShardPollIntervalMillis int

+ RegionName string

+ ShardSyncIntervalMillis int

+ ShutdownGraceMillis int

+ SkipShardSyncAtWorkerInitializationIfLeasesExist bool

+ StreamName string

+ TableName string

+ TaskBackoffTimeMillis int

+ ValidateSequenceNumberBeforeCheckpointing bool

+ WorkerID string

+ func NewKinesisClientLibConfig(applicationName, streamName, regionName, workerID string) *KinesisClientLibConfiguration

+ func NewKinesisClientLibConfigWithCredential(applicationName, streamName, regionName, workerID string, ...) *KinesisClientLibConfiguration

+ func NewKinesisClientLibConfigWithCredentials(applicationName, streamName, regionName, workerID string, ...) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithCallProcessRecordsEvenForEmptyRecordList(callProcessRecordsEvenForEmptyRecordList bool) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithDynamoDBEndpoint(dynamoDBEndpoint string) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithFailoverTimeMillis(failoverTimeMillis int) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithIdleTimeBetweenReadsInMillis(idleTimeBetweenReadsInMillis int) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithInitialPositionInStream(initialPositionInStream InitialPositionInStream) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithKinesisEndpoint(kinesisEndpoint string) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithLogger(logger logger.Logger) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithMaxLeasesForWorker(n int) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithMaxRecords(maxRecords int) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithMetricsBufferTimeMillis(metricsBufferTimeMillis int) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithMetricsMaxQueueSize(metricsMaxQueueSize int) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithShardSyncIntervalMillis(shardSyncIntervalMillis int) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithTableName(tableName string) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithTaskBackoffTimeMillis(taskBackoffTimeMillis int) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithTimestampAtInitialPositionInStream(timestamp *time.Time) *KinesisClientLibConfiguration

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL