lib

type DownstreamConfig struct {
	Enabled bool
}

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"`
	UpstreamConfig   UpstreamConfig   `json:"upstream"`
	DownstreamConfig DownstreamConfig `json:"downstream"`
}

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

type UpstreamConfig struct {
	Enabled bool
}