Versions in this module Expand all Collapse all v2 v2.4.3 Feb 9, 2022 Changes in this version + const SignatureVersionV2 + const SignatureVersionV4 + var Fixtures = []testutils.Fixture + func NewDynamoDBChunkClient(cfg DynamoDBConfig, schemaCfg chunk.SchemaConfig, reg prometheus.Registerer) (chunk.Client, error) + func NewDynamoDBIndexClient(cfg DynamoDBConfig, schemaCfg chunk.SchemaConfig, reg prometheus.Registerer) (chunk.IndexClient, error) + func NewDynamoDBIndexReader(cfg DynamoDBConfig, schemaCfg chunk.SchemaConfig, reg prometheus.Registerer, ...) (chunk.IndexReader, error) + func NewDynamoDBTableClient(cfg DynamoDBConfig, reg prometheus.Registerer) (chunk.TableClient, error) + type DynamoDBConfig struct + APILimit float64 + BackoffConfig backoff.Config + ChunkGangSize int + ChunkGetMaxParallelism int + DynamoDB flagext.URLValue + Metrics MetricsAutoScalingConfig + ThrottleLimit float64 + func (cfg *DynamoDBConfig) RegisterFlags(f *flag.FlagSet) + type HTTPConfig struct + CAFile string + IdleConnTimeout time.Duration + InsecureSkipVerify bool + ResponseHeaderTimeout 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 + SSEEncryption bool + SecretAccessKey string + SignatureVersion 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) List(ctx context.Context, prefix, delimiter string) ([]chunk.StorageObject, []chunk.StorageCommonPrefix, 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
Go to main page