Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var HTTP_REQUEST_DEF = core.TypeDef{ Type: "map", Map: map[string]*core.TypeDef{ "method": { Type: "string", }, "path": { Type: "string", }, "query": { Type: "string", }, "params": { Type: "stream", Stream: &core.TypeDef{ Type: "map", Map: map[string]*core.TypeDef{ "key": { Type: "string", }, "values": { Type: "stream", Stream: &core.TypeDef{ Type: "string", }, }, }, }, }, "headers": { Type: "stream", Stream: &core.TypeDef{ Type: "map", Map: map[string]*core.TypeDef{ "key": { Type: "string", }, "values": { Type: "stream", Stream: &core.TypeDef{ Type: "string", }, }, }, }, }, "body": { Type: "binary", }, }, }
HttpRequest Slang type
View Source
var HTTP_RESPONSE_DEF = core.TypeDef{ Type: "map", Map: map[string]*core.TypeDef{ "status": { Type: "number", }, "headers": { Type: "stream", Stream: &core.TypeDef{ Type: "map", Map: map[string]*core.TypeDef{ "key": { Type: "string", }, "value": { Type: "string", }, }, }, }, "body": { Type: "binary", }, }, }
HttpResponse Slang type
Functions ¶
func GetBuiltinNames ¶
func GetBuiltinNames() []string
func GetOperatorDef ¶
func GetOperatorDef(operator string) (core.OperatorDef, error)
func IsRegistered ¶
func MakeOperator ¶
func MakeOperator(def core.InstanceDef) (*core.Operator, error)
Types ¶
type EvaluableExpression ¶
type EvaluableExpression struct {
govaluate.EvaluableExpression
}
Source Files
¶
- control_iterate.go
- control_loop.go
- control_merge.go
- control_reduce.go
- control_single_split.go
- control_split.go
- control_switch.go
- control_take.go
- data_convert.go
- data_evaluate.go
- data_value.go
- database_execute.go
- database_query.go
- encoding_csv_read.go
- encoding_json_read.go
- encoding_json_write.go
- encoding_url_write.go
- encoding_xlsx_read.go
- files_append.go
- files_read.go
- files_read_lines.go
- files_write.go
- files_zip_pack.go
- files_zip_unpack.go
- image_decode.go
- image_encode.go
- manager.go
- meta_store.go
- net_http_client.go
- net_http_server.go
- net_mqtt_publish.go
- net_mqtt_subscribe.go
- net_mqtt_subscribe_legacy.go
- net_send_email.go
- stream_concatenate.go
- stream_map_access.go
- stream_map_to_stream.go
- stream_parallelize.go
- stream_serialize.go
- stream_slice.go
- stream_stream_to_map.go
- stream_transform.go
- stream_window.go
- stream_window_collect.go
- stream_window_release.go
- string_beginswith.go
- string_contains.go
- string_endswith.go
- string_format.go
- string_split.go
- string_template.go
- system_execute.go
- time_crontab.go
- time_date.go
- time_date_now.go
- time_delay.go
- types.go
Click to show internal directories.
Click to hide internal directories.