Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetSourceSpecDefault ¶ added in v0.0.3
func SetSourceSpecDefault(s *SourceSpec)
func ValidateSpec ¶
func ValidateSpec(schema string, spec interface{}) (*gojsonschema.Result, error)
Types ¶
type ConnectionSpec ¶
type DestinationSpec ¶
type SourceSpec ¶
type SourceSpec struct {
Name string `json:"name" yaml:"name"`
Version string `json:"version" yaml:"version"`
// Path is the path in the registry
Path string `json:"path" yaml:"path"`
// Registry can be github,local,grpc. Might support things like https in the future.
Registry string `json:"registry" yaml:"registry"`
MaxGoRoutines uint64 `json:"max_goroutines" yaml:"max_goroutines"`
Tables []string `json:"tables" yaml:"tables"`
SkipTables []string `json:"skip_tables" yaml:"skip_tables"`
}
SourceSpec is the shared configuration for all source plugins
func (*SourceSpec) UnmarshalYAML ¶
func (s *SourceSpec) UnmarshalYAML(n *yaml.Node) error
type Spec ¶
type Spec struct {
Kind string `yaml:"kind"`
Spec interface{} `yaml:"-"`
}
func (*Spec) UnmarshalYAML ¶
type SpecReader ¶
type SpecReader struct {
// contains filtered or unexported fields
}
func NewSpecReader ¶
func NewSpecReader(directory string) (*SpecReader, error)
func (*SpecReader) Connections ¶
func (s *SpecReader) Connections() []ConnectionSpec
func (*SpecReader) GetConnectionByName ¶
func (s *SpecReader) GetConnectionByName(name string) ConnectionSpec
func (*SpecReader) GetDestinatinoByName ¶
func (s *SpecReader) GetDestinatinoByName(name string) DestinationSpec
func (*SpecReader) GetSourceByName ¶
func (s *SpecReader) GetSourceByName(name string) SourceSpec
Click to show internal directories.
Click to hide internal directories.