dax

package
v1.2.2 Latest Latest
Warning

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

Go to latest
Published: Nov 16, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const ServiceName = "dax"

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	client.Config

	// Default request options
	RequestTimeout time.Duration
	WriteRetries   int
	ReadRetries    int

	LogLevel aws.LogLevelType
	Logger   aws.Logger
}

func DefaultConfig

func DefaultConfig() Config

DefaultConfig returns the default DAX configuration.

Config.Region and Config.HostPorts still need to be configured properly to start up a DAX client.

func NewConfigWithSession added in v1.2.0

func NewConfigWithSession(session session.Session) Config

NewWithSession creates a new instance of the DAX config with a session.

Only configurations relevent to DAX will be used, others will be ignored.

type Dax

type Dax struct {
	// contains filtered or unexported fields
}

Dax makes requests to the Amazon DAX API, which conforms to the DynamoDB API.

Dax methods are safe to use concurrently

func New

func New(cfg Config) (*Dax, error)

New creates a new instance of the DAX client with a DAX configuration.

func NewWithSession

func NewWithSession(session session.Session) (*Dax, error)

NewWithSession creates a new instance of the DAX client with a session.

Only configurations relevent to DAX will be used, others will be ignored.

Example:

mySession := session.Must(session.NewSession(
	&aws.Config{
		Region: aws.String("us-east-1"),
		Endpoint: aws.String("mycluster.frfx8h.clustercfg.dax.usw2.amazonaws.com:8111"),
	}))

// Create a DAX client from just a session.
svc := dax.NewWithSession(mySession)

func (*Dax) BatchGetItem

func (d *Dax) BatchGetItem(input *dynamodb.BatchGetItemInput) (*dynamodb.BatchGetItemOutput, error)

func (*Dax) BatchGetItemPages

func (d *Dax) BatchGetItemPages(input *dynamodb.BatchGetItemInput, fn func(*dynamodb.BatchGetItemOutput, bool) bool) error

func (*Dax) BatchGetItemPagesWithContext

func (d *Dax) BatchGetItemPagesWithContext(ctx aws.Context, input *dynamodb.BatchGetItemInput, fn func(*dynamodb.BatchGetItemOutput, bool) bool, opts ...request.Option) error

func (*Dax) BatchGetItemRequest

func (d *Dax) BatchGetItemRequest(input *dynamodb.BatchGetItemInput) (*request.Request, *dynamodb.BatchGetItemOutput)

func (*Dax) BatchGetItemWithContext

func (d *Dax) BatchGetItemWithContext(ctx aws.Context, input *dynamodb.BatchGetItemInput, opts ...request.Option) (*dynamodb.BatchGetItemOutput, error)

func (*Dax) BatchWriteItem

func (d *Dax) BatchWriteItem(input *dynamodb.BatchWriteItemInput) (*dynamodb.BatchWriteItemOutput, error)

func (*Dax) BatchWriteItemRequest

func (d *Dax) BatchWriteItemRequest(input *dynamodb.BatchWriteItemInput) (*request.Request, *dynamodb.BatchWriteItemOutput)

func (*Dax) BatchWriteItemWithContext

func (d *Dax) BatchWriteItemWithContext(ctx aws.Context, input *dynamodb.BatchWriteItemInput, opts ...request.Option) (*dynamodb.BatchWriteItemOutput, error)

func (*Dax) Close

func (d *Dax) Close() error

func (*Dax) CreateBackup

func (*Dax) CreateBackupRequest

func (d *Dax) CreateBackupRequest(*dynamodb.CreateBackupInput) (r *request.Request, o *dynamodb.CreateBackupOutput)

func (*Dax) CreateTable

func (*Dax) CreateTableRequest

func (d *Dax) CreateTableRequest(*dynamodb.CreateTableInput) (r *request.Request, o *dynamodb.CreateTableOutput)

func (*Dax) DeleteBackup

func (*Dax) DeleteBackupRequest

func (d *Dax) DeleteBackupRequest(*dynamodb.DeleteBackupInput) (r *request.Request, o *dynamodb.DeleteBackupOutput)

func (*Dax) DeleteItem

func (d *Dax) DeleteItem(input *dynamodb.DeleteItemInput) (*dynamodb.DeleteItemOutput, error)

func (*Dax) DeleteItemRequest

func (d *Dax) DeleteItemRequest(input *dynamodb.DeleteItemInput) (*request.Request, *dynamodb.DeleteItemOutput)

func (*Dax) DeleteItemWithContext

func (d *Dax) DeleteItemWithContext(ctx aws.Context, input *dynamodb.DeleteItemInput, opts ...request.Option) (*dynamodb.DeleteItemOutput, error)

func (*Dax) DeleteTable

func (*Dax) DeleteTableRequest

func (d *Dax) DeleteTableRequest(*dynamodb.DeleteTableInput) (r *request.Request, o *dynamodb.DeleteTableOutput)

func (*Dax) DescribeBackupRequest

func (d *Dax) DescribeBackupRequest(*dynamodb.DescribeBackupInput) (r *request.Request, o *dynamodb.DescribeBackupOutput)

func (*Dax) DescribeContributorInsights added in v1.1.5

func (*Dax) DescribeContributorInsightsRequest added in v1.1.5

func (*Dax) DescribeEndpoints added in v1.0.2

func (*Dax) DescribeEndpointsRequest added in v1.0.2

func (d *Dax) DescribeEndpointsRequest(*dynamodb.DescribeEndpointsInput) (r *request.Request, o *dynamodb.DescribeEndpointsOutput)

func (*Dax) DescribeEndpointsWithContext added in v1.0.2

func (*Dax) DescribeLimitsRequest

func (d *Dax) DescribeLimitsRequest(*dynamodb.DescribeLimitsInput) (r *request.Request, o *dynamodb.DescribeLimitsOutput)

func (*Dax) DescribeTable

func (*Dax) DescribeTableReplicaAutoScalingRequest added in v1.1.5

func (*Dax) DescribeTableRequest

func (d *Dax) DescribeTableRequest(*dynamodb.DescribeTableInput) (r *request.Request, o *dynamodb.DescribeTableOutput)

func (*Dax) GetItem

func (d *Dax) GetItem(input *dynamodb.GetItemInput) (*dynamodb.GetItemOutput, error)

func (*Dax) GetItemRequest

func (d *Dax) GetItemRequest(input *dynamodb.GetItemInput) (*request.Request, *dynamodb.GetItemOutput)

func (*Dax) GetItemWithContext

func (d *Dax) GetItemWithContext(ctx aws.Context, input *dynamodb.GetItemInput, opts ...request.Option) (*dynamodb.GetItemOutput, error)

func (*Dax) ListBackups

func (*Dax) ListBackupsRequest

func (d *Dax) ListBackupsRequest(*dynamodb.ListBackupsInput) (r *request.Request, o *dynamodb.ListBackupsOutput)

func (*Dax) ListContributorInsights added in v1.1.5

func (*Dax) ListContributorInsightsPages added in v1.1.5

func (*Dax) ListContributorInsightsPagesWithContext added in v1.1.5

func (d *Dax) ListContributorInsightsPagesWithContext(aws.Context, *dynamodb.ListContributorInsightsInput, func(*dynamodb.ListContributorInsightsOutput, bool) bool, ...request.Option) error

func (*Dax) ListContributorInsightsRequest added in v1.1.5

func (d *Dax) ListContributorInsightsRequest(*dynamodb.ListContributorInsightsInput) (r *request.Request, o *dynamodb.ListContributorInsightsOutput)

func (*Dax) ListContributorInsightsWithContext added in v1.1.5

func (*Dax) ListTables

func (*Dax) ListTablesPages

func (d *Dax) ListTablesPages(*dynamodb.ListTablesInput, func(*dynamodb.ListTablesOutput, bool) bool) error

func (*Dax) ListTablesPagesWithContext

func (d *Dax) ListTablesPagesWithContext(aws.Context, *dynamodb.ListTablesInput, func(*dynamodb.ListTablesOutput, bool) bool, ...request.Option) error

func (*Dax) ListTablesRequest

func (d *Dax) ListTablesRequest(*dynamodb.ListTablesInput) (r *request.Request, o *dynamodb.ListTablesOutput)

func (*Dax) ListTablesWithContext

func (d *Dax) ListTablesWithContext(aws.Context, *dynamodb.ListTablesInput, ...request.Option) (*dynamodb.ListTablesOutput, error)

func (*Dax) PutItem

func (d *Dax) PutItem(input *dynamodb.PutItemInput) (*dynamodb.PutItemOutput, error)

func (*Dax) PutItemRequest

func (d *Dax) PutItemRequest(input *dynamodb.PutItemInput) (*request.Request, *dynamodb.PutItemOutput)

func (*Dax) PutItemWithContext

func (d *Dax) PutItemWithContext(ctx aws.Context, input *dynamodb.PutItemInput, opts ...request.Option) (*dynamodb.PutItemOutput, error)

func (*Dax) Query

func (d *Dax) Query(input *dynamodb.QueryInput) (*dynamodb.QueryOutput, error)

func (*Dax) QueryPages

func (d *Dax) QueryPages(input *dynamodb.QueryInput, fn func(*dynamodb.QueryOutput, bool) bool) error

func (*Dax) QueryPagesWithContext

func (d *Dax) QueryPagesWithContext(ctx aws.Context, input *dynamodb.QueryInput, fn func(*dynamodb.QueryOutput, bool) bool, opts ...request.Option) error

func (*Dax) QueryRequest

func (d *Dax) QueryRequest(input *dynamodb.QueryInput) (*request.Request, *dynamodb.QueryOutput)

func (*Dax) QueryWithContext

func (d *Dax) QueryWithContext(ctx aws.Context, input *dynamodb.QueryInput, opts ...request.Option) (*dynamodb.QueryOutput, error)

func (*Dax) Scan

func (d *Dax) Scan(input *dynamodb.ScanInput) (*dynamodb.ScanOutput, error)

func (*Dax) ScanPages

func (d *Dax) ScanPages(input *dynamodb.ScanInput, fn func(*dynamodb.ScanOutput, bool) bool) error

func (*Dax) ScanPagesWithContext

func (d *Dax) ScanPagesWithContext(ctx aws.Context, input *dynamodb.ScanInput, fn func(*dynamodb.ScanOutput, bool) bool, opts ...request.Option) error

func (*Dax) ScanRequest

func (d *Dax) ScanRequest(input *dynamodb.ScanInput) (*request.Request, *dynamodb.ScanOutput)

func (*Dax) ScanWithContext

func (d *Dax) ScanWithContext(ctx aws.Context, input *dynamodb.ScanInput, opts ...request.Option) (*dynamodb.ScanOutput, error)

func (*Dax) TagResource

func (*Dax) TagResourceRequest

func (d *Dax) TagResourceRequest(*dynamodb.TagResourceInput) (r *request.Request, o *dynamodb.TagResourceOutput)

func (*Dax) TransactGetItems added in v1.1.0

func (d *Dax) TransactGetItems(input *dynamodb.TransactGetItemsInput) (*dynamodb.TransactGetItemsOutput, error)

func (*Dax) TransactGetItemsRequest added in v1.1.0

func (d *Dax) TransactGetItemsRequest(input *dynamodb.TransactGetItemsInput) (*request.Request, *dynamodb.TransactGetItemsOutput)

func (*Dax) TransactGetItemsWithContext added in v1.1.0

func (d *Dax) TransactGetItemsWithContext(ctx aws.Context, input *dynamodb.TransactGetItemsInput, opts ...request.Option) (*dynamodb.TransactGetItemsOutput, error)

func (*Dax) TransactWriteItems added in v1.1.0

func (d *Dax) TransactWriteItems(input *dynamodb.TransactWriteItemsInput) (*dynamodb.TransactWriteItemsOutput, error)

func (*Dax) TransactWriteItemsRequest added in v1.1.0

func (d *Dax) TransactWriteItemsRequest(input *dynamodb.TransactWriteItemsInput) (*request.Request, *dynamodb.TransactWriteItemsOutput)

func (*Dax) TransactWriteItemsWithContext added in v1.1.0

func (d *Dax) TransactWriteItemsWithContext(ctx aws.Context, input *dynamodb.TransactWriteItemsInput, opts ...request.Option) (*dynamodb.TransactWriteItemsOutput, error)

func (*Dax) UntagResource

func (*Dax) UntagResourceRequest

func (d *Dax) UntagResourceRequest(*dynamodb.UntagResourceInput) (r *request.Request, o *dynamodb.UntagResourceOutput)

func (*Dax) UpdateContributorInsights added in v1.1.5

func (*Dax) UpdateContributorInsightsRequest added in v1.1.5

func (*Dax) UpdateContributorInsightsWithContext added in v1.1.5

func (*Dax) UpdateItem

func (d *Dax) UpdateItem(input *dynamodb.UpdateItemInput) (*dynamodb.UpdateItemOutput, error)

func (*Dax) UpdateItemRequest

func (d *Dax) UpdateItemRequest(input *dynamodb.UpdateItemInput) (*request.Request, *dynamodb.UpdateItemOutput)

func (*Dax) UpdateItemWithContext

func (d *Dax) UpdateItemWithContext(ctx aws.Context, input *dynamodb.UpdateItemInput, opts ...request.Option) (*dynamodb.UpdateItemOutput, error)

func (*Dax) UpdateTable

func (*Dax) UpdateTableReplicaAutoScaling added in v1.1.5

func (*Dax) UpdateTableReplicaAutoScalingRequest added in v1.1.5

func (*Dax) UpdateTableRequest

func (d *Dax) UpdateTableRequest(*dynamodb.UpdateTableInput) (r *request.Request, o *dynamodb.UpdateTableOutput)

func (*Dax) WaitUntilTableExists

func (d *Dax) WaitUntilTableExists(*dynamodb.DescribeTableInput) error

func (*Dax) WaitUntilTableExistsWithContext

func (d *Dax) WaitUntilTableExistsWithContext(aws.Context, *dynamodb.DescribeTableInput, ...request.WaiterOption) error

func (*Dax) WaitUntilTableNotExists

func (d *Dax) WaitUntilTableNotExists(*dynamodb.DescribeTableInput) error

func (*Dax) WaitUntilTableNotExistsWithContext

func (d *Dax) WaitUntilTableNotExistsWithContext(aws.Context, *dynamodb.DescribeTableInput, ...request.WaiterOption) error

Directories

Path Synopsis
internal
client
A stub implementation of the DaxAPI interface that can be configured to return a series of responses to BatchGetItem, Query, and Scan requests.
A stub implementation of the DaxAPI interface that can be configured to return a series of responses to BatchGetItem, Query, and Scan requests.
lru

Jump to

Keyboard shortcuts

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