defmodule Cratis.Chronicle.Contracts.ReadModels.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.ReadModels.ReadModelObserverType do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :NotSet, 0
field :Reducer, 1
field :Projection, 2
end
defmodule Cratis.Chronicle.Contracts.ReadModels.ReadModelOwner do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :READ_MODEL_OWNER_None, 0
field :Client, 1
field :Server, 2
end
defmodule Cratis.Chronicle.Contracts.ReadModels.ReadModelSource do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :Unknown, 0
field :Code, 1
field :User, 2
end
defmodule Cratis.Chronicle.Contracts.ReadModels.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.ReadModels.AppendedEvent do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :Context, 1, type: Cratis.Chronicle.Contracts.ReadModels.EventContext
field :Content, 2, type: :string
field :OriginalContent, 3, type: :string
field :Revisions, 4, repeated: true, type: Cratis.Chronicle.Contracts.ReadModels.EventRevision
field :GenerationalContent, 5,
repeated: true,
type: Cratis.Chronicle.Contracts.ReadModels.AppendedEvent.GenerationalContentEntry,
map: true
end
defmodule Cratis.Chronicle.Contracts.ReadModels.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.ReadModels.Causation do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :Occurred, 1, type: Cratis.Chronicle.Contracts.ReadModels.SerializableDateTimeOffset
field :Type, 2, type: :string
field :Properties, 3,
repeated: true,
type: Cratis.Chronicle.Contracts.ReadModels.Causation.PropertiesEntry,
map: true
end
defmodule Cratis.Chronicle.Contracts.ReadModels.DehydrateSessionRequest 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 :ReadModelIdentifier, 3, type: :string
field :EventSequenceId, 4, type: :string
field :ReadModelKey, 5, type: :string
field :SessionId, 6, type: :string
end
defmodule Cratis.Chronicle.Contracts.ReadModels.EventContext do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :EventType, 1, type: Cratis.Chronicle.Contracts.ReadModels.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.ReadModels.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.ReadModels.Causation
field :CausedBy, 12, type: Cratis.Chronicle.Contracts.ReadModels.Identity
field :ObservationState, 13,
type: Cratis.Chronicle.Contracts.ReadModels.EventObservationState,
enum: true
field :Tags, 14, repeated: true, type: :string
field :Hash, 15, type: :string
end
defmodule Cratis.Chronicle.Contracts.ReadModels.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.ReadModels.Identity
field :Occurred, 4, type: Cratis.Chronicle.Contracts.ReadModels.SerializableDateTimeOffset
field :Content, 5, type: :string
end
defmodule Cratis.Chronicle.Contracts.ReadModels.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.ReadModels.GetAllInstancesRequest 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 :ReadModelIdentifier, 3, type: :string
field :EventSequenceId, 4, type: :string
field :EventCount, 5, type: :uint64
end
defmodule Cratis.Chronicle.Contracts.ReadModels.GetAllInstancesResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :Instances, 1, repeated: true, type: :string
field :ProcessedEventsCount, 2, type: :uint64
end
defmodule Cratis.Chronicle.Contracts.ReadModels.GetDefinitionsRequest do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :EventStore, 1, type: :string
end
defmodule Cratis.Chronicle.Contracts.ReadModels.GetDefinitionsResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :ReadModels, 1,
repeated: true,
type: Cratis.Chronicle.Contracts.ReadModels.ReadModelDefinition
end
defmodule Cratis.Chronicle.Contracts.ReadModels.GetInstanceByKeyRequest 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 :ReadModelIdentifier, 3, type: :string
field :EventSequenceId, 4, type: :string
field :ReadModelKey, 5, type: :string
field :SessionId, 6, type: :string
end
defmodule Cratis.Chronicle.Contracts.ReadModels.GetInstanceByKeyResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :ReadModel, 1, type: :string
field :ProjectedEventsCount, 2, type: :uint64
field :LastHandledEventSequenceNumber, 3, type: :uint64
end
defmodule Cratis.Chronicle.Contracts.ReadModels.GetInstancesRequest 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 :ReadModel, 3, type: :string
field :Occurrence, 4, type: :string
field :Page, 5, type: :int32
field :PageSize, 6, type: :int32
end
defmodule Cratis.Chronicle.Contracts.ReadModels.GetInstancesResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :Instances, 1, repeated: true, type: :string
field :TotalCount, 2, type: :int64
field :Page, 3, type: :int32
field :PageSize, 4, type: :int32
end
defmodule Cratis.Chronicle.Contracts.ReadModels.GetOccurrencesRequest 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 :Type, 3, type: Cratis.Chronicle.Contracts.ReadModels.ReadModelType
end
defmodule Cratis.Chronicle.Contracts.ReadModels.GetOccurrencesResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :Occurrences, 1,
repeated: true,
type: Cratis.Chronicle.Contracts.ReadModels.ReadModelOccurrence
end
defmodule Cratis.Chronicle.Contracts.ReadModels.GetSnapshotsByKeyRequest 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 :ReadModelIdentifier, 3, type: :string
field :EventSequenceId, 4, type: :string
field :ReadModelKey, 5, type: :string
end
defmodule Cratis.Chronicle.Contracts.ReadModels.GetSnapshotsByKeyResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :Snapshots, 1,
repeated: true,
type: Cratis.Chronicle.Contracts.ReadModels.ReadModelSnapshot
end
defmodule Cratis.Chronicle.Contracts.ReadModels.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.ReadModels.Identity
end
defmodule Cratis.Chronicle.Contracts.ReadModels.IndexDefinition do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :PropertyPath, 1, type: :string
end
defmodule Cratis.Chronicle.Contracts.ReadModels.ReadModelChangeset do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :Namespace, 1, type: :string
field :ModelKey, 2, type: :string
field :ReadModel, 3, type: :string
field :Removed, 4, type: :bool
end
defmodule Cratis.Chronicle.Contracts.ReadModels.ReadModelDefinition do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :Type, 1, type: Cratis.Chronicle.Contracts.ReadModels.ReadModelType
field :ContainerName, 2, type: :string
field :DisplayName, 3, type: :string
field :Sink, 4, type: Cratis.Chronicle.Contracts.ReadModels.SinkDefinition
field :Schema, 5, type: :string
field :Indexes, 6, repeated: true, type: Cratis.Chronicle.Contracts.ReadModels.IndexDefinition
field :ObserverType, 7,
type: Cratis.Chronicle.Contracts.ReadModels.ReadModelObserverType,
enum: true
field :ObserverIdentifier, 8, type: :string
field :Owner, 9, type: Cratis.Chronicle.Contracts.ReadModels.ReadModelOwner, enum: true
field :Source, 10, type: Cratis.Chronicle.Contracts.ReadModels.ReadModelSource, enum: true
end
defmodule Cratis.Chronicle.Contracts.ReadModels.ReadModelOccurrence do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :ObserverId, 1, type: :string
field :Occurred, 2, type: Cratis.Chronicle.Contracts.ReadModels.SerializableDateTimeOffset
field :Type, 3, type: Cratis.Chronicle.Contracts.ReadModels.ReadModelType
field :ContainerName, 4, type: :string
field :RevertContainerName, 5, type: :string
end
defmodule Cratis.Chronicle.Contracts.ReadModels.ReadModelSnapshot do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :ReadModel, 1, type: :string
field :Events, 2, repeated: true, type: Cratis.Chronicle.Contracts.ReadModels.AppendedEvent
field :Occurred, 3, type: Cratis.Chronicle.Contracts.ReadModels.SerializableDateTimeOffset
field :CorrelationId, 4, type: Bcl.Guid
end
defmodule Cratis.Chronicle.Contracts.ReadModels.ReadModelType do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :Identifier, 1, type: :string
field :Generation, 2, type: :uint32
end
defmodule Cratis.Chronicle.Contracts.ReadModels.RegisterManyRequest do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :EventStore, 1, type: :string
field :Owner, 2, type: Cratis.Chronicle.Contracts.ReadModels.ReadModelOwner, enum: true
field :ReadModels, 3,
repeated: true,
type: Cratis.Chronicle.Contracts.ReadModels.ReadModelDefinition
field :Source, 4, type: Cratis.Chronicle.Contracts.ReadModels.ReadModelSource, enum: true
end
defmodule Cratis.Chronicle.Contracts.ReadModels.RegisterSingleRequest do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :EventStore, 1, type: :string
field :Owner, 2, type: Cratis.Chronicle.Contracts.ReadModels.ReadModelOwner, enum: true
field :ReadModel, 3, type: Cratis.Chronicle.Contracts.ReadModels.ReadModelDefinition
field :Source, 4, type: Cratis.Chronicle.Contracts.ReadModels.ReadModelSource, enum: true
end
defmodule Cratis.Chronicle.Contracts.ReadModels.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.ReadModels.SinkDefinition do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :ConfigurationId, 1, type: Bcl.Guid
field :TypeId, 2, type: Bcl.Guid
end
defmodule Cratis.Chronicle.Contracts.ReadModels.UpdateDefinitionRequest do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.16.0", syntax: :proto3
field :EventStore, 1, type: :string
field :ReadModel, 2, type: Cratis.Chronicle.Contracts.ReadModels.ReadModelDefinition
end
defmodule Cratis.Chronicle.Contracts.ReadModels.WatchRequest 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 :ReadModelIdentifier, 3, type: :string
field :EventSequenceId, 4, type: :string
end
defmodule Cratis.Chronicle.Contracts.ReadModels.ReadModels.Service do
@moduledoc false
use GRPC.Service,
name: "Cratis.Chronicle.Contracts.ReadModels.ReadModels",
protoc_gen_elixir_version: "0.16.0"
rpc :DehydrateSession,
Cratis.Chronicle.Contracts.ReadModels.DehydrateSessionRequest,
Google.Protobuf.Empty
rpc :GetAllInstances,
Cratis.Chronicle.Contracts.ReadModels.GetAllInstancesRequest,
Cratis.Chronicle.Contracts.ReadModels.GetAllInstancesResponse
rpc :GetDefinitions,
Cratis.Chronicle.Contracts.ReadModels.GetDefinitionsRequest,
Cratis.Chronicle.Contracts.ReadModels.GetDefinitionsResponse
rpc :GetInstanceByKey,
Cratis.Chronicle.Contracts.ReadModels.GetInstanceByKeyRequest,
Cratis.Chronicle.Contracts.ReadModels.GetInstanceByKeyResponse
rpc :GetInstances,
Cratis.Chronicle.Contracts.ReadModels.GetInstancesRequest,
Cratis.Chronicle.Contracts.ReadModels.GetInstancesResponse
rpc :GetOccurrences,
Cratis.Chronicle.Contracts.ReadModels.GetOccurrencesRequest,
Cratis.Chronicle.Contracts.ReadModels.GetOccurrencesResponse
rpc :GetSnapshotsByKey,
Cratis.Chronicle.Contracts.ReadModels.GetSnapshotsByKeyRequest,
Cratis.Chronicle.Contracts.ReadModels.GetSnapshotsByKeyResponse
rpc :RegisterMany,
Cratis.Chronicle.Contracts.ReadModels.RegisterManyRequest,
Google.Protobuf.Empty
rpc :RegisterSingle,
Cratis.Chronicle.Contracts.ReadModels.RegisterSingleRequest,
Google.Protobuf.Empty
rpc :UpdateDefinition,
Cratis.Chronicle.Contracts.ReadModels.UpdateDefinitionRequest,
Google.Protobuf.Empty
rpc :Watch,
Cratis.Chronicle.Contracts.ReadModels.WatchRequest,
stream(Cratis.Chronicle.Contracts.ReadModels.ReadModelChangeset)
end
defmodule Cratis.Chronicle.Contracts.ReadModels.ReadModels.Stub do
@moduledoc false
use GRPC.Stub, service: Cratis.Chronicle.Contracts.ReadModels.ReadModels.Service
end