fix enum value (#325)

Author: noamcohen97

azkustoingest/managed_test.go

@@ -404,7 +404,7 @@ func TestManaged(t *testing.T) {
 			} else {
 				assert.NoError(t, err)
 				if test.expectedStatus == "" {
-					test.expectedStatus = "Success"
+					test.expectedStatus = Succeeded
 				}
 				assert.Equal(t, result.record.Status, test.expectedStatus)
 			}
@@ -419,7 +419,7 @@ func TestManaged(t *testing.T) {
 			} else {
 				assert.NoError(t, err)
 				if test.expectedStatus == "" {
-					test.expectedStatus = "Success"
+					test.expectedStatus = Succeeded
 				}
 				assert.Equal(t, result.record.Status, test.expectedStatus)
 			}

azkustoingest/streaming.go

@@ -177,7 +177,7 @@ func streamImpl(c streamIngestor, ctx context.Context, payload io.Reader, props
 
 	result := newResult()
 	result.putProps(props)
-	result.record.Status = "Success"
+	result.record.Status = Succeeded
 
 	return result, nil
 }

azkustoingest/streaming_test.go

@@ -207,7 +207,7 @@ func TestStreaming(t *testing.T) {
 				assert.Nil(t, result)
 			} else {
 				assert.NoError(t, err)
-				assert.Equal(t, result.record.Status, StatusCode("Success"))
+				assert.Equal(t, result.record.Status, Succeeded)
 			}
 
 			result, err = streaming.FromReader(ctx, bytes.NewReader(internalData), test.options...)
@@ -216,7 +216,7 @@ func TestStreaming(t *testing.T) {
 				assert.Nil(t, result)
 			} else {
 				assert.NoError(t, err)
-				assert.Equal(t, result.record.Status, StatusCode("Success"))
+				assert.Equal(t, result.record.Status, Succeeded)
 			}
 
 		})