Get.swift 1.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344
  1. /*
  2. * Copyright 2024, gRPC Authors All rights reserved.
  3. *
  4. * Licensed under the Apache License, Version 2.0 (the "License");
  5. * you may not use this file except in compliance with the License.
  6. * You may obtain a copy of the License at
  7. *
  8. * http://www.apache.org/licenses/LICENSE-2.0
  9. *
  10. * Unless required by applicable law or agreed to in writing, software
  11. * distributed under the License is distributed on an "AS IS" BASIS,
  12. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13. * See the License for the specific language governing permissions and
  14. * limitations under the License.
  15. */
  16. import ArgumentParser
  17. import GRPCCore
  18. import GRPCNIOTransportHTTP2
  19. struct Get: AsyncParsableCommand {
  20. static let configuration = CommandConfiguration(abstract: "Makes a unary RPC to the echo server.")
  21. @OptionGroup
  22. var arguments: ClientArguments
  23. func run() async throws {
  24. try await withGRPCClient(
  25. transport: .http2NIOPosix(
  26. target: self.arguments.target,
  27. transportSecurity: .plaintext
  28. )
  29. ) { client in
  30. let echo = Echo_Echo.Client(wrapping: client)
  31. for _ in 0 ..< self.arguments.repetitions {
  32. let message = Echo_EchoRequest.with { $0.text = self.arguments.message }
  33. print("get → \(message.text)")
  34. let response = try await echo.get(message)
  35. print("get ← \(response.text)")
  36. }
  37. }
  38. }
  39. }