feat: support route dataframe to dedicate sfn instance

[woorui]

Adding WriteWithTarget api for Source, call it like:

source.WriteWithTarget(0x33, []byte("hello handler"), "target-id-1")

And sfn will receive the payload that be written by source like this:

sfn.SetWantedTarget("target-id-1")

sfn.SetHandler(func(ctx serverless.Context) {
  fmt.Println(ctx.Data())
  ctx.WriteWithTarget(0x34, []byte("hello next"), "target-id-2")
})

And the sfn that has called sfn.SetWantedTarget("target-id-2") will receive data from the above sfn.

The route rules is:

1. find all sfn in tag.
2. if the sfn do not called SetWantedTarget, send data to the sfn.
3. if the sfn called SetWantedTarget, send the data only when dataFrame.Metadata.Target == sfn.WantedTarget.

TODO: cli/wasm support.

[vercel]

The latest updates on your projects. Learn more about Vercel for Git ↗︎

1 Ignored Deployment

Name	Status	Preview	Comments	Updated (UTC)
yomo	⬜️ Ignored (Inspect)	Visit Preview		Jan 26, 2024 5:28pm

[codecov]

Codecov Report

Attention: 14 lines in your changes are missing coverage. Please review.

Comparison is base (c9ed644) 59.45% compared to head (8eeda72) 59.58%.

Files	Patch %	Lines
source.go	71.42%	4 Missing and 2 partials ⚠️
core/server.go	0.00%	2 Missing and 1 partial ⚠️
pkg/frame-codec/y3codec/handshake_frame.go	70.00%	2 Missing and 1 partial ⚠️
core/client.go	33.33%	2 Missing ⚠️

Additional details and impacted files

@@            Coverage Diff             @@
##           master     #704      +/-   ##
==========================================
+ Coverage   59.45%   59.58%   +0.12%     
==========================================
  Files          37       37              
  Lines        2733     2781      +48     
==========================================
+ Hits         1625     1657      +32     
- Misses       1009     1019      +10     
- Partials       99      105       +6     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

[venjiang]

how to use SetWantedTarget(string)? any tests?

[woorui]

how to use SetWantedTarget(string)? any tests?

I add some tests about target in source_test.go and sfn_test.go files.

[venjiang]

👍