issues
search
numaproj
/
numaflow-go
Numaflow Golang SDK
Apache License 2.0
46
stars
11
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
chore: increase default max msg size to 64 MB
#62
whynowy
closed
1 year ago
0
chore: move client from SDK to numaflow
#61
kohlisid
closed
1 year ago
0
fix: fix tests
#60
jy4096
closed
1 year ago
0
chore: add map udf stream example
#59
xdevxy
closed
1 year ago
0
chore: add uuid to metadata
#58
yhl25
closed
1 year ago
1
chore: add error test case for map streaming UDF client
#57
xdevxy
closed
1 year ago
0
feat: error handling for mapFn mapTFn and reduceFn
#56
jy4096
closed
1 year ago
3
chore: update map stream interface
#55
xdevxy
closed
1 year ago
0
feat: introduce `MapStreamFn` to stream processed messages during map operation
#54
xdevxy
closed
1 year ago
3
fix: update event time filter transformer to use tag
#53
KeranYang
closed
1 year ago
0
chore: server info file readiness check in the clients
#52
whynowy
closed
1 year ago
0
feat: use serv-info data for starting client
#51
kohlisid
closed
1 year ago
1
chore: fix NewMessageT order
#50
yhl25
closed
1 year ago
1
doc: explain how to use datum metadata.
#49
xdevxy
closed
1 year ago
0
chore: fix some typos
#48
KeranYang
closed
1 year ago
0
test: fix server conn in test
#47
kohlisid
closed
1 year ago
0
revert: metadata for udsink
#46
xdevxy
closed
1 year ago
0
feat: introducing tags for conditional forwarding
#45
yhl25
closed
1 year ago
0
feat: add multiproc tcp client support
#44
kohlisid
closed
1 year ago
1
feat: Add ID and numDelivered fields to Datum.
#43
xdevxy
closed
1 year ago
8
feat: introduce handshake to client and gRPC server
#42
whynowy
closed
1 year ago
5
udf for creating a new key 'even' or 'odd' based on the value of the incoming [integer] key
#41
juliev0
closed
1 year ago
1
feat: support for multi keys
#40
yhl25
closed
1 year ago
0
refactor: un-export MessageT's attributes
#39
KeranYang
closed
1 year ago
4
numaflow-go changes to support gRPC bidirectional streaming for reduce
#38
yhl25
closed
1 year ago
0
feat: bidirectional streaming
#37
yhl25
closed
1 year ago
0
refactor: return error for server start
#36
sandangel
closed
1 year ago
6
server Start to return error instead of calling log.Fatal()
#35
sandangel
closed
1 year ago
5
feat: improved performance using one grpc stream per window
#34
yhl25
closed
1 year ago
0
Add a user defined source data transformer example for numaflow e2e test
#33
KeranYang
closed
1 year ago
1
Add a user defined source data transformer example for numaflow e2e test
#32
KeranYang
closed
1 year ago
0
feat: add mapTFn to allow user defined function to assign a new event time to message
#31
KeranYang
closed
1 year ago
0
feat: add sdk for implementing user defined source data transformer
#30
KeranYang
closed
1 year ago
0
.
#29
KeranYang
closed
1 year ago
0
chore: add reduce example to doc
#28
jy4096
closed
1 year ago
0
chore: add redis udsink to support numaflow E2E testing
#27
KeranYang
closed
1 year ago
1
chore: update examples
#26
jy4096
closed
1 year ago
0
feat: udsink gRPC stream
#25
jy4096
closed
1 year ago
4
chore: unify examples
#24
jy4096
closed
1 year ago
4
Udsink grpc stream
#23
jy4096
closed
1 year ago
0
passing metadata to reduce handler
#22
yhl25
closed
1 year ago
0
feat: add support to configure max message size
#21
jy4096
closed
1 year ago
0
chore: update readme sink example and minor proto formatting
#20
dseapy
closed
1 year ago
0
chore: rename example images
#19
whynowy
closed
2 years ago
0
feature: mock code for reduce client
#18
yhl25
closed
2 years ago
0
chore: Update readme and cleanup old libs
#17
whynowy
closed
2 years ago
0
feature: udsink gRPC
#16
jy4096
closed
2 years ago
1
chore: function examples
#15
whynowy
closed
2 years ago
0
feat: proto file for UDSink
#14
vigith
closed
2 years ago
1
chore: move datum to a standalone interface
#13
vigith
closed
2 years ago
0
Previous
Next