cratis_chronicle_contracts

16.0.3

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 Chronicle

HexDocs

Current section

Files

Jump to

Readme 87 Versions 3 Dependencies Dependants Files Activity

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 :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.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
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.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

Operator	Description	Example
name:	Match package name. Supports * wildcards and repo/package form	name:phx* or name:hexpm/phoenix
description:	Full-text search of package descriptions	description:auth
depends:	Packages depending on a given package. Supports repo:package form	depends:ecto or depends:hexpm:ecto
build_tool:	Filter by build tool	build_tool:mix
updated_after:	Packages updated after an ISO8601 datetime	updated_after:2025-01-01T00:00:00Z
extra:	Match custom metadata (key,value). Nested keys are separated by commas	extra:license,MIT