Comments (3)
Hey @felixbecker, we just merged #33. This gives you access to an iterator that iterates over the whole view. Let me know if any issues arise. Example assuming string values:
state, err = view.Iterator()
if err != nil {
log.Fatalf("error getting iterator: %v", err)
}
defer state.Release()
for state.Next() {
key := state.Key()
val, err := state.Value()
if err != nil {
log.Fatalf("error getting value from iterator: %v", err)
}
log.Printf("key: %s, value: %s", string(key), val.(string))
}
from goka.
Hi Felix,
to iterate over all key-value pairs of a table, we use View.Iterator()
which should be pretty soon merged to the master.
And yes, we do have plans to extend the docs. Have you checked this blog post? We should probably link it in the README at some point.
from goka.
Hi, thanks for your reply. I think View.Iterator()
interface would be a great fit.
I saw the blog post and I am looking forward to other posts in that series since it made me curious for more.
from goka.
Related Issues (20)
- check partition mismatch
- create actions for examples
- The process is disconnected when Kafka restart HOT 2
- Wiki references ZKTopicManagerBuilder but it doesn't exist HOT 1
- Goka set debug mode to custom logger HOT 3
- ctx.Value() changes initial message HOT 5
- RedisIterator skips first key when it.Next() is called HOT 5
- Failing to run examples HOT 6
- Question: Goka compatibility with Kafka 3.3.1 (KRaft) HOT 1
- Bug: `PartitionProcessor.VisitValues` does not clean up `Signal.waiters`, causing a memory leak
- Question: Regarding Emitters Connection HOT 2
- Pause and Resume Functionality in Processor HOT 4
- Link to blog post is dead HOT 1
- Processor calls wrong decode codec on message receipt HOT 1
- Any way allow to customize key of KTable HOT 1
- bug error setting up for partition HOT 3
- how to use Goka to move data from group table state to different storage system HOT 4
- EmitSync stuck in channel HOT 3
- Cannot connect to broker if the program is on docker container HOT 3
- Kafka server: Message was too large, server rejected it to avoid allocation error HOT 3
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from goka.