Help us shape the future of Go! Take the 2026 Go Developer Survey

aws

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 5, 2019 License: Apache-2.0 Imports: 38 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL