ex_esdb_grpc

0.5.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