dynamodb

Documentation

Index

• func CreatePatch(in *dynamodb.TableDescription, target *v1alpha1.DynamoTableParameters) (*v1alpha1.DynamoTableParameters, error)
• func GenerateCreateTableInput(name string, p *v1alpha1.DynamoTableParameters) *dynamodb.CreateTableInput
• func GenerateObservation(t dynamodb.TableDescription) v1alpha1.DynamoTableObservation
• func GenerateUpdateTableInput(name string, p *v1alpha1.DynamoTableParameters) *dynamodb.UpdateTableInput
• func IsErrorNotFound(err error) bool
• func IsUpToDate(p v1alpha1.DynamoTableParameters, t dynamodb.TableDescription) (bool, error)
• func LateInitialize(in *v1alpha1.DynamoTableParameters, t *dynamodb.TableDescription)
• type Client
  • func NewClient(ctx context.Context, credentials []byte, region string, ...) (Client, error)

Functions

func CreatePatch

func CreatePatch(in *dynamodb.TableDescription, target *v1alpha1.DynamoTableParameters) (*v1alpha1.DynamoTableParameters, error)

CreatePatch creates a *v1alpha1.DynamoTableParameters that has only the changed values between the target *v1alpha1.DynamoTableParameters and the current *dynamodb.TableDescription

func GenerateCreateTableInput

func GenerateCreateTableInput(name string, p *v1alpha1.DynamoTableParameters) *dynamodb.CreateTableInput

GenerateCreateTableInput from DynamoTaleSpec

func GenerateObservation

func GenerateObservation(t dynamodb.TableDescription) v1alpha1.DynamoTableObservation

GenerateObservation is used to produce v1alpha1.DynamoTableObservation from dynamodb.TableDescription.

func GenerateUpdateTableInput

func GenerateUpdateTableInput(name string, p *v1alpha1.DynamoTableParameters) *dynamodb.UpdateTableInput

GenerateUpdateTableInput from DynamoTaleSpec

func IsErrorNotFound

func IsErrorNotFound(err error) bool

IsErrorNotFound helper function to test for ErrCodeTableNotFoundException error

func IsUpToDate

func IsUpToDate(p v1alpha1.DynamoTableParameters, t dynamodb.TableDescription) (bool, error)

IsUpToDate checks whether there is a change in any of the modifiable fields.

func LateInitialize

func LateInitialize(in *v1alpha1.DynamoTableParameters, t *dynamodb.TableDescription)

LateInitialize fills the empty fields in *v1alpha1.DynamoTableParameters with the values seen in dynamodb.TableDescription.

Types

type Client

type Client interface {
	DescribeTableRequest(input *dynamodb.DescribeTableInput) dynamodb.DescribeTableRequest
	CreateTableRequest(input *dynamodb.CreateTableInput) dynamodb.CreateTableRequest
	DeleteTableRequest(input *dynamodb.DeleteTableInput) dynamodb.DeleteTableRequest
	UpdateTableRequest(input *dynamodb.UpdateTableInput) dynamodb.UpdateTableRequest
}

Client defines DyanmoDB client operations

func NewClient

func NewClient(ctx context.Context, credentials []byte, region string, auth awsclients.AuthMethod) (Client, error)

NewClient creates new DynamoDB Client with provided AWS Configurations/Credentials