defmodule Cratis.Chronicle.Contracts.Observation.ObserverOwner do
  @moduledoc false
  use Protobuf, enum: true, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :None, 0
  field :Client, 1
  field :Kernel, 2
end

defmodule Cratis.Chronicle.Contracts.Observation.ObserverRunningState do
  @moduledoc false
  use Protobuf, enum: true, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :OBSERVER_RUNNING_STATE_Unknown, 0
  field :Active, 1
  field :Suspended, 2
  field :Replaying, 3
  field :Disconnected, 4
  field :Quarantined, 5
end

defmodule Cratis.Chronicle.Contracts.Observation.ObserverType do
  @moduledoc false
  use Protobuf, enum: true, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :OBSERVER_TYPE_Unknown, 0
  field :Reactor, 1
  field :Projection, 2
  field :Reducer, 3
  field :External, 4
end

defmodule Cratis.Chronicle.Contracts.Observation.AllObserversRequest do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :EventStore, 1, type: :string
  field :Namespace, 2, type: :string
end

defmodule Cratis.Chronicle.Contracts.Observation.ClearObserverQuarantine do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :EventStore, 1, type: :string
  field :Namespace, 2, type: :string
  field :ObserverId, 3, type: :string
  field :EventSequenceId, 4, type: :string
end

defmodule Cratis.Chronicle.Contracts.Observation.EventType do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :Id, 1, type: :string
  field :Generation, 2, type: :uint32
  field :Tombstone, 3, type: :bool
end

defmodule Cratis.Chronicle.Contracts.Observation.FailedPartition do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :Id, 1, type: Bcl.Guid
  field :ObserverId, 2, type: :string
  field :Partition, 3, type: :string

  field :Attempts, 4,
    repeated: true,
    type: Cratis.Chronicle.Contracts.Observation.FailedPartitionAttempt
end

defmodule Cratis.Chronicle.Contracts.Observation.FailedPartitionAttempt do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :Occurred, 1, type: Cratis.Chronicle.Contracts.Observation.SerializableDateTimeOffset
  field :SequenceNumber, 2, type: :uint64
  field :Messages, 3, repeated: true, type: :string
  field :StackTrace, 4, type: :string
end

defmodule Cratis.Chronicle.Contracts.Observation.GetFailedPartitionsRequest do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :EventStore, 1, type: :string
  field :Namespace, 2, type: :string
  field :ObserverId, 3, type: :string
end

defmodule Cratis.Chronicle.Contracts.Observation.GetObserverInformationRequest do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :EventStore, 1, type: :string
  field :Namespace, 2, type: :string
  field :ObserverId, 3, type: :string
  field :EventSequenceId, 4, type: :string
end

defmodule Cratis.Chronicle.Contracts.Observation.GetReplayableObserversForEventTypesRequest do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :EventStore, 1, type: :string
  field :Namespace, 2, type: :string
  field :EventTypes, 3, repeated: true, type: Cratis.Chronicle.Contracts.Observation.EventType
end

defmodule Cratis.Chronicle.Contracts.Observation.IEnumerable_FailedPartition do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :items, 1, repeated: true, type: Cratis.Chronicle.Contracts.Observation.FailedPartition
end

defmodule Cratis.Chronicle.Contracts.Observation.IEnumerable_ObserverInformation do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :items, 1,
    repeated: true,
    type: Cratis.Chronicle.Contracts.Observation.ObserverInformation
end

defmodule Cratis.Chronicle.Contracts.Observation.ObserverInformation do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :Id, 1, type: :string
  field :EventSequenceId, 2, type: :string
  field :Type, 3, type: Cratis.Chronicle.Contracts.Observation.ObserverType, enum: true
  field :Owner, 4, type: Cratis.Chronicle.Contracts.Observation.ObserverOwner, enum: true
  field :EventTypes, 5, repeated: true, type: Cratis.Chronicle.Contracts.Observation.EventType
  field :NextEventSequenceNumber, 6, type: :uint64
  field :LastHandledEventSequenceNumber, 7, type: :uint64

  field :RunningState, 8,
    type: Cratis.Chronicle.Contracts.Observation.ObserverRunningState,
    enum: true

  field :IsSubscribed, 9, type: :bool
  field :IsReplayable, 10, type: :bool
end

defmodule Cratis.Chronicle.Contracts.Observation.Replay do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :EventStore, 1, type: :string
  field :Namespace, 2, type: :string
  field :ObserverId, 3, type: :string
  field :EventSequenceId, 4, type: :string
end

defmodule Cratis.Chronicle.Contracts.Observation.ReplayPartition do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :EventStore, 1, type: :string
  field :Namespace, 2, type: :string
  field :ObserverId, 3, type: :string
  field :EventSequenceId, 4, type: :string
  field :Partition, 5, type: :string
end

defmodule Cratis.Chronicle.Contracts.Observation.RetryPartition do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :EventStore, 1, type: :string
  field :Namespace, 2, type: :string
  field :ObserverId, 3, type: :string
  field :EventSequenceId, 4, type: :string
  field :Partition, 5, type: :string
end

defmodule Cratis.Chronicle.Contracts.Observation.SerializableDateTimeOffset do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :Value, 1, type: :string
end

defmodule Cratis.Chronicle.Contracts.Observation.WaitForObserverCompletionRequest do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :EventStore, 1, type: :string
  field :Namespace, 2, type: :string
  field :EventSequenceId, 3, type: :string
  field :TailEventSequenceNumber, 4, type: :uint64
end

defmodule Cratis.Chronicle.Contracts.Observation.WaitForObserverCompletionResponse do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :IsSuccess, 1, type: :bool

  field :FailedPartitions, 2,
    repeated: true,
    type: Cratis.Chronicle.Contracts.Observation.FailedPartition
end

defmodule Cratis.Chronicle.Contracts.Observation.FailedPartitions.Service do
  @moduledoc false

  use GRPC.Service,
    name: "Cratis.Chronicle.Contracts.Observation.FailedPartitions",
    protoc_gen_elixir_version: "0.16.0"

  rpc :GetFailedPartitions,
      Cratis.Chronicle.Contracts.Observation.GetFailedPartitionsRequest,
      Cratis.Chronicle.Contracts.Observation.IEnumerable_FailedPartition

  rpc :ObserveFailedPartitions,
      Cratis.Chronicle.Contracts.Observation.GetFailedPartitionsRequest,
      stream(Cratis.Chronicle.Contracts.Observation.IEnumerable_FailedPartition)
end

defmodule Cratis.Chronicle.Contracts.Observation.FailedPartitions.Stub do
  @moduledoc false

  use GRPC.Stub, service: Cratis.Chronicle.Contracts.Observation.FailedPartitions.Service
end

defmodule Cratis.Chronicle.Contracts.Observation.Observers.Service do
  @moduledoc false

  use GRPC.Service,
    name: "Cratis.Chronicle.Contracts.Observation.Observers",
    protoc_gen_elixir_version: "0.16.0"

  rpc :ClearObserverQuarantine,
      Cratis.Chronicle.Contracts.Observation.ClearObserverQuarantine,
      Google.Protobuf.Empty

  rpc :GetObserverInformation,
      Cratis.Chronicle.Contracts.Observation.GetObserverInformationRequest,
      Cratis.Chronicle.Contracts.Observation.ObserverInformation

  rpc :GetObservers,
      Cratis.Chronicle.Contracts.Observation.AllObserversRequest,
      Cratis.Chronicle.Contracts.Observation.IEnumerable_ObserverInformation

  rpc :GetReplayableObserversForEventTypes,
      Cratis.Chronicle.Contracts.Observation.GetReplayableObserversForEventTypesRequest,
      Cratis.Chronicle.Contracts.Observation.IEnumerable_ObserverInformation

  rpc :ObserveObservers,
      Cratis.Chronicle.Contracts.Observation.AllObserversRequest,
      stream(Cratis.Chronicle.Contracts.Observation.IEnumerable_ObserverInformation)

  rpc :Replay, Cratis.Chronicle.Contracts.Observation.Replay, Google.Protobuf.Empty

  rpc :ReplayPartition,
      Cratis.Chronicle.Contracts.Observation.ReplayPartition,
      Google.Protobuf.Empty

  rpc :RetryPartition,
      Cratis.Chronicle.Contracts.Observation.RetryPartition,
      Google.Protobuf.Empty

  rpc :WaitForCompletion,
      Cratis.Chronicle.Contracts.Observation.WaitForObserverCompletionRequest,
      Cratis.Chronicle.Contracts.Observation.WaitForObserverCompletionResponse
end

defmodule Cratis.Chronicle.Contracts.Observation.Observers.Stub do
  @moduledoc false

  use GRPC.Stub, service: Cratis.Chronicle.Contracts.Observation.Observers.Service
end