cratis_chronicle_contracts

15.26.8

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.pb.ex

Raw

lib/generated/observation.pb.ex

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

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

  use GRPC.Stub, service: Cratis.Chronicle.Contracts.Observation.Observers.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