Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

config

package

Go to main page

Versions in this module

v0

v0.0.5

Jun 17, 2023

Changes in this version

+ const DefaultLeaseRefreshWaitTime

+ const DefaultMaxRetryCount

type KinesisClientLibConfiguration

+ LeaseRefreshWaitTime int

+ MaxRetryCount int

+ func (c *KinesisClientLibConfiguration) WithLeaseRefreshWaitTime(leaseRefreshWaitTime int) *KinesisClientLibConfiguration

+ func (c *KinesisClientLibConfiguration) WithMaxRetryCount(maxRetryCount int) *KinesisClientLibConfiguration

v0.0.4

Feb 8, 2023

v0.0.3

Nov 25, 2022

v0.0.2

Oct 27, 2022

v0.0.1

Oct 27, 2022

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 DefaultLeaseStealingClaimTimeoutMillis

+ const DefaultLeaseStealingIntervalMillis

+ const DefaultLeaseSyncingIntervalMillis

+ const DefaultMaxLeasesForWorker

+ const DefaultMaxLeasesToStealAtOneTime

+ const DefaultMaxRecords

+ 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

+ LeaseStealingClaimTimeoutMillis int

+ LeaseStealingIntervalMillis int

+ LeaseSyncingTimeIntervalMillis int

+ Logger logger.Logger

+ MaxLeasesForWorker int

+ MaxLeasesToStealAtOneTime int

+ MaxRecords 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) 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) 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