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

  field :EVENT_OBSERVATION_STATE_None, 0
  field :Initial, 1
  field :HeadOfReplay, 2
  field :Replay, 4
  field :TailOfReplay, 8
end

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

  field :OBSERVATION_STATE_None, 0
  field :Success, 1
  field :Failed, 2
end

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

  field :REPLAY_STATE_None, 0
  field :BeginReplay, 1
  field :EndReplay, 2
  field :BeginReplayPartition, 3
  field :EndReplayPartition, 4
end

defmodule Cratis.Chronicle.Contracts.Observation.Reactors.AppendedEvent.GenerationalContentEntry do
  @moduledoc false
  use Protobuf, map: true, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :key, 1, type: :int32
  field :value, 2, type: :string
end

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

  field :Context, 1, type: Cratis.Chronicle.Contracts.Observation.Reactors.EventContext
  field :Content, 2, type: :string
  field :OriginalContent, 3, type: :string

  field :Revisions, 4,
    repeated: true,
    type: Cratis.Chronicle.Contracts.Observation.Reactors.EventRevision

  field :GenerationalContent, 5,
    repeated: true,
    type: Cratis.Chronicle.Contracts.Observation.Reactors.AppendedEvent.GenerationalContentEntry,
    map: true
end

defmodule Cratis.Chronicle.Contracts.Observation.Reactors.Causation.PropertiesEntry do
  @moduledoc false
  use Protobuf, map: true, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :key, 1, type: :string
  field :value, 2, type: :string
end

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

  field :Occurred, 1,
    type: Cratis.Chronicle.Contracts.Observation.Reactors.SerializableDateTimeOffset

  field :Type, 2, type: :string

  field :Properties, 3,
    repeated: true,
    type: Cratis.Chronicle.Contracts.Observation.Reactors.Causation.PropertiesEntry,
    map: true
end

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

  field :EventType, 1, type: Cratis.Chronicle.Contracts.Observation.Reactors.EventType
  field :EventSourceType, 2, type: :string
  field :EventSourceId, 3, type: :string
  field :SequenceNumber, 4, type: :uint64
  field :EventStreamType, 5, type: :string
  field :EventStreamId, 6, type: :string

  field :Occurred, 7,
    type: Cratis.Chronicle.Contracts.Observation.Reactors.SerializableDateTimeOffset

  field :EventStore, 8, type: :string
  field :Namespace, 9, type: :string
  field :CorrelationId, 10, type: Bcl.Guid

  field :Causation, 11,
    repeated: true,
    type: Cratis.Chronicle.Contracts.Observation.Reactors.Causation

  field :CausedBy, 12, type: Cratis.Chronicle.Contracts.Observation.Reactors.Identity

  field :ObservationState, 13,
    type: Cratis.Chronicle.Contracts.Observation.Reactors.EventObservationState,
    enum: true

  field :Tags, 14, repeated: true, type: :string
  field :Hash, 15, type: :string
end

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

  field :Generation, 1, type: :uint32
  field :CorrelationId, 2, type: :string
  field :CausedBy, 3, type: Cratis.Chronicle.Contracts.Observation.Reactors.Identity

  field :Occurred, 4,
    type: Cratis.Chronicle.Contracts.Observation.Reactors.SerializableDateTimeOffset

  field :Content, 5, type: :string
end

defmodule Cratis.Chronicle.Contracts.Observation.Reactors.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.Reactors.EventTypeWithKeyExpression do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3

  field :EventType, 1, type: Cratis.Chronicle.Contracts.Observation.Reactors.EventType
  field :Key, 2, type: :string
end

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

  field :Partition, 1, type: :string

  field :Events, 2,
    repeated: true,
    type: Cratis.Chronicle.Contracts.Observation.Reactors.AppendedEvent

  field :ReplayState, 3,
    type: Cratis.Chronicle.Contracts.Observation.Reactors.ReplayState,
    enum: true
end

defmodule Cratis.Chronicle.Contracts.Observation.Reactors.HasReactorRequest 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 :ReactorId, 3, type: :string
end

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

  field :Exists, 1, type: :bool
  field :EventSequenceId, 2, type: :string
end

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

  field :Subject, 1, type: :string
  field :Name, 2, type: :string
  field :UserName, 3, type: :string
  field :OnBehalfOf, 4, type: Cratis.Chronicle.Contracts.Observation.Reactors.Identity
end

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

  field :FilterTags, 1, repeated: true, type: :string
  field :EventSourceType, 2, type: :string
  field :EventStreamType, 3, type: :string
end

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

  field :Value0, 1, type: Cratis.Chronicle.Contracts.Observation.Reactors.RegisterReactor
  field :Value1, 2, type: Cratis.Chronicle.Contracts.Observation.Reactors.ReactorResult
end

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

  field :ReactorId, 1, type: :string
  field :EventSequenceId, 2, type: :string

  field :EventTypes, 3,
    repeated: true,
    type: Cratis.Chronicle.Contracts.Observation.Reactors.EventTypeWithKeyExpression

  field :IsReplayable, 4, type: :bool
  field :Tags, 5, repeated: true, type: :string
  field :Filters, 6, type: Cratis.Chronicle.Contracts.Observation.Reactors.ObserverFilters
end

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

  field :Content, 1,
    type: Cratis.Chronicle.Contracts.Observation.Reactors.OneOf_RegisterReactor_ReactorResult
end

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

  field :Partition, 1, type: :string

  field :State, 2,
    type: Cratis.Chronicle.Contracts.Observation.Reactors.ObservationState,
    enum: true

  field :LastSuccessfulObservation, 3, type: :uint64
  field :ExceptionMessages, 4, repeated: true, type: :string
  field :ExceptionStackTrace, 5, type: :string
end

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

  field :ConnectionId, 1, type: :string
  field :EventStore, 2, type: :string
  field :Namespace, 3, type: :string
  field :Reactor, 4, type: Cratis.Chronicle.Contracts.Observation.Reactors.ReactorDefinition
end

defmodule Cratis.Chronicle.Contracts.Observation.Reactors.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.Reactors.Reactors.Service do
  @moduledoc false

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

  rpc :HasReactor,
      Cratis.Chronicle.Contracts.Observation.Reactors.HasReactorRequest,
      Cratis.Chronicle.Contracts.Observation.Reactors.HasReactorResponse

  rpc :Observe,
      stream(Cratis.Chronicle.Contracts.Observation.Reactors.ReactorMessage),
      stream(Cratis.Chronicle.Contracts.Observation.Reactors.EventsToObserve)
end

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

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