Skip to content

Commit f375ccf

Browse files
author
Matthew Barnes
committed
database: Remove unused ListAllOperationDocs method
1 parent 501bdc9 commit f375ccf

File tree

2 files changed

+0
-20
lines changed

2 files changed

+0
-20
lines changed

internal/database/database.go

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,6 @@ type DBClient interface {
8080
CreateOperationDoc(ctx context.Context, doc *OperationDocument) error
8181
UpdateOperationDoc(ctx context.Context, operationID string, callback func(*OperationDocument) bool) (bool, error)
8282
ListOperationDocs(subscriptionID string) DBClientIterator[OperationDocument]
83-
ListAllOperationDocs() DBClientIterator[OperationDocument]
8483

8584
// GetSubscriptionDoc retrieves a SubscriptionDocument from the database given the subscriptionID.
8685
// ErrNotFound is returned if an associated SubscriptionDocument cannot be found.
@@ -422,11 +421,6 @@ func (d *CosmosDBClient) ListOperationDocs(subscriptionID string) DBClientIterat
422421
return newQueryItemsIterator[OperationDocument](pager)
423422
}
424423

425-
func (d *CosmosDBClient) ListAllOperationDocs() DBClientIterator[OperationDocument] {
426-
pk := azcosmos.NewPartitionKeyString(operationsPartitionKey)
427-
return newQueryItemsIterator[OperationDocument](d.operations.NewQueryItemsPager("SELECT * FROM c", pk, nil))
428-
}
429-
430424
// GetSubscriptionDoc retreives a subscription document from async DB using the subscription ID
431425
func (d *CosmosDBClient) GetSubscriptionDoc(ctx context.Context, subscriptionID string) (*SubscriptionDocument, error) {
432426
// Make sure lookup keys are lowercase.

internal/mocks/dbclient.go

Lines changed: 0 additions & 14 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)