MCPcopy Create free account

hub / github.com/MaterializeInc/demos / functions

Functions200 in github.com/MaterializeInc/demos

⨍ Functions 200◇ Types & classes 54
↓ 54 callersMethodconnect
Connect to Materialize @return a Connection object
connection-examples/java/view.java:20
↓ 21 callersMethodquery
()
connection-examples/java/query.java:29
↓ 14 callersMethodquery
* Run a query in Materialize * @param statement * @returns
antennas-kafka/backend/src/MaterializeClient/index.ts:24
↓ 13 callersMethodquery
* Run a query in Materialize * @param statement * @returns
antennas-postgres/backend/src/MaterializeClient/index.ts:24
↓ 6 callersFunctioncreate_client
Create a client using localhost
connection-examples/rust/src/connection.rs:4
↓ 4 callersFunctionconnect
(string $host, int $port, string $db, string $user, string $password)
connection-examples/php/connection.php:3
↓ 4 callersFunctionsetSourceData
* Set up a source data * @param map MapBox * @param sourceName Map source name * @param data Data to set
antennas-postgres/frontend/src/components/AntennasMap/index.tsx:70
↓ 3 callersMethodcleanBatch
()
antennas-postgres/backend/src/MaterializeClient/TransformStream/index.ts:28
↓ 3 callersMethodcleanBatch
()
antennas-kafka/backend/src/MaterializeClient/TransformStream/index.ts:28
↓ 3 callersFunctionsubscribe
()
antennas-postgres/microservice/src/app.ts:172
↓ 3 callersMethodsubscribe
* Run a subscribe in Materialize * @param statement * @param eventEmmiter * @returns
antennas-postgres/backend/src/MaterializeClient/index.ts:81
↓ 2 callersFunctionbuildEvent
(antennaId: number, value: number)
antennas-kafka/microservice/src/app.ts:77
↓ 2 callersFunctionbuildQuery
(antennaId: number, value: number)
antennas-postgres/microservice/src/app.ts:43
↓ 2 callersFunctiondataGenerator
()
antennas-postgres/helper/src/app.ts:86
↓ 2 callersFunctiongeneratePageview
(viewer_id, target_id, page_type)
ecommerce/loadgen/generate_load.py:54
↓ 2 callersMethodget_state
(self)
connection-examples/python/state.py:18
↓ 2 callersMethodprocess
* Process and push rows * @param rows
antennas-postgres/backend/src/MaterializeClient/SubscribeStream/index.ts:99
↓ 2 callersMethodprocess
* Process and push rows * @param rows
antennas-kafka/backend/src/MaterializeClient/SubscribeStream/index.ts:99
↓ 2 callersFunctionregisterValidSW
(swUrl: string, config?: Config)
antennas-postgres/frontend/src/serviceWorker.ts:60
↓ 2 callersMethodsubscribe
* Run a subscribe in Materialize * @param statement * @param eventEmmiter * @returns
antennas-kafka/backend/src/MaterializeClient/index.ts:81
↓ 2 callersMethodupdate
(self, updates: List[Update], timestamp: int)
connection-examples/python/state.py:49
↓ 1 callersMethod#validate
(timestamp)
connection-examples/nodejs/state.js:35
↓ 1 callersFunctionNewState
(collectHistory bool)
connection-examples/go/state.go:25
↓ 1 callersFunctionREPLACE_ME_WITH_YOUR_TOKEN
* Replace with your own MapBox token
antennas-postgres/frontend/src/components/AntennasMap/index.tsx:106
↓ 1 callersMethodUpdate
(updates []Update, timestamp int64)
connection-examples/go/state.go:97
↓ 1 callersFunctionaddPulsingDot
* * @param map MapBox * @param name Image layer name * @param source Source name * @param color Color to be used
antennas-postgres/frontend/src/components/AntennasMap/index.tsx:88
↓ 1 callersFunctionbuildEvent
(antennaId: number, value: number)
antennas-kafka/backend/src/app.ts:87
↓ 1 callersFunctionbuildEvent
* Build a custom Postgres insert with a random performance and clients connected * @param antennaId Antenna Identifier * @returns
antennas-kafka/helper/src/app.ts:132
↓ 1 callersFunctionbuildPulsingDot
(map, color, size)
antennas-postgres/frontend/src/components/AntennasMap/DotClone/index.js:1
↓ 1 callersFunctionbuildQuery
* Build a custom Postgres insert with a low performance value to crash antenna * @param antennaId Antenna Identifier * @returns
antennas-postgres/backend/src/app.ts:76
↓ 1 callersFunctionbuildQuery
* Build a custom Postgres insert with a random performance and clients connected * @param antennaId Antenna Identifier * @returns
antennas-postgres/helper/src/app.ts:71
↓ 1 callersFunctioncheckValidServiceWorker
(swUrl: string, config?: Config)
antennas-postgres/frontend/src/serviceWorker.ts:104
↓ 1 callersMethodconnect
Connect to Materialize @return a Connection object
connection-examples/java/insert.java:20
↓ 1 callersMethodconnect
Connect to Materialize @return a Connection object
connection-examples/java/subscribe.java:19
↓ 1 callersMethodconnect
Connect to Materialize @return a Connection object
connection-examples/java/connection.java:17
↓ 1 callersMethodconnect
Connect to Materialize @return a Connection object
connection-examples/java/query.java:19
↓ 1 callersMethodconnect
Connect to Materialize @return a Connection object
connection-examples/java/source.java:20
↓ 1 callersFunctioncreateLayer
(id: string, source: string, color: string)
antennas-postgres/frontend/src/components/AntennasMap/index.tsx:151
↓ 1 callersFunctioncreate_materialized_view
Creates a materialized view over the PUBNUB source
connection-examples/rust/src/view.rs:6
↓ 1 callersFunctioncreate_source
Creates a PUBNUB source
connection-examples/rust/src/source.rs:6
↓ 1 callersFunctioncreate_table
Create a simple table
connection-examples/rust/src/table.rs:6
↓ 1 callersFunctiondataGenerator
* Generate data to Postgres indefinitely
antennas-kafka/helper/src/app.ts:173
↓ 1 callersFunctionfindHelperAntennas
(antennaName)
antennas-postgres/microservice/src/app.ts:58
↓ 1 callersFunctionfindHelperAntennas
(antennaName)
antennas-kafka/microservice/src/app.ts:90
↓ 1 callersMethodgetDiff
()
connection-examples/php/state.php:16
↓ 1 callersMethodgetState
()
connection-examples/go/state.go:37
↓ 1 callersMethodgetState
()
connection-examples/nodejs/state.js:16
↓ 1 callersMethodgetState
()
connection-examples/deno/state.ts:21
↓ 1 callersMethodgetValue
()
connection-examples/php/state.php:12
↓ 1 callersMethodget_state
(self)
connection-examples/python/pg8000/state.py:18
↓ 1 callersMethodget_state
()
connection-examples/php/state.php:43
↓ 1 callersMethodget_state
connection-examples/ruby/state.rb:11
↓ 1 callersFunctionhandleTailEventUpdate
* Tail updates require another step here to detect added and removed antennas * @param antennasMap * @param update
antennas-postgres/frontend/src/components/AntennasMap/index.tsx:120
↓ 1 callersFunctionimproveAntennaPerformance
(antennaId, antennaName)
antennas-postgres/microservice/src/app.ts:81
↓ 1 callersFunctionimproveAntennaPerformance
(antennaId, antennaName)
antennas-kafka/microservice/src/app.ts:113
↓ 1 callersFunctioninsert
Insert data into the table
connection-examples/rust/src/insert.rs:6
↓ 1 callersMethodinsert
()
connection-examples/java/insert.java:30
↓ 1 callersMethodintervalRead
* Interval fetching used when there are no results from the subscribe * Rather than pausing and waiting for results * Run a subscribe fetch ever
antennas-postgres/backend/src/MaterializeClient/SubscribeStream/index.ts:123
↓ 1 callersMethodintervalRead
* Interval fetching used when there are no results from the subscribe * Rather than pausing and waiting for results * Run a subscribe fetch ever
antennas-kafka/backend/src/MaterializeClient/SubscribeStream/index.ts:123
↓ 1 callersMethodlistener
(results: Array<any>)
antennas-postgres/backend/src/MaterializeClient/index.ts:125
↓ 1 callersMethodlistener
(results: Array<any>)
antennas-kafka/backend/src/MaterializeClient/index.ts:125
↓ 1 callersFunctionmain
()
connection-examples/typescript/src/view.ts:14
↓ 1 callersFunctionmain
()
connection-examples/typescript/src/source.ts:14
↓ 1 callersFunctionmain
()
connection-examples/typescript/src/subscribe.ts:19
↓ 1 callersFunctionmain
()
connection-examples/typescript/src/query.ts:14
↓ 1 callersFunctionmain
()
connection-examples/typescript/src/connection.ts:19
↓ 1 callersFunctionmain
()
connection-examples/typescript/src/insert.ts:18
↓ 1 callersFunctionmain
()
connection-examples/nodejs/source.js:12
↓ 1 callersFunctionmain
()
connection-examples/nodejs/view.js:12
↓ 1 callersFunctionmain
()
connection-examples/nodejs/connection.js:17
↓ 1 callersFunctionmain
()
connection-examples/nodejs/insert.js:15
↓ 1 callersFunctionmain
()
connection-examples/nodejs/query.js:12
↓ 1 callersFunctionmain
()
connection-examples/nodejs/subscribe.js:4
↓ 1 callersFunctionmain
({ response }: { response: any })
connection-examples/deno/example.ts:10
↓ 1 callersFunctionmain
({ response }: { response: any })
connection-examples/deno/view.ts:12
↓ 1 callersFunctionmain
({ response }: { response: any })
connection-examples/deno/source.ts:12
↓ 1 callersFunctionmain
({ response }: { response: any })
connection-examples/deno/subscribe.ts:18
↓ 1 callersFunctionmain
({ response }: { response: any })
connection-examples/deno/query.ts:12
↓ 1 callersFunctionmain
({ response }: { response: any })
connection-examples/deno/connection.ts:16
↓ 1 callersFunctionmain
({ response }: { response: any })
connection-examples/deno/insert.ts:12
↓ 1 callersMethodprocess
(self, update: Update)
connection-examples/python/state.py:37
↓ 1 callersMethodprocess
(self, update: Update)
connection-examples/python/pg8000/state.py:37
↓ 1 callersMethodprocess
(Update $update)
connection-examples/php/state.php:68
↓ 1 callersMethodprocess
(update Update)
connection-examples/go/state.go:70
↓ 1 callersFunctionpurchaseLoop
()
ecommerce/loadgen/generate_load.py:62
↓ 1 callersFunctionreportWebVitals
(onPerfEntry?: ReportHandler)
antennas-postgres/frontend/src/reportWebVitals.ts:3
↓ 1 callersFunctionrun_query
Run a query over the table.
connection-examples/rust/src/query.rs:4
↓ 1 callersFunctionsetUpKafka
()
antennas-kafka/helper/src/app.ts:141
↓ 1 callersFunctionsetUpMaterialize
* Create Materialize sources and materialized views * Before creating the views it will check if they aren't created already.
antennas-postgres/helper/src/app.ts:16
↓ 1 callersFunctionsetUpMaterialize
()
antennas-kafka/helper/src/app.ts:36
↓ 1 callersMethodsource
()
connection-examples/java/source.java:30
↓ 1 callersFunctionsubscribe
Run a subscribe over the PUBNUB materialized view
connection-examples/rust/src/subscribe.rs:4
↓ 1 callersMethodsubscribe
()
connection-examples/java/subscribe.java:29
↓ 1 callersMethodupdate
(self, updates: List[Update], timestamp: int)
connection-examples/python/pg8000/state.py:49
↓ 1 callersMethodupdate
($updates, $timestamp)
connection-examples/php/state.php:90
↓ 1 callersMethodupdate
(updates, timestamp)
connection-examples/ruby/state.rb:54
↓ 1 callersMethodupdate
(updates: Array<Update<T>>, timestamp: number)
connection-examples/typescript/src/state.ts:71
↓ 1 callersMethodupdate
(updates, timestamp)
connection-examples/nodejs/state.js:66
↓ 1 callersMethodupdate
(updates: Array<Update<T>>, timestamp: number)
connection-examples/deno/state.ts:71
↓ 1 callersMethodvalidate
(self, timestamp: int)
connection-examples/python/state.py:29
next →1–100 of 200, ranked by callers