Proto commits in numaproj/numaflow-go

These 47 commits are when the Protocol Buffers files have changed:

Commit:4157177
Author:Vaibhav Tiwari
Committer:Vaibhav Tiwari

feat: add nack_options proto + sink NACK status for per-message nack Signed-off-by: Vaibhav Tiwari <vaibhav.tiwari33@gmail.com>

Commit:6f4297d
Author:Vaibhav Kant Tiwari
Committer:GitHub

feat: Update Sourcer interface for propagating totalPartitions (#225) Signed-off-by: Vaibhav Tiwari <vaibhav.tiwari33@gmail.com>

The documentation is generated from this commit.

Commit:a75410d
Author:Vaibhav Kant Tiwari
Committer:GitHub

feat: add onSuccess sink support (#216) Signed-off-by: Vaibhav Tiwari <vaibhav.tiwari33@gmail.com>

Commit:3abee2e
Author:Adarsh Jain
Committer:GitHub

feat: metadata implementation for source, map and sink (#208) Signed-off-by: adarsh0728 <gooneriitk@gmail.com> Signed-off-by: Yashash H L <yashashhl25@gmail.com> Co-authored-by: Yashash H L <yashashhl25@gmail.com>

Commit:b9ce966
Author:Yashash H L
Committer:GitHub

feat: nack support for udsource (#210) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:c156c6b
Author:adarsh0728

update Signed-off-by: adarsh0728 <gooneriitk@gmail.com>

Commit:5c8bfb3
Author:adarsh0728

metadata for mapper Signed-off-by: adarsh0728 <gooneriitk@gmail.com>

Commit:2d2bc6e
Author:Yashash H L
Committer:GitHub

chore: update accumulator proto (#200) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:d5c1110
Author:Yashash H L
Committer:GitHub

feat: Accumulator (#185) Signed-off-by: Yashash H L <yashashhl25@gmail.com> Signed-off-by: Vigith Maurice <vigith@gmail.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>

Commit:bfa4ed9
Author:Vigith Maurice
Committer:GitHub

feat: Custom Serve Store for integration with any user-defined store (#176) Signed-off-by: Vigith Maurice <vigith@gmail.com> Signed-off-by: Sreekanth <prsreekanth920@gmail.com> Signed-off-by: Yashash H L <yashashhl25@gmail.com> Co-authored-by: Sreekanth <prsreekanth920@gmail.com> Co-authored-by: Yashash H L <yashashhl25@gmail.com>

Commit:7ec3f2c
Author:Yashash H L
Committer:GitHub

chore: Batch ack requests and sink responses for better performance (#163) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:53eedf8
Author:Yashash H L
Committer:GitHub

feat: Unify Map Stream and Unary Map Operations Using a Shared gRPC Protocol (#162) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:ed18862
Author:Yashash H L
Committer:GitHub

feat: Unify Batch Map and Unary Map Operations Using a Shared gRPC Protocol (#161) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:702acef
Author:Yashash H L
Committer:GitHub

feat: Using gRPC Bidirectional Streaming for Map (#158) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:e65c766
Author:Sreekanth
Committer:GitHub

feat: Use bidirectional streaming for Source Transformer (#147) Signed-off-by: Sreekanth <prsreekanth920@gmail.com>

Commit:0d92638
Author:Yashash H L
Committer:GitHub

feat: Bidirectional Streaming for UDSink (#151) Signed-off-by: Yashash H L <yashashhl25@gmail.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>

Commit:d657640
Author:Yashash H L
Committer:GitHub

feat: use gRPC bidirectional streaming for udsource (#146) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:15e4521
Author:Sidhant Kohli
Committer:GitHub

feat: implement batch map (#133) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com> Co-authored-by: Sidhant Kohli <sidhant.kohli@gmail.com>

Commit:9747b4d
Author:Yashash H L
Committer:GitHub

feat: Fallback Sink (#120) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:526a7c6
Author:Yashash H L
Committer:GitHub

feat: support headers for message (#108) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:c30dfc0
Author:Derek Wang

Merge remote-tracking branch 'origin/main' into protof Signed-off-by: Derek Wang <whynowy@gmail.com>

Commit:2903e27
Author:Yashash H L
Committer:GitHub

feat: Session Window and Reduce Streaming (#87) Signed-off-by: Yashash H L <yashashhl25@gmail.com> Signed-off-by: Vigith Maurice <vigith@gmail.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>

Commit:bd836d0
Author:Yashash H L
Committer:GitHub

chore: adding partitions for user defined source (#91) Signed-off-by: Yashash H L <yashashhl25@gmail.com> Signed-off-by: Vigith Maurice <vigith@gmail.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>

Commit:3b15796
Author:Derek Wang
Committer:Derek Wang

chore: centralize proto files Signed-off-by: Derek Wang <whynowy@gmail.com>

This commit does not contain any .proto files.

Commit:24b54b9
Author:Keran Yang
Committer:GitHub

fix: allow returning negative value from source pending api (#81) Signed-off-by: Keran Yang <yangkr920208@gmail.com>

Commit:630a5eb
Author:Sidhant Kohli
Committer:GitHub

feat: add side input grpc service (#69) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com>

Commit:f7a6a02
Author:Yashash H L
Committer:GitHub

chore: remove event time and watermark from sink proto (#76) Signed-off-by: Yashash H L <yashash_hl@intuit.com>

Commit:938fd82
Author:Yashash H L
Committer:GitHub

chore: separate server for each service (#70) Signed-off-by: Vigith Maurice <vigith@gmail.com> Signed-off-by: Yashash H L <yashash_hl@intuit.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>

Commit:44ff06c
Author:Keran Yang
Committer:GitHub

feat: add gRPC services for user-defined source (#72) Signed-off-by: Keran Yang <yangkr920208@gmail.com>

Commit:d680ace
Author:Keran Yang
Committer:GitHub

feat: add proto file for user defined source (#65) Signed-off-by: Keran Yang <yangkr920208@gmail.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>

Commit:581a46a
Author:Sidhant Kohli
Committer:GitHub

feat: Add Side input proto specifications (#66) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com>

Commit:74809b4
Author:xdevxy
Committer:GitHub

feat: introduce `MapStreamFn` to stream processed messages during map operation (#54) Signed-off-by: Hao Hao <xdevxhao@gmail.com>

Commit:348c06a
Author:Yashash H L
Committer:GitHub

feat: introducing tags for conditional forwarding (#45) Signed-off-by: Yashash H L <yashash_hl@intuit.com>

Commit:54e73e1
Author:Yashash H L

doc Signed-off-by: Yashash H L <yashash_hl@intuit.com>

Commit:878f676
Author:Yashash H L

doc Signed-off-by: Yashash H L <yashash_hl@intuit.com>

Commit:51a7e53
Author:Yashash H L

introduce datum request and response Signed-off-by: Yashash H L <yashash_hl@intuit.com>

Commit:2ecaa6c
Author:xdevxy
Committer:GitHub

revert: metadata for udsink (#46) Signed-off-by: Hao Hao <xdevxhao@gmail.com>

Commit:57af86f
Author:xdevxy
Committer:GitHub

feat: Add ID and numDelivered fields to Datum. (#43) Signed-off-by: Hao Hao <xdevxhao@gmail.com>

Commit:f9e5320
Author:Yashash H L
Committer:GitHub

feat: support for multi keys (#40) Signed-off-by: Yashash H L <yashash_hl@intuit.com> Signed-off-by: Vigith Maurice <vigith@gmail.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>

Commit:57b41ee
Author:Yashash H L
Committer:GitHub

feat: bidirectional streaming (#37) Signed-off-by: Yashash H L <yashash_hl@intuit.com>

Commit:d54cbbe
Author:Keran Yang
Committer:GitHub

feat: add mapTFn to allow user defined function to assign a new event time to message (#31) This change adds a new mapTFn API to allow numaflow user to define a function to transform data at source vertex. Having such feature allows user to assign a new event time to messages and filter data at source vertex to reduce traffic sent to the out-going isb. More details in: https://github.com/numaproj/numaflow/issues/446 Signed-off-by: Keran Yang <yangkr920208@gmail.com>

Commit:7c6f7b1
Author:Juanlu Yu
Committer:GitHub

feat: udsink gRPC stream (#25) Signed-off-by: jyu6 <juanlu_yu@intuit.com>

Commit:b495631
Author:David Seapy
Committer:GitHub

chore: update readme sink example and minor proto formatting (#20)

Commit:3ec0220
Author:Juanlu Yu
Committer:GitHub

feature: udsink gRPC (#16) Signed-off-by: jyu6 <juanlu_yu@intuit.com>

Commit:082acca
Author:Vigith Maurice
Committer:GitHub

feat: proto file for UDSink (#14) Signed-off-by: Vigith Maurice <vigith@gmail.com> Signed-off-by: Vigith Maurice <vigith@gmail.com>

Commit:ff4a1e5
Author:Vigith Maurice
Committer:GitHub

chore: refactor proto definition (#10)

Commit:dc42bf6
Author:Chrome
Committer:GitHub

Initial gRPC (#3) Signed-off-by: jyu6 <juanlu_yu@intuit.com>