Skip to content

Commit

Permalink
FIx formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
akashkulk committed Feb 13, 2024
1 parent 62b9a67 commit 3ab6ca5
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 1 deletion.
Original file line number Diff line number Diff line change
@@ -1,15 +1,22 @@
/*
* Copyright (c) 2023 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.cdk.db;

import io.airbyte.protocol.models.v0.AirbyteAnalyticsTraceMessage;

/**
* Utility class to define constants associated with database source connector analytics events. Make sure to add the analytics event to
* Utility class to define constants associated with database source connector analytics events.
* Make sure to add the analytics event to
* https://www.notion.so/Connector-Analytics-Events-892a79a49852465f8d59a18bd84c36de
*/
public class DbAnalyticsUtils {

public static final String CDC_CURSOR_INVALID_KEY = "db-sources-cdc-cursor-invalid";

public static AirbyteAnalyticsTraceMessage cdcCursorInvalidMessage() {
return new AirbyteAnalyticsTraceMessage().withType(CDC_CURSOR_INVALID_KEY).withValue("1");
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -111,4 +111,5 @@ private static AirbyteMessage makeAirbyteMessageFromTraceMessage(final AirbyteTr
private static AirbyteTraceMessage makeAirbyteTraceMessage(final AirbyteTraceMessage.Type traceMessageType) {
return new AirbyteTraceMessage().withType(traceMessageType).withEmittedAt((double) System.currentTimeMillis());
}

}

0 comments on commit 3ab6ca5

Please sign in to comment.