parser

Feb 6, 2024

Changes in this version

type FlowParser

+ func (f FlowParser) DecideDeploymentPlatform(cells []flows_api.Cell) (newCells []flows_api.Cell)

Jan 4, 2024

Changes in this version

+ type DownstreamConfig struct

+ Enabled bool

type Operator

+ DownstreamConfig DownstreamConfig

+ UpstreamConfig UpstreamConfig

+ type UpstreamConfig struct

+ Enabled bool

Dec 19, 2023

Changes in this version

+ type FlowParser struct

+ func NewFlowParser(flowApi lib.FlowApiService) *FlowParser

+ func (f FlowParser) CreatePipelineList(flow flows_api.Flow) Pipeline

+ func (f FlowParser) GetInputsAndConfig(id string, userId string, authorization string) ([]flows_api.Cell, error)

+ func (f FlowParser) ParseFlow(id string, userId string, authorization string) (pipeline Pipeline, err error)

+ type InputTopic struct

+ FilterType string

+ FilterValue string

+ Mappings []Mapping

+ TopicName string

+ type Mapping struct

+ Dest string

+ Source string

+ type Operator struct

+ Cost uint

+ DeploymentType string

+ Id string

+ ImageId string

+ InputTopics []InputTopic

+ Name string

+ OperatorId string

+ type Pipeline struct

+ FlowId string

+ Image string

+ Operators map[string]Operator