parser

Documentation

Index

• type DownstreamConfig
• type FlowParser
  • func NewFlowParser(flowApi lib.FlowApiService) *FlowParser
  • func (f FlowParser) CreatePipelineList(flow flows_api.Flow) Pipeline
  • func (f FlowParser) DecideDeploymentPlatform(cells []flows_api.Cell) (newCells []flows_api.Cell)
  • 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
• type Mapping
• type Operator
• type Pipeline
• type UpstreamConfig

Types

type DownstreamConfig

type DownstreamConfig struct {
	Enabled bool
}

type FlowParser

type FlowParser struct {
	// contains filtered or unexported fields
}

func NewFlowParser

func NewFlowParser(flowApi lib.FlowApiService) *FlowParser

func (FlowParser) CreatePipelineList

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

func (FlowParser) DecideDeploymentPlatform

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

func (FlowParser) GetInputsAndConfig

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

func (FlowParser) ParseFlow

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

type InputTopic

type InputTopic struct {
	TopicName   string
	FilterType  string
	FilterValue string
	Mappings    []Mapping
}

type Mapping

type Mapping struct {
	Source string
	Dest   string
}

type Operator

type Operator struct {
	Id               string `json:"id,omitempty"`
	Name             string `json:"name,omitempty"`
	OperatorId       string `json:"operatorId,omitempty"`
	DeploymentType   string `json:"deploymentType,omitempty"`
	ImageId          string
	InputTopics      []InputTopic
	Cost             uint             `json:"cost"`
	UpstreamConfig   UpstreamConfig   `json:"upstream"`
	DownstreamConfig DownstreamConfig `json:"downstream"`
}

type Pipeline

type Pipeline struct {
	FlowId    string              `json:"flowId,omitempty"`
	Image     string              `json:"image,omitempty"`
	Operators map[string]Operator `json:"operators,omitempty"`
}

type UpstreamConfig

type UpstreamConfig struct {
	Enabled bool
}