Paket google.cloud.pubsublite.v1

Index

AdminService

Der Dienst, mit dem eine Clientanwendung Themen und Abos verwaltet, z. B. das Erstellen, Auflisten und Löschen von Themen und Abos.

CreateSubscription

rpc CreateSubscription(CreateSubscriptionRequest) returns (Subscription)

Erstellt ein neues Abo.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.
CreateTopic

rpc CreateTopic(CreateTopicRequest) returns (Topic)

Erstellt ein neues Thema.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.
DeleteSubscription

rpc DeleteSubscription(DeleteSubscriptionRequest) returns (Empty)

Löscht das angegebene Abo.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.
DeleteTopic

rpc DeleteTopic(DeleteTopicRequest) returns (Empty)

Löscht das angegebene Thema.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.
GetSubscription

rpc GetSubscription(GetSubscriptionRequest) returns (Subscription)

Gibt die Abo-Konfiguration zurück.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.
GetTopic

rpc GetTopic(GetTopicRequest) returns (Topic)

Gibt die Konfiguration des Themas zurück.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.
GetTopicPartitions

rpc GetTopicPartitions(GetTopicPartitionsRequest) returns (TopicPartitions)

Gibt die Partitionsinformationen für das angeforderte Thema zurück.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.
ListSubscriptions

rpc ListSubscriptions(ListSubscriptionsRequest) returns (ListSubscriptionsResponse)

Gibt die Liste der Abos für das angegebene Projekt zurück.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.
ListTopicSubscriptions

rpc ListTopicSubscriptions(ListTopicSubscriptionsRequest) returns (ListTopicSubscriptionsResponse)

Listet die Abos auf, die mit dem angegebenen Thema verknüpft sind.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.
ListTopics

rpc ListTopics(ListTopicsRequest) returns (ListTopicsResponse)

Gibt die Liste der Themen für das angegebene Projekt zurück.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.
UpdateSubscription

rpc UpdateSubscription(UpdateSubscriptionRequest) returns (Subscription)

Aktualisiert die Attribute des angegebenen Abos.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.
UpdateTopic

rpc UpdateTopic(UpdateTopicRequest) returns (Topic)

Aktualisiert die Attribute des angegebenen Themas.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.

CursorService

Der Dienst, den eine Abonnentenclientanwendung verwendet, um zugesicherte Cursor zu verwalten, während Nachrichten empfangen werden. Ein Cursor stellt den Fortschritt eines Abonnenten innerhalb einer Themenpartition für ein bestimmtes Abo dar.

CommitCursor

rpc CommitCursor(CommitCursorRequest) returns (CommitCursorResponse)

Aktualisiert den Commit-Cursor.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.
ListPartitionCursors

rpc ListPartitionCursors(ListPartitionCursorsRequest) returns (ListPartitionCursorsResponse)

Gibt alle Commit-Cursor-Informationen für ein Abo zurück.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.
StreamingCommitCursor

rpc StreamingCommitCursor(StreamingCommitCursorRequest) returns (StreamingCommitCursorResponse)

Richtet einen Stream mit dem Server für die Verwaltung von Commit-Cursors ein.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.

PublisherService

Der Dienst, den eine Publisher-Client-Anwendung zum Veröffentlichen von Nachrichten zu Themen verwendet. Veröffentlichte Nachrichten werden vom Dienst für die Dauer des für das jeweilige Thema konfigurierten Aufbewahrungsdauer aufbewahrt und werden auf Anfrage über SubscriberService an Abonnentenclients gesendet.

Veröffentlichen

rpc Publish(PublishRequest) returns (PublishResponse)

Richtet einen Stream mit dem Server für die Veröffentlichung von Nachrichten ein. Nachdem der Stream initialisiert wurde, veröffentlicht der Client Nachrichten, indem er Veröffentlichungsanfragen im Stream sendet. Der Server antwortet mit einer PublishResponse für jede vom Client gesendete PublishRequest in der Reihenfolge, in der die Anfragen gesendet wurden. Beachten Sie, dass mehrere PublishRequests gleichzeitig ausgeführt werden können, aber vom Server in der Reihenfolge verarbeitet werden, in der sie vom Client in einem bestimmten Stream gesendet werden.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.

SubscriberService

Der Dienst, den eine Abonnentenclientanwendung zum Empfangen von Nachrichten von Abonnements verwendet.

Abonnieren

rpc Subscribe(SubscribeRequest) returns (SubscribeResponse)

Richtet einen Stream mit dem Server für den Empfang von Nachrichten ein.

Autorisierungsbereiche

Erfordert den folgenden OAuth-Bereich:

  • https://www.googleapis.com/auth/cloud-platform

Weitere Informationen finden Sie unter Authentifizierung.

AttributeValues

Die mit einem Schlüssel eines Attributs verknüpften Werte.

Felder
values[]

bytes

Die Liste der mit einem Schlüssel verknüpften Werte.

CommitCursorRequest

Anfrage für CommitCursor.

Felder
subscription

string

Das Abo, für das der Cursor aktualisiert werden soll.
partition

int64

Die Partition, für die der Cursor aktualisiert werden soll. Partitionen sind null indexiert, daher muss partition im Bereich [0, topic.num_partitions) liegen.
cursor

Cursor

Der neue Wert für den Commit-Cursor.

CommitCursorResponse

Antwort für CommitCursor.

CreateSubscriptionRequest

Anfrage für CreateSubscription.

Felder
parent

string

Erforderlich Der übergeordnete Standort, an dem das Abo erstellt werden soll. Strukturiert wie projects/{project_number}/locations/{location}.
subscription

Subscription

Erforderlich Konfiguration des zu erstellenden Abos. Das Feld name wird ignoriert.
subscription_id

string

Erforderlich Die für das Abo zu verwendende ID, die die letzte Komponente des Abonamens wird.

Dieser Wert ist strukturiert wie: my-sub-name.

CreateTopicRequest

Anfrage für CreateTopic.

Felder
parent

string

Erforderlich Der übergeordnete Speicherort, an dem das Thema erstellt werden soll. Strukturiert wie projects/{project_number}/locations/{location}.
topic

Topic

Erforderlich Konfiguration des zu erstellenden Themas. Das Feld name wird ignoriert.
topic_id

string

Erforderlich Die für das Thema zu verwendende ID, die die letzte Komponente des Themennamens wird.

Dieser Wert ist strukturiert wie: my-topic-name.

Cursor

Ein Cursor, der die Position einer Nachricht innerhalb einer Themenpartition beschreibt.

Felder
offset

int64

Der Offset einer Nachricht innerhalb einer Themenpartition. Muss größer oder gleich 0 sein.

DeleteSubscriptionRequest

Anfrage für DeleteSubscription.

Felder
name

string

Erforderlich Der Name des zu löschenden Abos.

DeleteTopicRequest

Anfrage für DeleteTopic.

Felder
name

string

Erforderlich Der Name des zu löschenden Themas.

FlowControlRequest

Anfrage zum Erteilen von Tokens an den Server, die die Zustellung von Nachrichten anfordert, sobald sie verfügbar sind.

Felder
allowed_messages

int64

Die Anzahl der zu erteilenden Nachrichtentokens. muss größer oder gleich 0 sein.
allowed_bytes

int64

Die Anzahl der zu erteilenden Byte-Tokens. muss größer oder gleich 0 sein.

GetSubscriptionRequest

Anfrage für GetSubscription.

Felder
name

string

Erforderlich Der Name des Abos, dessen Konfiguration zurückgegeben werden soll.

GetTopicPartitionsRequest

Anfrage für GetTopicPartitions.

Felder
name

string

Erforderlich Das Thema, dessen Partitionsinformationen zurückgegeben werden sollen.

GetTopicRequest

Anfrage für GetTopic.

Felder
name

string

Erforderlich Der Name des Themas, dessen Konfiguration zurückgegeben werden soll.

InitialCommitCursorRequest

Die erste Streaming-Anfrage, die über einen neu geöffneten Stream gesendet werden muss. Der Client muss auf die Antwort warten, bevor er weitere Anfragen über den Stream sendet.

Felder
subscription

string

Das Abo, für das Commited-Cursors verwaltet werden sollen.
partition

int64

Die Partition, für die zugesicherte Cursor verwaltet werden sollen. Partitionen sind null indexiert, daher muss partition im Bereich [0, topic.num_partitions) liegen.

InitialCommitCursorResponse

Antwort auf eine InitialCommitCursorRequest.

InitialPublishRequest

Die erste Anfrage, die über einen neu geöffneten Stream gesendet werden muss.

Felder
topic

string

Das Thema, in das Nachrichten geschrieben werden.
partition

int64

Die Partition innerhalb des Themas, in die Nachrichten geschrieben werden. Partitionen sind null indexiert, daher muss partition im Bereich [0, topic.num_partitions) liegen.

InitialPublishResponse

Antwort auf eine InitialPublishRequest.

InitialSubscribeRequest

Die erste Anfrage, die über einen neu geöffneten Stream gesendet werden muss. Der Client muss auf die Antwort warten, bevor er weitere Anfragen über den Stream sendet.

Felder
subscription

string

Das Abo, von dem Nachrichten empfangen werden sollen.
partition

int64

Die Partition, von der Nachrichten empfangen werden sollen. Partitionen sind null indexiert, daher muss partition im Bereich [0, topic.num_partitions) liegen.

InitialSubscribeResponse

Antwort auf eine InitialSubscribeRequest.

Felder
cursor

Cursor

Der Cursor, ab dessen Position der Abonnent Nachrichten empfängt, sobald Ablaufsteuerungstokens verfügbar sind.

ListPartitionCursorsRequest

Anfrage für ListPartitionCursors.

Felder
parent

string

Erforderlich Das Abo, für das Cursors abgerufen werden sollen. Strukturiert wie projects/{project_number}/locations/{location}/subscriptions/{subscription_id}.
page_size

int32

Die maximale Anzahl der zurückzugebenden Cursor. Der Dienst gibt möglicherweise weniger als diesen Wert zurück. Wenn nicht festgelegt oder null, werden alle Cursor für das übergeordnete Element zurückgegeben.
page_token

string

Ein Seitentoken, das von einem vorherigen ListPartitionCursors-Aufruf empfangen wurde. Geben Sie diese an, um die nachfolgende Seite abzurufen.

Beim Paginieren müssen alle anderen für ListPartitionCursors bereitgestellten Parameter mit dem Aufruf übereinstimmen, der das Seitentoken bereitgestellt hat.

ListPartitionCursorsResponse

Antwort für ListPartitionCursors

Felder
partition_cursors[]

PartitionCursor

Die Partitions-Cursors dieser Anfrage.
next_page_token

string

Ein Token, das als page_token gesendet werden kann, um die nächste Seite abzurufen. Wenn dieses Feld weggelassen wird, gibt es keine nachfolgenden Seiten.

ListSubscriptionsRequest

Anfrage für ListSubscriptions.

Felder
parent

string

Erforderlich Das übergeordnete Element, dessen Abos aufgelistet werden sollen. Strukturiert wie projects/{project_number}/locations/{location}.
page_size

int32

Die maximale Anzahl von Abos, die zurückgegeben werden sollen. Der Dienst gibt möglicherweise weniger als diesen Wert zurück. Wenn nicht festgelegt oder null, werden alle Abos für das übergeordnete Element zurückgegeben.
page_token

string

Ein Seitentoken, das von einem vorherigen ListSubscriptions-Aufruf empfangen wurde. Geben Sie diese an, um die nachfolgende Seite abzurufen.

Beim Paginieren müssen alle anderen für ListSubscriptions bereitgestellten Parameter mit dem Aufruf übereinstimmen, der das Seitentoken bereitgestellt hat.

ListSubscriptionsResponse

Antwort für ListSubscriptions.

Felder
subscriptions[]

Subscription

Die Liste der Abos im angeforderten übergeordneten Element. Die Reihenfolge der Abos ist nicht angegeben.
next_page_token

string

Ein Token, das als page_token gesendet werden kann, um die nächste Ergebnisseite abzurufen. Wenn dieses Feld weggelassen wird, gibt es keine weiteren Ergebnisse.

ListTopicSubscriptionsRequest

Anfrage für ListTopicSubscriptions.

Felder
name

string

Erforderlich Der Name des Themas, dessen Abos aufgelistet werden sollen.
page_size

int32

Die maximale Anzahl von Abos, die zurückgegeben werden sollen. Der Dienst gibt möglicherweise weniger als diesen Wert zurück. Wenn nicht festgelegt oder null, werden alle Abos für das angegebene Thema zurückgegeben.
page_token

string

Ein Seitentoken, das von einem vorherigen ListTopicSubscriptions-Aufruf empfangen wurde. Geben Sie diese an, um die nachfolgende Seite abzurufen.

Beim Paginieren müssen alle anderen für ListTopicSubscriptions bereitgestellten Parameter mit dem Aufruf übereinstimmen, der das Seitentoken bereitgestellt hat.

ListTopicSubscriptionsResponse

Antwort für ListTopicSubscriptions.

Felder
subscriptions[]

string

Die Namen der mit dem Thema verknüpften Abos. Die Reihenfolge der Abos ist nicht angegeben.
next_page_token

string

Ein Token, das als page_token gesendet werden kann, um die nächste Ergebnisseite abzurufen. Wenn dieses Feld weggelassen wird, gibt es keine weiteren Ergebnisse.

ListTopicsRequest

Anfrage für ListTopics.

Felder
parent

string

Erforderlich Das übergeordnete Element, dessen Themen aufgelistet werden sollen. Strukturiert wie projects/{project_number}/locations/{location}.
page_size

int32

Die maximale Anzahl der zurückzugebenden Themen. Der Dienst gibt möglicherweise weniger als diesen Wert zurück. Wenn nicht festgelegt oder null, werden alle Themen für das übergeordnete Element zurückgegeben.
page_token

string

Ein Seitentoken, das von einem vorherigen ListTopics-Aufruf empfangen wurde. Geben Sie diese an, um die nachfolgende Seite abzurufen.

Beim Paginieren müssen alle anderen für ListTopics bereitgestellten Parameter mit dem Aufruf übereinstimmen, der das Seitentoken bereitgestellt hat.

ListTopicsResponse

Antwort für ListTopics.

Felder
topics[]

Topic

Die Liste der Themen im angeforderten übergeordneten Element. Die Reihenfolge der Themen ist nicht angegeben.
next_page_token

string

Ein Token, das als page_token gesendet werden kann, um die nächste Ergebnisseite abzurufen. Wenn dieses Feld weggelassen wird, gibt es keine weiteren Ergebnisse.

MessagePublishRequest

Anfrage zum Veröffentlichen von Nachrichten zu dem Thema

Felder
messages[]

PubSubMessage

MessagePublishResponse

Antwort auf eine MessagePublishRequest.

Felder
start_cursor

Cursor

Der Cursor der ersten veröffentlichten Nachricht im Batch. Die Cursors für alle verbleibenden Nachrichten im Batch sind sequenziell.

MessageResponse

Antwort mit einer Liste von Nachrichten. Nach der Zustellung einer MessageResponse an den Client: *Aktualisiert den Zustellungscursor des Streams auf einen Wert, der größer als der Cursor der letzten Nachricht in der Liste ist. *Subtrahiert die Gesamtzahl der Byte und Nachrichten aus den für den Server verfügbaren Tokens.

Felder
messages[]

SequencedMessage

Nachrichten aus der Themenpartition

PartitionCursor

Ein Paar aus einem Cursor und der Partition, für die er vorgesehen ist.

Felder
partition

int64

Die Partition, für die dies vorgesehen ist.
cursor

Cursor

Der Wert des Cursors.

PubSubMessage

Eine Nachricht, die von Publishern veröffentlicht und an Abonnenten gesendet wird.

Felder
key

bytes

Der Schlüssel, der zum Weiterleiten von Nachrichten an Partitionen oder zur Verdichtung verwendet wird (z. B. die letzten N Nachrichten pro Schlüssel behalten). Wenn der Schlüssel leer ist, wird die Nachricht an eine beliebige Partition weitergeleitet.
data

bytes

Die Nutzlast der Nachricht.
attributes

map<string, AttributeValues>

Optionale Attribute, die für Metadaten/Header von Nachrichten verwendet werden können.
event_time

Timestamp

Eine optionale, benutzerdefinierte Ereigniszeit.

PublishRequest

Anfrage, die vom Client an den Server über einen Stream gesendet wird.

Felder

Union-Feld request_type.

Für request_type ist nur einer der folgenden Werte zulässig:
initial_request

InitialPublishRequest

Erste Anfrage auf dem Stream.
message_publish_request

MessagePublishRequest

Anfrage zur Veröffentlichung von Nachrichten.

PublishResponse

Antwort auf eine PublishRequest.

Felder

Union-Feld response_type.

Für response_type ist nur einer der folgenden Werte zulässig:
initial_response

InitialPublishResponse

Erste Antwort im Stream.
message_response

MessagePublishResponse

Antwort auf die Veröffentlichung von Nachrichten.

SeekRequest

Anfrage zum Aktualisieren des Zustellungscursors des Streams basierend auf dem angegebenen Ziel. Setzt die verfügbaren Server-Tokens auf 0 zurück. SeekRequests dürfen nicht gesendet werden, solange ein anderer SeekRequest auf demselben Stream aussteht (d. h. keine SeekResponse erhalten hat). SeekRequests nach dem Head führen zu einer Unterbrechung des Streams.

Felder
Union-Feld target. Das Ziel, zu dem gesprungen werden soll. darf nicht leer bleiben Für target ist nur einer der folgenden Werte zulässig:
named_target

NamedTarget

Ein benanntes Ziel.
cursor

Cursor

Ein Ziel, das dem Cursor entspricht und auf eine beliebige Stelle in der Themenpartition verweist.

NamedTarget

Ein spezielles Ziel in der Partition, das keine anderen Parameter nimmt.

Enums
NAMED_TARGET_UNSPECIFIED Standardwert Dieser Wert wird nicht verwendet.
HEAD Ein Ziel, das der zuletzt veröffentlichten Nachricht in der Partition entspricht.
COMMITTED_CURSOR Ein Ziel, das dem Commit-Cursor für die angegebene Abo- und Themenpartition entspricht.

SeekResponse

Antwort auf eine SeekRequest.

Felder
cursor

Cursor

Der neue Zustellungscursor für den aktuellen Stream.

SequencedCommitCursorRequest

Streaming-Anfrage zum Aktualisieren des zugesicherten Cursors. Nachfolgende SequencedCommitCursorRequests überschreiben ausstehende.

Felder
cursor

Cursor

Der neue Wert für den Commit-Cursor.

SequencedCommitCursorResponse

Antwort auf eine SequencedCommitCurser-Anfrage.

Felder
acknowledged_commits

int64

Die Anzahl ausstehender SequencedCommitCursorRequests, die von dieser Antwort bestätigt wurden. Beachten Sie, dass SequencedCommitCursorRequests in der Reihenfolge ihres Eingangs bestätigt werden.

SequencedMessage

Felder
cursor

Cursor

Die Position einer Nachricht innerhalb der Partition, in der sie gespeichert ist.
publish_time

Timestamp

Der Zeitpunkt, zu dem die Nachricht vom Server bei der ersten Veröffentlichung empfangen wurde.
message

PubSubMessage

Die Nachricht des Nutzers.
size_bytes

int64

Die Größe dieser Nachricht in Byte für Ablaufsteuerungs- und Kontingentzwecke.

StreamingCommitCursorRequest

Anfrage, die vom Client an den Server über einen Stream gesendet wird.

Felder

Union-Feld request.

Für request ist nur einer der folgenden Werte zulässig:
initial

InitialCommitCursorRequest

Erste Anfrage auf dem Stream.
commit

SequencedCommitCursorRequest

Anfrage zum Commit eines neuen Cursorwerts.

StreamingCommitCursorResponse

Antwort auf eine StreamingCommitCursorRequest.

Felder

Union-Feld request.

Für request ist nur einer der folgenden Werte zulässig:
initial

InitialCommitCursorResponse

Erste Antwort im Stream.
commit

SequencedCommitCursorResponse

Antwort auf das Committen eines neuen Cursorwerts.

SubscribeRequest

Anfrage, die vom Client an den Server über einen Stream gesendet wird.

Felder

Union-Feld request.

Für request ist nur einer der folgenden Werte zulässig:
initial

InitialSubscribeRequest

Erste Anfrage auf dem Stream.
seek

SeekRequest

Anfrage zur Aktualisierung des Zustellungscursors des Streams.
flow_control

FlowControlRequest

Anfrage zum Zuweisen von Tokens an den Server,

SubscribeResponse

Antwort auf SubscribeRequest

Felder

Union-Feld response.

Für response ist nur einer der folgenden Werte zulässig:
initial

InitialSubscribeResponse

Erste Antwort im Stream.
seek

SeekResponse

Antwort auf einen Suchvorgang.
messages

MessageResponse

Antwort, die Nachrichten von der Themenpartition enthält.

Abo

Metadaten zu einer Aboressource.

Felder
name

string

Der Name des Abos. Strukturiert wie: projects/{project_number}/locations/{location}/subscriptions/{subscription_id}
topic

string

Der Name des Themas, mit dem dieses Abo verknüpft ist. Strukturiert wie: projects/{project_number}/locations/{location}/topics/{topic_id}
delivery_config

DeliveryConfig

Die Einstellungen für die Nachrichtenzustellung dieses Abos.

DeliveryConfig

Die Einstellungen für die Nachrichtenzustellung eines Abos.

Felder
delivery_requirement

DeliveryRequirement

Die Auslieferungsanforderung für dieses Abo.

DeliveryRequirement

Gibt an, wann dieses Abo Nachrichten an Abonnenten im Verhältnis zur Persistenz von Nachrichten senden soll. Weitere Informationen finden Sie unter Lite-Abos erstellen.

Enums
DELIVERY_REQUIREMENT_UNSPECIFIED Standardwert Dieser Wert wird nicht verwendet.
DELIVER_IMMEDIATELY Der Server wartet nicht darauf, dass eine veröffentlichte Nachricht erfolgreich in den Speicher geschrieben wird, bevor sie an Abonnenten gesendet wird.
DELIVER_AFTER_STORED Der Server sendet eine veröffentlichte Nachricht erst dann an Abonnenten, wenn die Nachricht erfolgreich in den Speicher geschrieben wurde. Dies führt zu einer höheren End-to-End-Latenz, aber einer konsistenten Bereitstellung.

Topic

Metadaten zu einer Themenressource.

Felder
name

string

Der Name des Themas. Strukturiert wie: projects/{project_number}/locations/{location}/topics/{topic_id}
partition_config

PartitionConfig

Die Einstellungen für die Partitionen dieses Themas.
retention_config

RetentionConfig

Die Einstellungen für die Nachrichtenaufbewahrung dieses Themas.

PartitionConfig

Die Einstellungen für die Partitionen eines Themas.

Felder
count

int64

Die Anzahl der Partitionen im Thema. Muss mindestens 1 sein
scale

int32

Jeder Partition im Thema wird ein Durchsatz zugewiesen, der dem scale-fachen Standarddurchsatz der Partition (4 MiB/s) entspricht. Dies spiegelt sich auch in den Kosten für dieses Thema wider. Ein Thema mit einem scale von 2 und einer Anzahl von 10 wird mit 20 Partitionen berechnet. Dieser Wert muss im Bereich [1,4] liegen.

RetentionConfig

Die Einstellungen für die Nachrichtenaufbewahrung eines Themas.

Felder
per_partition_bytes

int64

Der bereitgestellte Speicher in Byte pro Partition. Wenn die Anzahl der in einer der Partitionen des Themas gespeicherten Byte diesen Wert überschreitet, werden ältere Nachrichten gelöscht, um Platz für neuere Nachrichten zu schaffen, unabhängig vom Wert von period.
period

Duration

Die Aufbewahrungsdauer einer veröffentlichten Nachricht. Wenn nicht weiter festgelegt, werden Nachrichten aufbewahrt, solange die für jede Partition aufbewahrten Byte unter per_partition_bytes liegen.

TopicPartitions

Antwort für GetTopicPartitions.

Felder
partition_count

int64

Die Anzahl der Partitionen im Thema.

UpdateSubscriptionRequest

Anfrage für UpdateSubscription.

Felder
subscription

Subscription

Erforderlich Das zu aktualisierende Abo. Das Feld name muss ausgefüllt werden. Das Feld "Thema" darf nicht ausgefüllt werden.
update_mask

FieldMask

Erforderlich Eine Maske, die die zu ändernden Abofelder angibt.

UpdateTopicRequest

Anfrage für UpdateTopic.

Felder
topic

Topic

Erforderlich Das zu aktualisierende Thema. Das Feld name muss ausgefüllt werden.
update_mask

FieldMask

Erforderlich Eine Maske, die die zu ändernden Themenfelder angibt.