spear

0.6.1
1.4.1 1.4.0 1.3.2 1.3.1 1.3.0 1.2.1 1.2.0 1.1.0 1.0.2 1.0.1 1.0.0 0.11.0 0.10.0 0.10.0-rc.1 0.9.1 0.9.0 0.8.1 0.8.0 0.7.0 0.6.1 0.6.0 0.5.0 0.4.0 0.3.0 0.2.1 0.2.0 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0
A sharp EventStoreDB 20+ client backed by mint
HexDocs
Current section
Files
Jump to
Readme 31 Versions 4 Dependencies Dependants Files Activity
spear src spear_proto_persistent.hrl
Raw
src/spear_proto_persistent.hrl

%% -*- coding: utf-8 -*-
%% Automatically generated, do not edit
%% Generated by gpb_compile version 4.17.0

-ifndef(spear_proto_persistent).
-define(spear_proto_persistent, true).

-define(spear_proto_persistent_gpb_version, "4.17.0").

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READREQ.OPTIONS_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READREQ.OPTIONS_PB_H', true).
-record('event_store.client.persistent_subscriptions.ReadReq.Options',
        {stream_identifier = undefined :: spear_proto_persistent:'event_store.client.shared.StreamIdentifier'() | undefined, % = 1, optional
         group_name = <<>>      :: unicode:chardata() | undefined, % = 2, optional
         buffer_size = 0        :: integer() | undefined, % = 3, optional, 32 bits
         uuid_option = undefined :: spear_proto_persistent:'event_store.client.persistent_subscriptions.ReadReq.Options.UUIDOption'() | undefined % = 4, optional
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READREQ.OPTIONS.UUIDOPTION_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READREQ.OPTIONS.UUIDOPTION_PB_H', true).
-record('event_store.client.persistent_subscriptions.ReadReq.Options.UUIDOption',
        {content                :: {structured, spear_proto_persistent:'event_store.client.shared.Empty'()} | {string, spear_proto_persistent:'event_store.client.shared.Empty'()} | undefined % oneof
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READREQ.ACK_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READREQ.ACK_PB_H', true).
-record('event_store.client.persistent_subscriptions.ReadReq.Ack',
        {id = <<>>              :: iodata() | undefined, % = 1, optional
         ids = []               :: [spear_proto_persistent:'event_store.client.shared.UUID'()] | undefined % = 2, repeated
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READREQ.NACK_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READREQ.NACK_PB_H', true).
-record('event_store.client.persistent_subscriptions.ReadReq.Nack',
        {id = <<>>              :: iodata() | undefined, % = 1, optional
         ids = []               :: [spear_proto_persistent:'event_store.client.shared.UUID'()] | undefined, % = 2, repeated
         action = 'Unknown'     :: 'Unknown' | 'Park' | 'Retry' | 'Skip' | 'Stop' | integer() | undefined, % = 3, optional, enum event_store.client.persistent_subscriptions.ReadReq.Nack.Action
         reason = <<>>          :: unicode:chardata() | undefined % = 4, optional
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READREQ_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READREQ_PB_H', true).
-record('event_store.client.persistent_subscriptions.ReadReq',
        {content                :: {options, spear_proto_persistent:'event_store.client.persistent_subscriptions.ReadReq.Options'()} | {ack, spear_proto_persistent:'event_store.client.persistent_subscriptions.ReadReq.Ack'()} | {nack, spear_proto_persistent:'event_store.client.persistent_subscriptions.ReadReq.Nack'()} | undefined % oneof
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READRESP.READEVENT_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READRESP.READEVENT_PB_H', true).
-record('event_store.client.persistent_subscriptions.ReadResp.ReadEvent',
        {event = undefined      :: spear_proto_persistent:'event_store.client.persistent_subscriptions.ReadResp.ReadEvent.RecordedEvent'() | undefined, % = 1, optional
         link = undefined       :: spear_proto_persistent:'event_store.client.persistent_subscriptions.ReadResp.ReadEvent.RecordedEvent'() | undefined, % = 2, optional
         position               :: {commit_position, non_neg_integer()} | {no_position, spear_proto_persistent:'event_store.client.shared.Empty'()} | undefined, % oneof
         count                  :: {retry_count, integer()} | {no_retry_count, spear_proto_persistent:'event_store.client.shared.Empty'()} | undefined % oneof
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READRESP.READEVENT.RECORDEDEVENT_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READRESP.READEVENT.RECORDEDEVENT_PB_H', true).
-record('event_store.client.persistent_subscriptions.ReadResp.ReadEvent.RecordedEvent',
        {id = undefined         :: spear_proto_persistent:'event_store.client.shared.UUID'() | undefined, % = 1, optional
         stream_identifier = undefined :: spear_proto_persistent:'event_store.client.shared.StreamIdentifier'() | undefined, % = 2, optional
         stream_revision = 0    :: non_neg_integer() | undefined, % = 3, optional, 64 bits
         prepare_position = 0   :: non_neg_integer() | undefined, % = 4, optional, 64 bits
         commit_position = 0    :: non_neg_integer() | undefined, % = 5, optional, 64 bits
         metadata = []          :: [{unicode:chardata(), unicode:chardata()}] | undefined, % = 6
         custom_metadata = <<>> :: iodata() | undefined, % = 7, optional
         data = <<>>            :: iodata() | undefined % = 8, optional
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READRESP.SUBSCRIPTIONCONFIRMATION_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READRESP.SUBSCRIPTIONCONFIRMATION_PB_H', true).
-record('event_store.client.persistent_subscriptions.ReadResp.SubscriptionConfirmation',
        {subscription_id = <<>> :: unicode:chardata() | undefined % = 1, optional
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READRESP_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.READRESP_PB_H', true).
-record('event_store.client.persistent_subscriptions.ReadResp',
        {content                :: {event, spear_proto_persistent:'event_store.client.persistent_subscriptions.ReadResp.ReadEvent'()} | {subscription_confirmation, spear_proto_persistent:'event_store.client.persistent_subscriptions.ReadResp.SubscriptionConfirmation'()} | undefined % oneof
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.CREATEREQ.OPTIONS_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.CREATEREQ.OPTIONS_PB_H', true).
-record('event_store.client.persistent_subscriptions.CreateReq.Options',
        {stream_identifier = undefined :: spear_proto_persistent:'event_store.client.shared.StreamIdentifier'() | undefined, % = 1, optional
         group_name = <<>>      :: unicode:chardata() | undefined, % = 2, optional
         settings = undefined   :: spear_proto_persistent:'event_store.client.persistent_subscriptions.CreateReq.Settings'() | undefined % = 3, optional
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.CREATEREQ.SETTINGS_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.CREATEREQ.SETTINGS_PB_H', true).
-record('event_store.client.persistent_subscriptions.CreateReq.Settings',
        {resolve_links = false  :: boolean() | 0 | 1 | undefined, % = 1, optional
         revision = 0           :: non_neg_integer() | undefined, % = 2, optional, 64 bits
         extra_statistics = false :: boolean() | 0 | 1 | undefined, % = 3, optional
         max_retry_count = 0    :: integer() | undefined, % = 5, optional, 32 bits
         min_checkpoint_count = 0 :: integer() | undefined, % = 7, optional, 32 bits
         max_checkpoint_count = 0 :: integer() | undefined, % = 8, optional, 32 bits
         max_subscriber_count = 0 :: integer() | undefined, % = 9, optional, 32 bits
         live_buffer_size = 0   :: integer() | undefined, % = 10, optional, 32 bits
         read_batch_size = 0    :: integer() | undefined, % = 11, optional, 32 bits
         history_buffer_size = 0 :: integer() | undefined, % = 12, optional, 32 bits
         named_consumer_strategy = 'DispatchToSingle' :: 'DispatchToSingle' | 'RoundRobin' | 'Pinned' | integer() | undefined, % = 13, optional, enum event_store.client.persistent_subscriptions.CreateReq.ConsumerStrategy
         message_timeout        :: {message_timeout_ticks, integer()} | {message_timeout_ms, integer()} | undefined, % oneof
         checkpoint_after       :: {checkpoint_after_ticks, integer()} | {checkpoint_after_ms, integer()} | undefined % oneof
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.CREATEREQ_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.CREATEREQ_PB_H', true).
-record('event_store.client.persistent_subscriptions.CreateReq',
        {options = undefined    :: spear_proto_persistent:'event_store.client.persistent_subscriptions.CreateReq.Options'() | undefined % = 1, optional
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.CREATERESP_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.CREATERESP_PB_H', true).
-record('event_store.client.persistent_subscriptions.CreateResp',
        {
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.UPDATEREQ.OPTIONS_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.UPDATEREQ.OPTIONS_PB_H', true).
-record('event_store.client.persistent_subscriptions.UpdateReq.Options',
        {stream_identifier = undefined :: spear_proto_persistent:'event_store.client.shared.StreamIdentifier'() | undefined, % = 1, optional
         group_name = <<>>      :: unicode:chardata() | undefined, % = 2, optional
         settings = undefined   :: spear_proto_persistent:'event_store.client.persistent_subscriptions.UpdateReq.Settings'() | undefined % = 3, optional
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.UPDATEREQ.SETTINGS_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.UPDATEREQ.SETTINGS_PB_H', true).
-record('event_store.client.persistent_subscriptions.UpdateReq.Settings',
        {resolve_links = false  :: boolean() | 0 | 1 | undefined, % = 1, optional
         revision = 0           :: non_neg_integer() | undefined, % = 2, optional, 64 bits
         extra_statistics = false :: boolean() | 0 | 1 | undefined, % = 3, optional
         max_retry_count = 0    :: integer() | undefined, % = 5, optional, 32 bits
         min_checkpoint_count = 0 :: integer() | undefined, % = 7, optional, 32 bits
         max_checkpoint_count = 0 :: integer() | undefined, % = 8, optional, 32 bits
         max_subscriber_count = 0 :: integer() | undefined, % = 9, optional, 32 bits
         live_buffer_size = 0   :: integer() | undefined, % = 10, optional, 32 bits
         read_batch_size = 0    :: integer() | undefined, % = 11, optional, 32 bits
         history_buffer_size = 0 :: integer() | undefined, % = 12, optional, 32 bits
         named_consumer_strategy = 'DispatchToSingle' :: 'DispatchToSingle' | 'RoundRobin' | 'Pinned' | integer() | undefined, % = 13, optional, enum event_store.client.persistent_subscriptions.UpdateReq.ConsumerStrategy
         message_timeout        :: {message_timeout_ticks, integer()} | {message_timeout_ms, integer()} | undefined, % oneof
         checkpoint_after       :: {checkpoint_after_ticks, integer()} | {checkpoint_after_ms, integer()} | undefined % oneof
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.UPDATEREQ_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.UPDATEREQ_PB_H', true).
-record('event_store.client.persistent_subscriptions.UpdateReq',
        {options = undefined    :: spear_proto_persistent:'event_store.client.persistent_subscriptions.UpdateReq.Options'() | undefined % = 1, optional
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.UPDATERESP_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.UPDATERESP_PB_H', true).
-record('event_store.client.persistent_subscriptions.UpdateResp',
        {
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.DELETEREQ.OPTIONS_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.DELETEREQ.OPTIONS_PB_H', true).
-record('event_store.client.persistent_subscriptions.DeleteReq.Options',
        {stream_identifier = undefined :: spear_proto_persistent:'event_store.client.shared.StreamIdentifier'() | undefined, % = 1, optional
         group_name = <<>>      :: unicode:chardata() | undefined % = 2, optional
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.DELETEREQ_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.DELETEREQ_PB_H', true).
-record('event_store.client.persistent_subscriptions.DeleteReq',
        {options = undefined    :: spear_proto_persistent:'event_store.client.persistent_subscriptions.DeleteReq.Options'() | undefined % = 1, optional
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.DELETERESP_PB_H').
-define('EVENT_STORE.CLIENT.PERSISTENT_SUBSCRIPTIONS.DELETERESP_PB_H', true).
-record('event_store.client.persistent_subscriptions.DeleteResp',
        {
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.SHARED.UUID.STRUCTURED_PB_H').
-define('EVENT_STORE.CLIENT.SHARED.UUID.STRUCTURED_PB_H', true).
-record('event_store.client.shared.UUID.Structured',
        {most_significant_bits = 0 :: integer() | undefined, % = 1, optional, 64 bits
         least_significant_bits = 0 :: integer() | undefined % = 2, optional, 64 bits
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.SHARED.UUID_PB_H').
-define('EVENT_STORE.CLIENT.SHARED.UUID_PB_H', true).
-record('event_store.client.shared.UUID',
        {value                  :: {structured, spear_proto_persistent:'event_store.client.shared.UUID.Structured'()} | {string, unicode:chardata()} | undefined % oneof
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.SHARED.EMPTY_PB_H').
-define('EVENT_STORE.CLIENT.SHARED.EMPTY_PB_H', true).
-record('event_store.client.shared.Empty',
        {
        }).
-endif.

-ifndef('EVENT_STORE.CLIENT.SHARED.STREAMIDENTIFIER_PB_H').
-define('EVENT_STORE.CLIENT.SHARED.STREAMIDENTIFIER_PB_H', true).
-record('event_store.client.shared.StreamIdentifier',
        {streamName = <<>>      :: iodata() | undefined % = 3, optional
        }).
-endif.

-endif.
Operator	Description	Example
name:	Match package name. Supports * wildcards and repo/package form	name:phx* or name:hexpm/phoenix
description:	Full-text search of package descriptions	description:auth
depends:	Packages depending on a given package. Supports repo:package form	depends:ecto or depends:hexpm:ecto
build_tool:	Filter by build tool	build_tool:mix
updated_after:	Packages updated after an ISO8601 datetime	updated_after:2025-01-01T00:00:00Z
extra:	Match custom metadata (key,value). Nested keys are separated by commas	extra:license,MIT