core

type Config struct {
	Source       string             `json:"source,omitempty" yaml:"source,omitempty"`
	Dest         string             `json:"dest,omitempty" yaml:"dest,omitempty"`
	SourceConn   *Connection        `json:"-" yaml:"-"`
	DestConn     *Connection        `json:"-" yaml:"-"`
	StreamConfig *data.StreamConfig `json:"stream_config,omitempty" yaml:"stream_config,omitempty"`
}

type Connection struct {
	Url       string
	ParsedUrl *url.URL
}

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