Function newClient

redimo_test.go:31–77

(t *testing.T)

}

func newClient(t *testing.T) Client {
	t.Parallel()

	tableName := uuid.New().String()
	indexName := "idx"
	partitionKey := "pk"
	sortKey := "sk"
	sortKeyNum := "skN"
	dynamoService := dynamodb.New(newConfig(t))
	_, err := dynamoService.CreateTableRequest(&dynamodb.CreateTableInput{
		AttributeDefinitions: []dynamodb.AttributeDefinition{
			{AttributeName: aws.String(partitionKey), AttributeType: "S"},
			{AttributeName: aws.String(sortKey), AttributeType: "S"},
			{AttributeName: aws.String(sortKeyNum), AttributeType: "N"},
		},
		BillingMode:            "",
		GlobalSecondaryIndexes: nil,
		KeySchema: []dynamodb.KeySchemaElement{
			{AttributeName: aws.String(partitionKey), KeyType: dynamodb.KeyTypeHash},
			{AttributeName: aws.String(sortKey), KeyType: dynamodb.KeyTypeRange},
		},
		LocalSecondaryIndexes: []dynamodb.LocalSecondaryIndex{
			{
				IndexName: aws.String(indexName),
				KeySchema: []dynamodb.KeySchemaElement{
					{AttributeName: aws.String(partitionKey), KeyType: dynamodb.KeyTypeHash},
					{AttributeName: aws.String(sortKeyNum), KeyType: dynamodb.KeyTypeRange},
				},
				Projection: &dynamodb.Projection{
					NonKeyAttributes: nil,
					ProjectionType:   dynamodb.ProjectionTypeKeysOnly,
				},
			},
		},
		ProvisionedThroughput: &dynamodb.ProvisionedThroughput{
			ReadCapacityUnits:  aws.Int64(1),
			WriteCapacityUnits: aws.Int64(1),
		},
		SSESpecification:    nil,
		StreamSpecification: nil,
		TableName:           aws.String(tableName),
		Tags:                nil,
	}).Send(context.TODO())
	assert.NoError(t, err)

	return NewClient(dynamoService).Table(tableName, indexName).Attributes(partitionKey, sortKey, sortKeyNum)
}

func newConfig(t *testing.T) aws.Config {
	cfgs := external.Configs{}