Packages

cratis_chronicle_contracts

19.26.2
19.39.2 19.39.1 19.39.0 19.38.2 19.38.1 19.38.0 19.37.9 19.37.8 19.37.7 19.37.6 19.37.5 19.37.4 19.37.3 19.37.2 19.37.1 19.37.0 19.36.0 19.35.2 19.35.1 19.35.0 19.34.2 19.34.1 19.34.0 19.33.4 19.33.3 19.33.2 19.33.1 19.33.0 19.32.5 19.32.4 19.32.3 19.32.2 19.32.1 19.32.0 19.31.11 19.31.10 19.31.9 19.31.8 19.31.7 19.31.6 19.31.5 19.31.4 19.31.3 19.31.2 19.31.1 19.31.0 19.30.0 19.29.5 19.29.4 19.29.3 19.29.2 19.29.1 19.29.0 19.28.0 19.27.4 19.27.3 19.27.2 19.27.1 19.27.0 19.26.3 19.26.2 19.26.1 19.26.0 19.25.2 19.25.1 19.25.0 19.24.1 19.24.0 19.23.1 19.23.0 19.22.2 19.22.1 19.22.0 19.21.1 19.21.0 19.20.0 19.19.0 19.18.0 19.17.0 19.16.1 19.16.0 19.15.0 19.14.2 19.14.1 19.14.0 19.13.3 19.13.2 19.13.1 19.13.0 19.12.0 19.11.1 19.11.0 19.10.1 19.10.0 19.9.0 19.8.1 19.8.0 19.7.11 19.7.10 19.7.9 19.7.8 19.7.7 19.7.6 19.7.5 19.7.4 19.7.3 19.7.2 19.7.1 19.7.0 19.6.1 19.6.0 19.5.0 19.4.9-hotfix.3 19.4.9-hotfix.1 19.4.8 19.4.7 19.4.6 19.4.5 19.4.4 19.4.3 19.4.2 19.4.1 19.4.0 19.3.2 19.3.1 19.3.0 19.2.2 19.2.1 19.2.0 19.1.8 19.1.7 19.1.6 19.1.5 19.1.4 19.1.3 19.1.2 19.1.1 19.1.0 19.0.1 19.0.0 18.5.1 18.5.0 18.4.1 18.4.0 18.3.1 18.3.0 18.2.0 18.1.6 18.1.5 18.1.4 18.1.3 18.1.2 18.1.1 18.1.0 18.0.0 17.1.1 17.1.0 17.0.5 17.0.4 17.0.3 17.0.2 17.0.1 17.0.0 16.45.3 16.45.2 16.45.1 16.45.0 16.44.2 16.44.1 16.44.0 16.43.0 16.42.2 16.42.1 16.42.0 16.41.0 16.40.0 16.39.2 16.39.1 16.39.0 16.38.6 16.38.5 16.38.4 16.38.3 16.38.2 16.38.1 16.38.0 16.37.2 16.37.1 16.37.0 16.36.3 16.36.2 16.36.1 16.36.0 16.35.8 16.35.7 16.35.6 16.35.5 16.35.4 16.35.3 16.35.2 16.35.1 16.35.0 16.34.3 16.34.2 16.34.1 16.34.0 16.33.1 16.33.0 16.32.0 16.31.0 16.30.1 16.30.0 16.29.1 16.29.0 16.28.0 16.27.0 16.26.3 16.26.2 16.26.1 16.26.0 16.25.0 16.24.1 16.24.0 16.23.0 16.22.4 16.22.3 16.22.2 16.22.1 16.22.0 16.21.0 16.20.0 16.19.3 16.19.2 16.19.1 16.19.0 16.18.0 16.17.0 16.16.1 16.16.0 16.15.0 16.13.4 16.13.3 16.13.2 16.13.1 16.13.0 16.12.0 16.11.1 16.11.0 16.10.0 16.9.4 16.9.3 16.9.2 16.9.1 16.9.0 16.8.1 16.8.0 16.7.0 16.6.1 16.6.0 16.5.0 16.4.1 16.4.0 16.3.1 16.3.0 16.2.1 16.2.0 16.1.1 16.1.0 16.0.6 16.0.5 16.0.4 16.0.3 16.0.2 16.0.1 16.0.0 15.41.0 15.40.0 15.39.1 15.39.0 15.38.4 15.38.3 15.38.2 15.38.1 15.38.0 15.37.0 15.36.1 15.36.0 15.35.8 15.35.7 15.35.6 15.35.5 15.35.4 15.35.3 15.35.2 15.35.1 15.35.0 15.34.13 15.34.12 15.34.11 15.34.10 15.34.9 15.34.8 15.34.7 15.34.6 15.34.5 15.34.4 15.34.3 15.34.2 15.31.5 15.31.4 15.31.3 15.31.2 15.31.1 15.31.0 15.30.2 15.30.1 15.30.0 15.29.8 15.29.7 15.29.6 15.29.4 15.29.3 15.29.2 15.29.1 15.29.0 15.28.0 15.27.3 15.27.2 15.27.1 15.27.0 15.26.11 15.26.10 15.26.9 15.26.8 15.26.7 15.26.6 15.26.5 15.26.4 15.26.3 15.26.1 15.25.5 15.25.4 15.25.3

Generated Elixir gRPC contracts for Cratis Chronicle - the open-source event-sourcing database

Current section

Files

Jump to
cratis_chronicle_contracts lib generated observation_reactors.pb.ex
Raw

lib/generated/observation_reactors.pb.ex

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

  field :EVENT_OBSERVATION_STATE_None, 0
  field :Initial, 1
  field :Replay, 2
end

defmodule Cratis.Chronicle.Contracts.Observation.Reactors.ObservationState do
  @moduledoc false
  use Protobuf, enum: true, protoc_gen_elixir_version: "0.17.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.17.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.17.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.17.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.17.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.17.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.17.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
  field :Subject, 16, type: :string

  field :NamedTags, 17,
    repeated: true,
    type: Cratis.Chronicle.Contracts.Observation.Reactors.NamedTag
end

defmodule Cratis.Chronicle.Contracts.Observation.Reactors.EventRevision do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.17.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.17.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.17.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.17.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.17.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.17.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.17.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.NamedTag do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.17.0", syntax: :proto3

  field :Name, 1, type: :string
  field :Value, 2, type: :string
end

defmodule Cratis.Chronicle.Contracts.Observation.Reactors.ObserverFilters do
  @moduledoc false
  use Protobuf, protoc_gen_elixir_version: "0.17.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.17.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.17.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.17.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.17.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.17.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.17.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.17.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