parser

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

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

type Mapping struct {
	Source string
	Dest   string
}

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"`
}

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