Versions in this module Expand all Collapse all v3 v3.0.0 Apr 8, 2024 Changes in this version + const SignatureVersionV4 + var Fixtures = []testutils.Fixture + func NewDynamoDBChunkClient(cfg DynamoDBConfig, schemaCfg config.SchemaConfig, reg prometheus.Registerer) (chunkclient.Client, error) + func NewDynamoDBIndexClient(cfg DynamoDBConfig, schemaCfg config.SchemaConfig, reg prometheus.Registerer) (index.Client, error) + func NewDynamoDBIndexReader(cfg DynamoDBConfig, schemaCfg config.SchemaConfig, reg prometheus.Registerer, ...) (index.Reader, error) + func NewDynamoDBTableClient(cfg DynamoDBConfig, reg prometheus.Registerer) (index.TableClient, error) + type DynamoDBConfig struct + APILimit float64 + BackoffConfig backoff.Config + ChunkGangSize int + ChunkGetMaxParallelism int + DynamoDB flagext.URLValue + KMSKeyID string + Metrics MetricsAutoScalingConfig + ThrottleLimit float64 + func (cfg *DynamoDBConfig) RegisterFlags(f *flag.FlagSet) + type HTTPConfig struct + CAFile string + IdleConnTimeout time.Duration + InsecureSkipVerify bool + ResponseHeaderTimeout time.Duration + Timeout time.Duration + type InjectRequestMiddleware func(next http.RoundTripper) http.RoundTripper + type MetricsAutoScalingConfig struct + MinThrottling float64 + QueueLengthQuery string + ReadErrorQuery string + ReadUsageQuery string + ScaleUpFactor float64 + TargetQueueLen int64 + ThrottleQuery string + URL string + UsageQuery string + func (cfg *MetricsAutoScalingConfig) RegisterFlags(f *flag.FlagSet) + type S3Config struct + AccessKeyID string + BackoffConfig backoff.Config + BucketNames string + Endpoint string + HTTPConfig HTTPConfig + Inject InjectRequestMiddleware + Insecure bool + Region string + S3 flagext.URLValue + S3ForcePathStyle bool + SSEConfig bucket_s3.SSEConfig + SecretAccessKey flagext.Secret + SessionToken flagext.Secret + SignatureVersion string + StorageClass string + func (cfg *S3Config) RegisterFlags(f *flag.FlagSet) + func (cfg *S3Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet) + func (cfg *S3Config) Validate() error + type S3ObjectClient struct + S3 s3iface.S3API + func NewS3ObjectClient(cfg S3Config, hedgingCfg hedging.Config) (*S3ObjectClient, error) + func (a *S3ObjectClient) DeleteObject(ctx context.Context, objectKey string) error + func (a *S3ObjectClient) GetObject(ctx context.Context, objectKey string) (io.ReadCloser, int64, error) + func (a *S3ObjectClient) IsObjectNotFoundErr(err error) bool + func (a *S3ObjectClient) IsRetryableErr(error) bool + func (a *S3ObjectClient) List(ctx context.Context, prefix, delimiter string) ([]client.StorageObject, []client.StorageCommonPrefix, error) + func (a *S3ObjectClient) ObjectExists(ctx context.Context, objectKey string) (bool, error) + func (a *S3ObjectClient) PutObject(ctx context.Context, objectKey string, object io.ReadSeeker) error + func (a *S3ObjectClient) Stop() + type SSEParsedConfig struct + KMSEncryptionContext *string + KMSKeyID *string + ServerSideEncryption string + func NewSSEParsedConfig(cfg bucket_s3.SSEConfig) (*SSEParsedConfig, error) + type StorageConfig struct + func (cfg *StorageConfig) RegisterFlags(f *flag.FlagSet) + func (cfg *StorageConfig) Validate() error