Sources/ApacheBeam/Generated/Model/org/apache/beam/model/job_management/v1/beam_artifact_api.pb.swift

// DO NOT EDIT.
// swift-format-ignore-file
//
// Generated by the Swift generator plugin for the protocol buffer compiler.
// Source: org/apache/beam/model/job_management/v1/beam_artifact_api.proto
//
// For information on using the generated types, please see the documentation:
//   https://github.com/apple/swift-protobuf/

//
// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements.  See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership.  The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License.  You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

//
// Protocol Buffers describing the Artifact API, for communicating with a runner
// for artifact staging and retrieval over GRPC.

import Foundation
import SwiftProtobuf

// If the compiler emits an error on this type, it is because this file
// was generated by a version of the `protoc` Swift plug-in that is
// incompatible with the version of SwiftProtobuf to which you are linking.
// Please ensure that you are building against the same version of the API
// that was used to generate this file.
fileprivate struct _GeneratedWithProtocGenSwiftVersion: SwiftProtobuf.ProtobufAPIVersionCheck {
  struct _2: SwiftProtobuf.ProtobufAPIVersion_2 {}
  typealias Version = _2
}

/// A request for artifact resolution.
struct Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsRequest {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  /// An (ordered) set of artifacts to (jointly) resolve.
  var artifacts: [Org_Apache_Beam_Model_Pipeline_V1_ArtifactInformation] = []

  /// A set of artifact type urns that are understood by the requester.
  /// An attempt should be made to resolve the artifacts in terms of these URNs,
  /// but other URNs may be used as well with the understanding that they must
  /// be fetch-able as bytes via GetArtifact.
  var preferredUrns: [String] = []

  var unknownFields = SwiftProtobuf.UnknownStorage()

  init() {}
}

/// A response for artifact resolution.
struct Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsResponse {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  /// A full (ordered) set of replacements for the set of requested artifacts,
  /// preferably in terms of the requested type URNs.  If there is no better
  /// resolution, the original list is returned.
  var replacements: [Org_Apache_Beam_Model_Pipeline_V1_ArtifactInformation] = []

  var unknownFields = SwiftProtobuf.UnknownStorage()

  init() {}
}

/// A request to get an artifact.
struct Org_Apache_Beam_Model_JobManagement_V1_GetArtifactRequest {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  var artifact: Org_Apache_Beam_Model_Pipeline_V1_ArtifactInformation {
    get {return _artifact ?? Org_Apache_Beam_Model_Pipeline_V1_ArtifactInformation()}
    set {_artifact = newValue}
  }
  /// Returns true if `artifact` has been explicitly set.
  var hasArtifact: Bool {return self._artifact != nil}
  /// Clears the value of `artifact`. Subsequent reads from it will return its default value.
  mutating func clearArtifact() {self._artifact = nil}

  var unknownFields = SwiftProtobuf.UnknownStorage()

  init() {}

  fileprivate var _artifact: Org_Apache_Beam_Model_Pipeline_V1_ArtifactInformation? = nil
}

/// Part of a response to getting an artifact.
struct Org_Apache_Beam_Model_JobManagement_V1_GetArtifactResponse {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  var data: Data = Data()

  var unknownFields = SwiftProtobuf.UnknownStorage()

  init() {}
}

/// Wraps an ArtifactRetrievalService request for use in ReverseArtifactRetrievalService.
struct Org_Apache_Beam_Model_JobManagement_V1_ArtifactRequestWrapper {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  var request: Org_Apache_Beam_Model_JobManagement_V1_ArtifactRequestWrapper.OneOf_Request? = nil

  var resolveArtifact: Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsRequest {
    get {
      if case .resolveArtifact(let v)? = request {return v}
      return Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsRequest()
    }
    set {request = .resolveArtifact(newValue)}
  }

  var getArtifact: Org_Apache_Beam_Model_JobManagement_V1_GetArtifactRequest {
    get {
      if case .getArtifact(let v)? = request {return v}
      return Org_Apache_Beam_Model_JobManagement_V1_GetArtifactRequest()
    }
    set {request = .getArtifact(newValue)}
  }

  var unknownFields = SwiftProtobuf.UnknownStorage()

  enum OneOf_Request: Equatable {
    case resolveArtifact(Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsRequest)
    case getArtifact(Org_Apache_Beam_Model_JobManagement_V1_GetArtifactRequest)

  #if !swift(>=4.1)
    static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_ArtifactRequestWrapper.OneOf_Request, rhs: Org_Apache_Beam_Model_JobManagement_V1_ArtifactRequestWrapper.OneOf_Request) -> Bool {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch (lhs, rhs) {
      case (.resolveArtifact, .resolveArtifact): return {
        guard case .resolveArtifact(let l) = lhs, case .resolveArtifact(let r) = rhs else { preconditionFailure() }
        return l == r
      }()
      case (.getArtifact, .getArtifact): return {
        guard case .getArtifact(let l) = lhs, case .getArtifact(let r) = rhs else { preconditionFailure() }
        return l == r
      }()
      default: return false
      }
    }
  #endif
  }

  init() {}
}

/// Wraps an ArtifactRetrievalService response for use in ReverseArtifactRetrievalService.
struct Org_Apache_Beam_Model_JobManagement_V1_ArtifactResponseWrapper {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  /// A token indicating which job these artifacts are being staged for.
  var stagingToken: String = String()

  /// Whether this is the last response for this request (for those responses that
  /// would typically be terminated by the end of the response stream.)
  var isLast: Bool = false

  /// The response itself.
  var response: Org_Apache_Beam_Model_JobManagement_V1_ArtifactResponseWrapper.OneOf_Response? = nil

  var resolveArtifactResponse: Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsResponse {
    get {
      if case .resolveArtifactResponse(let v)? = response {return v}
      return Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsResponse()
    }
    set {response = .resolveArtifactResponse(newValue)}
  }

  var getArtifactResponse: Org_Apache_Beam_Model_JobManagement_V1_GetArtifactResponse {
    get {
      if case .getArtifactResponse(let v)? = response {return v}
      return Org_Apache_Beam_Model_JobManagement_V1_GetArtifactResponse()
    }
    set {response = .getArtifactResponse(newValue)}
  }

  var unknownFields = SwiftProtobuf.UnknownStorage()

  /// The response itself.
  enum OneOf_Response: Equatable {
    case resolveArtifactResponse(Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsResponse)
    case getArtifactResponse(Org_Apache_Beam_Model_JobManagement_V1_GetArtifactResponse)

  #if !swift(>=4.1)
    static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_ArtifactResponseWrapper.OneOf_Response, rhs: Org_Apache_Beam_Model_JobManagement_V1_ArtifactResponseWrapper.OneOf_Response) -> Bool {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch (lhs, rhs) {
      case (.resolveArtifactResponse, .resolveArtifactResponse): return {
        guard case .resolveArtifactResponse(let l) = lhs, case .resolveArtifactResponse(let r) = rhs else { preconditionFailure() }
        return l == r
      }()
      case (.getArtifactResponse, .getArtifactResponse): return {
        guard case .getArtifactResponse(let l) = lhs, case .getArtifactResponse(let r) = rhs else { preconditionFailure() }
        return l == r
      }()
      default: return false
      }
    }
  #endif
  }

  init() {}
}

/// An artifact identifier and associated metadata.
struct Org_Apache_Beam_Model_JobManagement_V1_ArtifactMetadata {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  /// (Required) The name of the artifact.
  var name: String = String()

  /// (Optional) The Unix-like permissions of the artifact
  var permissions: UInt32 = 0

  /// (Optional) The hex-encoded sha256 checksum of the artifact. Used, among other things, by
  /// harness boot code to validate the integrity of the artifact.
  var sha256: String = String()

  var unknownFields = SwiftProtobuf.UnknownStorage()

  init() {}
}

/// A collection of artifacts.
struct Org_Apache_Beam_Model_JobManagement_V1_Manifest {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  var artifact: [Org_Apache_Beam_Model_JobManagement_V1_ArtifactMetadata] = []

  var unknownFields = SwiftProtobuf.UnknownStorage()

  init() {}
}

/// A manifest with location information.
struct Org_Apache_Beam_Model_JobManagement_V1_ProxyManifest {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  var manifest: Org_Apache_Beam_Model_JobManagement_V1_Manifest {
    get {return _manifest ?? Org_Apache_Beam_Model_JobManagement_V1_Manifest()}
    set {_manifest = newValue}
  }
  /// Returns true if `manifest` has been explicitly set.
  var hasManifest: Bool {return self._manifest != nil}
  /// Clears the value of `manifest`. Subsequent reads from it will return its default value.
  mutating func clearManifest() {self._manifest = nil}

  var location: [Org_Apache_Beam_Model_JobManagement_V1_ProxyManifest.Location] = []

  var unknownFields = SwiftProtobuf.UnknownStorage()

  struct Location {
    // SwiftProtobuf.Message conformance is added in an extension below. See the
    // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
    // methods supported on all messages.

    var name: String = String()

    var uri: String = String()

    var unknownFields = SwiftProtobuf.UnknownStorage()

    init() {}
  }

  init() {}

  fileprivate var _manifest: Org_Apache_Beam_Model_JobManagement_V1_Manifest? = nil
}

/// A request to get the manifest of a Job.
struct Org_Apache_Beam_Model_JobManagement_V1_GetManifestRequest {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  /// (Required) An opaque token representing the entirety of the staged artifacts.
  /// Returned in CommitManifestResponse.
  var retrievalToken: String = String()

  var unknownFields = SwiftProtobuf.UnknownStorage()

  init() {}
}

/// A response containing a job manifest.
struct Org_Apache_Beam_Model_JobManagement_V1_GetManifestResponse {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  var manifest: Org_Apache_Beam_Model_JobManagement_V1_Manifest {
    get {return _manifest ?? Org_Apache_Beam_Model_JobManagement_V1_Manifest()}
    set {_manifest = newValue}
  }
  /// Returns true if `manifest` has been explicitly set.
  var hasManifest: Bool {return self._manifest != nil}
  /// Clears the value of `manifest`. Subsequent reads from it will return its default value.
  mutating func clearManifest() {self._manifest = nil}

  var unknownFields = SwiftProtobuf.UnknownStorage()

  init() {}

  fileprivate var _manifest: Org_Apache_Beam_Model_JobManagement_V1_Manifest? = nil
}

/// A request to get an artifact. The artifact must be present in the manifest for the job.
struct Org_Apache_Beam_Model_JobManagement_V1_LegacyGetArtifactRequest {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  /// (Required) The name of the artifact to retrieve.
  var name: String = String()

  /// (Required) An opaque token representing the entirety of the staged artifacts.
  /// Returned in CommitManifestResponse.
  var retrievalToken: String = String()

  var unknownFields = SwiftProtobuf.UnknownStorage()

  init() {}
}

/// Part of an artifact.
struct Org_Apache_Beam_Model_JobManagement_V1_ArtifactChunk {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  var data: Data = Data()

  var unknownFields = SwiftProtobuf.UnknownStorage()

  init() {}
}

struct Org_Apache_Beam_Model_JobManagement_V1_PutArtifactMetadata {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  /// (Required) A token for artifact staging session. This token can be obtained
  /// from PrepareJob request in JobService
  var stagingSessionToken: String = String()

  /// (Required) The Artifact metadata.
  var metadata: Org_Apache_Beam_Model_JobManagement_V1_ArtifactMetadata {
    get {return _metadata ?? Org_Apache_Beam_Model_JobManagement_V1_ArtifactMetadata()}
    set {_metadata = newValue}
  }
  /// Returns true if `metadata` has been explicitly set.
  var hasMetadata: Bool {return self._metadata != nil}
  /// Clears the value of `metadata`. Subsequent reads from it will return its default value.
  mutating func clearMetadata() {self._metadata = nil}

  var unknownFields = SwiftProtobuf.UnknownStorage()

  init() {}

  fileprivate var _metadata: Org_Apache_Beam_Model_JobManagement_V1_ArtifactMetadata? = nil
}

/// A request to stage an artifact.
struct Org_Apache_Beam_Model_JobManagement_V1_PutArtifactRequest {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  /// (Required)
  var content: Org_Apache_Beam_Model_JobManagement_V1_PutArtifactRequest.OneOf_Content? = nil

  /// The first message in a PutArtifact call must contain this field.
  var metadata: Org_Apache_Beam_Model_JobManagement_V1_PutArtifactMetadata {
    get {
      if case .metadata(let v)? = content {return v}
      return Org_Apache_Beam_Model_JobManagement_V1_PutArtifactMetadata()
    }
    set {content = .metadata(newValue)}
  }

  /// A chunk of the artifact. All messages after the first in a PutArtifact call must contain a
  /// chunk.
  var data: Org_Apache_Beam_Model_JobManagement_V1_ArtifactChunk {
    get {
      if case .data(let v)? = content {return v}
      return Org_Apache_Beam_Model_JobManagement_V1_ArtifactChunk()
    }
    set {content = .data(newValue)}
  }

  var unknownFields = SwiftProtobuf.UnknownStorage()

  /// (Required)
  enum OneOf_Content: Equatable {
    /// The first message in a PutArtifact call must contain this field.
    case metadata(Org_Apache_Beam_Model_JobManagement_V1_PutArtifactMetadata)
    /// A chunk of the artifact. All messages after the first in a PutArtifact call must contain a
    /// chunk.
    case data(Org_Apache_Beam_Model_JobManagement_V1_ArtifactChunk)

  #if !swift(>=4.1)
    static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_PutArtifactRequest.OneOf_Content, rhs: Org_Apache_Beam_Model_JobManagement_V1_PutArtifactRequest.OneOf_Content) -> Bool {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch (lhs, rhs) {
      case (.metadata, .metadata): return {
        guard case .metadata(let l) = lhs, case .metadata(let r) = rhs else { preconditionFailure() }
        return l == r
      }()
      case (.data, .data): return {
        guard case .data(let l) = lhs, case .data(let r) = rhs else { preconditionFailure() }
        return l == r
      }()
      default: return false
      }
    }
  #endif
  }

  init() {}
}

struct Org_Apache_Beam_Model_JobManagement_V1_PutArtifactResponse {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  var unknownFields = SwiftProtobuf.UnknownStorage()

  init() {}
}

/// A request to commit the manifest for a Job. All artifacts must have been successfully uploaded
/// before this call is made.
struct Org_Apache_Beam_Model_JobManagement_V1_CommitManifestRequest {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  /// (Required) The manifest to commit.
  var manifest: Org_Apache_Beam_Model_JobManagement_V1_Manifest {
    get {return _manifest ?? Org_Apache_Beam_Model_JobManagement_V1_Manifest()}
    set {_manifest = newValue}
  }
  /// Returns true if `manifest` has been explicitly set.
  var hasManifest: Bool {return self._manifest != nil}
  /// Clears the value of `manifest`. Subsequent reads from it will return its default value.
  mutating func clearManifest() {self._manifest = nil}

  /// (Required) A token for artifact staging session. This token can be obtained
  /// from PrepareJob request in JobService
  var stagingSessionToken: String = String()

  var unknownFields = SwiftProtobuf.UnknownStorage()

  init() {}

  fileprivate var _manifest: Org_Apache_Beam_Model_JobManagement_V1_Manifest? = nil
}

/// The result of committing a manifest.
struct Org_Apache_Beam_Model_JobManagement_V1_CommitManifestResponse {
  // SwiftProtobuf.Message conformance is added in an extension below. See the
  // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
  // methods supported on all messages.

  /// (Required) An opaque token representing the entirety of the staged artifacts.
  /// This can be used to retrieve the manifest and artifacts from an associated
  /// LegacyArtifactRetrievalService.
  var retrievalToken: String = String()

  var unknownFields = SwiftProtobuf.UnknownStorage()

  enum Constants: SwiftProtobuf.Enum {
    typealias RawValue = Int

    /// Token indicating that no artifacts were staged and therefore no retrieval attempt is necessary.
    case noArtifactsStagedToken // = 0
    case UNRECOGNIZED(Int)

    init() {
      self = .noArtifactsStagedToken
    }

    init?(rawValue: Int) {
      switch rawValue {
      case 0: self = .noArtifactsStagedToken
      default: self = .UNRECOGNIZED(rawValue)
      }
    }

    var rawValue: Int {
      switch self {
      case .noArtifactsStagedToken: return 0
      case .UNRECOGNIZED(let i): return i
      }
    }

  }

  init() {}
}

#if swift(>=4.2)

extension Org_Apache_Beam_Model_JobManagement_V1_CommitManifestResponse.Constants: CaseIterable {
  // The compiler won't synthesize support with the UNRECOGNIZED case.
  static var allCases: [Org_Apache_Beam_Model_JobManagement_V1_CommitManifestResponse.Constants] = [
    .noArtifactsStagedToken,
  ]
}

#endif  // swift(>=4.2)

#if swift(>=5.5) && canImport(_Concurrency)
extension Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsRequest: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsResponse: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_GetArtifactRequest: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_GetArtifactResponse: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_ArtifactRequestWrapper: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_ArtifactRequestWrapper.OneOf_Request: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_ArtifactResponseWrapper: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_ArtifactResponseWrapper.OneOf_Response: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_ArtifactMetadata: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_Manifest: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_ProxyManifest: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_ProxyManifest.Location: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_GetManifestRequest: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_GetManifestResponse: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_LegacyGetArtifactRequest: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_ArtifactChunk: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_PutArtifactMetadata: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_PutArtifactRequest: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_PutArtifactRequest.OneOf_Content: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_PutArtifactResponse: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_CommitManifestRequest: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_CommitManifestResponse: @unchecked Sendable {}
extension Org_Apache_Beam_Model_JobManagement_V1_CommitManifestResponse.Constants: @unchecked Sendable {}
#endif  // swift(>=5.5) && canImport(_Concurrency)

// MARK: - Code below here is support for the SwiftProtobuf runtime.

fileprivate let _protobuf_package = "org.apache.beam.model.job_management.v1"

extension Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsRequest: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".ResolveArtifactsRequest"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .same(proto: "artifacts"),
    2: .standard(proto: "preferred_urns"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try { try decoder.decodeRepeatedMessageField(value: &self.artifacts) }()
      case 2: try { try decoder.decodeRepeatedStringField(value: &self.preferredUrns) }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    if !self.artifacts.isEmpty {
      try visitor.visitRepeatedMessageField(value: self.artifacts, fieldNumber: 1)
    }
    if !self.preferredUrns.isEmpty {
      try visitor.visitRepeatedStringField(value: self.preferredUrns, fieldNumber: 2)
    }
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsRequest, rhs: Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsRequest) -> Bool {
    if lhs.artifacts != rhs.artifacts {return false}
    if lhs.preferredUrns != rhs.preferredUrns {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsResponse: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".ResolveArtifactsResponse"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .same(proto: "replacements"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try { try decoder.decodeRepeatedMessageField(value: &self.replacements) }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    if !self.replacements.isEmpty {
      try visitor.visitRepeatedMessageField(value: self.replacements, fieldNumber: 1)
    }
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsResponse, rhs: Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsResponse) -> Bool {
    if lhs.replacements != rhs.replacements {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_GetArtifactRequest: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".GetArtifactRequest"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .same(proto: "artifact"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try { try decoder.decodeSingularMessageField(value: &self._artifact) }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    // The use of inline closures is to circumvent an issue where the compiler
    // allocates stack space for every if/case branch local when no optimizations
    // are enabled. https://github.com/apple/swift-protobuf/issues/1034 and
    // https://github.com/apple/swift-protobuf/issues/1182
    try { if let v = self._artifact {
      try visitor.visitSingularMessageField(value: v, fieldNumber: 1)
    } }()
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_GetArtifactRequest, rhs: Org_Apache_Beam_Model_JobManagement_V1_GetArtifactRequest) -> Bool {
    if lhs._artifact != rhs._artifact {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_GetArtifactResponse: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".GetArtifactResponse"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .same(proto: "data"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try { try decoder.decodeSingularBytesField(value: &self.data) }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    if !self.data.isEmpty {
      try visitor.visitSingularBytesField(value: self.data, fieldNumber: 1)
    }
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_GetArtifactResponse, rhs: Org_Apache_Beam_Model_JobManagement_V1_GetArtifactResponse) -> Bool {
    if lhs.data != rhs.data {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_ArtifactRequestWrapper: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".ArtifactRequestWrapper"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1000: .standard(proto: "resolve_artifact"),
    1001: .standard(proto: "get_artifact"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1000: try {
        var v: Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsRequest?
        var hadOneofValue = false
        if let current = self.request {
          hadOneofValue = true
          if case .resolveArtifact(let m) = current {v = m}
        }
        try decoder.decodeSingularMessageField(value: &v)
        if let v = v {
          if hadOneofValue {try decoder.handleConflictingOneOf()}
          self.request = .resolveArtifact(v)
        }
      }()
      case 1001: try {
        var v: Org_Apache_Beam_Model_JobManagement_V1_GetArtifactRequest?
        var hadOneofValue = false
        if let current = self.request {
          hadOneofValue = true
          if case .getArtifact(let m) = current {v = m}
        }
        try decoder.decodeSingularMessageField(value: &v)
        if let v = v {
          if hadOneofValue {try decoder.handleConflictingOneOf()}
          self.request = .getArtifact(v)
        }
      }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    // The use of inline closures is to circumvent an issue where the compiler
    // allocates stack space for every if/case branch local when no optimizations
    // are enabled. https://github.com/apple/swift-protobuf/issues/1034 and
    // https://github.com/apple/swift-protobuf/issues/1182
    switch self.request {
    case .resolveArtifact?: try {
      guard case .resolveArtifact(let v)? = self.request else { preconditionFailure() }
      try visitor.visitSingularMessageField(value: v, fieldNumber: 1000)
    }()
    case .getArtifact?: try {
      guard case .getArtifact(let v)? = self.request else { preconditionFailure() }
      try visitor.visitSingularMessageField(value: v, fieldNumber: 1001)
    }()
    case nil: break
    }
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_ArtifactRequestWrapper, rhs: Org_Apache_Beam_Model_JobManagement_V1_ArtifactRequestWrapper) -> Bool {
    if lhs.request != rhs.request {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_ArtifactResponseWrapper: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".ArtifactResponseWrapper"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .standard(proto: "staging_token"),
    2: .standard(proto: "is_last"),
    1000: .standard(proto: "resolve_artifact_response"),
    1001: .standard(proto: "get_artifact_response"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try { try decoder.decodeSingularStringField(value: &self.stagingToken) }()
      case 2: try { try decoder.decodeSingularBoolField(value: &self.isLast) }()
      case 1000: try {
        var v: Org_Apache_Beam_Model_JobManagement_V1_ResolveArtifactsResponse?
        var hadOneofValue = false
        if let current = self.response {
          hadOneofValue = true
          if case .resolveArtifactResponse(let m) = current {v = m}
        }
        try decoder.decodeSingularMessageField(value: &v)
        if let v = v {
          if hadOneofValue {try decoder.handleConflictingOneOf()}
          self.response = .resolveArtifactResponse(v)
        }
      }()
      case 1001: try {
        var v: Org_Apache_Beam_Model_JobManagement_V1_GetArtifactResponse?
        var hadOneofValue = false
        if let current = self.response {
          hadOneofValue = true
          if case .getArtifactResponse(let m) = current {v = m}
        }
        try decoder.decodeSingularMessageField(value: &v)
        if let v = v {
          if hadOneofValue {try decoder.handleConflictingOneOf()}
          self.response = .getArtifactResponse(v)
        }
      }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    // The use of inline closures is to circumvent an issue where the compiler
    // allocates stack space for every if/case branch local when no optimizations
    // are enabled. https://github.com/apple/swift-protobuf/issues/1034 and
    // https://github.com/apple/swift-protobuf/issues/1182
    if !self.stagingToken.isEmpty {
      try visitor.visitSingularStringField(value: self.stagingToken, fieldNumber: 1)
    }
    if self.isLast != false {
      try visitor.visitSingularBoolField(value: self.isLast, fieldNumber: 2)
    }
    switch self.response {
    case .resolveArtifactResponse?: try {
      guard case .resolveArtifactResponse(let v)? = self.response else { preconditionFailure() }
      try visitor.visitSingularMessageField(value: v, fieldNumber: 1000)
    }()
    case .getArtifactResponse?: try {
      guard case .getArtifactResponse(let v)? = self.response else { preconditionFailure() }
      try visitor.visitSingularMessageField(value: v, fieldNumber: 1001)
    }()
    case nil: break
    }
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_ArtifactResponseWrapper, rhs: Org_Apache_Beam_Model_JobManagement_V1_ArtifactResponseWrapper) -> Bool {
    if lhs.stagingToken != rhs.stagingToken {return false}
    if lhs.isLast != rhs.isLast {return false}
    if lhs.response != rhs.response {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_ArtifactMetadata: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".ArtifactMetadata"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .same(proto: "name"),
    2: .same(proto: "permissions"),
    4: .same(proto: "sha256"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try { try decoder.decodeSingularStringField(value: &self.name) }()
      case 2: try { try decoder.decodeSingularUInt32Field(value: &self.permissions) }()
      case 4: try { try decoder.decodeSingularStringField(value: &self.sha256) }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    if !self.name.isEmpty {
      try visitor.visitSingularStringField(value: self.name, fieldNumber: 1)
    }
    if self.permissions != 0 {
      try visitor.visitSingularUInt32Field(value: self.permissions, fieldNumber: 2)
    }
    if !self.sha256.isEmpty {
      try visitor.visitSingularStringField(value: self.sha256, fieldNumber: 4)
    }
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_ArtifactMetadata, rhs: Org_Apache_Beam_Model_JobManagement_V1_ArtifactMetadata) -> Bool {
    if lhs.name != rhs.name {return false}
    if lhs.permissions != rhs.permissions {return false}
    if lhs.sha256 != rhs.sha256 {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_Manifest: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".Manifest"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .same(proto: "artifact"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try { try decoder.decodeRepeatedMessageField(value: &self.artifact) }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    if !self.artifact.isEmpty {
      try visitor.visitRepeatedMessageField(value: self.artifact, fieldNumber: 1)
    }
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_Manifest, rhs: Org_Apache_Beam_Model_JobManagement_V1_Manifest) -> Bool {
    if lhs.artifact != rhs.artifact {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_ProxyManifest: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".ProxyManifest"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .same(proto: "manifest"),
    2: .same(proto: "location"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try { try decoder.decodeSingularMessageField(value: &self._manifest) }()
      case 2: try { try decoder.decodeRepeatedMessageField(value: &self.location) }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    // The use of inline closures is to circumvent an issue where the compiler
    // allocates stack space for every if/case branch local when no optimizations
    // are enabled. https://github.com/apple/swift-protobuf/issues/1034 and
    // https://github.com/apple/swift-protobuf/issues/1182
    try { if let v = self._manifest {
      try visitor.visitSingularMessageField(value: v, fieldNumber: 1)
    } }()
    if !self.location.isEmpty {
      try visitor.visitRepeatedMessageField(value: self.location, fieldNumber: 2)
    }
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_ProxyManifest, rhs: Org_Apache_Beam_Model_JobManagement_V1_ProxyManifest) -> Bool {
    if lhs._manifest != rhs._manifest {return false}
    if lhs.location != rhs.location {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_ProxyManifest.Location: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = Org_Apache_Beam_Model_JobManagement_V1_ProxyManifest.protoMessageName + ".Location"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .same(proto: "name"),
    2: .same(proto: "uri"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try { try decoder.decodeSingularStringField(value: &self.name) }()
      case 2: try { try decoder.decodeSingularStringField(value: &self.uri) }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    if !self.name.isEmpty {
      try visitor.visitSingularStringField(value: self.name, fieldNumber: 1)
    }
    if !self.uri.isEmpty {
      try visitor.visitSingularStringField(value: self.uri, fieldNumber: 2)
    }
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_ProxyManifest.Location, rhs: Org_Apache_Beam_Model_JobManagement_V1_ProxyManifest.Location) -> Bool {
    if lhs.name != rhs.name {return false}
    if lhs.uri != rhs.uri {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_GetManifestRequest: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".GetManifestRequest"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .standard(proto: "retrieval_token"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try { try decoder.decodeSingularStringField(value: &self.retrievalToken) }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    if !self.retrievalToken.isEmpty {
      try visitor.visitSingularStringField(value: self.retrievalToken, fieldNumber: 1)
    }
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_GetManifestRequest, rhs: Org_Apache_Beam_Model_JobManagement_V1_GetManifestRequest) -> Bool {
    if lhs.retrievalToken != rhs.retrievalToken {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_GetManifestResponse: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".GetManifestResponse"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .same(proto: "manifest"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try { try decoder.decodeSingularMessageField(value: &self._manifest) }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    // The use of inline closures is to circumvent an issue where the compiler
    // allocates stack space for every if/case branch local when no optimizations
    // are enabled. https://github.com/apple/swift-protobuf/issues/1034 and
    // https://github.com/apple/swift-protobuf/issues/1182
    try { if let v = self._manifest {
      try visitor.visitSingularMessageField(value: v, fieldNumber: 1)
    } }()
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_GetManifestResponse, rhs: Org_Apache_Beam_Model_JobManagement_V1_GetManifestResponse) -> Bool {
    if lhs._manifest != rhs._manifest {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_LegacyGetArtifactRequest: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".LegacyGetArtifactRequest"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .same(proto: "name"),
    2: .standard(proto: "retrieval_token"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try { try decoder.decodeSingularStringField(value: &self.name) }()
      case 2: try { try decoder.decodeSingularStringField(value: &self.retrievalToken) }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    if !self.name.isEmpty {
      try visitor.visitSingularStringField(value: self.name, fieldNumber: 1)
    }
    if !self.retrievalToken.isEmpty {
      try visitor.visitSingularStringField(value: self.retrievalToken, fieldNumber: 2)
    }
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_LegacyGetArtifactRequest, rhs: Org_Apache_Beam_Model_JobManagement_V1_LegacyGetArtifactRequest) -> Bool {
    if lhs.name != rhs.name {return false}
    if lhs.retrievalToken != rhs.retrievalToken {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_ArtifactChunk: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".ArtifactChunk"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .same(proto: "data"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try { try decoder.decodeSingularBytesField(value: &self.data) }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    if !self.data.isEmpty {
      try visitor.visitSingularBytesField(value: self.data, fieldNumber: 1)
    }
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_ArtifactChunk, rhs: Org_Apache_Beam_Model_JobManagement_V1_ArtifactChunk) -> Bool {
    if lhs.data != rhs.data {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_PutArtifactMetadata: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".PutArtifactMetadata"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .standard(proto: "staging_session_token"),
    2: .same(proto: "metadata"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try { try decoder.decodeSingularStringField(value: &self.stagingSessionToken) }()
      case 2: try { try decoder.decodeSingularMessageField(value: &self._metadata) }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    // The use of inline closures is to circumvent an issue where the compiler
    // allocates stack space for every if/case branch local when no optimizations
    // are enabled. https://github.com/apple/swift-protobuf/issues/1034 and
    // https://github.com/apple/swift-protobuf/issues/1182
    if !self.stagingSessionToken.isEmpty {
      try visitor.visitSingularStringField(value: self.stagingSessionToken, fieldNumber: 1)
    }
    try { if let v = self._metadata {
      try visitor.visitSingularMessageField(value: v, fieldNumber: 2)
    } }()
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_PutArtifactMetadata, rhs: Org_Apache_Beam_Model_JobManagement_V1_PutArtifactMetadata) -> Bool {
    if lhs.stagingSessionToken != rhs.stagingSessionToken {return false}
    if lhs._metadata != rhs._metadata {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_PutArtifactRequest: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".PutArtifactRequest"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .same(proto: "metadata"),
    2: .same(proto: "data"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try {
        var v: Org_Apache_Beam_Model_JobManagement_V1_PutArtifactMetadata?
        var hadOneofValue = false
        if let current = self.content {
          hadOneofValue = true
          if case .metadata(let m) = current {v = m}
        }
        try decoder.decodeSingularMessageField(value: &v)
        if let v = v {
          if hadOneofValue {try decoder.handleConflictingOneOf()}
          self.content = .metadata(v)
        }
      }()
      case 2: try {
        var v: Org_Apache_Beam_Model_JobManagement_V1_ArtifactChunk?
        var hadOneofValue = false
        if let current = self.content {
          hadOneofValue = true
          if case .data(let m) = current {v = m}
        }
        try decoder.decodeSingularMessageField(value: &v)
        if let v = v {
          if hadOneofValue {try decoder.handleConflictingOneOf()}
          self.content = .data(v)
        }
      }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    // The use of inline closures is to circumvent an issue where the compiler
    // allocates stack space for every if/case branch local when no optimizations
    // are enabled. https://github.com/apple/swift-protobuf/issues/1034 and
    // https://github.com/apple/swift-protobuf/issues/1182
    switch self.content {
    case .metadata?: try {
      guard case .metadata(let v)? = self.content else { preconditionFailure() }
      try visitor.visitSingularMessageField(value: v, fieldNumber: 1)
    }()
    case .data?: try {
      guard case .data(let v)? = self.content else { preconditionFailure() }
      try visitor.visitSingularMessageField(value: v, fieldNumber: 2)
    }()
    case nil: break
    }
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_PutArtifactRequest, rhs: Org_Apache_Beam_Model_JobManagement_V1_PutArtifactRequest) -> Bool {
    if lhs.content != rhs.content {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_PutArtifactResponse: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".PutArtifactResponse"
  static let _protobuf_nameMap = SwiftProtobuf._NameMap()

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let _ = try decoder.nextFieldNumber() {
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_PutArtifactResponse, rhs: Org_Apache_Beam_Model_JobManagement_V1_PutArtifactResponse) -> Bool {
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_CommitManifestRequest: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".CommitManifestRequest"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .same(proto: "manifest"),
    2: .standard(proto: "staging_session_token"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try { try decoder.decodeSingularMessageField(value: &self._manifest) }()
      case 2: try { try decoder.decodeSingularStringField(value: &self.stagingSessionToken) }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    // The use of inline closures is to circumvent an issue where the compiler
    // allocates stack space for every if/case branch local when no optimizations
    // are enabled. https://github.com/apple/swift-protobuf/issues/1034 and
    // https://github.com/apple/swift-protobuf/issues/1182
    try { if let v = self._manifest {
      try visitor.visitSingularMessageField(value: v, fieldNumber: 1)
    } }()
    if !self.stagingSessionToken.isEmpty {
      try visitor.visitSingularStringField(value: self.stagingSessionToken, fieldNumber: 2)
    }
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_CommitManifestRequest, rhs: Org_Apache_Beam_Model_JobManagement_V1_CommitManifestRequest) -> Bool {
    if lhs._manifest != rhs._manifest {return false}
    if lhs.stagingSessionToken != rhs.stagingSessionToken {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_CommitManifestResponse: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
  static let protoMessageName: String = _protobuf_package + ".CommitManifestResponse"
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    1: .standard(proto: "retrieval_token"),
  ]

  mutating func decodeMessage<D: SwiftProtobuf.Decoder>(decoder: inout D) throws {
    while let fieldNumber = try decoder.nextFieldNumber() {
      // The use of inline closures is to circumvent an issue where the compiler
      // allocates stack space for every case branch when no optimizations are
      // enabled. https://github.com/apple/swift-protobuf/issues/1034
      switch fieldNumber {
      case 1: try { try decoder.decodeSingularStringField(value: &self.retrievalToken) }()
      default: break
      }
    }
  }

  func traverse<V: SwiftProtobuf.Visitor>(visitor: inout V) throws {
    if !self.retrievalToken.isEmpty {
      try visitor.visitSingularStringField(value: self.retrievalToken, fieldNumber: 1)
    }
    try unknownFields.traverse(visitor: &visitor)
  }

  static func ==(lhs: Org_Apache_Beam_Model_JobManagement_V1_CommitManifestResponse, rhs: Org_Apache_Beam_Model_JobManagement_V1_CommitManifestResponse) -> Bool {
    if lhs.retrievalToken != rhs.retrievalToken {return false}
    if lhs.unknownFields != rhs.unknownFields {return false}
    return true
  }
}

extension Org_Apache_Beam_Model_JobManagement_V1_CommitManifestResponse.Constants: SwiftProtobuf._ProtoNameProviding {
  static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
    0: .same(proto: "NO_ARTIFACTS_STAGED_TOKEN"),
  ]
}