MCPcopy Create free account

hub / github.com/MaterializeInc/demos / functions

Functions200 in github.com/MaterializeInc/demos

⨍ Functions 200◇ Types & classes 54
↓ 1 callersMethodvalidate
(self, timestamp: int)
connection-examples/python/pg8000/state.py:29
↓ 1 callersMethodvalidate
($timestamp)
connection-examples/php/state.php:58
↓ 1 callersMethodvalidate
(timestamp: number)
connection-examples/typescript/src/state.ts:40
↓ 1 callersMethodvalidate
(timestamp int64)
connection-examples/go/state.go:60
↓ 1 callersMethodvalidate
(timestamp: number)
connection-examples/deno/state.ts:40
↓ 1 callersMethodview
()
connection-examples/java/view.java:30
Method#process
({ value: _value, diff })
connection-examples/nodejs/state.js:49
FunctionAllProviders
({children}: {children?: React.ReactNode})
antennas-postgres/frontend/src/test-utils.tsx:5
FunctionAntennasMap
()
antennas-postgres/frontend/src/components/AntennasMap/index.tsx:169
FunctionApp
()
antennas-postgres/frontend/src/App.tsx:15
FunctionColorModeSwitcher
(props)
antennas-postgres/frontend/src/ColorModeSwitcher.tsx:7
Method__construct
($value, $diff)
connection-examples/php/state.php:7
Method__construct
($collectHistory = false)
connection-examples/php/state.php:27
Method__init__
(self, value: T, diff: int)
connection-examples/python/state.py:7
Method__init__
(self, collect_history: bool = False)
connection-examples/python/state.py:12
Method__init__
(self, value: T, diff: int)
connection-examples/python/pg8000/state.py:7
Method__init__
(self, collect_history: bool = False)
connection-examples/python/pg8000/state.py:12
Method_flush
(callback: () => void)
antennas-postgres/backend/src/MaterializeClient/TransformStream/index.ts:44
Method_flush
(callback: () => void)
antennas-kafka/backend/src/MaterializeClient/TransformStream/index.ts:44
Method_read
* Readable method to fetch subscribe data * @param n
antennas-postgres/backend/src/MaterializeClient/SubscribeStream/index.ts:39
Method_read
* Readable method to fetch subscribe data * @param n
antennas-kafka/backend/src/MaterializeClient/SubscribeStream/index.ts:39
Method_transform
(row: any, encoding: string, callback: () => void)
antennas-postgres/backend/src/MaterializeClient/TransformStream/index.ts:32
Method_transform
(row: any, encoding: string, callback: () => void)
antennas-kafka/backend/src/MaterializeClient/TransformStream/index.ts:32
Method_write
(rows: Array<any>, encoding: BufferEncoding, callback: (error?: Error) => void)
antennas-postgres/backend/src/MaterializeClient/WriteStream/index.ts:19
Method_write
(rows: Array<any>, encoding: BufferEncoding, callback: (error?: Error) => void)
antennas-kafka/backend/src/MaterializeClient/WriteStream/index.ts:19
FunctionantennasPerformanceListener
(data)
antennas-postgres/microservice/src/app.ts:124
FunctionantennasPerformanceListener
(data)
antennas-kafka/microservice/src/app.ts:153
FunctionantennasUpdates
* Subscriptions
antennas-postgres/backend/src/app.ts:144
FunctionantennasUpdates
* Subscriptions
antennas-kafka/backend/src/app.ts:146
MethodasyncStream
()
antennas-postgres/backend/src/MaterializeClient/index.ts:83
MethodasyncStream
()
antennas-kafka/backend/src/MaterializeClient/index.ts:83
FunctionbuildButtonSelection
(mapBox)
antennas-postgres/frontend/src/components/AntennasMap/ButtonSelection/index.js:1
MethodcatchClientErr
* Capture any error while fetching subscribe results * @param clientReasonErr
antennas-postgres/backend/src/MaterializeClient/SubscribeStream/index.ts:84
MethodcatchClientErr
* Capture any error while fetching subscribe results * @param clientReasonErr
antennas-kafka/backend/src/MaterializeClient/SubscribeStream/index.ts:84
Methodconstructor
(collectHistory?: boolean)
connection-examples/typescript/src/state.ts:12
Methodconstructor
(collectHistory)
connection-examples/nodejs/state.js:7
Methodconstructor
(collectHistory?: boolean)
connection-examples/deno/state.ts:12
Methodconstructor
(options: ClientOptions)
antennas-postgres/frontend/src/link.ts:10
Methodconstructor
(config: PoolConfig)
antennas-postgres/backend/src/MaterializeClient/index.ts:14
Methodconstructor
(listener: (results: Array<any>) => void)
antennas-postgres/backend/src/MaterializeClient/WriteStream/index.ts:10
Methodconstructor
()
antennas-postgres/backend/src/MaterializeClient/TransformStream/index.ts:19
Methodconstructor
(client: Client, cursorId: string)
antennas-postgres/backend/src/MaterializeClient/SubscribeStream/index.ts:24
Methodconstructor
(config: PoolConfig)
antennas-kafka/backend/src/MaterializeClient/index.ts:14
Methodconstructor
(listener: (results: Array<any>) => void)
antennas-kafka/backend/src/MaterializeClient/WriteStream/index.ts:10
Methodconstructor
()
antennas-kafka/backend/src/MaterializeClient/TransformStream/index.ts:19
Methodconstructor
(client: Client, cursorId: string)
antennas-kafka/backend/src/MaterializeClient/SubscribeStream/index.ts:24
FunctioncrashAntenna
(context)
antennas-postgres/backend/src/app.ts:113
FunctioncrashAntenna
(context)
antennas-kafka/backend/src/app.ts:122
FunctioncustomRender
(ui: React.ReactElement, options?: RenderOptions)
antennas-postgres/frontend/src/test-utils.tsx:9
MethodendClient
()
antennas-postgres/backend/src/MaterializeClient/index.ts:93
MethodendClient
()
antennas-kafka/backend/src/MaterializeClient/index.ts:93
Functionfetch_data
()
streamlit-subscribe/subscribe.py:13
FunctiongetAntennas
()
antennas-postgres/backend/src/app.ts:90
FunctiongetAntennas
()
antennas-kafka/backend/src/app.ts:99
MethodgetHistory
()
connection-examples/typescript/src/state.ts:36
MethodgetHistory
()
connection-examples/go/state.go:56
MethodgetHistory
()
connection-examples/nodejs/state.js:31
MethodgetHistory
()
connection-examples/deno/state.ts:36
MethodgetState
()
connection-examples/typescript/src/state.ts:21
Methodget_history
(self)
connection-examples/python/state.py:26
Methodget_history
(self)
connection-examples/python/pg8000/state.py:26
Methodget_history
()
connection-examples/php/state.php:39
Methodget_history
connection-examples/ruby/state.rb:22
MethodhandleSubscribeError
(err)
antennas-postgres/backend/src/MaterializeClient/index.ts:132
MethodhandleSubscribeError
(err)
antennas-kafka/backend/src/MaterializeClient/index.ts:132
Methodinitialize
(collect_history)
connection-examples/ruby/state.rb:4
Functionmain
()
connection-examples/rust/src/main.rs:17
Functionmain
()
connection-examples/go/query.go:10
Functionmain
()
connection-examples/go/source.go:10
Functionmain
()
connection-examples/go/connection.go:10
Functionmain
()
connection-examples/go/insert.go:10
Functionmain
()
connection-examples/go/view.go:10
Functionmain
()
connection-examples/go/subscribe.go:15
Methodmain
(String[] args)
connection-examples/java/insert.java:46
Methodmain
(String[] args)
connection-examples/java/view.java:47
Methodmain
(String[] args)
connection-examples/java/subscribe.java:46
Methodmain
(String[] args)
connection-examples/java/connection.java:33
Methodmain
(String[] args)
connection-examples/java/query.java:44
Methodmain
(String[] args)
connection-examples/java/source.java:45
FunctiononClose
()
antennas-postgres/backend/src/app.ts:225
FunctiononClose
()
antennas-kafka/backend/src/app.ts:226
FunctiononComplete
()
antennas-postgres/microservice/src/app.ts:164
FunctiononComplete
()
antennas-kafka/microservice/src/app.ts:189
FunctiononConnect
()
antennas-postgres/backend/src/app.ts:228
FunctiononConnect
()
antennas-kafka/backend/src/app.ts:229
FunctiononDisconnect
(ctx)
antennas-postgres/backend/src/app.ts:231
FunctiononDisconnect
(ctx)
antennas-kafka/backend/src/app.ts:232
FunctiononError
(ctx, msg, errors)
antennas-postgres/backend/src/app.ts:235
FunctiononError
(err)
antennas-postgres/microservice/src/app.ts:156
FunctiononError
(ctx, msg, errors)
antennas-kafka/backend/src/app.ts:236
FunctiononError
(err)
antennas-kafka/microservice/src/app.ts:185
FunctiononSubscribe
(ctx, msg)
antennas-postgres/backend/src/app.ts:241
FunctiononSubscribe
(ctx, msg)
antennas-kafka/backend/src/app.ts:242
Methodprocess
(update)
connection-examples/ruby/state.rb:38
Methodprocess
({ value: _value, diff }: Update<T>)
connection-examples/typescript/src/state.ts:54
Methodprocess
({ value: _value, diff }: Update<T>)
connection-examples/deno/state.ts:54
Functionregister
(config?: Config)
antennas-postgres/frontend/src/serviceWorker.ts:26
Methodrequest
(operation: Operation)
antennas-postgres/frontend/src/link.ts:15
Functionunregister
()
antennas-postgres/frontend/src/serviceWorker.ts:132
Methodvalidate
(timestamp)
connection-examples/ruby/state.rb:28
← previous101–200 of 200, ranked by callers