|
|
| version 1.271, 2026/05/06 20:33:38 | version 1.273, 2026/10/09 18:53:41 |
|---|---|
| Line 749 regex | Line 749 regex |
| $pattern.options | $pattern.options |
| the string with the original text of the options | the string with the original text of the options |
| amqp | |
| ^amqp::create[[ | |
| $.host[localhost] $.port(5672) $.user[guest] $.password[guest] $.vhost[/] $.locale[en_US] | |
| $.heartbeat(30) $.auto_reconnect(seconds) | |
| $.tls[ $.ca[file] $.cert[file] $.key[file] $.verify(true) ] | |
| ]] | |
| connects to a RabbitMQ broker | |
| auto_reconnect(N): after a lost connection reconnect before the next operation, waiting N seconds | |
| tls: the server certificate is verified only if ca is specified | |
| ^amqp.publish[message][[ | |
| $.exchange[] $.routing_key[key]|$.queue[name] $.mandatory(false) | |
| message properties: $.content_type[] $.content_encoding[] $.delivery_mode(1|2) $.priority(N) $.correlation_id[] $.reply_to[] | |
| $.expiration[] $.message_id[] $.timestamp(N) $.type[] $.user_id[] $.app_id[] $.cluster_id[] $.headers[hash] | |
| ]] | |
| ^amqp.consume[ $.queue[name] $.ack(true) $.count(1) $.timeout(0) $.exclusive(false) $.consumer_tag[] ] | |
| array of messages ready within timeout seconds (only the first one is waited for) | |
| ^amqp.consume[ $.queue[name] $.callback[$method] ... ] | |
| calls @method[message] for each message until ^amqp.stop_consume[], count messages or timeout seconds without messages | |
| count and timeout are unlimited by default | |
| message: hash with msg, delivery_tag, routing_key, exchange, redelivered, consumer_tag and the properties set | |
| ^amqp.ack(delivery_tag) | |
| with $.ack(true) (default) received messages must be acknowledged | |
| ^amqp.nack(delivery_tag)[ $.requeue(false) ] | |
| ^amqp.reject(delivery_tag)[ $.requeue(true) ] | |
| ^amqp.qos[ $.prefetch_count(N) ] | |
| ^amqp.declare[ $.queue[name] $.durable(false) $.exclusive(false) $.auto_delete(false) $.passive(false) $.arguments[hash] ] | |
| for an empty name the server creates a queue with its own name, which is returned | |
| ^amqp.declare[ $.exchange[name] $.type[direct] $.durable(false) $.auto_delete(false) $.internal(false) $.passive(false) $.arguments[hash] ] | |
| ^amqp.delete[ $.queue[name]|$.exchange[name] $.if_unused(false) $.if_empty(false) ] | |
| ^amqp.bind[ $.exchange[name] $.queue[name] $.routing_key[] ] | |
| ^amqp.unbind[ $.exchange[name] $.queue[name] $.routing_key[] ] | |
| ^amqp.purge[ $.queue[name] ] | |
| number of deleted messages | |
| ^amqp.info[ $.queue[name] ] | |
| hash with queue, messages, consumers | |
| ^amqp.release[] | |
| closes the connection | |
| arguments and headers values: [string], (number), (true|false) | |
| console | console |
| $console:timeout | $console:timeout |
| $console:line | $console:line |
| Line 758 cookie | Line 797 cookie |
| $cookie:name read old or newly set cookie | $cookie:name read old or newly set cookie |
| $cookie:name[value] for 90 days | $cookie:name[value] for 90 days |
| $cookie:name[$.value[value] $.expires[VALUE] $.secure(true) $.domain[domain name] $.httponly(true)] | $cookie:name[$.value[value] $.expires[VALUE] $.secure(true) $.domain[domain name] $.httponly(true)] |
| the expires field value can be 'session', a date, or a number of days (0days=forever) | the expires field value can be 'session', a date, or a number of days (0days=session) |
| if it's a date, it will be converted to "Sun, 25-Aug-2002 12:03:45 GMT" | if it's a date, it will be converted to "Sun, 25-Aug-2002 12:03:45 GMT" |
| $cookie:fields | $cookie:fields |
| hash with all cookies | hash with all cookies |
| Line 1103 reflection | Line 1142 reflection |
| ^reflection:override[method[; $.to[target] $.name[new_name]]] | ^reflection:override[method[; $.to[target] $.name[new_name]]] |
| overrides or defines a method | overrides or defines a method |
| redis | |
| ^redis::open[[ | |
| $.host[localhost] $.port(6379)|$.unix_socket[path] | |
| $.user[] $.password[] $.db(0) $.timeout(2) $.protocol(3) $.auto_reconnect(seconds) | |
| $.tls[ $.ca[file] $.cert[file] $.key[file] $.verify(true) ] | |
| ]] | |
| connects to a redis server | |
| timeout in seconds for connecting and for each command, 0 - unlimited | |
| protocol(2) for servers before redis 6 | |
| auto_reconnect(N): after a lost connection reconnect before the next command, waiting N seconds | |
| tls: the server certificate is verified only if ca is specified | |
| ^redis.command_name[arguments;...] | |
| any redis command, e.g. ^redis.set[key;value] ^redis.get[key] ^redis.hgetall[key] | |
| ^redis.call[command;arguments;...] | |
| ^redis.f-command_name[arguments;...], ^redis.f-call[command;arguments;...] | |
| the strings of the reply are files (binary data) | |
| arguments: string, number, bool as 1/0, file as its content; array - its elements, hash - key value pairs | |
| reply: string, int, double, bool, void (nil), array, hash (map); an error reply is an exception | |
| ^redis.release[] | |
| closes the connection | |
| request | request |
| https://site.name/a%20b/?name=some%20value | https://site.name/a%20b/?name=some%20value |
| $request:query | $request:query |
| Line 1433 system error types: | Line 1493 system error types: |
| http.response ^file::load[http://ok/there] host found, connection accepted, bad answer | http.response ^file::load[http://ok/there] host found, connection accepted, bad answer |
| http.status ^file::load[http://ok/there] host found, connection accepted, status!=200 | http.status ^file::load[http://ok/there] host found, connection accepted, status!=200 |
| date.range ^date::create(10000;1;1) date out of valid range | date.range ^date::create(10000;1;1) date out of valid range |
| amqp ^amqp::create[$.port(1)] connection failed/error from the broker | |
| redis ^redis::open[$.port(1)] connection failed/error reply | |
| if $SIGPIPE(1) is defined in MAIN, then if processing was interrupted by the user, a message | if $SIGPIPE(1) is defined in MAIN, then if processing was interrupted by the user, a message |
| about this is written to parser3.log | about this is written to parser3.log |