Subscription Deprecated
SubscriptionService.UpdateSubscription is deprecated. Set filters on the StartStream request instead; it applies for the life of that stream with no separate call and no ordering to get right. This RPC and subscription.proto will be removed in a future release. Migration: move the same filter JSON onto StartStreamRequest.filters — see Filtering.
The subscription.proto contract defines the UpdateSubscription RPC, which is deprecated in favour of setting filters directly on AircraftStreamingService.StartStream's request. UpdateSubscription still works for backward compatibility: it changes the filter on the subscription's open stream at the gateway's next revalidation pass, and does not survive a reconnect — a new connection is filtered by its own filters value only. See Filtering for the full contract, including the deprecated UpdateSubscription behaviour and how to migrate off it.
syntax = "proto3";
package jetnet.streaming;
message Filter {
FilterGroup root_group = 1;
}
message FilterGroup {
enum LogicalOperator {
LOGICAL_OPERATOR_UNSPECIFIED = 0;
AND = 1;
OR = 2;
}
LogicalOperator op = 1;
repeated FilterCondition conditions = 2;
repeated FilterGroup groups = 3;
}
message FilterCondition {
string field = 1;
string op = 2;
string value = 3;
}
message UpdateSubscriptionRequest {
string subscription_id = 1;
string name = 2;
Filter filters = 3;
}
message Subscription {
string id = 1;
string client_id = 2;
string name = 3;
Filter filters = 4;
string topic_name = 5;
}
service SubscriptionService {
// Deprecated: set `filters` on StartStreamRequest instead.
rpc UpdateSubscription(UpdateSubscriptionRequest) returns (Subscription);
}
Related
- The primary way to filter a stream, plus the deprecated
UpdateSubscriptionpath and how to migrate off it — see Filtering.