uma_db_client

# Generated from umadb-proto 0.6.7 proto/v1/umadb.proto (package umadb.v1)
# To regenerate:
#   protoc --elixir_out=plugins=grpc:./lib \
#          --proto_path=<path-to-proto-dir> \
#          umadb/v1/umadb.proto

defmodule UmaDb.V1.ErrorResponse.ErrorType do
  use Protobuf, enum: true, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:IO, 0)
  field(:SERIALIZATION, 1)
  field(:INTEGRITY, 2)
  field(:CORRUPTION, 3)
  field(:INTERNAL, 4)
  field(:AUTHENTICATION, 5)
  field(:INVALID_ARGUMENT, 6)
end

defmodule UmaDb.V1.Event do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:event_type, 1, type: :string, json_name: "eventType")
  field(:tags, 2, repeated: true, type: :string)
  field(:data, 3, type: :bytes)
  field(:uuid, 4, type: :string)
  field(:metadata, 5, repeated: true, type: UmaDb.V1.MetadataEntry)
end

defmodule UmaDb.V1.MetadataEntry do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:key, 1, type: :string)
  field(:value, 2, type: :string)
end

defmodule UmaDb.V1.SequencedEvent do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:position, 1, type: :uint64)
  field(:event, 2, type: UmaDb.V1.Event)
end

defmodule UmaDb.V1.QueryItem do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:types, 1, repeated: true, type: :string)
  field(:tags, 2, repeated: true, type: :string)
end

defmodule UmaDb.V1.Query do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:items, 1, repeated: true, type: UmaDb.V1.QueryItem)
end

defmodule UmaDb.V1.AppendCondition do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:fail_if_events_match, 1,
    proto3_optional: true,
    type: UmaDb.V1.Query,
    json_name: "failIfEventsMatch"
  )

  field(:after, 2, proto3_optional: true, type: :uint64)
end

defmodule UmaDb.V1.ReadRequest do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:query, 1, proto3_optional: true, type: UmaDb.V1.Query)
  field(:start, 2, proto3_optional: true, type: :uint64)
  field(:backwards, 3, proto3_optional: true, type: :bool)
  field(:limit, 4, proto3_optional: true, type: :uint32)
  field(:subscribe, 5, proto3_optional: true, type: :bool, deprecated: true)
  field(:batch_size, 6, proto3_optional: true, type: :uint32, json_name: "batchSize")
end

defmodule UmaDb.V1.ReadResponse do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:events, 1, repeated: true, type: UmaDb.V1.SequencedEvent)
  field(:head, 2, proto3_optional: true, type: :uint64)
end

defmodule UmaDb.V1.SubscribeRequest do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:query, 1, proto3_optional: true, type: UmaDb.V1.Query)
  field(:after, 2, proto3_optional: true, type: :uint64)
  field(:batch_size, 3, proto3_optional: true, type: :uint32, json_name: "batchSize")
end

defmodule UmaDb.V1.SubscribeResponse do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:events, 1, repeated: true, type: UmaDb.V1.SequencedEvent)
end

defmodule UmaDb.V1.TrackingInfo do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:source, 1, type: :string)
  field(:position, 2, type: :uint64)
end

defmodule UmaDb.V1.AppendRequest do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:events, 1, repeated: true, type: UmaDb.V1.Event)
  field(:condition, 2, proto3_optional: true, type: UmaDb.V1.AppendCondition)

  field(:tracking_info, 3,
    proto3_optional: true,
    type: UmaDb.V1.TrackingInfo,
    json_name: "trackingInfo"
  )
end

defmodule UmaDb.V1.AppendResponse do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:position, 1, type: :uint64)
end

defmodule UmaDb.V1.HeadRequest do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"
end

defmodule UmaDb.V1.HeadResponse do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:position, 1, proto3_optional: true, type: :uint64)
end

defmodule UmaDb.V1.TrackingRequest do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:source, 1, type: :string)
end

defmodule UmaDb.V1.TrackingResponse do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:position, 1, proto3_optional: true, type: :uint64)
end

defmodule UmaDb.V1.ErrorResponse do
  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field(:message, 1, type: :string)

  field(:error_type, 2,
    type: UmaDb.V1.ErrorResponse.ErrorType,
    enum: true,
    json_name: "errorType"
  )
end

defmodule UmaDb.V1.DCB.Service do
  use GRPC.Service, name: "umadb.v1.DCB", protoc_gen_elixir_version: "0.12.0"

  rpc(:Read, UmaDb.V1.ReadRequest, stream(UmaDb.V1.ReadResponse))
  rpc(:Subscribe, UmaDb.V1.SubscribeRequest, stream(UmaDb.V1.SubscribeResponse))
  rpc(:Append, UmaDb.V1.AppendRequest, UmaDb.V1.AppendResponse)
  rpc(:Head, UmaDb.V1.HeadRequest, UmaDb.V1.HeadResponse)
  rpc(:GetTrackingInfo, UmaDb.V1.TrackingRequest, UmaDb.V1.TrackingResponse)
end

defmodule UmaDb.V1.DCB.Stub do
  use GRPC.Stub, service: UmaDb.V1.DCB.Service
end