ex_esdb_grpc

0.2.0
EventStore-compatible gRPC API server for ExESDB event store clusters. Provides complete stream operations, real-time subscriptions, transaction support, and comprehensive monitoring capabilities with high performance and production-ready reliability.
HexDocs
Current section
Files
Jump to
Readme 5 Versions 4 Dependencies Dependants Files Activity
ex_esdb_grpc lib protobuf ClientAPI ClientMessageDtos.pb.ex
Raw
lib/protobuf/ClientAPI/ClientMessageDtos.pb.ex

defmodule Reckondb.Client.Messages.OperationResult do
  @moduledoc false

  use Protobuf, enum: true, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :Success, 0
  field :PrepareTimeout, 1
  field :CommitTimeout, 2
  field :ForwardTimeout, 3
  field :WrongExpectedVersion, 4
  field :StreamDeleted, 5
  field :InvalidTransaction, 6
  field :AccessDenied, 7
end

defmodule Reckondb.Client.Messages.ReadEventCompleted.ReadEventResult do
  @moduledoc false

  use Protobuf, enum: true, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :Success, 0
  field :NotFound, 1
  field :NoStream, 2
  field :StreamDeleted, 3
  field :Error, 4
  field :AccessDenied, 5
end

defmodule Reckondb.Client.Messages.ReadStreamEventsCompleted.ReadStreamResult do
  @moduledoc false

  use Protobuf, enum: true, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :Success, 0
  field :NoStream, 1
  field :StreamDeleted, 2
  field :NotModified, 3
  field :Error, 4
  field :AccessDenied, 5
end

defmodule Reckondb.Client.Messages.ReadAllEventsCompleted.ReadAllResult do
  @moduledoc false

  use Protobuf, enum: true, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :Success, 0
  field :NotModified, 1
  field :Error, 2
  field :AccessDenied, 3
end

defmodule Reckondb.Client.Messages.Filter.FilterContext do
  @moduledoc false

  use Protobuf, enum: true, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :StreamId, 0
  field :EventType, 1
end

defmodule Reckondb.Client.Messages.Filter.FilterType do
  @moduledoc false

  use Protobuf, enum: true, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :Regex, 0
  field :Prefix, 1
end

defmodule Reckondb.Client.Messages.FilteredReadAllEventsCompleted.FilteredReadAllResult do
  @moduledoc false

  use Protobuf, enum: true, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :Success, 0
  field :NotModified, 1
  field :Error, 2
  field :AccessDenied, 3
end

defmodule Reckondb.Client.Messages.UpdatePersistentSubscriptionCompleted.UpdatePersistentSubscriptionResult do
  @moduledoc false

  use Protobuf, enum: true, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :Success, 0
  field :DoesNotExist, 1
  field :Fail, 2
  field :AccessDenied, 3
end

defmodule Reckondb.Client.Messages.CreatePersistentSubscriptionCompleted.CreatePersistentSubscriptionResult do
  @moduledoc false

  use Protobuf, enum: true, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :Success, 0
  field :AlreadyExists, 1
  field :Fail, 2
  field :AccessDenied, 3
end

defmodule Reckondb.Client.Messages.DeletePersistentSubscriptionCompleted.DeletePersistentSubscriptionResult do
  @moduledoc false

  use Protobuf, enum: true, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :Success, 0
  field :DoesNotExist, 1
  field :Fail, 2
  field :AccessDenied, 3
end

defmodule Reckondb.Client.Messages.PersistentSubscriptionNakEvents.NakAction do
  @moduledoc false

  use Protobuf, enum: true, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :Unknown, 0
  field :Park, 1
  field :Retry, 2
  field :Skip, 3
  field :Stop, 4
end

defmodule Reckondb.Client.Messages.SubscriptionDropped.SubscriptionDropReason do
  @moduledoc false

  use Protobuf, enum: true, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :Unsubscribed, 0
  field :AccessDenied, 1
  field :NotFound, 2
  field :PersistentSubscriptionDeleted, 3
  field :SubscriberMaxCountReached, 4
end

defmodule Reckondb.Client.Messages.NotHandled.NotHandledReason do
  @moduledoc false

  use Protobuf, enum: true, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :NotReady, 0
  field :TooBusy, 1
  field :NotLeader, 2
  field :IsReadOnly, 3
end

defmodule Reckondb.Client.Messages.ScavengeDatabaseResponse.ScavengeResult do
  @moduledoc false

  use Protobuf, enum: true, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :Started, 0
  field :InProgress, 1
  field :Unauthorized, 2
end

defmodule Reckondb.Client.Messages.NewEvent do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :event_id, 1, type: :bytes, json_name: "eventId"
  field :event_type, 2, type: :string, json_name: "eventType"
  field :data_content_type, 3, type: :int32, json_name: "dataContentType"
  field :metadata_content_type, 4, type: :int32, json_name: "metadataContentType"
  field :data, 5, type: :bytes
  field :metadata, 6, type: :bytes
  field :properties, 7, type: :bytes
end

defmodule Reckondb.Client.Messages.EventRecord do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :event_stream_id, 1, type: :string, json_name: "eventStreamId"
  field :event_number, 2, type: :int64, json_name: "eventNumber"
  field :event_id, 3, type: :bytes, json_name: "eventId"
  field :event_type, 4, type: :string, json_name: "eventType"
  field :data_content_type, 5, type: :int32, json_name: "dataContentType"
  field :metadata_content_type, 6, type: :int32, json_name: "metadataContentType"
  field :data, 7, type: :bytes
  field :metadata, 8, type: :bytes
  field :created, 9, type: :int64
  field :created_epoch, 10, type: :int64, json_name: "createdEpoch"
  field :properties, 11, type: :bytes
end

defmodule Reckondb.Client.Messages.ResolvedIndexedEvent do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :event, 1, type: Reckondb.Client.Messages.EventRecord
  field :link, 2, type: Reckondb.Client.Messages.EventRecord
end

defmodule Reckondb.Client.Messages.ResolvedEvent do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :event, 1, type: Reckondb.Client.Messages.EventRecord
  field :link, 2, type: Reckondb.Client.Messages.EventRecord
  field :commit_position, 3, type: :int64, json_name: "commitPosition"
  field :prepare_position, 4, type: :int64, json_name: "preparePosition"
end

defmodule Reckondb.Client.Messages.WriteEvents do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :event_stream_id, 1, type: :string, json_name: "eventStreamId"
  field :expected_version, 2, type: :int64, json_name: "expectedVersion"
  field :events, 3, repeated: true, type: Reckondb.Client.Messages.NewEvent
  field :require_leader, 4, type: :bool, json_name: "requireLeader"
end

defmodule Reckondb.Client.Messages.WriteEventsCompleted do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :result, 1, type: Reckondb.Client.Messages.OperationResult, enum: true
  field :message, 2, type: :string
  field :first_event_number, 3, type: :int64, json_name: "firstEventNumber"
  field :last_event_number, 4, type: :int64, json_name: "lastEventNumber"
  field :prepare_position, 5, type: :int64, json_name: "preparePosition"
  field :commit_position, 6, type: :int64, json_name: "commitPosition"
  field :current_version, 7, type: :int64, json_name: "currentVersion"
end

defmodule Reckondb.Client.Messages.DeleteStream do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :event_stream_id, 1, type: :string, json_name: "eventStreamId"
  field :expected_version, 2, type: :int64, json_name: "expectedVersion"
  field :require_leader, 3, type: :bool, json_name: "requireLeader"
  field :hard_delete, 4, type: :bool, json_name: "hardDelete"
end

defmodule Reckondb.Client.Messages.DeleteStreamCompleted do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :result, 1, type: Reckondb.Client.Messages.OperationResult, enum: true
  field :message, 2, type: :string
  field :prepare_position, 3, type: :int64, json_name: "preparePosition"
  field :commit_position, 4, type: :int64, json_name: "commitPosition"
  field :current_version, 5, type: :int64, json_name: "currentVersion"
end

defmodule Reckondb.Client.Messages.TransactionStart do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :event_stream_id, 1, type: :string, json_name: "eventStreamId"
  field :expected_version, 2, type: :int64, json_name: "expectedVersion"
  field :require_leader, 3, type: :bool, json_name: "requireLeader"
end

defmodule Reckondb.Client.Messages.TransactionStartCompleted do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :transaction_id, 1, type: :int64, json_name: "transactionId"
  field :result, 2, type: Reckondb.Client.Messages.OperationResult, enum: true
  field :message, 3, type: :string
end

defmodule Reckondb.Client.Messages.TransactionWrite do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :transaction_id, 1, type: :int64, json_name: "transactionId"
  field :events, 2, repeated: true, type: Reckondb.Client.Messages.NewEvent
  field :require_leader, 3, type: :bool, json_name: "requireLeader"
end

defmodule Reckondb.Client.Messages.TransactionWriteCompleted do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :transaction_id, 1, type: :int64, json_name: "transactionId"
  field :result, 2, type: Reckondb.Client.Messages.OperationResult, enum: true
  field :message, 3, type: :string
end

defmodule Reckondb.Client.Messages.TransactionCommit do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :transaction_id, 1, type: :int64, json_name: "transactionId"
  field :require_leader, 2, type: :bool, json_name: "requireLeader"
end

defmodule Reckondb.Client.Messages.TransactionCommitCompleted do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :transaction_id, 1, type: :int64, json_name: "transactionId"
  field :result, 2, type: Reckondb.Client.Messages.OperationResult, enum: true
  field :message, 3, type: :string
  field :first_event_number, 4, type: :int64, json_name: "firstEventNumber"
  field :last_event_number, 5, type: :int64, json_name: "lastEventNumber"
  field :prepare_position, 6, type: :int64, json_name: "preparePosition"
  field :commit_position, 7, type: :int64, json_name: "commitPosition"
end

defmodule Reckondb.Client.Messages.ReadEvent do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :event_stream_id, 1, type: :string, json_name: "eventStreamId"
  field :event_number, 2, type: :int64, json_name: "eventNumber"
  field :resolve_link_tos, 3, type: :bool, json_name: "resolveLinkTos"
  field :require_leader, 4, type: :bool, json_name: "requireLeader"
end

defmodule Reckondb.Client.Messages.ReadEventCompleted do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :result, 1, type: Reckondb.Client.Messages.ReadEventCompleted.ReadEventResult, enum: true
  field :event, 2, type: Reckondb.Client.Messages.ResolvedIndexedEvent
  field :error, 3, type: :string
end

defmodule Reckondb.Client.Messages.ReadStreamEvents do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :event_stream_id, 1, type: :string, json_name: "eventStreamId"
  field :from_event_number, 2, type: :int64, json_name: "fromEventNumber"
  field :max_count, 3, type: :int32, json_name: "maxCount"
  field :resolve_link_tos, 4, type: :bool, json_name: "resolveLinkTos"
  field :require_leader, 5, type: :bool, json_name: "requireLeader"
end

defmodule Reckondb.Client.Messages.ReadStreamEventsCompleted do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :events, 1, repeated: true, type: Reckondb.Client.Messages.ResolvedIndexedEvent

  field :result, 2,
    type: Reckondb.Client.Messages.ReadStreamEventsCompleted.ReadStreamResult,
    enum: true

  field :next_event_number, 3, type: :int64, json_name: "nextEventNumber"
  field :last_event_number, 4, type: :int64, json_name: "lastEventNumber"
  field :is_end_of_stream, 5, type: :bool, json_name: "isEndOfStream"
  field :last_commit_position, 6, type: :int64, json_name: "lastCommitPosition"
  field :error, 7, type: :string
end

defmodule Reckondb.Client.Messages.ReadAllEvents do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :commit_position, 1, type: :int64, json_name: "commitPosition"
  field :prepare_position, 2, type: :int64, json_name: "preparePosition"
  field :max_count, 3, type: :int32, json_name: "maxCount"
  field :resolve_link_tos, 4, type: :bool, json_name: "resolveLinkTos"
  field :require_leader, 5, type: :bool, json_name: "requireLeader"
end

defmodule Reckondb.Client.Messages.ReadAllEventsCompleted do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :commit_position, 1, type: :int64, json_name: "commitPosition"
  field :prepare_position, 2, type: :int64, json_name: "preparePosition"
  field :events, 3, repeated: true, type: Reckondb.Client.Messages.ResolvedEvent
  field :next_commit_position, 4, type: :int64, json_name: "nextCommitPosition"
  field :next_prepare_position, 5, type: :int64, json_name: "nextPreparePosition"

  field :result, 6,
    type: Reckondb.Client.Messages.ReadAllEventsCompleted.ReadAllResult,
    enum: true

  field :error, 7, type: :string
end

defmodule Reckondb.Client.Messages.Filter do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :context, 1, type: Reckondb.Client.Messages.Filter.FilterContext, enum: true
  field :type, 2, type: Reckondb.Client.Messages.Filter.FilterType, enum: true
  field :data, 3, repeated: true, type: :string
end

defmodule Reckondb.Client.Messages.FilteredReadAllEvents do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :commit_position, 1, type: :int64, json_name: "commitPosition"
  field :prepare_position, 2, type: :int64, json_name: "preparePosition"
  field :max_count, 3, type: :int32, json_name: "maxCount"
  field :max_search_window, 4, type: :int32, json_name: "maxSearchWindow"
  field :resolve_link_tos, 5, type: :bool, json_name: "resolveLinkTos"
  field :require_leader, 6, type: :bool, json_name: "requireLeader"
  field :filter, 7, type: Reckondb.Client.Messages.Filter
end

defmodule Reckondb.Client.Messages.FilteredReadAllEventsCompleted do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :commit_position, 1, type: :int64, json_name: "commitPosition"
  field :prepare_position, 2, type: :int64, json_name: "preparePosition"
  field :events, 3, repeated: true, type: Reckondb.Client.Messages.ResolvedEvent
  field :next_commit_position, 4, type: :int64, json_name: "nextCommitPosition"
  field :next_prepare_position, 5, type: :int64, json_name: "nextPreparePosition"
  field :is_end_of_stream, 6, type: :bool, json_name: "isEndOfStream"

  field :result, 7,
    type: Reckondb.Client.Messages.FilteredReadAllEventsCompleted.FilteredReadAllResult,
    enum: true

  field :error, 8, type: :string
end

defmodule Reckondb.Client.Messages.CreatePersistentSubscription do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :subscription_group_name, 1, type: :string, json_name: "subscriptionGroupName"
  field :event_stream_id, 2, type: :string, json_name: "eventStreamId"
  field :resolve_link_tos, 3, type: :bool, json_name: "resolveLinkTos"
  field :start_from, 4, type: :int64, json_name: "startFrom"
  field :message_timeout_milliseconds, 5, type: :int32, json_name: "messageTimeoutMilliseconds"
  field :record_statistics, 6, type: :bool, json_name: "recordStatistics"
  field :live_buffer_size, 7, type: :int32, json_name: "liveBufferSize"
  field :read_batch_size, 8, type: :int32, json_name: "readBatchSize"
  field :buffer_size, 9, type: :int32, json_name: "bufferSize"
  field :max_retry_count, 10, type: :int32, json_name: "maxRetryCount"
  field :prefer_round_robin, 11, type: :bool, json_name: "preferRoundRobin"
  field :checkpoint_after_time, 12, type: :int32, json_name: "checkpointAfterTime"
  field :checkpoint_max_count, 13, type: :int32, json_name: "checkpointMaxCount"
  field :checkpoint_min_count, 14, type: :int32, json_name: "checkpointMinCount"
  field :subscriber_max_count, 15, type: :int32, json_name: "subscriberMaxCount"
  field :named_consumer_strategy, 16, type: :string, json_name: "namedConsumerStrategy"
end

defmodule Reckondb.Client.Messages.DeletePersistentSubscription do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :subscription_group_name, 1, type: :string, json_name: "subscriptionGroupName"
  field :event_stream_id, 2, type: :string, json_name: "eventStreamId"
end

defmodule Reckondb.Client.Messages.UpdatePersistentSubscription do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :subscription_group_name, 1, type: :string, json_name: "subscriptionGroupName"
  field :event_stream_id, 2, type: :string, json_name: "eventStreamId"
  field :resolve_link_tos, 3, type: :bool, json_name: "resolveLinkTos"
  field :start_from, 4, type: :int64, json_name: "startFrom"
  field :message_timeout_milliseconds, 5, type: :int32, json_name: "messageTimeoutMilliseconds"
  field :record_statistics, 6, type: :bool, json_name: "recordStatistics"
  field :live_buffer_size, 7, type: :int32, json_name: "liveBufferSize"
  field :read_batch_size, 8, type: :int32, json_name: "readBatchSize"
  field :buffer_size, 9, type: :int32, json_name: "bufferSize"
  field :max_retry_count, 10, type: :int32, json_name: "maxRetryCount"
  field :prefer_round_robin, 11, type: :bool, json_name: "preferRoundRobin"
  field :checkpoint_after_time, 12, type: :int32, json_name: "checkpointAfterTime"
  field :checkpoint_max_count, 13, type: :int32, json_name: "checkpointMaxCount"
  field :checkpoint_min_count, 14, type: :int32, json_name: "checkpointMinCount"
  field :subscriber_max_count, 15, type: :int32, json_name: "subscriberMaxCount"
  field :named_consumer_strategy, 16, type: :string, json_name: "namedConsumerStrategy"
end

defmodule Reckondb.Client.Messages.UpdatePersistentSubscriptionCompleted do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :result, 1,
    type:
      Reckondb.Client.Messages.UpdatePersistentSubscriptionCompleted.UpdatePersistentSubscriptionResult,
    enum: true

  field :reason, 2, type: :string
end

defmodule Reckondb.Client.Messages.CreatePersistentSubscriptionCompleted do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :result, 1,
    type:
      Reckondb.Client.Messages.CreatePersistentSubscriptionCompleted.CreatePersistentSubscriptionResult,
    enum: true

  field :reason, 2, type: :string
end

defmodule Reckondb.Client.Messages.DeletePersistentSubscriptionCompleted do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :result, 1,
    type:
      Reckondb.Client.Messages.DeletePersistentSubscriptionCompleted.DeletePersistentSubscriptionResult,
    enum: true

  field :reason, 2, type: :string
end

defmodule Reckondb.Client.Messages.ConnectToPersistentSubscription do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :subscription_id, 1, type: :string, json_name: "subscriptionId"
  field :event_stream_id, 2, type: :string, json_name: "eventStreamId"
  field :allowed_in_flight_messages, 3, type: :int32, json_name: "allowedInFlightMessages"
end

defmodule Reckondb.Client.Messages.PersistentSubscriptionAckEvents do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :subscription_id, 1, type: :string, json_name: "subscriptionId"
  field :processed_event_ids, 2, repeated: true, type: :bytes, json_name: "processedEventIds"
end

defmodule Reckondb.Client.Messages.PersistentSubscriptionNakEvents do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :subscription_id, 1, type: :string, json_name: "subscriptionId"
  field :processed_event_ids, 2, repeated: true, type: :bytes, json_name: "processedEventIds"
  field :message, 3, type: :string

  field :action, 4,
    type: Reckondb.Client.Messages.PersistentSubscriptionNakEvents.NakAction,
    enum: true
end

defmodule Reckondb.Client.Messages.PersistentSubscriptionConfirmation do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :last_commit_position, 1, type: :int64, json_name: "lastCommitPosition"
  field :subscription_id, 2, type: :string, json_name: "subscriptionId"
  field :last_event_number, 3, type: :int64, json_name: "lastEventNumber"
end

defmodule Reckondb.Client.Messages.PersistentSubscriptionStreamEventAppeared do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :event, 1, type: Reckondb.Client.Messages.ResolvedIndexedEvent
  field :retryCount, 2, type: :int32
end

defmodule Reckondb.Client.Messages.SubscribeToStream do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :event_stream_id, 1, type: :string, json_name: "eventStreamId"
  field :resolve_link_tos, 2, type: :bool, json_name: "resolveLinkTos"
end

defmodule Reckondb.Client.Messages.FilteredSubscribeToStream do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :event_stream_id, 1, type: :string, json_name: "eventStreamId"
  field :resolve_link_tos, 2, type: :bool, json_name: "resolveLinkTos"
  field :filter, 3, type: Reckondb.Client.Messages.Filter
  field :checkpoint_interval, 4, type: :int32, json_name: "checkpointInterval"
end

defmodule Reckondb.Client.Messages.CheckpointReached do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :commit_position, 1, type: :int64, json_name: "commitPosition"
  field :prepare_position, 2, type: :int64, json_name: "preparePosition"
end

defmodule Reckondb.Client.Messages.SubscriptionConfirmation do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :last_commit_position, 1, type: :int64, json_name: "lastCommitPosition"
  field :last_event_number, 2, type: :int64, json_name: "lastEventNumber"
end

defmodule Reckondb.Client.Messages.StreamEventAppeared do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :event, 1, type: Reckondb.Client.Messages.ResolvedEvent
end

defmodule Reckondb.Client.Messages.UnsubscribeFromStream do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3
end

defmodule Reckondb.Client.Messages.SubscriptionDropped do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :reason, 1,
    type: Reckondb.Client.Messages.SubscriptionDropped.SubscriptionDropReason,
    enum: true
end

defmodule Reckondb.Client.Messages.NotHandled.LeaderInfo do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :external_tcp_address, 1, type: :string, json_name: "externalTcpAddress"
  field :external_tcp_port, 2, type: :int32, json_name: "externalTcpPort"
  field :http_address, 3, type: :string, json_name: "httpAddress"
  field :http_port, 4, type: :int32, json_name: "httpPort"
  field :external_secure_tcp_address, 5, type: :string, json_name: "externalSecureTcpAddress"
  field :external_secure_tcp_port, 6, type: :int32, json_name: "externalSecureTcpPort"
end

defmodule Reckondb.Client.Messages.NotHandled do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :reason, 1, type: Reckondb.Client.Messages.NotHandled.NotHandledReason, enum: true
  field :additional_info, 2, type: :bytes, json_name: "additionalInfo"
end

defmodule Reckondb.Client.Messages.ScavengeDatabase do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3
end

defmodule Reckondb.Client.Messages.ScavengeDatabaseResponse do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :result, 1,
    type: Reckondb.Client.Messages.ScavengeDatabaseResponse.ScavengeResult,
    enum: true

  field :scavengeId, 2, type: :string
end

defmodule Reckondb.Client.Messages.IdentifyClient do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3

  field :version, 1, type: :int32
  field :connection_name, 2, type: :string, json_name: "connectionName"
end

defmodule Reckondb.Client.Messages.ClientIdentified do
  @moduledoc false

  use Protobuf, protoc_gen_elixir_version: "0.14.1", syntax: :proto3
end
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