dynamodbstore

package
v0.0.0-...-ba1b225 Latest Latest
Warning

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

 Go to latest Published: Jun 20, 2019 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateDefaultTable 

func CreateDefaultTable(client *dynamodb.DynamoDB, tableName string) error

Types

type AWSBackendClient 

type AWSBackendClient struct {
	dynamodbiface.DynamoDBAPI
}

func (*AWSBackendClient) TransactWriteItems 

func (c *AWSBackendClient) TransactWriteItems(input *dynamodb.TransactWriteItemsInput) (*dynamodb.TransactWriteItemsOutput, TransactWriteErr)

type AtomicWriteOperation 

type AtomicWriteOperation struct {
	Backend *Backend
	// contains filtered or unexported fields
}

func (*AtomicWriteOperation) CAS 

func (op *AtomicWriteOperation) CAS(key string, oldValue, newValue string) keyvaluestore.AtomicWriteResult

func (*AtomicWriteOperation) Delete 

func (op *AtomicWriteOperation) Delete(key string) keyvaluestore.AtomicWriteResult

func (*AtomicWriteOperation) Exec 

func (op *AtomicWriteOperation) Exec() (bool, error)

func (*AtomicWriteOperation) SetNX 

func (op *AtomicWriteOperation) SetNX(key string, value interface{}) keyvaluestore.AtomicWriteResult

type Backend 

type Backend struct {
	Client                         BackendClient
	TableName                      string
	AllowEventuallyConsistentReads bool
}

func (*Backend) AddInt 

func (b *Backend) AddInt(key string, n int64) (int64, error)

func (*Backend) AtomicWrite 

func (b *Backend) AtomicWrite() keyvaluestore.AtomicWriteOperation

func (*Backend) Batch 

func (b *Backend) Batch() keyvaluestore.BatchOperation

func (*Backend) CAS 

func (b *Backend) CAS(key string, transform func(prev *string) (interface{}, error)) (bool, error)

func (*Backend) Delete 

func (b *Backend) Delete(key string) (bool, error)

func (*Backend) Get 

func (b *Backend) Get(key string) (*string, error)

func (*Backend) SAdd 

func (b *Backend) SAdd(key string, member interface{}, members ...interface{}) error

func (*Backend) SMembers 

func (b *Backend) SMembers(key string) ([]string, error)

func (*Backend) SRem 

func (b *Backend) SRem(key string, member interface{}, members ...interface{}) error

func (*Backend) Set 

func (b *Backend) Set(key string, value interface{}) error

func (*Backend) SetNX 

func (b *Backend) SetNX(key string, value interface{}) (bool, error)

func (*Backend) SetXX 

func (b *Backend) SetXX(key string, value interface{}) (bool, error)

func (*Backend) WithEventuallyConsistentReads 

func (b *Backend) WithEventuallyConsistentReads() *Backend

func (*Backend) WithProfiler 

func (b *Backend) WithProfiler(profiler Profiler) *Backend

func (*Backend) ZAdd 

func (b *Backend) ZAdd(key string, member interface{}, score float64) error

func (*Backend) ZCount 

func (b *Backend) ZCount(key string, min, max float64) (int, error)

func (*Backend) ZIncrBy 

func (b *Backend) ZIncrBy(key string, member string, n float64) (float64, error)

func (*Backend) ZLexCount 

func (b *Backend) ZLexCount(key, min, max string) (int, error)

func (*Backend) ZRangeByLex 

func (b *Backend) ZRangeByLex(key string, min, max string, limit int) ([]string, error)

func (*Backend) ZRangeByScore 

func (b *Backend) ZRangeByScore(key string, min, max float64, limit int) ([]string, error)

func (*Backend) ZRangeByScoreWithScores 

func (b *Backend) ZRangeByScoreWithScores(key string, min, max float64, limit int) (keyvaluestore.ScoredMembers, error)

func (*Backend) ZRem 

func (b *Backend) ZRem(key string, member interface{}) error

func (*Backend) ZRevRangeByLex 

func (b *Backend) ZRevRangeByLex(key string, min, max string, limit int) ([]string, error)

func (*Backend) ZRevRangeByScore 

func (b *Backend) ZRevRangeByScore(key string, min, max float64, limit int) ([]string, error)

func (*Backend) ZRevRangeByScoreWithScores 

func (b *Backend) ZRevRangeByScoreWithScores(key string, min, max float64, limit int) (keyvaluestore.ScoredMembers, error)

func (*Backend) ZScore 

func (b *Backend) ZScore(key string, member interface{}) (*float64, error)

type BackendClient 

type BackendClient interface {
	BatchGetItem(input *dynamodb.BatchGetItemInput) (*dynamodb.BatchGetItemOutput, error)
	BatchWriteItem(input *dynamodb.BatchWriteItemInput) (*dynamodb.BatchWriteItemOutput, error)
	DeleteItem(*dynamodb.DeleteItemInput) (*dynamodb.DeleteItemOutput, error)
	GetItem(*dynamodb.GetItemInput) (*dynamodb.GetItemOutput, error)
	PutItem(*dynamodb.PutItemInput) (*dynamodb.PutItemOutput, error)
	Query(*dynamodb.QueryInput) (*dynamodb.QueryOutput, error)
	UpdateItem(*dynamodb.UpdateItemInput) (*dynamodb.UpdateItemOutput, error)

	TransactWriteItems(*dynamodb.TransactWriteItemsInput) (*dynamodb.TransactWriteItemsOutput, TransactWriteErr)
}

type BasicProfiler 

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

func (*BasicProfiler) AddDynamoDBRequestProfile 

func (p *BasicProfiler) AddDynamoDBRequestProfile(operationName string, duration time.Duration)

func (*BasicProfiler) ConsumeDynamoDBReadCapacity 

func (p *BasicProfiler) ConsumeDynamoDBReadCapacity(capacity float64)

func (*BasicProfiler) ConsumeDynamoDBWriteCapacity 

func (p *BasicProfiler) ConsumeDynamoDBWriteCapacity(capacity float64)

func (*BasicProfiler) DynamoDBReadCapacityConsumed 

func (p *BasicProfiler) DynamoDBReadCapacityConsumed() float64

func (*BasicProfiler) DynamoDBRequestCount 

func (p *BasicProfiler) DynamoDBRequestCount() int

func (*BasicProfiler) DynamoDBRequestDuration 

func (p *BasicProfiler) DynamoDBRequestDuration() time.Duration

func (*BasicProfiler) DynamoDBWriteCapacityConsumed 

func (p *BasicProfiler) DynamoDBWriteCapacityConsumed() float64

type BatchOperation 

type BatchOperation struct {
	*keyvaluestore.FallbackBatchOperation
	Backend *Backend
	// contains filtered or unexported fields
}

func (*BatchOperation) Exec 

func (op *BatchOperation) Exec() error

func (*BatchOperation) Get 

func (op *BatchOperation) Get(key string) keyvaluestore.GetResult

func (*BatchOperation) SMembers 

func (op *BatchOperation) SMembers(key string) keyvaluestore.SMembersResult

func (*BatchOperation) Set 

func (op *BatchOperation) Set(key string, value interface{}) keyvaluestore.ErrorResult

func (*BatchOperation) ZAdd 

func (op *BatchOperation) ZAdd(key string, member interface{}, score float64) keyvaluestore.ErrorResult

type DaxBackendClient 

type DaxBackendClient struct {
	*dax.Dax
}

func (*DaxBackendClient) TransactWriteItems 

func (c *DaxBackendClient) TransactWriteItems(input *dynamodb.TransactWriteItemsInput) (*dynamodb.TransactWriteItemsOutput, TransactWriteErr)

type Profiler 

type Profiler interface {
	ConsumeDynamoDBReadCapacity(capacity float64)
	ConsumeDynamoDBWriteCapacity(capacity float64)
	AddDynamoDBRequestProfile(operationName string, duration time.Duration)
}

type ProfilingBackendClient 

type ProfilingBackendClient struct {
	Client   BackendClient
	Profiler Profiler
}

func (*ProfilingBackendClient) BatchGetItem 

func (c *ProfilingBackendClient) BatchGetItem(input *dynamodb.BatchGetItemInput) (*dynamodb.BatchGetItemOutput, error)

func (*ProfilingBackendClient) BatchWriteItem 

func (c *ProfilingBackendClient) BatchWriteItem(input *dynamodb.BatchWriteItemInput) (*dynamodb.BatchWriteItemOutput, error)

func (*ProfilingBackendClient) DeleteItem 

func (c *ProfilingBackendClient) DeleteItem(input *dynamodb.DeleteItemInput) (*dynamodb.DeleteItemOutput, error)

func (*ProfilingBackendClient) GetItem 

func (c *ProfilingBackendClient) GetItem(input *dynamodb.GetItemInput) (*dynamodb.GetItemOutput, error)

func (*ProfilingBackendClient) PutItem 

func (c *ProfilingBackendClient) PutItem(input *dynamodb.PutItemInput) (*dynamodb.PutItemOutput, error)

func (*ProfilingBackendClient) Query 

func (c *ProfilingBackendClient) Query(input *dynamodb.QueryInput) (*dynamodb.QueryOutput, error)

func (*ProfilingBackendClient) TransactWriteItems 

func (c *ProfilingBackendClient) TransactWriteItems(input *dynamodb.TransactWriteItemsInput) (*dynamodb.TransactWriteItemsOutput, TransactWriteErr)

func (*ProfilingBackendClient) UpdateItem 

func (c *ProfilingBackendClient) UpdateItem(input *dynamodb.UpdateItemInput) (*dynamodb.UpdateItemOutput, error)

type TransactWriteErr 

type TransactWriteErr interface {
	awserr.RequestFailure
	CancellationReasons() []awserr.Error
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.