From cc9db9cd8d9658ebccb90001a25038036fa1abed Mon Sep 17 00:00:00 2001
From: Yuri Shkuro <github@ysh.us>
Date: Sat, 30 Nov 2024 13:47:28 -0500
Subject: [PATCH] rename

Signed-off-by: Yuri Shkuro <github@ysh.us>
---
 plugin/storage/cassandra/schema/schema.go      | 18 +++++++++---------
 plugin/storage/cassandra/schema/schema_test.go |  4 ++--
 2 files changed, 11 insertions(+), 11 deletions(-)

diff --git a/plugin/storage/cassandra/schema/schema.go b/plugin/storage/cassandra/schema/schema.go
index bb1dfdfa03d..25aa172355f 100644
--- a/plugin/storage/cassandra/schema/schema.go
+++ b/plugin/storage/cassandra/schema/schema.go
@@ -31,20 +31,20 @@ type templateParams struct {
 	DependenciesTTLInSeconds int64
 }
 
-type SchemaCreator struct {
+type Creator struct {
 	session cassandra.Session
 	schema  config.Schema
 }
 
 // NewSchemaCreator returns a new SchemaCreator
-func NewSchemaCreator(session cassandra.Session, schema config.Schema) *SchemaCreator {
-	return &SchemaCreator{
+func NewSchemaCreator(session cassandra.Session, schema config.Schema) *Creator {
+	return &Creator{
 		session: session,
 		schema:  schema,
 	}
 }
 
-func (sc *SchemaCreator) constructTemplateParams() templateParams {
+func (sc *Creator) constructTemplateParams() templateParams {
 	return templateParams{
 		Keyspace:                  sc.schema.Keyspace,
 		Replication:               fmt.Sprintf("{'class': 'NetworkTopologyStrategy', 'replication_factor': '%v' }", sc.schema.ReplicationFactor),
@@ -54,7 +54,7 @@ func (sc *SchemaCreator) constructTemplateParams() templateParams {
 	}
 }
 
-func (*SchemaCreator) getQueryFileAsBytes(fileName string, params templateParams) ([]byte, error) {
+func (*Creator) getQueryFileAsBytes(fileName string, params templateParams) ([]byte, error) {
 	tmpl, err := template.ParseFS(schemaFile, fileName)
 	if err != nil {
 		return nil, err
@@ -69,7 +69,7 @@ func (*SchemaCreator) getQueryFileAsBytes(fileName string, params templateParams
 	return result.Bytes(), nil
 }
 
-func (*SchemaCreator) getQueriesFromBytes(queryFile []byte) ([]string, error) {
+func (*Creator) getQueriesFromBytes(queryFile []byte) ([]string, error) {
 	lines := bytes.Split(queryFile, []byte("\n"))
 
 	var extractedLines [][]byte
@@ -110,7 +110,7 @@ func (*SchemaCreator) getQueriesFromBytes(queryFile []byte) ([]string, error) {
 	return queries, nil
 }
 
-func (sc *SchemaCreator) getCassandraQueriesFromQueryStrings(queries []string) []cassandra.Query {
+func (sc *Creator) getCassandraQueriesFromQueryStrings(queries []string) []cassandra.Query {
 	var casQueries []cassandra.Query
 
 	for _, query := range queries {
@@ -120,7 +120,7 @@ func (sc *SchemaCreator) getCassandraQueriesFromQueryStrings(queries []string) [
 	return casQueries
 }
 
-func (sc *SchemaCreator) contructSchemaQueries() ([]cassandra.Query, error) {
+func (sc *Creator) contructSchemaQueries() ([]cassandra.Query, error) {
 	params := sc.constructTemplateParams()
 
 	queryFile, err := sc.getQueryFileAsBytes(`v004-go-tmpl.cql.tmpl`, params)
@@ -138,7 +138,7 @@ func (sc *SchemaCreator) contructSchemaQueries() ([]cassandra.Query, error) {
 	return casQueries, nil
 }
 
-func (sc *SchemaCreator) CreateSchemaIfNotPresent() error {
+func (sc *Creator) CreateSchemaIfNotPresent() error {
 	casQueries, err := sc.contructSchemaQueries()
 	if err != nil {
 		return err
diff --git a/plugin/storage/cassandra/schema/schema_test.go b/plugin/storage/cassandra/schema/schema_test.go
index d6efe20bdfa..39e69b89916 100644
--- a/plugin/storage/cassandra/schema/schema_test.go
+++ b/plugin/storage/cassandra/schema/schema_test.go
@@ -30,7 +30,7 @@ query1-finished;
 `,
 	}
 
-	sc := SchemaCreator{}
+	sc := Creator{}
 	queriesAsBytes := []byte(queriesAsString)
 	queries, err := sc.getQueriesFromBytes(queriesAsBytes)
 	require.NoError(t, err)
@@ -52,7 +52,7 @@ func TestInvalidQueryTemplate(t *testing.T) {
 	query2;
 	query-3 query-3-continue query-3-finished -- missing semicolon
 	`
-	sc := SchemaCreator{}
+	sc := Creator{}
 	queriesAsBytes := []byte(queriesAsString)
 	_, err := sc.getQueriesFromBytes(queriesAsBytes)
 	require.Error(t, err)