Janet 1.38.0-73334f3 Documentation
(Other Versions:
1.37.1
1.36.0
1.35.0
1.34.0
1.31.0
1.29.1
1.28.0
1.27.0
1.26.0
1.25.1
1.24.0
1.23.0
1.22.0
1.21.0
1.20.0
1.19.0
1.18.1
1.17.1
1.16.1
1.15.0
1.13.1
1.12.2
1.11.1
1.10.1
1.9.1
1.8.1
1.7.0
1.6.0
1.5.1
1.5.0
1.4.0
1.3.1
)
Spork
While not part of Janet's core library, Spork is an official "contributor" library as well as a collection of various useful utilties for Janet.
Spork can be installed with
jpm install spork
Index
spork/argparse/argparse spork/base64/decode spork/base64/encode spork/build-rules/build-rule spork/build-rules/build-run spork/cc/*ar* spork/cc/*build-dir* spork/cc/*build-type* spork/cc/*c++* spork/cc/*c++-std* spork/cc/*c++flags* spork/cc/*c-std* spork/cc/*cc* spork/cc/*cflags* spork/cc/*defines* spork/cc/*dynamic-libs* spork/cc/*lflags* spork/cc/*libs* spork/cc/*msvc-libs* spork/cc/*msvc-vcvars* spork/cc/*pkg-config-flags* spork/cc/*rules* spork/cc/*smart-libs* spork/cc/*static-libs* spork/cc/*target-os* spork/cc/*use-rdynamic* spork/cc/*use-rpath* spork/cc/*visit* spork/cc/check-library-exists spork/cc/compile-and-link-executable spork/cc/compile-and-link-shared spork/cc/compile-and-make-archive spork/cc/compile-c spork/cc/compile-c++ spork/cc/link-executable-c spork/cc/link-executable-c++ spork/cc/link-shared-c spork/cc/link-shared-c++ spork/cc/load-settings spork/cc/make-archive spork/cc/msvc-compile-and-link-executable spork/cc/msvc-compile-and-link-shared spork/cc/msvc-compile-and-make-archive spork/cc/msvc-compile-c spork/cc/msvc-compile-c++ spork/cc/msvc-find spork/cc/msvc-janet-import-lib spork/cc/msvc-link-executable spork/cc/msvc-link-shared spork/cc/msvc-make-archive spork/cc/msvc-setup? spork/cc/pkg-config spork/cc/save-settings spork/cc/search-dynamic-libraries spork/cc/search-libraries spork/cc/search-static-libraries spork/cc/visit-add-rule spork/cc/visit-clean spork/cc/visit-do-nothing spork/cc/visit-execute spork/cc/visit-execute-if-stale spork/cc/visit-execute-quiet spork/cc/visit-generate-makefile spork/channel/from-each spork/cjanet/*cdef-list* spork/cjanet/*cfun-list* spork/cjanet/*indent* spork/cjanet/@ spork/cjanet/block spork/cjanet/cdef spork/cjanet/cfunction spork/cjanet/declare spork/cjanet/emit-block-end spork/cjanet/emit-block-start spork/cjanet/emit-blocks spork/cjanet/emit-cdef spork/cjanet/emit-cfunction spork/cjanet/emit-comment spork/cjanet/emit-declare spork/cjanet/emit-function spork/cjanet/emit-include spork/cjanet/emit-indent spork/cjanet/emit-module-entry spork/cjanet/emit-preprocess spork/cjanet/emit-typedef spork/cjanet/function spork/cjanet/include spork/cjanet/mangle spork/cjanet/module-entry spork/cjanet/preprocess spork/cjanet/type-split spork/cjanet/typedef spork/cmath/invmod spork/cmath/jacobi spork/cmath/mulmod spork/cmath/powmod spork/crc/make-variant spork/crc/named-variant spork/cron/check spork/cron/next-timestamp spork/cron/parse-cron spork/data/diff spork/ev-utils/go-nursery spork/ev-utils/join-nursery spork/ev-utils/multithread-service spork/ev-utils/nursery spork/ev-utils/pcall spork/ev-utils/pdag spork/ev-utils/pmap spork/ev-utils/pmap-full spork/ev-utils/pmap-limited spork/ev-utils/spawn-nursery spork/ev-utils/wait-cancel spork/fmt/*user-indent-2-forms* spork/fmt/format spork/fmt/format-file spork/fmt/format-print spork/generators/concat spork/generators/cycle spork/generators/drop spork/generators/drop-until spork/generators/drop-while spork/generators/filter spork/generators/from-iterable spork/generators/map spork/generators/mapcat spork/generators/range spork/generators/run spork/generators/take spork/generators/take-until spork/generators/take-while spork/generators/to-array spork/getline/default-autocomplete-context spork/getline/default-autocomplete-options spork/getline/default-doc-fetch spork/getline/make-getline spork/getline/max-history spork/htmlgen/doctype-html spork/htmlgen/escape spork/htmlgen/html spork/htmlgen/raw spork/http/cookie-grammar spork/http/cookies spork/http/logger spork/http/middleware spork/http/query-string-grammar spork/http/read-body spork/http/read-request spork/http/read-response spork/http/request spork/http/request-peg spork/http/response-peg spork/http/router spork/http/send-response spork/http/server spork/http/server-handler spork/http/status-messages spork/http/url-grammar spork/httpf/add-bindings-as-routes spork/httpf/add-route spork/httpf/default-payload-wrapper spork/httpf/listen spork/httpf/server spork/infix/$$ spork/json/decode spork/json/encode spork/math/add spork/math/add-to-mean spork/math/approx-eq spork/math/bernoulli-distribution spork/math/binominal-coeficient spork/math/binominal-distribution spork/math/check-probability spork/math/chi-squared-distribution-table spork/math/cols spork/math/copy spork/math/cumulative-std-normal-probability spork/math/det spork/math/dot spork/math/dot-fast spork/math/epsilon spork/math/expand-m spork/math/extent spork/math/factor spork/math/factorial spork/math/fliplr spork/math/flipud spork/math/geometric-mean spork/math/get-only-el spork/math/harmonic-mean spork/math/ident spork/math/interquartile-range spork/math/invmod spork/math/jacobi spork/math/join-cols spork/math/join-rows spork/math/linear-regression spork/math/linear-regression-line spork/math/m-approx= spork/math/matmul spork/math/median spork/math/median-absolute-deviation spork/math/minor spork/math/mode spork/math/mop spork/math/mul spork/math/mulmod spork/math/next-prime spork/math/normalize-v spork/math/outer spork/math/perm spork/math/permutation-test spork/math/permutations spork/math/poisson-distribution spork/math/powmod spork/math/prime? spork/math/primes spork/math/qr spork/math/qr1 spork/math/quantile spork/math/quantile-rank spork/math/quantile-rank-sorted spork/math/quantile-sorted spork/math/quickselect spork/math/relative-err spork/math/root-mean-square spork/math/row->col spork/math/rows spork/math/sample-correlation spork/math/sample-covariance spork/math/sample-skewness spork/math/sample-standard-deviation spork/math/sample-variance spork/math/scalar spork/math/scale spork/math/shuffle-in-place spork/math/sign spork/math/size spork/math/slice-m spork/math/sop spork/math/squeeze spork/math/standard-deviation spork/math/standard-normal-table spork/math/subtract spork/math/sum-compensated spork/math/sum-nth-power-deviations spork/math/svd spork/math/swap spork/math/t-test spork/math/t-test-2 spork/math/trans spork/math/unit-e spork/math/variance spork/math/z-score spork/math/zero spork/mdz/*front-matter* spork/mdz/*markup-dom* spork/mdz/add-loader spork/mdz/anchor spork/mdz/bigger spork/mdz/blockquote spork/mdz/center spork/mdz/code spork/mdz/codeblock spork/mdz/div spork/mdz/em spork/mdz/hr spork/mdz/html spork/mdz/image spork/mdz/li spork/mdz/link spork/mdz/markup spork/mdz/mdz-loader spork/mdz/ol spork/mdz/p spork/mdz/pre spork/mdz/section spork/mdz/smaller spork/mdz/strong spork/mdz/sub spork/mdz/sup spork/mdz/tag spork/mdz/td spork/mdz/th spork/mdz/tr spork/mdz/u spork/mdz/ul spork/misc/always spork/misc/antepenultimate spork/misc/binary-search spork/misc/binary-search-by spork/misc/caperr spork/misc/capout spork/misc/cond-> spork/misc/cond->> spork/misc/dedent spork/misc/defs spork/misc/dfs spork/misc/do-def spork/misc/do-var spork/misc/format-table spork/misc/gett spork/misc/insert-sorted spork/misc/insert-sorted-by spork/misc/int->string spork/misc/int/ spork/misc/log spork/misc/make spork/misc/make-id spork/misc/map-keys spork/misc/map-keys-flat spork/misc/map-vals spork/misc/merge-sorted spork/misc/merge-sorted-by spork/misc/penultimate spork/misc/print-table spork/misc/randomize-array spork/misc/second spork/misc/select-keys spork/misc/set* spork/misc/string->int spork/misc/table-filter spork/misc/third spork/misc/trim-prefix spork/misc/trim-suffix spork/misc/until spork/misc/vars spork/msg/make-proto spork/msg/make-recv spork/msg/make-send spork/netrepl/client spork/netrepl/default-host spork/netrepl/default-port spork/netrepl/server spork/netrepl/server-single spork/path/abspath spork/path/abspath? spork/path/basename spork/path/delim spork/path/dirname spork/path/ext spork/path/join spork/path/normalize spork/path/parts spork/path/posix/abspath spork/path/posix/abspath? spork/path/posix/basename spork/path/posix/delim spork/path/posix/dirname spork/path/posix/ext spork/path/posix/join spork/path/posix/normalize spork/path/posix/parts spork/path/posix/relpath spork/path/posix/sep spork/path/relpath spork/path/sep spork/path/win32/abspath spork/path/win32/abspath? spork/path/win32/basename spork/path/win32/delim spork/path/win32/dirname spork/path/win32/ext spork/path/win32/join spork/path/win32/normalize spork/path/win32/parts spork/path/win32/relpath spork/path/win32/sep spork/pgp/hex->word spork/pgp/hexs->words spork/pgp/word->hex spork/pgp/word-list spork/pgp/words->hexs spork/randgen/*rng* spork/randgen/rand-cdf spork/randgen/rand-cdf-path spork/randgen/rand-gaussian spork/randgen/rand-index spork/randgen/rand-int spork/randgen/rand-path spork/randgen/rand-uniform spork/randgen/rand-value spork/randgen/rand-weights spork/randgen/rand-weights-path spork/randgen/sample-n spork/randgen/set-seed spork/randgen/weights-to-cdf spork/rawterm/begin spork/rawterm/buffer-traverse spork/rawterm/ctrl-z spork/rawterm/end spork/rawterm/getch spork/rawterm/isatty spork/rawterm/monowidth spork/rawterm/rune-monowidth spork/rawterm/size spork/rawterm/slice-monowidth spork/regex/compile spork/regex/find spork/regex/find-all spork/regex/match spork/regex/peg spork/regex/replace spork/regex/replace-all spork/regex/source spork/rpc/client spork/rpc/default-host spork/rpc/default-port spork/rpc/server spork/schema/make-predicate spork/schema/make-validator spork/schema/predicate spork/schema/validator spork/services/*current-manager* spork/services/*current-service* spork/services/add-service spork/services/all-services spork/services/get-manager spork/services/get-service spork/services/make-manager spork/services/print-all spork/services/remove-service spork/services/set-title spork/services/start-service spork/services/stop-service spork/services/wait spork/sh/copy spork/sh/copy-file spork/sh/create-dirs spork/sh/devnull spork/sh/escape spork/sh/exec spork/sh/exec-fail spork/sh/exec-slurp spork/sh/exec-slurp-all spork/sh/exists? spork/sh/list-all-files spork/sh/make-new-file spork/sh/rm spork/sh/scan-directory spork/sh/split spork/stream/lines spork/tarray/buffer spork/tarray/copy-bytes spork/tarray/length spork/tarray/new spork/tarray/properties spork/tarray/slice spork/tarray/swap-bytes spork/tasker/all-tasks spork/tasker/cancel-task spork/tasker/close-queues spork/tasker/default-expiration spork/tasker/default-priority spork/tasker/default-task-directory spork/tasker/err-file-name spork/tasker/max-priority spork/tasker/min-priority spork/tasker/new-tasker spork/tasker/out-file-name spork/tasker/queue-task spork/tasker/run-cleanup spork/tasker/run-executors spork/tasker/spawn-executors spork/tasker/statuses spork/tasker/task-file spork/tasker/task-meta-name spork/tasker/task-status spork/temple/add-loader spork/temple/base-env spork/temple/compile spork/temple/create spork/test/assert spork/test/assert-docs spork/test/assert-error spork/test/assert-no-error spork/test/assert-not spork/test/capture-stderr spork/test/capture-stdout spork/test/end-suite spork/test/start-suite spork/test/suppress-stderr spork/test/suppress-stdout spork/test/timeit spork/test/timeit-loop spork/utf8/decode-rune spork/utf8/encode-rune spork/utf8/prefix->width spork/zip/add-bytes spork/zip/add-file spork/zip/compress spork/zip/decompress spork/zip/extract spork/zip/file-directory? spork/zip/file-encrypted? spork/zip/file-supported? spork/zip/get-filename spork/zip/locate-file spork/zip/read-bytes spork/zip/read-file spork/zip/reader-close spork/zip/reader-count spork/zip/stat spork/zip/version spork/zip/write-buffer spork/zip/write-file spork/zip/writer-close spork/zip/writer-finalize
(argparse description &keys options)
Parse (dyn :args)
according to options. If the arguments are incorrect, will return nil and print usage
information.
Each option is a table or struct that specifies a flag or option for the script. The name of the option should
be a string, specified via (argparse/argparse "..." op1-name {...} op2-name {...} ...)
. A help option and
usage text is automatically generated for you.
The keys in each option table are as follows:
-
:kind
- What kind of option is this? One of:flag
,:multi
,:option
, or:accumulate
. A flag can either be on or off, a multi is a flag that can be provided multiple times, each time adding 1 to a returned integer, an option is a key that will be set in the returned table, and accumulate means an option can be specified 0 or more times, each time appending a value to an array. -
:short
- Single letter for shorthand access. -
:help
- Help text for the option, explaining what it is. -
:default
- Default value for the option. -
:required
- Whether or not an option is required. -
:short-circuit
- Whether or not to stop parsing if this option is hit. Result will also contain the rest of the arguments under the :rest key. -
:action
- A function that will be invoked when the option is parsed. -
:map
- A function that is applied to the value of the option to transform it
There is also a special option name :default
that will be invoked on arguments that do not start with a -- or
-. Use this option to collect unnamed arguments to your script. This is separate from the :default
key in
option specifiers.
After "--", every argument is treated as an unnamed argument.
Once parsed, values are accessible in the returned table by the name of the option. For example (result
"verbose")
will check if the verbose flag is enabled. You may also use a custom args array when specified via
the special option :args
.
(import spork)
(def argparse-params
["An example CLI tool."
"my-flag" {:kind :flag
:short "f"
:help "set my-flag"}
"my-opt" {:kind :option
:short "o"
:help "Value for option"
:default "DEFAULT VALUE"}
"my-req" {:kind :option
:short "r"
:required true}])
(def cli-args (spork/argparse/argparse ;argparse-params))
(unless cli-args
(os/exit 1))
(print "flag: " (get cli-args "my-flag"))
(print "my-opt: " (get cli-args "my-opt"))
(print "my-req: " (get cli-args "my-req"))
(base64/decode x)
Decodes a string from Base64. Returns decoded string.
(base64/encode x)
Encodes a string in Base64. Returns encoded string.
(build-rule rules target deps & body)
Add a rule to the rule graph. rules
should be a table, target
a string or tuple of strings, and deps
a
tuple of strings. body
is code that will be executed to create all of the targets by the rules. If target is
a keyword, the rule will always be considered out of date.
(build-run rules targets &opt n-workers)
Build a list of targets, as specified by rules. Return an array of all recursively updated targets.
Presets for compiler optimizations, can be :release, :develop, and :debug, defaults to :develop.
C++ standard to use as a 2 digit number, defaults to 11 on GCC-like compilers, 14 on msvc.
C standard to use as a 2 digit number, defaults to 99 on GCC-like compilers, 11 on msvc.
List of libraries to use when compiling - can be static or dynamic depending on system.
Path to vcvarsall.bat to use initialize MSVC environment. If unset, msvc-find
will try to guess using typical
install locations.
Try to resolve circular or out-of-order dependencies between libraries by using --start-group and --end-group. Some linkers support this by default, but not at all. Defaults to true on linux and macos.
Operating system to assume is being used for target compiler toolchain
Optional setting to enable using -rdynamic
or -Wl,-export_dynamic
when linking executables. This is the
preferred way on POSIX systems to let an executable load native modules dynamically at runtime. Defaults to
true
Optional setting to enable using (dyn *syspath*)
as the runtime path to load for Shared Objects. Defaults to
true
Optional callback to process each CLI command and its inputs and outputs
(check-library-exists libname &opt binding test-source-code)
Check if a library exists on the current POSIX system. Will run a test compilation and return true if the
compilation succeeds. Libname is passed directly to the compiler/linker, such as -lm
on GNU/Linux.
(compile-and-link-executable to & sources)
Compile and link an executable C/C++ program. Return an array of commands.
(compile-and-link-shared to & sources)
Compile and link a shared C/C++ library. Return an array of commands.
(compile-and-make-archive to & sources)
Compile and create a static archive. Return an array of commands.
(compile-c from to)
Compile a C program to an object file. Return the command arguments.
(compile-c++ from to)
Compile a C++ program to an object file. Return the command arguments.
(link-executable-c objects to)
Link a C program to make an executable. Return the command arguments.
(link-executable-c++ objects to)
Link a C++ program to make an executable. Return the command arguments.
(link-shared-c objects to)
Link a C program to make a shared library. Return the command arguments.
(link-shared-c++ objects to)
Link a C++ program to make a shared library. Return the command arguments.
(load-settings settings)
Load settings from a snapshot of settings saved with save-settings
.
(make-archive objects to)
Make an archive file. Return the command arguments.
(msvc-compile-and-link-executable to & sources)
Compile and link an executable C/C++ program. Return an array of commands.
(msvc-compile-and-link-shared to & sources)
Compile and link a shared C/C++ library. Return an array of commands.
(msvc-compile-and-make-archive to & sources)
Compile and create a static archive. Return an array of commands.
(msvc-compile-c from to)
Compile a C program with MSVC. Return the command arguments.
(msvc-compile-c++ from to)
Compile a C++ program with MSVC. Return the command arguments.
(msvc-find)
Find vcvarsall.bat and run it to setup the current environment for building. Uses (dyn *msvc-vcvars*)
to find
the location of the setup script, otherwise defaults to checking typical install locations for Visual Studio.
Supports VS 2017, 2019, and 2022, any edition. Will set environment variables such that invocations of cl.exe,
link.exe, etc. will work as expected.
(msvc-janet-import-lib)
Get path to the installed Janet import lib. This import lib is needed when create dlls for natives.
(msvc-link-executable objects to)
Link a C/C++ program with MSVC to make an executable. Return the command arguments.
(msvc-link-shared objects to)
Link a C/C++ program with MSVC to make a shared library. Return the command arguments.
(msvc-make-archive objects to)
Make an archive file with MSVC. Return the command arguments.
(pkg-config & pkg-config-libraries)
Setup defines, cflags, and library flags from pkg-config.
(save-settings)
Get a snapshot of the current settings for various compiler flags, libraries, defines, etc. that can be loaded later.
(search-dynamic-libraries & libs)
Search for dynamic libraries on the current POSIX system and configure (dyn *dynamic-libraries*)
. This is
done by checking for the existence of libraries with check-library-exists
. Returns an array of libraries that
were not found.
(search-libraries & libs)
Search for libraries on the current POSIX system and configure (dyn *libs*)
. This is done by checking for the
existence of libraries with check-library-exists
. Returns an array of libraries that were not found.
(search-static-libraries & libs)
Search for static libraries on the current POSIX system and configure (dyn *static-libs*)
. This is done by
checking for the existence of libraries with check-library-exists
. Returns an array of libraries that were
not found.
(visit-add-rule cmd inputs outputs message)
Used in conjuction with spork/build-rules. Adds rules to the (dyn *rules* (curenv))
(visit-clean cmd inputs outputs message)
A visiting function that will remove all outputs.
(visit-do-nothing &)
A visiting function that has no side effects and therefor does nothing.
(visit-execute cmd inputs outputs message)
A function that can be provided as (dyn *visit*)
that will execute commands.
(visit-execute-if-stale cmd inputs outputs message)
A function that can be provided as (dyn *visit*)
that will execute a command if inputs are newer than
outputs, providing a simple, single-threaded, incremental build tool. This is not optimal for parallel builds,
but is simple and works well for small projects.
(visit-execute-quiet cmd inputs outputs message)
A function that can be provided as (dyn *visit*)
that will execute commands quietly.
(visit-generate-makefile cmd inputs outputs message)
A function that can be provided as (dyn *visit*)
that will generate Makefile targets.
(from-each iterable &named supervisor)
Returns a channel that gives each item from an iterable data type. each
macro is used to iterate over all
iterable types. supervisor
argument is passed to ev/go
which launches two tasks that feed items to the
channel. To finish the tasks, drain all items from the channel, or close the channel. Otherwise, the tasks
remain frozen. When the tasks finish, the channel is closed. An error caused during iteration finishes the
tasks with an error. Writing to the channel finishes the tasks with an error or freezes the fiber that tries to
write to the channel.
(cdef name & more)
Define constant which will be registered in the module. It takes care of the docstring.
(cfunction name & more)
Define a C Function in cjanet. This also takes care of recording docstrings and such. Arity checking will be generated for you (by insertion of a call to janet_arity or janet_fixarity).
(emit-blocks statements)
Emit a number of statements in a bracketed block
(emit-cdef name & more)
Define constant which will be registered in the module. It takes care of the docstring.
(emit-cfunction name & more)
Functional form of cfunction
- takes the same arguments, but parameters must be manually quoted.
(emit-declare binding & form)
Emit a declaration of a variable or constant.
(emit-module-entry name)
Call this at the end of a cjanet module to add a module entry function.
(emit-preprocess & args)
Emit a line of source code for the pre-processor. For example (emit-preprocess "include" "<stdio.h>")
.
(emit-typedef name definition)
Emit a type declaration (C typedef).
(mangle token)
Convert any sequence of bytes to a valid C identifier in a way that is unlikely to collide. print-ir
will not
mangle symbols for you.
(module-entry name)
Call this at the end of a cjanet module to add a module entry function.
(type-split x &opt dflt-type)
Extract name and type from a variable. Allow typing variables as both (name type) or name:type as a shorthand. If no type is found, default to dflt-type. dflt-type itself defaults to 'auto
(math/invmod a m)
Modular multiplicative inverse of a
mod m
. Both arguments must be integer. The return value has the same
type as m
. If no inverse exists, returns math/nan
instead.
(math/mulmod a b m)
Modular multiplication of a
and b
mod m
. All arguments must be integer. The return value has the same
type as m
.
(math/powmod a b m)
Modular exponentiation of a
to the power of b
mod m
. All arguments must be integer. The return value has
the same type as m
.
(crc/make-variant size polynomial &opt init byte-flip xorout)
Create a CRC function based on the given polynomial, initial value, xourout, and whether to invert input bytes.
(check cron &opt time local)
Check if a given time matches a cron specifier.
(next-timestamp cron &opt time local)
Given a cron schedule, get the next instance on the cron tab after time
(parse-cron str)
Parse a cron string into a valid cron schedule object
(diff a b)
Compares a and b recursively. Returns an array of @[things-only-in-a things-only-in-b things-in-both].
(go-nursery nurse f &opt value)
Spawn a fiber into a nursery, similar to ev/go.
(join-nursery nurse)
Suspend the current fiber until the nursery is emptied.
(multithread-service thread-main n-threads)
Run instances of a function over multiple threads. On failures, restart the failed thread. Normal function returns will not trigger a restart.
(nursery)
Group a number of fibers into a single object for structured concurrency
(pcall f n)
Call a function n times (in parallel) for side effects. Each function is called with an integer argument indicating a fiber index. Returns nil.
(pdag f dag &opt n-workers)
Executes a dag by calling f on every node in the graph. Can set the number of workers for parallel execution.
The graph is represented as a table mapping nodes to arrays of child nodes. Each node will only be evaluated
after all children have been evaluated. Modifying dag
inside f
will not affect the scheduling of workers.
Returns a table mapping each node to the result of (f node)
.
(pmap f data &opt n-workers)
Map f
over data in parallel, optionally limiting parallelism to n
workers.
(pmap-full f data)
Function form of ev/gather
. If any of the sibling fibers error, all other siblings will be canceled. Returns
the gathered results in an array. data
can be any indexed data structure.
(pmap-limited f data n-workers)
Similar to pmap-full, but only runs work n-ways parallel.
(spawn-nursery nurse & body)
Similar to ev/spawn but associate spawned fibers with a nursery
(wait-cancel & body)
Wait forever until the current fiber is canceled, and then run some cleanup code.
A user list of forms that are control forms and should be indented two spaces.
(format-print source)
Format a string of source code and print the result.
(concat & xs)
Concatenate one or more generators or iterables into a single generator.
(cycle ds)
Repeatedly yield the elements of ds
, looping back to the beginning when finished.
(from-iterable ds)
Create a new generator around any iterable data structure.
(mapcat f ds)
Map f
over ds
, concatenating the results into a new generator.
(take-until p ds)
Return elements from ds
until p
is true.
(take-while p ds)
Return elements from ds
while p
is true.
(default-autocomplete-context buf pos)
Given a buffer and a cursor position, extract a string that will be used as context for autocompletion. Return a position and substring from the buffer to use for autocompletion.
(default-autocomplete-options prefix &)
Default handler to get available autocomplete options for a given substring.
(default-doc-fetch sym w &)
Default handler for Ctrl-G to lookup docstrings in the current environment.
(make-getline &opt autocomplete-context autocomplete-options doc-fetch)
Reads a line of input into a buffer, like getline
. However, allow looking up entries with a general lookup
function rather than an environment table.
(html data &opt buf)
Render HTML from standard data structures. Fills the provided optional buffer, or new one if it is not provided, with the html bytes.
(raw text)
Get an object that can be used to splice in HTML literals. text
is not escaped in the output string.
(logger nextmw)
Creates a logging middleware. The logger middleware prints URL route, return status, and elapsed request time.
Grammar that parses a query string (sans url path and ? character) and returns a table.
(read-body req)
Given a request, read the HTTP body from the connection. Returns the body as a buffer. If the request has no body, returns nil.
(read-request conn buf &opt no-query)
Read an HTTP request header from a connection. Returns a table with the following keys:
-
:headers
- table mapping header names to header values. Header names are lowercase. -
:connection
- the connection stream for the header. -
:buffer
- the buffer instance that may contain extra bytes. -
:head-size
- the number of bytes used by the header. -
:method
- the HTTP method used. -
:path
- the path of the resource requested.
The following keys are also present, but omitted if the user passes a truthy parameter to no-query
.
-
:route
- path of the resource requested without query string. -
:query-string
- segment of HTTP path after first ? character. -
:query
- the query string parsed into a table. Supports a single string value for every string key, and any query parameters that aren't given a value are mapped to true.
Note that data is read in chunks and any data after the header terminator is stored in :buffer
.
(read-response conn buf)
Read an HTTP response header from a connection. Returns a table with the following keys:
-
:headers
- table mapping header names to header values. Header names are lowercase. -
:connection
- the connection stream for the header. -
:buffer
- the buffer instance that may contain extra bytes. -
:head-size
- the number of bytes used by the header. -
:status
- the HTTP status code. -
:message
- the HTTP status message.
Note that data is read in chunks and any data after the header terminator is stored in :buffer
.
(request method url &keys {:body body :headers headers})
Make an HTTP request to a server. Returns a table containing response information.
-
:head-size
- number of bytes in the http header -
:headers
- table mapping header names to header values. Header names are lowercase. -
:connection
- the connection stream for the header. -
:buffer
- the buffer instance that may contain extra bytes. -
:status
- HTTP status code as an integer. -
:message
- HTTP status message. -
:body
- Bytes of the response body.
(router routes)
Creates a router middleware. A router will dispatch to different routes based on the URL path.
(send-response conn response &opt buf)
Send an HTTP response over a connection. Will automatically use chunked encoding if body is not a byte
sequence. response
should be a table with the following keys:
-
:headers
- optional headers to write -
:status
- integer status code to write -
:body
- optional byte sequence or iterable (for chunked body) for returning contents. The iterable can be lazy, i.e. for streaming data.
(server handler &opt host port)
Makes a simple http server. By default it binds to 0.0.0.0:8000, returns a new server stream. Simply wraps http/server-handler with a net/server.
(server-handler conn handler)
A simple connection handler for an HTTP server. When a connection is accepted. Call this with a handler function to handle the connect. The handler will be called with one argument, the request table, which will contain the following keys:
-
:head-size
- number of bytes in the http header. -
:headers
- table mapping header names to header values. -
:connection
- the connection stream for the header. -
:buffer
- the buffer instance that may contain extra bytes. -
:path
- HTTP path. -
:method
- HTTP method, as a string.
Grammar to parse a URL into domain, port, and path triplet. Only supports the http:// protocol.
(add-bindings-as-routes server &opt env)
Add all local functions defined with :path metadata to a server. Will read from the :schema, :doc, :path, and :route-doc metadata to determine how the route behaves.
(add-route server path docstring schema handler &opt read-mime render-mime)
Add a single route manually to a server. Prefer using httpf/add-bindings-as-routes
for the usual case.
(default-payload-wrapper payload)
Add some metadata to all responses
($$ & body)
Use infix syntax for writing expressions in a more familiar manner. Useful for writing mathematic expressions.
(json/decode json-source &opt keywords nils)
Returns a janet object after parsing JSON. If keywords is truthy, string keys will be converted to keywords. If nils is truthy, null will become nil instead of the keyword :null.
(json/encode x &opt tab newline buf)
Encodes a janet value in JSON (utf-8). tab and newline are optional byte sequence which are used to format the output JSON. if buf is provided, the formated JSON is append to buf instead of a new buffer. Returns the modifed buffer.
(add m a)
Add a
to matrix m
where it can be matrix or scalar. Matrix m
is mutated.
(approx-eq a e &opt t)
Approximate equality between actual number a
and expected number e
. Default tolerance t
is epsilon
.
(bernoulli-distribution p)
Creates Bernoulli distribution from probability p
in the tuple.
(binominal-coeficient n k)
Computes binominal coefficient from set of size n
and sample size k
.
(binominal-distribution t p)
Creates binominal distribution from trials t
and probability p
in the tuple.
(check-probability p)
Asserts that probability is in the [0 1] range.
(cumulative-std-normal-probability z)
Computes standard normal probability for y
.
(dot-fast v1 v2)
Fast dot product between two row vectors of equal size.
(expand-m n m)
Embeds a matrix m
inside an identity matrix of size n.
(extent xs)
Returns the minimum & maximum number in an xs
as tuple.
(get-only-el m)
Convenience macro for geting first element from first row of the two dimensional array m
.
(interquartile-range xs)
Gets the interquartile range from xs
.
(math/invmod a m)
Modular multiplicative inverse of a
mod m
. Both arguments must be integer. The return value has the same
type as m
. If no inverse exists, returns math/nan
instead.
(linear-regression coords)
Computes the slope :m
and y-intercept :b
of the function in the struct from set of coordinates.
(linear-regression-line {:b b :m m})
Constructs function from struct returned by linear regression.
(m-approx= m1 m2 &opt tolerance)
Compares two matrices of equal size for equivalence within epsilon.
(matmul ma mb)
Matrix multiplication between matrices ma
and mb
. Does not mutate.
(median-absolute-deviation xs)
Gets median absolute deviation from xs
.
(mop m op a)
Mutates every cell of the matrix m
with op
and corresponding cell from matrix arg a
.
(mul m a)
Multiply matrix m
with a
which can be matrix or a list. Mutates m
. A list a
will be converted to column
vector then multiplifed from the right as x * a
.
(math/mulmod a b m)
Modular multiplication of a
and b
mod m
. All arguments must be integer. The return value has the same
type as m
.
(next-prime n)
Returns the next prime number strictly larger than n
.
(normalize-v xs)
Returns normalized vector of xs
by Euclidian (L2) norm.
(permutation-test xs ys &opt a k)
Conducts a permutation test to determine if two data sets xs
and ys
are *significantly* different from each
other. You can use alternative hypothesis a
, which defaults to :two-side
, with :greater
and :lesser
being the other two options. The last optional argument is k
number of values in permutation distribution
(permutations s &opt k)
Returns permutations of length k
from members of s
(poisson-distribution lambda)
Creates Poisson distribution from lambda
in tuple.
(math/powmod a b m)
Modular exponentiation of a
to the power of b
mod m
. All arguments must be integer. The return value has
the same type as m
.
(prime? n)
A primality test, deterministic for all n
less than 2^63.
(qr m)
Stable and robust QR decomposition of a matrix. Decompose a matrix using Householder transformations. O(n^3).
(quantile xs p)
Gets the quantile value from xs
at p
from unsorted population.
(quantile-rank xs p)
Gets the quantile rank of value v
from unsorted xs
.
(quantile-rank-sorted xs v)
Gets the quantile rank of value v
from sorted xs
.
(quantile-sorted xs p)
Gets the quantile value from xs
at p
from sorted population.
(quickselect arr k &opt left right)
Rearrange items in arr
so that all items in [left, k]
range are the smallest. The k
-th element will have
the (k - left + 1)
-th smallest value in [left, right]
. Mutates arr
.
(relative-err a e)
Gets the relative err between actual number a
and expected number e
.
(row->col xs)
Transposes a row vector xs
to col vector. Returns xs
if it has higher dimensions.
(sample-correlation xs ys)
Gets the sample correlation between xs
and ys
.
(sample-covariance xs ys)
Gets the sample covariance between xs
and ys
.
(sample-skewness xs)
Gets the sample skeweness from the xs
.
(sample-standard-deviation xs)
Gets sample standard deviation from xs
.
(shuffle-in-place xs)
Generate random permutation of the array xs
which is shuffled in place.
(sop m op & a)
Mutates every cell of the matrix m
with op
and variadic args a
.
(squeeze m)
Concatenate a list of rows into a single row. Does not mutate m
.
(standard-deviation xs)
Gets the standard deviation from ds
.
(sum-compensated xs)
Returns sum of the members of xs
with Kahan-Babushka algorithm.
(sum-nth-power-deviations xs n)
Get the sum of deviations to the n power.
(svd m &opt n-iter)
Simple Singular-Value-Decomposition based on repeated QR decomposition. The algorithm converges at O(n^3).
(swap arr i j)
Swaps members with indices i
and j
of arr. Noop when i
equals j
.
(t-test xs expv)
Computes one sample t-test comparing the mean of xs
to known value expv
.
(t-test-2 xs ys &opt d)
Computes two sample t-test of two samples xs
and ys
with difference optional d
which defaults to 0.
(z-score x m d)
Gets the standard score for number x
from mean m
and standard deviation d
.
(zero c &opt r)
Creates vector of length c
, or matrix if r
is provided, and fills it with zeros.
Dynamic binding to front matter of markup after parsing, compilation, and evaluation completes.
The htmlgen source that can be used to generate a document with htmlgen/html.
Make a div element
Make a em element
Make a li element
(markup source &opt env where)
Parse mendoza markup and evaluate it returning an htmlgen document tree.
Make a ol element
Make a p element
Make a pre element
(section name content)
Create a section. Usually used to embed different parts of the content document into different parts of the main page.
Make a strong element
Make a sub element
Make a sup element
(tag name content)
Wrap some content in an html tag. If you need attributes or other properties, you may want to use raw HTML via the html function.
Make a td element
Make a th element
Make a tr element
Make a u element
Make a ul element
(always x)
Return a function that discards any arguments and always returns x
.
(antepenultimate xs)
Get the third-to-last element from an indexed data structure.
(binary-search x arr &opt <?)
Returns the index of x
in a sorted array or tuple or the index of the next item if x
is not present. This
is the correct insert index for x
within arr
. If a <?
comparator is given, the search uses that to
compare elements, otherwise uses <
.
(binary-search-by x arr f)
Returns the index of x
in an array or tuple which has been sorted by a mapping function f
, or the index of
the next item if x
is not present. This is the correct insert index for x
within arr
.
(caperr & body)
Captures the standard error output of the variadic body
and returns it as a buffer.
(capout & body)
Captures the standard output of the variadic body
and returns it as a buffer.
(cond-> val & clauses)
Threading conditional macro. It takes val
to mutate, and clauses
pairs with condition and operation to
which val
, is passed as first argument. All conditions are tried and for truthy conditions the operation is
executed. Returns the value mutated if any condition is truthy.
(cond->> val & clauses)
Threading conditional macro. It takes val
to mutate, and clauses
pairs of condition and operation to which
val
, is passed as last argument. All conditions are tried and for truthy conditions the operation is
executed. Returns mutated value if any condition is truthy.
(dedent & xs)
Remove indentation after concatenating the arguments. Works by removing leading whitespace, and then removing that same pattern of whitespace after new lines.
(defs & bindings)
Defines many constants as in let bindings
, but without creating a new scope.
(dfs data visit-leaf &opt node-before node-after get-children seen)
Do a depth first, pre-order traversal over a data structure. Also allow for callbacks before and after visiting
the children of a node. Also allow for a custom get-children
function to change traversal as needed. Will
detect cycles if an empty table is passed as the seen
parameter, which is used to cache values that have been
visited.
(do-def c d & body)
Convenience macro for defining constant named c
with value d
before body
and returning it after
evaluating body
, that presumably modifies the content referred to by c
. For example, a buffer, table or
array.
(do-var v d & body)
Convenience macro for defining variable named v
with value d
before body
and returning it after
evaluating body
, that presumably modifies v
.
(format-table buf-into data &opt columns header-mapping column-mapping)
Same as print-table but pushes table into a buffer.
(gett ds & keyz)
Recursive macro (get). Similar to get-in, but keyz
is variadic.
(insert-sorted arr <? & xs)
Insert elements in arr
such that it remains sorted by the comparator. If arr
is not sorted beforehand, the
results are undefined. Returns arr
.
(insert-sorted-by arr f & xs)
Insert elements in arr
such that it remains sorted by the value returned when f
is called with the element,
comparing the values with <
. If arr
is not sorted beforehand, the results are undefined. Returns arr
.
(int->string int &opt base)
Stringify an integer in a particular base. Defaults to decimal (base 10).
(log level & args)
Print to a dynamic binding stream if that stream is set, otherwise do nothing. Evaluate to nil. For example,
(log :err "value error: %V" my-value)
will print to (dyn :err)
only if (dyn :err)
has been set.
(make prototype & pairs)
Convenience macro for creating new table from even number of kvs pairs in variadic pairs
arguments and
setting its prototype to prototype
. Factory function for creating new objects from prototypes.
(make-id &opt prefix)
Create a random, printable keyword id with 10 bytes of entropy with an optional prefix.
(map-keys f data)
Returns new table with function f
applied to data
's keys recursively.
(map-keys-flat f data)
Returns new table with function f
applied to data
's keys without recursing.
(map-vals f data)
Returns new table with function f
applied to data
's values.
(merge-sorted a b &opt <?)
Merges two sorted arrays so that the result remains sorted, using an optional comparator. If no comparator is
given, <
is used.
(merge-sorted-by a b f)
Merges two sorted arrays so that result remains sorted when f
is called on each element, comparing the values
with <
.
(penultimate xs)
Get the second-to-last element from an indexed data structure.
(print-table data &opt columns header-mapping column-mapping)
Iterate through the rows of a data structure and print a table in a human readable way, with padding and
heading information. Can optionally provide a function used to print a row, as well as optionally select column
keys for each row. Lastly, a header-mapping
dictionary can be provided that changes the printed header names
by mapping column keys to the desired header name. If no mapping is found, then the column key will be used as
the header name. Returns nil.
(randomize-array arr &opt rng)
Randomizes array using the fisher-yates shuffle, takes an optional random number generator.
(select-keys data keyz)
Returns new table with selected keyz
from dictionary data
.
(set* tgts exprs)
Parallel set
function. Takes a list of targets and expressions, evaluates all the expressions, and then
assigns them to the targets. Each target can be a variable or a 2-tuple, just like in the normal set
special
form.
(string->int str &opt base)
Parse an integer in the given base. Defaults to decimal (base 10). Differs from scan-number in that this does not recognize floating point notation.
(table-filter pred dict)
Filter a key-value structure into a table. Semantics are the same as for built-in filter
, except that pred
takes two arguments (key and value). Does not consider prototypes.
(trim-prefix prefix str)
Trim the specified prefix of a string if it has one
(trim-suffix suffix str)
Trim the specified suffix of a string if it has one
(until cnd & body)
Repeat body
while the cnd
is false. Equivalent to (while (not cnd) ;body).
(vars & bindings)
Defines many variables as in let bindings
, but without creating a new scope.
(make-proto stream &opt pack unpack)
Create both a send an recv function from a stream, as with make-send
and make-recv
.
(make-recv stream &opt unpack)
Get a function that, when invoked, gets the next message from a readable stream. Provide an optional unpack function that will parse the received buffer.
(make-send stream &opt pack)
Create a function that when called with a msgs sends that msg. Provide an optional pack function that will convert a message to a string.
(client &opt host port name)
Connect to a repl server. The default host is "127.0.0.1" and the default port is "9365".
(server &opt host port env cleanup welcome-msg)
Start a repl server. The default host is "127.0.0.1" and the default port is "9365". Calling this will start a
TCP server that exposes a repl into the given env. If no env is provided, a new env will be created per
connection. If env is a function, that function will be invoked with the name and stream on each connection to
generate an environment. cleanup
is an optional function that will be called for each stream after closing if
provided. welcome-msg
is an optional string or function (welcome-msg client-name) to generate a message to
print for the client on connection.
(server-single &opt host port env cleanup welcome-msg)
Short-hand for serving up a a repl that has a single environment table in it. env
must be a proper env table,
not a function as is possible in netrepl/server.
(posix/normalize path)
Normalize a path. This removes . and .. in the path, as well as empty path elements.
(posix/normalize path)
Normalize a path. This removes . and .. in the path, as well as empty path elements.
(posix/relpath source target)
Get the relative path between two subpaths.
(posix/relpath source target)
Get the relative path between two subpaths.
(win32/normalize path)
Normalize a path. This removes . and .. in the path, as well as empty path elements.
(win32/relpath source target)
Get the relative path between two subpaths.
(hexs->words hex-string)
Returns an array of pgp words for arbitrary long string of hexs. Sanitizes out the whitespace from
hex-string
.
(word->hex word)
Returns a hex number as string for the pgp word.
Mapping from hex string < 100 to pgp words. One for odd and one for even position.
(words->hexs words-string)
Returns an array of hexs from the string with pgp words.
(rand-cdf cdf)
Pick a random index, weighted by a discrete cumulative distribution function.
(rand-cdf-path cdf & paths)
Execute one of the paths randomly given a discrete distribution as a CDF
(rand-gaussian &opt m sd)
Get a random sample from the standard Gaussian distribution. Optionall specify the mean m and the standard deviation sd.
(rand-index xs)
Get a random numeric index of an indexed data structure
(rand-int start end)
Get a random integer in a range [start, end) that is approximately uniformly distributed
(rand-path & paths)
Execute one of the paths randomly with uniform distribution
(rand-uniform)
Get a random number uniformly between 0 and 1
(rand-value xs)
Get a random value of an indexed data structure
(rand-weights weights)
Pick a random index given a set of weights
(rand-weights-path weights & paths)
Execute one of the paths randomly given a discrete distribution as a set of weights
(sample-n f n)
Generate n samples based on the random sampler f
.
(weights-to-cdf weights)
Convert an array of weights to a discrete cdf that can be more efficiently used to take a weighted random choice
(rawterm/begin &opt on-winch)
Begin raw terminal functionality. Return a stream that can be read from to get input.
(rawterm/buffer-traverse bytes index delta &opt skip-zerowidth)
Move to a new position in a buffer from index by incrementing by delta
codepoints. Can also skip zero-width
codepoints if desired.
(rawterm/ctrl-z)
A handler that a user can use to handle ctrl-z from input to suspend the current process.
(rawterm/getch &opt into)
Get a byte of input from stdin, without blocking if possible. Returns a buffer.
(rawterm/monowidth bytes &opt start-index end-index)
Measure the monospace width of a string.
(rawterm/rune-monowidth rune)
Get the monospace width of a rune. Returns either 0, 1, or 2.
(rawterm/size)
Get the number of rows and columns visible in the terminal as tuple [rows cols]
(rawterm/slice-monowidth bytes columns &opt start-index into)
Get a byte slice that will fit into a number of columns.
(compile pattern)
Compile a subset of regex to a PEG if pattern is a string. If pattern is a PEG, will return the PEG as is.
(find-all reg text &opt start)
Similar to peg/find-all, but for regexes.
Peg used to generate peg source code from a regular expression string.
(replace reg rep text &opt start)
Similar to peg/replace, but for regexes.
(replace-all reg rep text &opt start)
Similar to peg/replace-all, but for regexes.
(client &opt host port name)
Create an RPC client. The default host is "127.0.0.1" and the default port is "9366". Returns a table of async functions that can be used to make remote calls. This table also contains a :close function that can be used to close the connection.
(server functions &opt host port workers-per-connection)
Create an RPC server. The default host is "127.0.0.1" and the default port is "9366". Also must take a dictionary of functions that clients can call.
(make-predicate schema)
Generate a function that can be used to validate a data structure. This is the function form of predicate
.
(make-validator schema)
Generate a function that can be used to validate a data structure. This is the function form of validator
.
(predicate pattern)
Make a validation predicate given a certain schema.
(validator pattern)
Make a validation function of one argument. A validation function will throw an error on validation failure, otherwise, it will return the argument.
The currently running service manager, if there is one
(add-service service-name main-function & args)
Spawn a service
(get-manager)
Get the current manager. If no manager exists, create one.
(get-service)
Get the current service. If not in a service, raise an error
(make-manager &opt log-dir)
Group a number of fibers into a single object for structured concurrency. Also includes utilities for running services like servers in the background.
(print-all &opt filter-fn)
Print a table of all running services.
(set-title title)
Set a textual description of the service to describe what it is doing currently
(stop-service service-name &opt reason)
Stop a running service
(wait)
Once a number of services have been spawned, call wait
to block the fiber until the manager is canceled. This
lets a manager fiber behave as a service itself.
(copy src dest)
Copy a file or directory recursively from one location to another. Expects input to be unix style paths
(copy-file src-path dst-path)
Copy a file from source to destination. Creates all directories in the path to the destination file if they do not exist.
(create-dirs dir-path)
Create all directories in path specified as string including itself.
(devnull)
get the /dev/null equivalent of the current platform as an open file
(exec & args)
Execute command specified by args returning its exit code
(exec-fail & args)
Execute command specified by args, fails when command exits with non-zero exit code
(exec-slurp & args)
It executes args with os/spawn
and throws an error if the process returns with non-zero exit code. If the
process exits with zero exit code, this function trims standard output of the process and returns it. Before
the function finishes, the spawned process is closed for resource control.
(exec-slurp-all & args)
It executes args with os/spawn
and returns a struct which has the following keys.
-
:out
- trimmed standard output of the process -
:err
- trimmed standard error of the process -
:status
- the exit code of the process
Before the function finishes, the spawned process is closed for resource control.
(exists? path)
Check if the given file or directory exists. (Follows symlinks)
(list-all-files dir &opt into)
List the files in the given directory recursively. Return the paths to all files found, relative to the current working directory if the given path is a relative path, or as an absolute path otherwise.
(make-new-file file-path &opt mode)
Create and open a file, creating all the directories leading to the file if they do not exist, and return it.
By default, open as a writable file (mode is :w
).
(scan-directory dir func)
Scan a directory recursively, applying the given function on all files and directories in a depth-first manner. This function has no effect if the directory does not exist.
(split s)
Split a string into 'sh like' tokens, returns nil if unable to parse the string.
(lines stream &named separator)
Returns a fiber that yields each line from a core/stream value. If separator is not specified, the default
separator is \n
. After the fiber yields the last line, it returns nil
. If the fiber is resumed after the
stream is closed or after the fiber returns nil
, an error is thrown.
(tarray/buffer array|size)
Return typed array buffer or create a new buffer.
(tarray/copy-bytes src sindex dst dindex &opt count)
Copy count elements (default 1) of src array from index sindex to dst array at position dindex memory can overlap.
(tarray/length array|buffer)
Return typed array or buffer size.
(tarray/new type size &opt stride offset tarray|buffer)
Create new typed array.
(tarray/properties array)
Return typed array properties as a struct.
(tarray/slice tarr &opt start end)
Takes a slice of a typed array from start to end. The range is half open, [start, end). Indexes can also be negative, indicating indexing from the end of the end of the typed array. By default, start is 0 and end is the size of the typed array. Returns a new janet array.
(tarray/swap-bytes src sindex dst dindex &opt count)
Swap count elements (default 1) between src array from index sindex and dst array at position dindex memory can overlap.
(all-tasks tasker &opt detailed)
Get an array of all task ids for which there is still data on disk. If detailed
is truthy, return full task
metadata instead of ids.
(cancel-task tasker task-id)
Cancel a queued or running task.
(close-queues tasker)
Prevent any tasks from being added to queues. When an executor finishes its current job, if there are any, it
will terminate. When all executors complete, the call to run-executors
will complete.
Maximum allowed priority (lower priority tasks will execute first)
Minimum allowed priority (lower priority tasks will execute first)
(new-tasker &opt task-directory queues queue-size)
Create queues and various settings to run tasks. Create a new tasker table.
(queue-task tasker argv &opt note priority qname timeout expiration input)
Add a task specification to a queue. Supply an argv string array that will be used to invoke a subprocess. The
optional note
parameter is just a textual note for task tracking. The priority
parameter should be an
integer between 0 and 9 inclusive, default is 4. Lower priority jobs in the same queue will be executed by
higher priority. Use input to pass in generic, unstructured input to a task.
(run-executors tasker &opt workers-per-queue pre-task post-task)
Start a number of executors to run tasks as with tasker/spawn-executors
, and then wait for all executors to
complete.
(spawn-executors tasker &opt qnames workers-per-queue pre-task post-task)
Start a number of executors to run tasks. Tasks can be added to a queue by calling queue-task. A single tasker object can make multiple calls to spawn-executors.
(task-file tasker task-id &opt file-name)
Get a log file for a path. By default, will get a path to out.log.
(task-status tasker task-id)
Look up the status of a given task by id.
(add-loader)
Adds the custom template loader to Janet's module/loaders and update module/paths.
(compile str)
Compile a Temple template into a function which will return a rendered buffer.
The resulting function should receive the template arguments in the &keys format.
(create source &opt where)
Compile a template string into a function. Optionally provide a location where the source is from to improve debugging. Returns the template function.
(assert x &opt e)
Overrides the default assert with some nice error handling.
(assert-docs path)
Assert that all symbols have proper docstring when module on the path is required.
(assert-no-error msg & forms)
Test passes if forms do not error.
(capture-stderr & body)
Runs the form and captures stderr. Returns tuple with result of the form and a string with captured stderr.
(capture-stdout & body)
Runs the form and captures stdout. Returns tuple with result of the form and a string with captured stdout.
(end-suite)
Ends test suite, prints summary and exits if any tests have failed.
(timeit form &opt tag)
Time the execution of form
using os/clock
before and after, and print the result to stdout. Returns result
of executing form
. Uses tag
(default "Elapsed time:") to tag the printout.
(timeit-loop head & body)
Similar to loop
, but outputs performance statistics after completion. Additionally defines a :timeout
verb
to iterate continuously for a given number of seconds. If the first form of body
is a bytes, it will be taken
as a custom tag.
(utf8/decode-rune buf &opt start)
Read a UTF-8 encoded Unicode codepoint from the buffer which starts at the given index. Returns a tuple [value width], where width = number of bytes consumed. If at the end of buffer or the buffer contains malformed UTF-8, returns [nil 0].
(utf8/encode-rune rune &opt buf)
Encode a Unicode codepoint into the end of a buffer.
(utf8/prefix->width c)
Given the first byte in an UTF-8 sequence, get the number of bytes that the codepoint sequence takes up, including the prefix byte.
(zip/add-bytes writer path data &opt comment flags)
Add a byte sequence to the zip writer.
(zip/add-file writer path filename &opt comment flags)
Add a file to the zip writer.
(zip/compress bytes &opt level into)
Compress data and write to a buffer. Different compression levels can be used - higher compression levels trade
smaller output with longer compression times. Returns into
. If into
not provided, a new buffer is created.
(zip/decompress bytes &opt into)
Decompress data and write to a buffer. If an into
buffer is not provided, a new buffer will be created.
(zip/extract reader idx-or-filename &opt into flags)
Extract a file from the zip archive, either to memory or to a file on disk.
(zip/file-directory? reader idx)
Check if a file index is a directory.
(zip/file-encrypted? reader idx)
Check if a file is encrypted inside an archive.
(zip/file-supported? reader idx)
Check if a file is supported with this verstion of miniz.
(zip/get-filename reader idx)
Convert a file index index in the archive to a filename.
(zip/locate-file reader path &opt comment flags)
Get the index of a particular filename in the archive.
(zip/read-bytes bytes &opt flags)
Read a byte sequence as a zip archive. Returns a new zip reader.
(zip/read-file filename &opt flags)
Read a file as a zip archive. Returns a new zip reader.
(zip/reader-close reader)
Close a reader and free related memory.
(zip/reader-count reader)
Get the number of files inside the zip archive. The files can be indexed
(zip/stat reader idx)
Get stat information of file. Returns a new struct with the following fields:
- :index - integer index in master directory
- :version-made-by - zip verstion
- :version-needed - zip version needed to unzip
- :bit-flag
- :method - compression method
- :time - file time
- :crc32 - checksum of file contents
- :comp-size - size of file when compressed
- :uncomp-size - size of file when uncompressed
- :filename
- :comment
- :internal-attr
- :external-attr
(zip/version)
Get the version string of the underlying miniz library.
(zip/write-buffer)
Create a new zip archive writer that write to memory.
(zip/write-file dest-path)
Create a new zip archive writer that will write into an archive file.
(zip/writer-finalizer writer)
Finalize a writer, writing any zip files to disk. Return the writer.