aws

Documentation

Index

• Variables
• func NewDynamoDBIndexClient(cfg DynamoDBConfig, schemaCfg chunk.SchemaConfig) (chunk.IndexClient, error)
• func NewDynamoDBObjectClient(cfg DynamoDBConfig, schemaCfg chunk.SchemaConfig) (chunk.ObjectClient, error)
• func NewDynamoDBTableClient(cfg DynamoDBConfig) (chunk.TableClient, error)
• func NewS3ObjectClient(cfg StorageConfig, schemaCfg chunk.SchemaConfig) (chunk.ObjectClient, error)
• type DynamoDBConfig
  • func (cfg *DynamoDBConfig) RegisterFlags(f *flag.FlagSet)
• type MetricsAutoScalingConfig
  • func (cfg *MetricsAutoScalingConfig) RegisterFlags(f *flag.FlagSet)
• type StorageConfig
  • func (cfg *StorageConfig) RegisterFlags(f *flag.FlagSet)

Variables

var Fixtures = []testutils.Fixture{
	fixture{
		// contains filtered or unexported fields
	},
	dynamoDBFixture(0, 10, 20),
	dynamoDBFixture(0, 0, 20),
	dynamoDBFixture(2, 10, 20),
}

Fixtures for testing the various configuration of AWS storage.

Functions

func NewDynamoDBIndexClient

func NewDynamoDBIndexClient(cfg DynamoDBConfig, schemaCfg chunk.SchemaConfig) (chunk.IndexClient, error)

NewDynamoDBIndexClient makes a new DynamoDB-backed IndexClient.

func NewDynamoDBObjectClient

func NewDynamoDBObjectClient(cfg DynamoDBConfig, schemaCfg chunk.SchemaConfig) (chunk.ObjectClient, error)

NewDynamoDBObjectClient makes a new DynamoDB-backed ObjectClient.

func NewDynamoDBTableClient

func NewDynamoDBTableClient(cfg DynamoDBConfig) (chunk.TableClient, error)

NewDynamoDBTableClient makes a new DynamoTableClient.

func NewS3ObjectClient

func NewS3ObjectClient(cfg StorageConfig, schemaCfg chunk.SchemaConfig) (chunk.ObjectClient, error)

NewS3ObjectClient makes a new S3-backed ObjectClient.

Types

type DynamoDBConfig

type DynamoDBConfig struct {
	DynamoDB               flagext.URLValue
	APILimit               float64
	ThrottleLimit          float64
	ApplicationAutoScaling flagext.URLValue
	Metrics                MetricsAutoScalingConfig
	ChunkGangSize          int
	ChunkGetMaxParallelism int
	// contains filtered or unexported fields
}

DynamoDBConfig specifies config for a DynamoDB database.

func (*DynamoDBConfig) RegisterFlags

func (cfg *DynamoDBConfig) RegisterFlags(f *flag.FlagSet)

RegisterFlags adds the flags required to config this to the given FlagSet

type MetricsAutoScalingConfig

type MetricsAutoScalingConfig struct {
	URL              string  // URL to contact Prometheus store on
	TargetQueueLen   int64   // Queue length above which we will scale up capacity
	ScaleUpFactor    float64 // Scale up capacity by this multiple
	MinThrottling    float64 // Ignore throttling below this level
	QueueLengthQuery string  // Promql query to fetch ingester queue length
	ThrottleQuery    string  // Promql query to fetch throttle rate per table
	UsageQuery       string  // Promql query to fetch write capacity usage per table
	ReadUsageQuery   string  // Promql query to fetch read usage per table
	ReadErrorQuery   string  // Promql query to fetch read errors per table
	// contains filtered or unexported fields
}

MetricsAutoScalingConfig holds parameters to configure how it works

func (*MetricsAutoScalingConfig) RegisterFlags

func (cfg *MetricsAutoScalingConfig) RegisterFlags(f *flag.FlagSet)

RegisterFlags adds the flags required to config this to the given FlagSet

type StorageConfig

type StorageConfig struct {
	DynamoDBConfig
	S3               flagext.URLValue
	S3ForcePathStyle bool
}

StorageConfig specifies config for storing data on AWS.

func (*StorageConfig) RegisterFlags

func (cfg *StorageConfig) RegisterFlags(f *flag.FlagSet)

RegisterFlags adds the flags required to config this to the given FlagSet