aws

Documentation

Index

• Variables
• func NewDynamoDBTableClient(cfg DynamoDBConfig) (chunk.TableClient, error)
• func NewStorageClient(cfg StorageConfig, schemaCfg chunk.SchemaConfig) (chunk.StorageClient, error)
• type DynamoDBConfig
  • func (cfg *DynamoDBConfig) 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 NewDynamoDBTableClient

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

NewDynamoDBTableClient makes a new DynamoTableClient.

func NewStorageClient

func NewStorageClient(cfg StorageConfig, schemaCfg chunk.SchemaConfig) (chunk.StorageClient, error)

NewStorageClient makes a new AWS-backed StorageClient.

Types

type DynamoDBConfig

type DynamoDBConfig struct {
	DynamoDB               util.URLValue
	APILimit               float64
	ApplicationAutoScaling util.URLValue
	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 StorageConfig

type StorageConfig struct {
	DynamoDBConfig
	S3 util.URLValue
}

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