lua-kong-nginx-module - Nginx C module that exposes a Lua API to dynamically control Nginx
- Name
- Description
- Install
- Directives
- Methods
- resty.kong.tls.request_client_certificate
- resty.kong.tls.disable_session_reuse
- resty.kong.tls.get_full_client_certificate_chain
- resty.kong.tls.set_upstream_cert_and_key
- resty.kong.tls.set_upstream_ssl_trusted_store
- resty.kong.tls.set_upstream_ssl_verify
- resty.kong.tls.set_upstream_ssl_verify_depth
- resty.kong.grpc.set_authority
- resty.kong.tls.disable_proxy_ssl
- resty.kong.var.patch_metatable
- License
Kong often needs to be able to change Nginx behavior at runtime. Traditionally this has been done using various core patches. This module attempts to unify those approaches and ensure the least amount of modifications made directly to Nginx to support future maintainability.
Patches from openresty-patches are required for this module to compile successfully. You may use the openresty-build-tools script to automatically build an OpenResty binary with required patches as well as this module included.
This module can be installed just like any ordinary Nginx C module, using the
--add-module
configuration option:
./configure --prefix=/usr/local/kong-nginx \
--add-module=/path/to/lua-kong-nginx-module \
...
syntax: lua_kong_load_var_index $variable | default;
context: http
Ensure variable is indexed. Note that variables defined by set
directive
are always indexed by default and does not need to be defined here again.
Common variables defined by other modules that are already indexed:
$proxy_host
$proxy_internal_body_length
$proxy_internal_chunked
$remote_addr
$remote_user
$request
$http_referer
$http_user_agent
$host
Specially, use lua_kong_load_var_index default
to
index commonly used variables as follows:
$args
$is_args
$bytes_sent
$content_type
$http_authorization
$http_connection
$http_host
$http_kong_debug
$http_proxy
$http_proxy_connection
$http_te
$http_upgrade
$http_x_forwarded_for
$http_x_forwarded_host
$http_x_forwarded_path
$http_x_forwarded_port
$http_x_forwarded_prefix
$http_x_forwarded_proto
$https
$http2
$realip_remote_addr
$realip_remote_port
$remote_port
$request_length
$request_method
$request_time
$request_uri
$scheme
$server_addr
$server_port
$ssl_cipher
$ssl_client_raw_cert
$ssl_client_verify
$ssl_protocol
$ssl_server_name
$upstream_http_connection
$upstream_http_trailer
$upstream_http_upgrade
$upstream_status
See resty.kong.var.patch_metatable on how to enable indexed variable access.
syntax: succ, err = resty.kong.tls.request_client_certificate()
context: ssl_certificate_by_lua*
subsystems: http
Requests client to present its client-side certificate to initiate mutual TLS authentication between server and client.
This function only requests, but does not require the client to start the mTLS process. Even if the client did not present a client certificate the TLS handshake will still complete (obviously not being mTLS in that case). Whether the client honored the request can be determined using get_full_client_certificate_chain in later phases.
This function returns true
when the call is successful. Otherwise it returns
nil
and a string describing the error.
syntax: succ, err = resty.kong.tls.disable_session_reuse()
context: ssl_certificate_by_lua*
subsystems: http
Prevents the TLS session for the current connection from being reused by disabling session ticket and session ID for the current TLS connection.
This function returns true
when the call is successful. Otherwise it returns
nil
and a string describing the error.
syntax: pem_chain, err = resty.kong.tls.get_full_client_certificate_chain()
context: rewrite_by_lua*, access_by_lua*, content_by_lua*, log_by_lua*
subsystems: http
Returns the PEM encoded downstream client certificate chain with the client certificate at the top and intermediate certificates (if any) at the bottom.
If client did not present any certificate or if session was reused, then this
function will return nil
.
This is functionally similar to $ssl_client_raw_cert provided by ngx_http_ssl_module, with the notable exception that this function also returns any certificate chain client sent during handshake.
If the TLS session was reused, (signaled by $ssl_session_reused returns "r"), then no client certificate information will be available as a full handshake never occurred. In this case caller should use $ssl_session_id to associate this session with one of the previous handshakes to identify the connecting client.
syntax: ok, err = resty.kong.tls.set_upstream_cert_and_key(chain, key)
context: rewrite_by_lua*, access_by_lua*, balancer_by_lua*
subsystems: http
Overrides and enables sending client certificate while connecting to the upstream in the current request.
chain
is the client certificate and intermediate chain (if any) returned by
functions such as ngx.ssl.parse_pem_cert.
key
is the private key corresponding to the client certificate returned by
functions such as ngx.ssl.parse_pem_priv_key.
On success, this function returns true
and future handshakes with upstream servers
will always use the provided client certificate. Otherwise nil
and a string describing the error
will be returned.
This function can be called multiple times in the same request. Later calls override previous ones.
syntax: ok, err = resty.kong.tls.set_upstream_ssl_trusted_store(store)
context: rewrite_by_lua*, access_by_lua*, balancer_by_lua*
subsystems: http
Set upstream ssl verification trusted store of current request. Global setting set by
proxy_ssl_trusted_certificate
will be overwritten for the current request.
store
is a table object that can be created by
resty.openssl.x509.store.new.
On success, this function returns true
and future handshakes with upstream servers
will be verified with given store. Otherwise nil
and a string describing the
error will be returned.
This function can be called multiple times in the same request. Later calls override previous ones.
Example:
local x509 = require("resty.openssl.x509")
local crt, err = x509.new([[-----BEGIN CERTIFICATE-----
...
-----END CERTIFICATE-----]])
if err then
ngx.log(ngx.ERR, "failed to parse cert: ", err)
ngx.exit(500)
end
local store = require("resty.openssl.x509.store")
local st, err = store.new()
if err then
ngx.log(ngx.ERR, "failed to create store: ", err)
ngx.exit(500)
end
local ok, err = st:add(crt)
if err then
ngx.log(ngx.ERR, "failed to add cert to store: ", err)
ngx.exit(500)
end
-- st:add can be called multiple times, also accept a crl
-- st:add(another_crt)
-- st:add(crl)
-- OR
-- st:use_default() to load default CA bundle
local tls = require("resty.kong.tls")
local ok, err = tls.set_upstream_ssl_trusted_store(st.ctx)
if err then
ngx.log(ngx.ERR, "failed to set upstream trusted store: ", err)
ngx.exit(500)
end
local ok, err = tls.set_upstream_ssl_verify(true)
if err then
ngx.log(ngx.ERR, "failed to set upstream ssl verify: ", err)
ngx.exit(500)
end
syntax: ok, err = resty.kong.tls.set_upstream_ssl_verify(verify)
context: rewrite_by_lua*, access_by_lua*, balancer_by_lua*
subsystems: http
Set upstream ssl verification enablement of current request to the given boolean
argument verify
. Global setting set by proxy_ssl_verify
will be overwritten.
On success, this function returns true
. Otherwise nil
and a string
describing the error will be returned.
This function can be called multiple times in the same request. Later calls override previous ones.
syntax: ok, err = resty.kong.tls.set_upstream_ssl_verify_depth(depth)
context: rewrite_by_lua*, access_by_lua*, balancer_by_lua*
subsystems: http
Set upstream ssl verification depth of current request to the given non-negative integer
argument depth
. Global setting set by proxy_ssl_verify_depth
will be overwritten.
On success, this function returns true
. Otherwise nil
and a string
describing the error will be returned.
This function can be called multiple times in the same request. Later calls override previous ones.
syntax: ok, err = resty.kong.grpc.set_authority(new_authority)
context: rewrite_by_lua*, access_by_lua*, balancer_by_lua*
subsystems: http
Overrides the :authority
pseudo header sent to gRPC upstream by
ngx_http_grpc_module.
This function is a capability not possible in Nginx through means of config
directive alone. Reason being Nginx auto-generates the :authority
pseudo header
without giving us a way to override it at config time. Closest being
grpc_set_header Host "foo.example.com"
, but this will cause the gRPC
module to use the Host
header and not generate the :authority
pseudo header,
causing problems for certain gRPC server.
When called, this function accepts a new value to override the :authority
pseudo header that will be generated by the ngx_http_grpc_module for the
current request.
The new_authority
parameter can not be an empty string.
On success, this function returns true
. Otherwise nil
and a string
describing the error will be returned.
This function can be called multiple times in the same request. Later calls override previous ones.
If called in the balancer_by_lua
context, the request needs to be recreated
(see balancer.recreate.
syntax: ok, err = resty.kong.tls.disable_proxy_ssl()
context: preread_by_lua*, balancer_by_lua*
subsystems: stream
Disables the TLS handshake to upstream for ngx_stream_proxy_module.
Effectively this overrides proxy_ssl directive to off
setting
for the current stream session.
This function has no side effects if the proxy_ssl off;
setting has already
been specified inside nginx.conf
or if this function has been previously
called from the current session.
syntax: resty.kong.var.patch_metatable()
context: init_by_lua
subsystems: http
Indexed variable access is a faster way of accessing Nginx variables for OpenResty.
This method patches the metatable of ngx.var
to enable index access to variables
that supports it. It should be called once in the init
phase which will be effective for
all subsequent ngx.var
uses.
For variables that does not have indexed access, the slower hash based lookup will be used instead (this is the OpenResty default behavior).
To ensure a variable can be accessed using index, you can use the lua_kong_load_var_index directive.
Copyright 2020 Kong Inc.
Licensed 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.