class Kube::Transport

Included Modules

Extended Modules

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

Class Method Summary

Instance Method Summary

Constructor Detail

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

[View source]

Class Method Detail

def self.logger #

[View source]

Instance Method Detail

def _watch_request(response_class : T, response_channel : Kube::WatchChannel, path, req_options) forall T #

[View source]
def format_request(options) #

[View source]
def get(*path) #

[View source]
def get(*path, response_class : T.class, **options) forall T #

[View source]
def gets(*paths) #

[View source]
def gets(paths : Array(String), response_class : T.class, **options) forall T #

[View source]
def gets(*paths, response_class : T.class, **options) forall T #

[View source]
def logger #

[View source]
def need_delete_body? : Bool #

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


[View source]
def options : Options #

[View source]
def options=(options : Options) #

[View source]
def parse_response(response : HTTP::Client::Response, method : String, path : String, response_class : T.class | Nil = nil, **options) forall T #

[View source]
def path(*path) #

[View source]
def path_prefix : String #

[View source]
def request(response_class : T.class, response_block : Proc | Nil = nil, **options) forall T #

[View source]
def request(**options) #

[View source]
def request_options(request_object = nil, content_type = "application/json", **options) #

[View source]
def requests(options : Enumerable(W), skip_missing = false, skip_forbidden = false, retry_errors = true, skip_unknown = true, **common_options) forall W #

[View source]
def requests(*options, skip_missing = false, skip_forbidden = false, retry_errors = true, skip_unknown = true, **common_options) #

[View source]
def server : URI #

[View source]
def server=(server : URI) #

[View source]
def version : K8S::Apimachinery::Version::Info #

[View source]
def watch_request(response_class : T, response_channel : Kube::WatchChannel, **options) forall T #

[View source]