github_mirrors/kis-flow
1
0
Fork 0
mirror of https://github.com/aceld/kis-flow.git synced 2025-01-22 23:20:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

go fmt

Browse Source
This commit is contained in:
aceld 2024-04-16 15:28:59 +08:00
parent 71b74c6567
commit 6d83c3b3c2
3 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
file/config_export.go
View File

@ -7,7 +7,7 @@ import (
"github.com/aceld/kis-flow/common" "github.com/aceld/kis-flow/common"
"github.com/aceld/kis-flow/kis" "github.com/aceld/kis-flow/kis"
"gopkg.in/yaml.v3" yaml "gopkg.in/yaml.v3"
) )
// ConfigExportYaml exports the flow configuration and saves it locally // ConfigExportYaml exports the flow configuration and saves it locally

2
kis/faas.go
View File

@ -96,8 +96,6 @@ func NewFaaSDesc(fnName string, f FaaS) (*FaaSDesc, error) {
// If the current parameter does not implement the Serialize interface, use the default serialization implementation // If the current parameter does not implement the Serialize interface, use the default serialization implementation
serializeImpl = defaultSerialize // Use global default implementation serializeImpl = defaultSerialize // Use global default implementation
} }
} else {
// Other types are not supported
} }
// Append the current parameter type to the argsType collection // Append the current parameter type to the argsType collection

3
kis/function.go
View File

@ -6,8 +6,7 @@ import (
"github.com/aceld/kis-flow/config" "github.com/aceld/kis-flow/config"
) )
// Function is the basic computation unit of streaming computation. KisFunction is a basic logical unit of streaming computation, // Function is the basic computation unit of streaming computation. KisFunction is a basic logical unit of streaming computation, any number of KisFunctions can be combined into a KisFlow
// any number of KisFunctions can be combined into a KisFlow
type Function interface { type Function interface {
// Call executes the streaming computation logic // Call executes the streaming computation logic
Call(ctx context.Context, flow Flow) error Call(ctx context.Context, flow Flow) error