Packages

ex_esdb

0.0.11-alpha
0.11.0 0.10.0 0.9.0 0.8.0 0.7.8 0.7.7 0.7.6 0.7.5 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.1 0.6.0 0.5.1 0.5.0 0.4.8 0.4.7 0.4.6 0.4.5 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.3 0.3.2 0.3.1 0.3.0 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0 0.0.20 0.0.19 0.0.18 0.0.17 0.0.16 0.0.15 0.0.14-alpha 0.0.13-alpha 0.0.12-alpha 0.0.11-alpha 0.0.10-alpha 0.0.9-alpha 0.0.8-alpha 0.0.6-alpha 0.0.5-alpha 0.0.4-alpha 0.0.3-alpha 0.0.2-alfa 0.0.1-alfa

ExESDB is a reincarnation of rabbitmq/khepri, specialized for use as a BEAM-native event store.

HexDocs

Current section

Files

Jump to
Readme
63 Versions
9 Dependencies
Dependants
Files
Activity
ex_esdb lib ex_esdb schema subscripition_record.ex
Raw

lib/ex_esdb/schema/subscripition_record.ex 

defmodule ExESDB.Schema.SubscriptionRecord do

  @moduledoc false

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



  field(:subscription_group_name, 1,

    required: true,

    type: :string,

    json_name: "subscriptionGroupName"

  )



  field(:event_stream_id, 2, required: true, type: :string, json_name: "eventStreamId")

  field(:resolve_link_tos, 3, required: true, type: :bool, json_name: "resolveLinkTos")

  field(:start_from, 4, required: true, type: :int64, json_name: "startFrom")



  field(:message_timeout_milliseconds, 5,

    required: true,

    type: :int32,

    json_name: "messageTimeoutMilliseconds"

  )



  field(:record_statistics, 6, required: true, type: :bool, json_name: "recordStatistics")

  field(:live_buffer_size, 7, required: true, type: :int32, json_name: "liveBufferSize")

  field(:read_batch_size, 8, required: true, type: :int32, json_name: "readBatchSize")

  field(:buffer_size, 9, required: true, type: :int32, json_name: "bufferSize")

  field(:max_retry_count, 10, required: true, type: :int32, json_name: "maxRetryCount")

  field(:prefer_round_robin, 11, required: true, type: :bool, json_name: "preferRoundRobin")



  field(:checkpoint_after_time, 12,

    required: true,

    type: :int32,

    json_name: "checkpointAfterTime"

  )



  field(:checkpoint_max_count, 13, required: true, type: :int32, json_name: "checkpointMaxCount")

  field(:checkpoint_min_count, 14, required: true, type: :int32, json_name: "checkpointMinCount")

  field(:subscriber_max_count, 15, required: true, type: :int32, json_name: "subscriberMaxCount")



  field(:named_consumer_strategy, 16,

    optional: true,

    type: :string,

    json_name: "namedConsumerStrategy"

  )

end