Versions in this module Expand all Collapse all v1 v1.0.0 Mar 5, 2024 Changes in this version + const AT_TIMESTAMP + const DefaultCleanupLeasesUponShardsCompletion + const DefaultDontCallProcessRecordsForEmptyRecordList + const DefaultEnableLeaseStealing + const DefaultFailoverTimeMillis + const DefaultIdleTimeBetweenReadsMillis + const DefaultInitialLeaseTableReadCapacity + const DefaultInitialLeaseTableWriteCapacity + const DefaultInitialPositionInStream + const DefaultLeaseRefreshPeriodMillis + const DefaultLeaseRefreshWaitTime + const DefaultLeaseStealingClaimTimeoutMillis + const DefaultLeaseStealingIntervalMillis + const DefaultLeaseSyncingIntervalMillis + const DefaultMaxLeasesForWorker + const DefaultMaxLeasesToStealAtOneTime + const DefaultMaxRecords + const DefaultMaxRetryCount + const DefaultParentShardPollIntervalMillis + const DefaultShardSyncIntervalMillis + const DefaultShutdownGraceMillis + const DefaultSkipShardSyncAtStartupIfLeasesExist + const DefaultTaskBackoffTimeMillis + const DefaultValidateSequenceNumberBeforeCheckpointing + 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 + DynamoDBCredentials aws.CredentialsProvider + DynamoDBEndpoint string + EnableEnhancedFanOutConsumer bool + EnableLeaseStealing bool + EnhancedFanOutConsumerARN string + EnhancedFanOutConsumerName string + FailoverTimeMillis int + IdleTimeBetweenReadsInMillis int + InitialLeaseTableReadCapacity int + InitialLeaseTableWriteCapacity int + InitialPositionInStream InitialPositionInStream + InitialPositionInStreamExtended InitialPositionInStreamExtended + KinesisCredentials aws.CredentialsProvider + KinesisEndpoint string + LeaseRefreshPeriodMillis int + LeaseRefreshWaitTime int + LeaseStealingClaimTimeoutMillis int + LeaseStealingIntervalMillis int + LeaseSyncingTimeIntervalMillis int + Logger logger.Logger + MaxLeasesForWorker int + MaxLeasesToStealAtOneTime int + MaxRecords int + MaxRetryCount int + MonitoringService metrics.MonitoringService + 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) WithEnhancedFanOutConsumer(enable bool) *KinesisClientLibConfiguration + func (c *KinesisClientLibConfiguration) WithEnhancedFanOutConsumerARN(consumerARN string) *KinesisClientLibConfiguration + func (c *KinesisClientLibConfiguration) WithEnhancedFanOutConsumerName(consumerName 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) WithLeaseRefreshPeriodMillis(leaseRefreshPeriodMillis int) *KinesisClientLibConfiguration + func (c *KinesisClientLibConfiguration) WithLeaseRefreshWaitTime(leaseRefreshWaitTime int) *KinesisClientLibConfiguration + func (c *KinesisClientLibConfiguration) WithLeaseStealing(enableLeaseStealing bool) *KinesisClientLibConfiguration + func (c *KinesisClientLibConfiguration) WithLeaseStealingIntervalMillis(leaseStealingIntervalMillis int) *KinesisClientLibConfiguration + func (c *KinesisClientLibConfiguration) WithLeaseSyncingIntervalMillis(leaseSyncingIntervalMillis int) *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) WithMaxRetryCount(maxRetryCount int) *KinesisClientLibConfiguration + func (c *KinesisClientLibConfiguration) WithMonitoringService(mService metrics.MonitoringService) *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
Go to main page