@@ -124,6 +124,28 @@ message StatusByChangeIDResponse {
124124 repeated RequestSummary requests = 1 ;
125125}
126126
127+ // ListRequest defines one bounded queue receipt-history query.
128+ message ListRequest {
129+ // Exact queue to query.
130+ string queue = 1 ;
131+ // Inclusive lower receipt-time bound in Unix milliseconds.
132+ int64 received_at_or_after_ms = 2 ;
133+ // Exclusive upper receipt-time bound in Unix milliseconds.
134+ int64 received_before_ms = 3 ;
135+ // Maximum results to return. Zero selects the server default; values above the server maximum are invalid.
136+ int32 page_size = 4 ;
137+ // Opaque continuation token from a previous response. Empty selects the first page.
138+ string page_token = 5 ;
139+ }
140+
141+ // ListResponse defines one page of queue receipt history.
142+ message ListResponse {
143+ // Requests ordered by receipt time descending, then sqid descending.
144+ repeated RequestSummary requests = 1 ;
145+ // Opaque continuation token. Empty when this is the last page.
146+ string next_page_token = 2 ;
147+ }
148+
127149// ***************
128150// Error messages, returned as `google.rpc.Status` messages.
129151// ***************
@@ -184,4 +206,7 @@ service SubmitQueueGateway {
184206 // StatusByChangeID returns current materialized statuses for an exact pinned change URI.
185207 rpc StatusByChangeID (StatusByChangeIDRequest ) returns (StatusByChangeIDResponse ) {}
186208
209+ // List returns requests received for one queue during a bounded receipt-time range.
210+ rpc List (ListRequest ) returns (ListResponse ) {}
211+
187212}
0 commit comments