Jv/kinesis fix flush strategy naming (#6791)

* Expose library version in foundation, use it in kinesis user agent

* Fix flush strategy naming

* Apply autoformat

* Apply autoformat

Author: jvh-aws

packages/kinesis/aws_kinesis_datastreams/example/integration_test/kinesis_integration_test.dart

@@ -36,7 +36,7 @@ void main() {
       credentialsProvider: credentialsProvider,
       options: const AmplifyKinesisClientOptions(
         maxRetries: 3,
-        flushStrategy: KinesisDataStreamsNone(),
+        flushStrategy: FlushNone(),
       ),
     );
   });
@@ -150,7 +150,7 @@ void main() {
         credentialsProvider: credentialsProvider,
         options: const AmplifyKinesisClientOptions(
           cacheMaxBytes: 100,
-          flushStrategy: KinesisDataStreamsNone(),
+          flushStrategy: FlushNone(),
         ),
       );
 
@@ -237,7 +237,7 @@ void main() {
           region: testRegion,
           credentialsProvider: badCredentials,
           options: const AmplifyKinesisClientOptions(
-            flushStrategy: KinesisDataStreamsNone(),
+            flushStrategy: FlushNone(),
           ),
         );
 
@@ -307,7 +307,7 @@ void main() {
         credentialsProvider: credentialsProvider,
         options: const AmplifyKinesisClientOptions(
           maxRetries: maxRetries,
-          flushStrategy: KinesisDataStreamsNone(),
+          flushStrategy: FlushNone(),
         ),
       );
 
@@ -460,9 +460,7 @@ void main() {
         region: testRegion,
         credentialsProvider: credentialsProvider,
         options: const AmplifyKinesisClientOptions(
-          flushStrategy: KinesisDataStreamsInterval(
-            interval: Duration(seconds: 3),
-          ),
+          flushStrategy: FlushInterval(interval: Duration(seconds: 3)),
         ),
       );
       // Note: no explicit enable() call — scheduler should auto-start
@@ -492,9 +490,7 @@ void main() {
         region: testRegion,
         credentialsProvider: credentialsProvider,
         options: const AmplifyKinesisClientOptions(
-          flushStrategy: KinesisDataStreamsInterval(
-            interval: Duration(seconds: 5),
-          ),
+          flushStrategy: FlushInterval(interval: Duration(seconds: 5)),
         ),
       );
 
@@ -562,7 +558,7 @@ void main() {
         credentialsProvider: credentialsProvider,
         options: const AmplifyKinesisClientOptions(
           cacheMaxBytes: 12 * 1024 * 1024, // 12 MB
-          flushStrategy: KinesisDataStreamsNone(),
+          flushStrategy: FlushNone(),
         ),
       );
 
@@ -624,9 +620,7 @@ void main() {
       final newClient = await AmplifyKinesisClient.create(
         region: testRegion,
         credentialsProvider: credentialsProvider,
-        options: const AmplifyKinesisClientOptions(
-          flushStrategy: KinesisDataStreamsNone(),
-        ),
+        options: const AmplifyKinesisClientOptions(flushStrategy: FlushNone()),
       );
 
       try {

packages/kinesis/aws_kinesis_datastreams_dart/lib/src/amplify_kinesis_client.dart

@@ -7,7 +7,8 @@ import 'dart:typed_data';
 import 'package:amplify_foundation_dart/amplify_foundation_dart.dart'
     hide packageVersion;
 import 'package:amplify_foundation_dart/amplify_foundation_dart.dart'
-    as foundation show packageVersion;
+    as foundation
+    show packageVersion;
 import 'package:amplify_foundation_dart_bridge/amplify_foundation_dart_bridge.dart';
 import 'package:aws_kinesis_datastreams_dart/src/amplify_kinesis_client_options.dart';
 import 'package:aws_kinesis_datastreams_dart/src/exception/amplify_kinesis_exception.dart';
@@ -131,11 +132,11 @@ class AmplifyKinesisClient {
     );
 
     final scheduler = switch (opts.flushStrategy) {
-      KinesisDataStreamsInterval(:final interval) => AutoFlushScheduler(
+      FlushInterval(:final interval) => AutoFlushScheduler(
         interval: interval,
         client: recordClient,
       )..start(),
-      KinesisDataStreamsNone() => null,
+      FlushNone() => null,
     };
 
     return AmplifyKinesisClient._(

packages/kinesis/aws_kinesis_datastreams_dart/lib/src/amplify_kinesis_client_options.dart

@@ -13,7 +13,7 @@ final class AmplifyKinesisClientOptions {
   const AmplifyKinesisClientOptions({
     this.cacheMaxBytes = 5 * 1024 * 1024,
     this.maxRetries = 5,
-    this.flushStrategy = const KinesisDataStreamsInterval(),
+    this.flushStrategy = const FlushInterval(),
   });
 
   /// Maximum size of the local cache in bytes.
@@ -28,6 +28,6 @@ final class AmplifyKinesisClientOptions {
 
   /// Strategy for automatic flushing of cached records.
   ///
-  /// Defaults to [KinesisDataStreamsInterval] with a 30-second interval.
-  final KinesisDataStreamsFlushStrategy flushStrategy;
+  /// Defaults to [FlushInterval] with a 30-second interval.
+  final FlushStrategy flushStrategy;
 }

packages/kinesis/aws_kinesis_datastreams_dart/lib/src/flush_strategy/flush_strategy.dart

@@ -5,22 +5,20 @@
 /// Determines when automatic flushing of cached records occurs.
 ///
 /// Available strategies:
-/// - [KinesisDataStreamsInterval]: Flush at a fixed time interval (default)
-/// - [KinesisDataStreamsNone]: Disable automatic flushing entirely
+/// - [FlushInterval]: Flush at a fixed time interval (default)
+/// - [FlushNone]: Disable automatic flushing entirely
 /// {@endtemplate}
-sealed class KinesisDataStreamsFlushStrategy {
+sealed class FlushStrategy {
   /// {@macro aws_kinesis_datastreams.flush_strategy}
-  const KinesisDataStreamsFlushStrategy();
+  const FlushStrategy();
 }
 
 /// {@template aws_kinesis_datastreams.interval_flush_strategy}
 /// A flush strategy that triggers automatic flushes at a fixed interval.
 /// {@endtemplate}
-final class KinesisDataStreamsInterval extends KinesisDataStreamsFlushStrategy {
+final class FlushInterval extends FlushStrategy {
   /// {@macro aws_kinesis_datastreams.interval_flush_strategy}
-  const KinesisDataStreamsInterval({
-    this.interval = const Duration(seconds: 30),
-  });
+  const FlushInterval({this.interval = const Duration(seconds: 30)});
 
   /// The interval between automatic flush operations.
   final Duration interval;
@@ -29,7 +27,7 @@ final class KinesisDataStreamsInterval extends KinesisDataStreamsFlushStrategy {
 /// {@template aws_kinesis_datastreams.none_flush_strategy}
 /// A flush strategy that disables automatic flushing.
 /// {@endtemplate}
-final class KinesisDataStreamsNone extends KinesisDataStreamsFlushStrategy {
+final class FlushNone extends FlushStrategy {
   /// {@macro aws_kinesis_datastreams.none_flush_strategy}
-  const KinesisDataStreamsNone();
+  const FlushNone();
 }

packages/kinesis/aws_kinesis_datastreams_dart/test/kinesis_data_streams_test.dart

@@ -57,16 +57,14 @@ void main() {
         expect(client.region, equals('us-east-1'));
         expect(client.options.cacheMaxBytes, equals(5 * 1024 * 1024));
         expect(client.options.maxRetries, equals(5));
-        expect(client.options.flushStrategy, isA<KinesisDataStreamsInterval>());
+        expect(client.options.flushStrategy, isA<FlushInterval>());
       });
 
       test('initializes with custom options', () {
         const customOptions = AmplifyKinesisClientOptions(
           cacheMaxBytes: 10 * 1024 * 1024,
           maxRetries: 10,
-          flushStrategy: KinesisDataStreamsInterval(
-            interval: Duration(minutes: 1),
-          ),
+          flushStrategy: FlushInterval(interval: Duration(minutes: 1)),
         );
 
         final client = AmplifyKinesisClient.withRecordClient(
@@ -79,22 +77,22 @@ void main() {
         expect(client.options.cacheMaxBytes, equals(10 * 1024 * 1024));
         expect(client.options.maxRetries, equals(10));
         expect(
-          (client.options.flushStrategy as KinesisDataStreamsInterval).interval,
+          (client.options.flushStrategy as FlushInterval).interval,
           equals(const Duration(minutes: 1)),
         );
       });
 
       test('supports None flush strategy', () {
         const customOptions = AmplifyKinesisClientOptions(
-          flushStrategy: KinesisDataStreamsNone(),
+          flushStrategy: FlushNone(),
         );
 
         final client = AmplifyKinesisClient.withRecordClient(
           recordClient: mockRecordClient,
           options: customOptions,
         );
 
-        expect(client.options.flushStrategy, isA<KinesisDataStreamsNone>());
+        expect(client.options.flushStrategy, isA<FlushNone>());
       });
     });