pod

type Config struct {
	Name       string `yaml:"name"`
	Version    string `yaml:"version"`
	Datasource struct {
		Name    string   `yaml:"name"`
		Type    string   `yaml:"type"`
		Brokers []string `yaml:"brokers"`
		Topic   string   `yaml:"topic"`
	} `yaml:"datasource"`
	Preprocessor struct {
		Filename string `yaml:"filename"`
		Type     string `yaml:"type"`
	} `yaml:"preprocessor"`
	Model struct {
		Name     string `yaml:"name"`
		Filename string `yaml:"filename"`
	} `yaml:"model"`
	Endpoint struct {
		Name   string            `yaml:"name"`
		Type   string            `yaml:"type"`
		URL    string            `yaml:"url"`
		Fields map[string]string `yaml:"fields"`
	} `yaml:"endpoint"`
}

type Datasource interface {
	Fetch() ([]byte, error)
}

type Endpoint struct {
	Name   string            `yaml:"name"`
	Type   string            `yaml:"type"`
	URL    string            `yaml:"url"`
	Fields map[string]string `yaml:"fields"`
}

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

type Model struct {
	Name     string `yaml:"name"`
	Filename string `yaml:"filename"`
}

type Pod struct {
	Name         string
	Version      string
	Datasource   Datasource
	Preprocessor Preprocessor
	Model        Model
	Endpoint     Endpoint
}

type Preprocessor struct {
	Filename string `yaml:"filename"`
	Type     string `yaml:"type"`
}