package event_store.client.streams

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc Append (stream AppendReq, AppendResp)

  streams.proto:13

  message AppendReq

  streams.proto:177

  • oneof content

    • AppendReq.Options options = 1

    • AppendReq.ProposedMessage proposed_message = 2

  message AppendResp

  streams.proto:200

  • oneof result

    • AppendResp.Success success = 1

    • AppendResp.WrongExpectedVersion wrong_expected_version = 2

• rpc BatchAppend (stream BatchAppendReq, stream BatchAppendResp)

  streams.proto:16

  message BatchAppendReq

  streams.proto:246

  • optional UUID correlation_id = 1

  • optional BatchAppendReq.Options options = 2

  • repeated BatchAppendReq.ProposedMessage proposed_messages = 3

  • bool is_final = 4

  message BatchAppendResp

  streams.proto:274

  • optional UUID correlation_id = 1

  • oneof result

    • kurrentdbclient.status.Status error = 2

    • BatchAppendResp.Success success = 3

  • optional StreamIdentifier stream_identifier = 4

  • oneof expected_stream_position

    • uint64 stream_position = 5

    • google.protobuf.Empty no_stream = 6

    • google.protobuf.Empty any = 7

    • google.protobuf.Empty stream_exists = 8

• rpc Delete (DeleteReq, DeleteResp)

  streams.proto:14

  message DeleteReq

  streams.proto:302

  • optional DeleteReq.Options options = 1

  message DeleteResp

  streams.proto:316

  • oneof position_option

    • DeleteResp.Position position = 1

    • Empty no_position = 2

• rpc Read (ReadReq, stream ReadResp)

  streams.proto:12

  message ReadReq

  streams.proto:19

  • optional ReadReq.Options options = 1

  message ReadResp

  streams.proto:93

  • oneof content

    • ReadResp.ReadEvent event = 1

    • ReadResp.SubscriptionConfirmation confirmation = 2

    • ReadResp.Checkpoint checkpoint = 3

    • ReadResp.StreamNotFound stream_not_found = 4

    • uint64 first_stream_position = 5

    • uint64 last_stream_position = 6

    • AllStreamPosition last_all_stream_position = 7

    • ReadResp.CaughtUp caught_up = 8

    • ReadResp.FellBehind fell_behind = 9

• rpc Tombstone (TombstoneReq, TombstoneResp)

  streams.proto:15

  message TombstoneReq

  streams.proto:328

  • optional TombstoneReq.Options options = 1

  message TombstoneResp

  streams.proto:342

  • oneof position_option

    • TombstoneResp.Position position = 1

    • Empty no_position = 2

Used in: AppendReq

• optional StreamIdentifier stream_identifier = 1

• oneof expected_stream_revision

  • uint64 revision = 2

  • Empty no_stream = 3

  • Empty any = 4

  • Empty stream_exists = 5

Used in: AppendReq

• optional UUID id = 1

• map<string, string> metadata = 2

• bytes custom_metadata = 3

• bytes data = 4

Used in: Success

• uint64 commit_position = 1

• uint64 prepare_position = 2

Used in: AppendResp

• oneof current_revision_option

  • uint64 current_revision = 1

  • Empty no_stream = 2

• oneof position_option

  • Position position = 3

  • Empty no_position = 4

Used in: AppendResp

• oneof current_revision_option_20_6_0

  • uint64 current_revision_20_6_0 = 1

  • Empty no_stream_20_6_0 = 2

• oneof expected_revision_option_20_6_0

  • uint64 expected_revision_20_6_0 = 3

  • Empty any_20_6_0 = 4

  • Empty stream_exists_20_6_0 = 5

• oneof current_revision_option

  • uint64 current_revision = 6

  • Empty current_no_stream = 7

• oneof expected_revision_option

  • uint64 expected_revision = 8

  • Empty expected_any = 9

  • Empty expected_stream_exists = 10

  • Empty expected_no_stream = 11

Used in: BatchAppendReq

• optional StreamIdentifier stream_identifier = 1

• oneof expected_stream_position

  • uint64 stream_position = 2

  • google.protobuf.Empty no_stream = 3

  • google.protobuf.Empty any = 4

  • google.protobuf.Empty stream_exists = 5

• oneof deadline_option

  • google.protobuf.Timestamp deadline_21_10_0 = 6

  • google.protobuf.Duration deadline = 7

Used in: BatchAppendReq

• optional UUID id = 1

• map<string, string> metadata = 2

• bytes custom_metadata = 3

• bytes data = 4

Used in: BatchAppendResp

• oneof current_revision_option

  • uint64 current_revision = 1

  • google.protobuf.Empty no_stream = 2

• oneof position_option

  • AllStreamPosition position = 3

  • google.protobuf.Empty no_position = 4

Used in: DeleteReq

• optional StreamIdentifier stream_identifier = 1

• oneof expected_stream_revision

  • uint64 revision = 2

  • Empty no_stream = 3

  • Empty any = 4

  • Empty stream_exists = 5

Used in: DeleteResp

• uint64 commit_position = 1

• uint64 prepare_position = 2

Used in: ReadReq

• oneof stream_option

  • Options.StreamOptions stream = 1

  • Options.AllOptions all = 2

• Options.ReadDirection read_direction = 3

• bool resolve_links = 4

• oneof count_option

  • uint64 count = 5

  • Options.SubscriptionOptions subscription = 6

• oneof filter_option

  • Options.FilterOptions filter = 7

  • Empty no_filter = 8

• optional Options.UUIDOption uuid_option = 9

• optional Options.ControlOption control_option = 10

Used in: Options

• oneof all_option

  • Position position = 1

  • Empty start = 2

  • Empty end = 3

Used in: Options

• uint32 compatibility = 1

Used in: Options

• oneof filter

  • FilterOptions.Expression stream_identifier = 1

  • FilterOptions.Expression event_type = 2

• oneof window

  • uint32 max = 3

  • Empty count = 4

• uint32 checkpointIntervalMultiplier = 5

Used in: FilterOptions

• string regex = 1

• repeated string prefix = 2

Used in: AllOptions

• uint64 commit_position = 1

• uint64 prepare_position = 2

Used in: Options

• Forwards = 0

• Backwards = 1

Used in: Options

• optional StreamIdentifier stream_identifier = 1

• oneof revision_option

  • uint64 revision = 2

  • Empty start = 3

  • Empty end = 4

Used in: Options

(message has no fields)

Used in: Options

• oneof content

  • Empty structured = 1

  • Empty string = 2

The $all or stream subscription has caught up and become live.

Used in: ReadResp

• optional google.protobuf.Timestamp timestamp = 1

  Current time in the server when the subscription caught up

• optional int64 stream_revision = 2

  Checkpoint for resuming a stream subscription. For stream subscriptions it is populated unless the stream is empty. For $all subscriptions it is not populated.

• optional Position position = 3

  Checkpoint for resuming a $all subscription. For stream subscriptions it is not populated. For $all subscriptions it is populated unless the database is empty.

Used in: ReadResp

• uint64 commit_position = 1

• uint64 prepare_position = 2

• optional google.protobuf.Timestamp timestamp = 3

  Current time in the server when the checkpoint was reached

The $all or stream subscription has fallen back into catchup mode and is no longer live.

Used in: ReadResp

• optional google.protobuf.Timestamp timestamp = 1

  Current time in the server when the subscription fell behind

• optional int64 stream_revision = 2

  Checkpoint for resuming a stream subscription. For stream subscriptions it is populated unless the stream is empty. For $all subscriptions it is not populated.

• optional Position position = 3

  Checkpoint for resuming a $all subscription. For stream subscriptions it is not populated. For $all subscriptions it is populated unless the database is empty.

Used in: CaughtUp, FellBehind

• uint64 commit_position = 1

• uint64 prepare_position = 2

Used in: ReadResp

• optional ReadEvent.RecordedEvent event = 1

• optional ReadEvent.RecordedEvent link = 2

• oneof position

  • uint64 commit_position = 3

  • Empty no_position = 4

Used in: ReadEvent

• optional UUID id = 1

• optional StreamIdentifier stream_identifier = 2

• uint64 stream_revision = 3

• uint64 prepare_position = 4

• uint64 commit_position = 5

• map<string, string> metadata = 6

• bytes custom_metadata = 7

• bytes data = 8

Used in: ReadResp

• optional StreamIdentifier stream_identifier = 1

Used in: ReadResp

• string subscription_id = 1

Used in: TombstoneReq

• optional StreamIdentifier stream_identifier = 1

• oneof expected_stream_revision

  • uint64 revision = 2

  • Empty no_stream = 3

  • Empty any = 4

  • Empty stream_exists = 5

Used in: TombstoneResp

• uint64 commit_position = 1

• uint64 prepare_position = 2