envconfig.go 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071
  1. /*
  2. *
  3. * Copyright 2018 gRPC authors.
  4. *
  5. * Licensed under the Apache License, Version 2.0 (the "License");
  6. * you may not use this file except in compliance with the License.
  7. * You may obtain a copy of the License at
  8. *
  9. * http://www.apache.org/licenses/LICENSE-2.0
  10. *
  11. * Unless required by applicable law or agreed to in writing, software
  12. * distributed under the License is distributed on an "AS IS" BASIS,
  13. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14. * See the License for the specific language governing permissions and
  15. * limitations under the License.
  16. *
  17. */
  18. // Package envconfig contains grpc settings configured by environment variables.
  19. package envconfig
  20. import (
  21. "os"
  22. "strings"
  23. )
  24. const (
  25. prefix = "GRPC_GO_"
  26. retryStr = prefix + "RETRY"
  27. requireHandshakeStr = prefix + "REQUIRE_HANDSHAKE"
  28. )
  29. // RequireHandshakeSetting describes the settings for handshaking.
  30. type RequireHandshakeSetting int
  31. const (
  32. // RequireHandshakeHybrid (default, deprecated) indicates to not wait for
  33. // handshake before considering a connection ready, but wait before
  34. // considering successful.
  35. RequireHandshakeHybrid RequireHandshakeSetting = iota
  36. // RequireHandshakeOn (default after the 1.17 release) indicates to wait
  37. // for handshake before considering a connection ready/successful.
  38. RequireHandshakeOn
  39. // RequireHandshakeOff indicates to not wait for handshake before
  40. // considering a connection ready/successful.
  41. RequireHandshakeOff
  42. )
  43. var (
  44. // Retry is set if retry is explicitly enabled via "GRPC_GO_RETRY=on".
  45. Retry = strings.EqualFold(os.Getenv(retryStr), "on")
  46. // RequireHandshake is set based upon the GRPC_GO_REQUIRE_HANDSHAKE
  47. // environment variable.
  48. //
  49. // Will be removed after the 1.18 release.
  50. RequireHandshake RequireHandshakeSetting
  51. )
  52. func init() {
  53. switch strings.ToLower(os.Getenv(requireHandshakeStr)) {
  54. case "on":
  55. fallthrough
  56. default:
  57. RequireHandshake = RequireHandshakeOn
  58. case "off":
  59. RequireHandshake = RequireHandshakeOff
  60. case "hybrid":
  61. // Will be removed after the 1.17 release.
  62. RequireHandshake = RequireHandshakeHybrid
  63. }
  64. }