client

Dec 20, 2018

Changes in this version

+ const OpTransactGetItems

+ const OpTransactWriteItems

type ClusterDaxClient

+ func (cc *ClusterDaxClient) TransactGetItemsWithOptions(input *dynamodb.TransactGetItemsInput, output *dynamodb.TransactGetItemsOutput, ...) (*dynamodb.TransactGetItemsOutput, error)

+ func (cc *ClusterDaxClient) TransactWriteItemsWithOptions(input *dynamodb.TransactWriteItemsInput, ...) (*dynamodb.TransactWriteItemsOutput, error)

type DaxAPI

+ TransactGetItemsWithOptions func(input *dynamodb.TransactGetItemsInput, output *dynamodb.TransactGetItemsOutput, ...) (*dynamodb.TransactGetItemsOutput, error)

+ TransactWriteItemsWithOptions func(input *dynamodb.TransactWriteItemsInput, ...) (*dynamodb.TransactWriteItemsOutput, error)

type SingleDaxClient

+ func (client *SingleDaxClient) TransactGetItemsWithOptions(input *dynamodb.TransactGetItemsInput, output *dynamodb.TransactGetItemsOutput, ...) (*dynamodb.TransactGetItemsOutput, error)

+ func (client *SingleDaxClient) TransactWriteItemsWithOptions(input *dynamodb.TransactWriteItemsInput, ...) (*dynamodb.TransactWriteItemsOutput, error)

Jun 25, 2018

Changes in this version

+ const ErrCodeNotImplemented

+ const ErrCodeServiceUnavailable

+ const ErrCodeUnknown

+ const ErrCodeValidationException

+ const OpBatchGetItem

+ const OpBatchWriteItem

+ const OpDeleteItem

+ const OpGetItem

+ const OpPutItem

+ const OpQuery

+ const OpScan

+ const OpUpdateItem

+ func ValidateConfig(c aws.Config, isRequestConfig bool) error

+ func ValidateHandlers(h request.Handlers, expectDaxHandlers bool) error

+ func ValidateRequest(r *request.Request) error

+ type ClusterDaxClient struct

+ func New(config Config) (*ClusterDaxClient, error)

+ func (cc *ClusterDaxClient) BatchGetItemWithOptions(input *dynamodb.BatchGetItemInput, output *dynamodb.BatchGetItemOutput, ...) (*dynamodb.BatchGetItemOutput, error)

+ func (cc *ClusterDaxClient) BatchWriteItemWithOptions(input *dynamodb.BatchWriteItemInput, output *dynamodb.BatchWriteItemOutput, ...) (*dynamodb.BatchWriteItemOutput, error)

+ func (cc *ClusterDaxClient) Close() error

+ func (cc *ClusterDaxClient) DeleteItemWithOptions(input *dynamodb.DeleteItemInput, output *dynamodb.DeleteItemOutput, ...) (*dynamodb.DeleteItemOutput, error)

+ func (cc *ClusterDaxClient) GetItemWithOptions(input *dynamodb.GetItemInput, output *dynamodb.GetItemOutput, ...) (*dynamodb.GetItemOutput, error)

+ func (cc *ClusterDaxClient) NewDaxRequest(op *request.Operation, input, output interface{}, opt RequestOptions) *request.Request

+ func (cc *ClusterDaxClient) PutItemWithOptions(input *dynamodb.PutItemInput, output *dynamodb.PutItemOutput, ...) (*dynamodb.PutItemOutput, error)

+ func (cc *ClusterDaxClient) QueryWithOptions(input *dynamodb.QueryInput, output *dynamodb.QueryOutput, opt RequestOptions) (*dynamodb.QueryOutput, error)

+ func (cc *ClusterDaxClient) ScanWithOptions(input *dynamodb.ScanInput, output *dynamodb.ScanOutput, opt RequestOptions) (*dynamodb.ScanOutput, error)

+ func (cc *ClusterDaxClient) UpdateItemWithOptions(input *dynamodb.UpdateItemInput, output *dynamodb.UpdateItemOutput, ...) (*dynamodb.UpdateItemOutput, error)

+ type Config struct

+ ClusterUpdateInterval time.Duration

+ ClusterUpdateThreshold time.Duration

+ Credentials *credentials.Credentials

+ HostPorts []string

+ MaxPendingConnectionsPerHost int

+ Region string

+ func DefaultConfig() Config

+ type DaxAPI interface

+ BatchGetItemWithOptions func(input *dynamodb.BatchGetItemInput, output *dynamodb.BatchGetItemOutput, ...) (*dynamodb.BatchGetItemOutput, error)

+ BatchWriteItemWithOptions func(input *dynamodb.BatchWriteItemInput, output *dynamodb.BatchWriteItemOutput, ...) (*dynamodb.BatchWriteItemOutput, error)

+ DeleteItemWithOptions func(input *dynamodb.DeleteItemInput, output *dynamodb.DeleteItemOutput, ...) (*dynamodb.DeleteItemOutput, error)

+ GetItemWithOptions func(input *dynamodb.GetItemInput, output *dynamodb.GetItemOutput, ...) (*dynamodb.GetItemOutput, error)

+ NewDaxRequest func(op *request.Operation, input, output interface{}, opt RequestOptions) *request.Request

+ PutItemWithOptions func(input *dynamodb.PutItemInput, output *dynamodb.PutItemOutput, ...) (*dynamodb.PutItemOutput, error)

+ QueryWithOptions func(input *dynamodb.QueryInput, output *dynamodb.QueryOutput, opt RequestOptions) (*dynamodb.QueryOutput, error)

+ ScanWithOptions func(input *dynamodb.ScanInput, output *dynamodb.ScanOutput, opt RequestOptions) (*dynamodb.ScanOutput, error)

+ UpdateItemWithOptions func(input *dynamodb.UpdateItemInput, output *dynamodb.UpdateItemOutput, ...) (*dynamodb.UpdateItemOutput, error)

+ type RequestOptions struct

+ Context aws.Context

+ LogLevel aws.LogLevelType

+ Logger aws.Logger

+ MaxRetries int

+ RetryDelay time.Duration

+ SleepDelayFn func(time.Duration)

+ func (o *RequestOptions) MergeFromRequestOptions(ctx aws.Context, opts ...request.Option) error

+ type SingleDaxClient struct

+ func NewSingleClient(endpoint, region string, credentials *credentials.Credentials) (*SingleDaxClient, error)

+ func (client *SingleDaxClient) BatchGetItemWithOptions(input *dynamodb.BatchGetItemInput, output *dynamodb.BatchGetItemOutput, ...) (*dynamodb.BatchGetItemOutput, error)

+ func (client *SingleDaxClient) BatchWriteItemWithOptions(input *dynamodb.BatchWriteItemInput, output *dynamodb.BatchWriteItemOutput, ...) (*dynamodb.BatchWriteItemOutput, error)

+ func (client *SingleDaxClient) Close() error

+ func (client *SingleDaxClient) DeleteItemWithOptions(input *dynamodb.DeleteItemInput, output *dynamodb.DeleteItemOutput, ...) (*dynamodb.DeleteItemOutput, error)

+ func (client *SingleDaxClient) GetItemWithOptions(input *dynamodb.GetItemInput, output *dynamodb.GetItemOutput, ...) (*dynamodb.GetItemOutput, error)

+ func (client *SingleDaxClient) NewDaxRequest(op *request.Operation, input, output interface{}, opt RequestOptions) *request.Request

+ func (client *SingleDaxClient) PutItemWithOptions(input *dynamodb.PutItemInput, output *dynamodb.PutItemOutput, ...) (*dynamodb.PutItemOutput, error)

+ func (client *SingleDaxClient) QueryWithOptions(input *dynamodb.QueryInput, output *dynamodb.QueryOutput, opt RequestOptions) (*dynamodb.QueryOutput, error)

+ func (client *SingleDaxClient) ScanWithOptions(input *dynamodb.ScanInput, output *dynamodb.ScanOutput, opt RequestOptions) (*dynamodb.ScanOutput, error)

+ func (client *SingleDaxClient) UpdateItemWithOptions(input *dynamodb.UpdateItemInput, output *dynamodb.UpdateItemOutput, ...) (*dynamodb.UpdateItemOutput, error)