dynamodb_service

Documentation

Index

• Constants
• func New(provider core.AwsProvider) (document.DocumentService, error)
• func NewWithClient(provider core.AwsProvider, client *dynamodb.DynamoDB) (document.DocumentService, error)
• type DynamoDocService
  • func (s *DynamoDocService) Delete(key *document.Key) error
  • func (s *DynamoDocService) Get(key *document.Key) (*document.Document, error)
  • func (s *DynamoDocService) Query(collection *document.Collection, expressions []document.QueryExpression, ...) (*document.QueryResult, error)
  • func (s *DynamoDocService) QueryStream(collection *document.Collection, expressions []document.QueryExpression, ...) document.DocumentIterator
  • func (s *DynamoDocService) Set(key *document.Key, value map[string]interface{}) error

Constants

const AttribPk = "_pk"

const AttribSk = "_sk"

Functions

func New

func New(provider core.AwsProvider) (document.DocumentService, error)

New - Create a new DynamoDB key value plugin implementation

func NewWithClient

func NewWithClient(provider core.AwsProvider, client *dynamodb.DynamoDB) (document.DocumentService, error)

NewWithClient - Mainly used for testing

Types

type DynamoDocService

type DynamoDocService struct {
	document.UnimplementedDocumentPlugin
	// contains filtered or unexported fields
}

DynamoDocService - AWS DynamoDB AWS Nitric Document service

func (*DynamoDocService) Delete

func (s *DynamoDocService) Delete(key *document.Key) error

func (*DynamoDocService) Get

func (s *DynamoDocService) Get(key *document.Key) (*document.Document, error)

func (*DynamoDocService) Query

func (s *DynamoDocService) Query(collection *document.Collection, expressions []document.QueryExpression, limit int, pagingToken map[string]string) (*document.QueryResult, error)

func (*DynamoDocService) QueryStream

func (s *DynamoDocService) QueryStream(collection *document.Collection, expressions []document.QueryExpression, limit int) document.DocumentIterator

func (*DynamoDocService) Set

func (s *DynamoDocService) Set(key *document.Key, value map[string]interface{}) error