Packages
cratis_chronicle_contracts
19.4.6
19.71.0
19.70.0
19.69.0
19.68.0
19.67.0
19.66.0
19.65.2
19.65.1
19.65.0
19.64.2
19.64.1
19.64.0
19.63.0
19.62.4
19.62.3
19.62.2
19.62.1
19.62.0
19.61.0
19.60.0
19.59.7
19.59.6
19.59.5
19.59.4
19.59.3
19.59.2
19.59.1
19.59.0
19.58.0
19.57.1
19.57.0
19.56.1
19.56.0
19.55.2
19.55.1
19.55.0
19.54.1
19.54.0
19.53.3
19.53.2
19.53.1
19.53.0
19.52.0
19.51.2
19.51.1
19.51.0
19.50.1
19.50.0
19.49.0
19.48.0
19.47.0
19.46.0
19.45.0
19.44.0
19.43.0
19.42.0
19.41.0
19.40.1
19.40.0
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
Current section
Files
lib/generated/observation.pb.ex
defmodule Cratis.Chronicle.Contracts.Observation.FailureKind do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.17.0", syntax: :proto3
field :FAILURE_KIND_Unknown, 0
field :Handling, 1
field :Timeout, 2
field :FAILURE_KIND_Disconnected, 3
end
defmodule Cratis.Chronicle.Contracts.Observation.ObserverOwner do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.17.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.17.0", syntax: :proto3
field :OBSERVER_RUNNING_STATE_Unknown, 0
field :Active, 1
field :Suspended, 2
field :Replaying, 3
field :OBSERVER_RUNNING_STATE_Disconnected, 4
field :Quarantined, 5
end
defmodule Cratis.Chronicle.Contracts.Observation.ObserverType do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.17.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.PartitionRecoveryOutcome do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.17.0", syntax: :proto3
field :Started, 0
field :PartitionNotFound, 1
field :ObserverQuarantined, 2
field :PartitionQuarantined, 3
end
defmodule Cratis.Chronicle.Contracts.Observation.AllObserversRequest do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.17.0", syntax: :proto3
field :EventStore, 1, type: :string
field :Namespace, 2, type: :string
end
defmodule Cratis.Chronicle.Contracts.Observation.ClearFailedPartitions 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 :ObserverId, 3, type: :string
field :EventSequenceId, 4, type: :string
end
defmodule Cratis.Chronicle.Contracts.Observation.ClearObserverQuarantine 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 :ObserverId, 3, type: :string
field :EventSequenceId, 4, type: :string
end
defmodule Cratis.Chronicle.Contracts.Observation.ConnectedClient do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.17.0", syntax: :proto3
field :ConnectionId, 1, type: :string
field :Version, 2, type: :string
field :LastSeen, 3, type: Cratis.Chronicle.Contracts.Observation.SerializableDateTimeOffset
field :IsRunningWithDebugger, 4, type: :bool
field :SiloAddress, 5, type: :string
field :ProcessId, 6, type: :int32
field :ProcessPath, 7, type: :string
field :MachineName, 8, type: :string
field :ClientType, 9, type: :string
end
defmodule Cratis.Chronicle.Contracts.Observation.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.FailedPartition do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.17.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
field :IsResolved, 5, type: :bool
field :IsQuarantined, 6, type: :bool
end
defmodule Cratis.Chronicle.Contracts.Observation.FailedPartitionAttempt do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.17.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
field :Kind, 5, type: Cratis.Chronicle.Contracts.Observation.FailureKind, enum: true
end
defmodule Cratis.Chronicle.Contracts.Observation.GetConnectedClientsForObserverRequest 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 :ObserverId, 3, type: :string
field :EventSequenceId, 4, type: :string
end
defmodule Cratis.Chronicle.Contracts.Observation.GetFailedPartitionsRequest 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 :ObserverId, 3, type: :string
end
defmodule Cratis.Chronicle.Contracts.Observation.GetObserverInformationRequest 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 :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.17.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_ConnectedClient do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.17.0", syntax: :proto3
field :items, 1, repeated: true, type: Cratis.Chronicle.Contracts.Observation.ConnectedClient
end
defmodule Cratis.Chronicle.Contracts.Observation.IEnumerable_FailedPartition do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.17.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.17.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.17.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
field :TailEventSequenceNumber, 11, type: :uint64
field :HandledEventCount, 12, type: :uint64
end
defmodule Cratis.Chronicle.Contracts.Observation.Replay 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 :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.17.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.ReplayResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.17.0", syntax: :proto3
field :JobId, 1, type: :string
end
defmodule Cratis.Chronicle.Contracts.Observation.RetryPartition 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 :ObserverId, 3, type: :string
field :EventSequenceId, 4, type: :string
field :Partition, 5, type: :string
end
defmodule Cratis.Chronicle.Contracts.Observation.RetryPartitionResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.17.0", syntax: :proto3
field :Outcome, 1,
type: Cratis.Chronicle.Contracts.Observation.PartitionRecoveryOutcome,
enum: true
end
defmodule Cratis.Chronicle.Contracts.Observation.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.WaitForObserverCompletionRequest 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 :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.17.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.17.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.17.0"
rpc :ClearFailedPartitions,
Cratis.Chronicle.Contracts.Observation.ClearFailedPartitions,
Google.Protobuf.Empty
rpc :ClearObserverQuarantine,
Cratis.Chronicle.Contracts.Observation.ClearObserverQuarantine,
Google.Protobuf.Empty
rpc :GetConnectedClientsForObserver,
Cratis.Chronicle.Contracts.Observation.GetConnectedClientsForObserverRequest,
Cratis.Chronicle.Contracts.Observation.IEnumerable_ConnectedClient
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,
Cratis.Chronicle.Contracts.Observation.ReplayResponse
rpc :ReplayPartition,
Cratis.Chronicle.Contracts.Observation.ReplayPartition,
Google.Protobuf.Empty
rpc :RetryPartition,
Cratis.Chronicle.Contracts.Observation.RetryPartition,
Cratis.Chronicle.Contracts.Observation.RetryPartitionResponse
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