Skip to content

Commit

Permalink
address comments 1
Browse files Browse the repository at this point in the history
  • Loading branch information
Realmonia committed Aug 31, 2023
1 parent cc0437a commit 3c6b9e6
Show file tree
Hide file tree
Showing 5 changed files with 7 additions and 7 deletions.
2 changes: 1 addition & 1 deletion agent/data/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -135,7 +135,7 @@ func setup(dataDir string) (*client, error) {
})

// create transformer
transformer := modeltransformer.NewTransFormer()
transformer := modeltransformer.NewTransformer()

// registering task transformation functions
transformationfunctions.RegisterTaskTransformationFunctions(transformer)
Expand Down
2 changes: 1 addition & 1 deletion agent/data/client_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ func newTestClient(t *testing.T) Client {
testDir := t.TempDir()

testDB, err := bolt.Open(filepath.Join(testDir, dbName), dbMode, nil)
transformer := modeltransformer.NewTransFormer()
transformer := modeltransformer.NewTransformer()
require.NoError(t, err)
require.NoError(t, testDB.Update(func(tx *bolt.Tx) error {
for _, b := range buckets {
Expand Down
2 changes: 1 addition & 1 deletion agent/data/transformationfunctions/tasktf_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ const (
)

func TestRegisterTaskTransformationFunctions(t *testing.T) {
transformer := modeltransformer.NewTransFormer()
transformer := modeltransformer.NewTransformer()
RegisterTaskTransformationFunctions(transformer)
assert.Equal(t, expectedTaskTransformationChainLength, transformer.GetNumberOfTransformationFunctions("Task"))
}
4 changes: 2 additions & 2 deletions ecs-agent/modeltransformer/transformer.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ type TransformFunc struct {
function interface{}
}

func NewTransFormer() *Transformer {
func NewTransformer() *Transformer {
t := &Transformer{}
return t
}
Expand All @@ -56,7 +56,7 @@ func (t *Transformer) GetNumberOfTransformationFunctions(modelType string) int {
}
}

// TransformTask executes the transformation functions when version associated with model in boltdb is below the
// TransformTask executes the transformation functions when version associated with model in boltdb is below the threshold
func (t *Transformer) TransformTask(version string, data []byte) ([]byte, error) {
var err error
// execute transformation functions sequentially and skip those not applicable
Expand Down
4 changes: 2 additions & 2 deletions ecs-agent/modeltransformer/transformer_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -131,7 +131,7 @@ func TestAddTaskTransformationFunctionsAndTransformTask(t *testing.T) {
TestFieldTaskVCpu: 1,
})
dataIn, _ := json.Marshal(&tc.dataIn)
transformer := NewTransFormer()
transformer := NewTransformer()
transformer.AddTaskTransformationFunctions(firstThresholdVersion, testTransformationFunction1100)
transformer.AddTaskTransformationFunctions(secondThresholdVersion, testTransformationFunction1200)
dataOut, err := transformer.TransformTask(tc.boltDbMetadataVersion, dataIn)
Expand Down Expand Up @@ -170,7 +170,7 @@ func TestCheckIsUpgrade(t *testing.T) {

for _, tc := range testCases {
t.Run(tc.name, func(t *testing.T) {
transformer := NewTransFormer()
transformer := NewTransformer()
assert.Equal(t, tc.expect, transformer.IsUpgrade(tc.runningAgentVersion, tc.persistedAgentVersion))
})
}
Expand Down

0 comments on commit 3c6b9e6

Please sign in to comment.