Versions in this module Expand all Collapse all v1 v1.0.1 Jul 13, 2018 v1.0.0 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)
Go to main page