defmodule Reckondb.Client.Messages.HealthCheckResponse.ServingStatus do
  @moduledoc false

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

  field :UNKNOWN, 0
  field :SERVING, 1
  field :NOT_SERVING, 2
end

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

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

  field :service, 1, type: :string
end

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

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

  field :status, 1, type: Reckondb.Client.Messages.HealthCheckResponse.ServingStatus, enum: true
end

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

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

  field :event_stream_id, 1, type: :string, json_name: "eventStreamId"
end

defmodule Reckondb.Client.Messages.GetStreamInfoResponse 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 :current_version, 2, type: :int64, json_name: "currentVersion"
  field :event_count, 3, type: :int64, json_name: "eventCount"
  field :exists, 4, type: :bool
  field :created_date, 5, type: :int64, json_name: "createdDate"
end

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

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

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

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

  field :stores, 1, repeated: true, type: Reckondb.Client.Messages.StoreInfo
end

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

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

  field :store_id, 1, type: :string, json_name: "storeId"
  field :name, 2, type: :string
  field :active, 3, type: :bool
  field :event_count, 4, type: :int64, json_name: "eventCount"
  field :stream_count, 5, type: :int64, json_name: "streamCount"
end

defmodule Reckondb.Client.Messages.EventStore.Service do
  @moduledoc false

  use GRPC.Service,
    name: "reckondb.client.messages.EventStore",
    protoc_gen_elixir_version: "0.14.1"

  rpc :WriteEvents,
      Reckondb.Client.Messages.WriteEvents,
      Reckondb.Client.Messages.WriteEventsCompleted

  rpc :ReadEvent, Reckondb.Client.Messages.ReadEvent, Reckondb.Client.Messages.ReadEventCompleted

  rpc :ReadStreamEvents,
      Reckondb.Client.Messages.ReadStreamEvents,
      Reckondb.Client.Messages.ReadStreamEventsCompleted

  rpc :ReadAllEvents,
      Reckondb.Client.Messages.ReadAllEvents,
      Reckondb.Client.Messages.ReadAllEventsCompleted

  rpc :SubscribeToStream,
      Reckondb.Client.Messages.SubscribeToStream,
      stream(Reckondb.Client.Messages.StreamEventAppeared)

  rpc :DeleteStream,
      Reckondb.Client.Messages.DeleteStream,
      Reckondb.Client.Messages.DeleteStreamCompleted

  rpc :StartTransaction,
      Reckondb.Client.Messages.TransactionStart,
      Reckondb.Client.Messages.TransactionStartCompleted

  rpc :WriteToTransaction,
      Reckondb.Client.Messages.TransactionWrite,
      Reckondb.Client.Messages.TransactionWriteCompleted

  rpc :CommitTransaction,
      Reckondb.Client.Messages.TransactionCommit,
      Reckondb.Client.Messages.TransactionCommitCompleted

  rpc :HealthCheck,
      Reckondb.Client.Messages.HealthCheckRequest,
      Reckondb.Client.Messages.HealthCheckResponse

  rpc :GetStreamInfo,
      Reckondb.Client.Messages.GetStreamInfoRequest,
      Reckondb.Client.Messages.GetStreamInfoResponse
end

defmodule Reckondb.Client.Messages.EventStore.Stub do
  @moduledoc false

  use GRPC.Stub, service: Reckondb.Client.Messages.EventStore.Service
end

defmodule Reckondb.Client.Messages.StoreManagement.Service do
  @moduledoc false

  use GRPC.Service,
    name: "reckondb.client.messages.StoreManagement",
    protoc_gen_elixir_version: "0.14.1"

  rpc :ListStores,
      Reckondb.Client.Messages.ListStoresRequest,
      Reckondb.Client.Messages.ListStoresResponse
end

defmodule Reckondb.Client.Messages.StoreManagement.Stub do
  @moduledoc false

  use GRPC.Stub, service: Reckondb.Client.Messages.StoreManagement.Service
end