Skip to content

Commit

Permalink
trying Diagram 2 with ContainerInternal instead of ContainerInlineCore
Browse files Browse the repository at this point in the history
  • Loading branch information
philipthomas-MSFT committed Sep 19, 2024
1 parent 35acb5f commit 1b17ab7
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 30 deletions.
11 changes: 3 additions & 8 deletions Microsoft.Azure.Cosmos/src/Resource/Container/Container.cs
Original file line number Diff line number Diff line change
Expand Up @@ -1755,7 +1755,7 @@ public abstract Task<IEnumerable<string>> GetPartitionKeyRangesAsync(
public abstract ChangeFeedProcessorBuilder GetChangeFeedProcessorBuilderWithAllVersionsAndDeletes<T>(
string processorName,
ChangeFeedHandler<ChangeFeedItem<T>> onChangesDelegate);
#endif

/// <summary>
/// Determines whether the given child feed range is a subset of the specified parent feed range.
/// </summary>
Expand All @@ -1781,18 +1781,13 @@ public abstract ChangeFeedProcessorBuilder GetChangeFeedProcessorBuilderWithAllV
/// </code>
/// </example>
/// <returns>True if the child feed range is a subset of the parent feed range; otherwise, false.</returns>
#if PREVIEW
public
#else
internal
#endif

virtual Task<bool> IsFeedRangePartOfAsync(
public virtual Task<bool> IsFeedRangePartOfAsync(
Cosmos.FeedRange parentFeedRange,
Cosmos.FeedRange childFeedRange,
CancellationToken cancellationToken = default)
{
throw new NotImplementedException();
}
#endif
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -1257,12 +1257,7 @@ private ChangeFeedProcessorBuilder GetChangeFeedProcessorBuilderPrivate(
applyBuilderConfiguration: changeFeedProcessor.ApplyBuildConfiguration).WithChangeFeedMode(mode);
}

#if PREVIEW
public
#else
internal
#endif
override async Task<bool> IsFeedRangePartOfAsync(
public override async Task<bool> IsFeedRangePartOfAsync(
FeedRange parentFeedRange,
FeedRange childFeedRange,
CancellationToken cancellationToken = default)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -674,21 +674,5 @@ public override Task<ResponseMessage> DeleteAllItemsByPartitionKeyStreamAsync(
task: (trace) => base.DeleteAllItemsByPartitionKeyStreamAsync(partitionKey, trace, requestOptions, cancellationToken),
openTelemetry: new (OpenTelemetryConstants.Operations.DeleteAllItemsByPartitionKey, (response) => new OpenTelemetryResponse(response)));
}

#if PREVIEW
public
#else
internal
#endif
override Task<bool> IsFeedRangePartOfAsync(
Cosmos.FeedRange parentFeedRange,
Cosmos.FeedRange childFeedRange,
CancellationToken cancellationToken = default)
{
return base.IsFeedRangePartOfAsync(
parentFeedRange,
childFeedRange,
cancellationToken);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -151,6 +151,11 @@ public abstract Task<IEnumerable<string>> GetPartitionKeyRangesAsync(
public abstract ChangeFeedProcessorBuilder GetChangeFeedProcessorBuilderWithAllVersionsAndDeletes<T>(
string processorName,
ChangeFeedHandler<ChangeFeedItem<T>> onChangesDelegate);

public abstract Task<bool> IsFeedRangePartOfAsync(
Cosmos.FeedRange parentFeedRange,
Cosmos.FeedRange childFeedRange,
CancellationToken cancellationToken = default);
#endif

public abstract class TryExecuteQueryResult
Expand Down

0 comments on commit 1b17ab7

Please sign in to comment.