package event_store.client.persistent_subscriptions

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc Create (CreateReq, CreateResp)

  persistent.proto:8

  message CreateReq

  persistent.proto:96

  • optional CreateReq.Options options = 1

  message CreateResp

  persistent.proto:182

  (message has no fields)

• rpc Update (UpdateReq, UpdateResp)

  persistent.proto:9

  message UpdateReq

  persistent.proto:185

  • optional UpdateReq.Options options = 1

  message UpdateResp

  persistent.proto:249

  (message has no fields)

• rpc Delete (DeleteReq, DeleteResp)

  persistent.proto:10

  message DeleteReq

  persistent.proto:252

  • optional DeleteReq.Options options = 1

  message DeleteResp

  persistent.proto:265

  (message has no fields)

• rpc Read (stream ReadReq, stream ReadResp)

  persistent.proto:11

  message ReadReq

  persistent.proto:18

  • oneof content

    • ReadReq.Options options = 1

    • ReadReq.Ack ack = 2

    • ReadReq.Nack nack = 3

  message ReadResp

  persistent.proto:64

  • oneof content

    • ReadResp.ReadEvent event = 1

    • ReadResp.SubscriptionConfirmation subscription_confirmation = 2

• rpc GetInfo (GetInfoReq, GetInfoResp)

  persistent.proto:12

  message GetInfoReq

  persistent.proto:268

  • optional GetInfoReq.Options options = 1

  message GetInfoResp

  persistent.proto:281

  • optional SubscriptionInfo subscription_info = 1

• rpc ReplayParked (ReplayParkedReq, ReplayParkedResp)

  persistent.proto:13

  message ReplayParkedReq

  persistent.proto:333

  • optional ReplayParkedReq.Options options = 1

  message ReplayParkedResp

  persistent.proto:349

  (message has no fields)

• rpc List (ListReq, ListResp)

  persistent.proto:14

  message ListReq

  persistent.proto:352

  • optional ListReq.Options options = 1

  message ListResp

  persistent.proto:369

  • repeated SubscriptionInfo subscriptions = 1

• rpc RestartSubsystem (Empty, Empty)

  persistent.proto:15

Used in: Options

• oneof all_option

  • Position position = 1

  • Empty start = 2

  • Empty end = 3

• oneof filter_option

  • AllOptions.FilterOptions filter = 4

  • Empty no_filter = 5

Used in: AllOptions

• 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: Settings

• DispatchToSingle = 0

• RoundRobin = 1

• Pinned = 2

Used in: CreateReq

• oneof stream_option

  • StreamOptions stream = 4

  • AllOptions all = 5

• optional StreamIdentifier stream_identifier = 1

• string group_name = 2

• optional Settings settings = 3

Used in: AllOptions

• uint64 commit_position = 1

• uint64 prepare_position = 2

Used in: Options

• bool resolve_links = 1

• uint64 revision = 2

• bool extra_statistics = 3

• int32 max_retry_count = 5

• int32 min_checkpoint_count = 7

• int32 max_checkpoint_count = 8

• int32 max_subscriber_count = 9

• int32 live_buffer_size = 10

• int32 read_batch_size = 11

• int32 history_buffer_size = 12

• ConsumerStrategy named_consumer_strategy = 13

• oneof message_timeout

  • int64 message_timeout_ticks = 4

  • int32 message_timeout_ms = 14

• oneof checkpoint_after

  • int64 checkpoint_after_ticks = 6

  • int32 checkpoint_after_ms = 15

• string consumer_strategy = 16

Used in: Options

• optional StreamIdentifier stream_identifier = 1

• oneof revision_option

  • uint64 revision = 2

  • Empty start = 3

  • Empty end = 4

Used in: DeleteReq

• oneof stream_option

  • StreamIdentifier stream_identifier = 1

  • Empty all = 3

• string group_name = 2

Used in: GetInfoReq

• oneof stream_option

  • StreamIdentifier stream_identifier = 1

  • Empty all = 2

• string group_name = 3

Used in: ListReq

• oneof list_option

  • Empty list_all_subscriptions = 1

  • StreamOption list_for_stream = 2

Used in: Options

• oneof stream_option

  • StreamIdentifier stream = 1

  • Empty all = 2

Used in: ReadReq

• bytes id = 1

• repeated UUID ids = 2

Used in: ReadReq

• bytes id = 1

• repeated UUID ids = 2

• Nack.Action action = 3

• string reason = 4

Used in: Nack

• Unknown = 0

• Park = 1

• Retry = 2

• Skip = 3

• Stop = 4

Used in: ReadReq

• oneof stream_option

  • StreamIdentifier stream_identifier = 1

  • Empty all = 5

• string group_name = 2

• int32 buffer_size = 3

• optional Options.UUIDOption uuid_option = 4

Used in: Options

• oneof content

  • Empty structured = 1

  • Empty string = 2

Used in: ReadResp

• optional ReadEvent.RecordedEvent event = 1

• optional ReadEvent.RecordedEvent link = 2

• oneof position

  • uint64 commit_position = 3

  • Empty no_position = 4

• oneof count

  • int32 retry_count = 5

  • Empty no_retry_count = 6

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

• string subscription_id = 1

Used in: ReplayParkedReq

• string group_name = 1

• oneof stream_option

  • StreamIdentifier stream_identifier = 2

  • Empty all = 3

• oneof stop_at_option

  • int64 stop_at = 4

  • Empty no_limit = 5

Used in: GetInfoResp, ListResp

• string event_source = 1

• string group_name = 2

• string status = 3

• repeated SubscriptionInfo.ConnectionInfo connections = 4

• int32 average_per_second = 5

• int64 total_items = 6

• int64 count_since_last_measurement = 7

• string last_checkpointed_event_position = 8

• string last_known_event_position = 9

• bool resolve_link_tos = 10

• string start_from = 11

• int32 message_timeout_milliseconds = 12

• bool extra_statistics = 13

• int32 max_retry_count = 14

• int32 live_buffer_size = 15

• int32 buffer_size = 16

• int32 read_batch_size = 17

• int32 check_point_after_milliseconds = 18

• int32 min_check_point_count = 19

• int32 max_check_point_count = 20

• int32 read_buffer_count = 21

• int64 live_buffer_count = 22

• int32 retry_buffer_count = 23

• int32 total_in_flight_messages = 24

• int32 outstanding_messages_count = 25

• string named_consumer_strategy = 26

• int32 max_subscriber_count = 27

• int64 parked_message_count = 28

Used in: SubscriptionInfo

• string from = 1

• string username = 2

• int32 average_items_per_second = 3

• int64 total_items = 4

• int64 count_since_last_measurement = 5

• repeated Measurement observed_measurements = 6

• int32 available_slots = 7

• int32 in_flight_messages = 8

• string connection_name = 9

Used in: ConnectionInfo

• string key = 1

• int64 value = 2

Used in: Options

• oneof all_option

  • Position position = 1

  • Empty start = 2

  • Empty end = 3

Used in: Settings

• DispatchToSingle = 0

• RoundRobin = 1

• Pinned = 2

Used in: UpdateReq

• oneof stream_option

  • StreamOptions stream = 4

  • AllOptions all = 5

• optional StreamIdentifier stream_identifier = 1

• string group_name = 2

• optional Settings settings = 3

Used in: AllOptions

• uint64 commit_position = 1

• uint64 prepare_position = 2

Used in: Options

• bool resolve_links = 1

• uint64 revision = 2

• bool extra_statistics = 3

• int32 max_retry_count = 5

• int32 min_checkpoint_count = 7

• int32 max_checkpoint_count = 8

• int32 max_subscriber_count = 9

• int32 live_buffer_size = 10

• int32 read_batch_size = 11

• int32 history_buffer_size = 12

• ConsumerStrategy named_consumer_strategy = 13

• oneof message_timeout

  • int64 message_timeout_ticks = 4

  • int32 message_timeout_ms = 14

• oneof checkpoint_after

  • int64 checkpoint_after_ticks = 6

  • int32 checkpoint_after_ms = 15

Used in: Options

• optional StreamIdentifier stream_identifier = 1

• oneof revision_option

  • uint64 revision = 2

  • Empty start = 3

  • Empty end = 4