Documentation ¶
Index ¶
Constants ¶
View Source
const ( // ErrCodeKMSThrottlingException is defined in the API Reference // https://docs.aws.amazon.com/sdk-for-go/api/service/kinesis/#Kinesis.GetRecords ErrCodeKMSThrottlingException = "KMSThrottlingException" )
Variables ¶
View Source
var (
ErrLeaseNotAcquired = errors.New("the shard could not be leased due to a collision")
)
Common errors that might occur throughout checkpointing.
Functions ¶
func GetSession ¶
func GetSession(ctx context.Context, parsedConf *service.ParsedConfig, opts ...func(*config.LoadOptions) error) (aws.Config, error)
Types ¶
This section is empty.
Source Files ¶
- cache_dynamodb.go
- cache_s3.go
- input_kinesis.go
- input_kinesis_checkpointer.go
- input_kinesis_record_batcher.go
- input_s3.go
- input_sqs.go
- metrics_cloudwatch.go
- output_dynamodb.go
- output_kinesis.go
- output_kinesis_firehose.go
- output_s3.go
- output_sns.go
- output_sqs.go
- processor_dynamodb_partiql.go
- processor_lambda.go
- session.go
Click to show internal directories.
Click to hide internal directories.