class Kube::Transport

• Kube::Transport
• Reference
• Object

Included Modules

• Spoved::SystemCmd

Extended Modules

• Kube::Transport::ClassMethods

Defined in:

kube/transport.cr
kube/transport/requests.cr

Constant Summary

DEFAULT_AUTH_OPTIONS = {auth_username: nil, auth_password: nil, auth_token: nil, auth_token_file: nil}

DEFAULT_SOCKET_OPTIONS = {socket_class: nil, ssl_socket_class: nil}

DEFAULT_SSL_OPTIONS = {client_cert: nil, client_key: nil, ssl_ca_file: nil, verify_ssl: OpenSSL::SSL::VerifyMode::PEER}

DEFAULT_TIMEOUTS = {open: nil, read: nil}

DELETE_OPTS_BODY_VERSION_MIN = SemanticVersion.parse("1.11.0")

REQUEST_HEADERS = {"Accept" => "application/json"}

Default request headers

Constructors

• .new(server : String, auth_token : String | Nil = nil, auth_username : String | Nil = nil, auth_password : String | Nil = nil, pool_options : PoolOptions = PoolOptions.new, **options)

Class Method Summary

• .logger

Instance Method Summary

• #_watch_request(response_class : T, response_channel, path, req_options) forall T
• #format_request(options)
• #get(*path)
• #get(*path, response_class : T.class, **options) forall T
• #gets(*paths)
• #gets(paths : Array(String), response_class : T.class, **options) forall T
• #gets(*paths, response_class : T.class, **options) forall T
• #logger
• #need_delete_body? : Bool

  Returns true if delete options should be sent as bode of the DELETE request

• #options : Options
• #options=(options : Options)
• #parse_response(response : HTTP::Client::Response, method : String, path : String, response_class : T.class | Nil = nil, **options) forall T
• #path(*path)
• #path_prefix : String
• #request(response_class : T.class, response_block : Proc | Nil = nil, **options) forall T
• #request(**options)
• #request_options(request_object = nil, content_type = "application/json", **options)
• #requests(options : Enumerable(W), skip_missing = false, skip_forbidden = false, retry_errors = true, skip_unknown = true, **common_options) forall W
• #requests(*options, skip_missing = false, skip_forbidden = false, retry_errors = true, skip_unknown = true, **common_options)
• #server : URI
• #server=(server : URI)
• #version : K8S::Apimachinery::Version::Info
• #watch_request(response_class : T, response_channel, **options) forall T

Constructor Detail

Class Method Detail

Instance Method Detail