specs

Documentation

Index

• func SpecUnmarshalYamlStrict(b []byte, spec *Spec) error
• func UnmarshalJsonStrict(b []byte, out interface{}) error
• func ValidateSpec(schema string, spec interface{}) (*gojsonschema.Result, error)
• type Destination
  • func (d *Destination) SetDefaults()
  • func (d *Destination) UnmarshalSpec(out interface{}) error
• type Kind
  • func KindFromString(s string) (Kind, error)
  • func (k Kind) MarshalJSON() ([]byte, error)
  • func (k Kind) String() string
  • func (k *Kind) UnmarshalJSON(data []byte) (err error)
• type Registry
  • func RegistryFromString(s string) (Registry, error)
  • func (r Registry) MarshalJSON() ([]byte, error)
  • func (r Registry) String() string
  • func (r *Registry) UnmarshalJSON(data []byte) (err error)
• type Source
  • func (s *Source) SetDefaults()
  • func (s *Source) UnmarshalSpec(out interface{}) error
  • func (*Source) Validate() (*gojsonschema.Result, error)
• type Spec
  • func (s *Spec) UnmarshalJSON(data []byte) error
• type SpecReader
  • func NewSpecReader(directory string) (*SpecReader, error)
  • func (s *SpecReader) GetDestinatinoByName(name string) *Destination
  • func (s *SpecReader) GetSourceByName(name string) *Source
  • func (s *SpecReader) GetSources() []Source
• type WriteMode
  • func WriteModeFromString(s string) (WriteMode, error)
  • func (m WriteMode) MarshalJSON() ([]byte, error)
  • func (m WriteMode) String() string
  • func (m *WriteMode) UnmarshalJSON(data []byte) (err error)

Functions

func SpecUnmarshalYamlStrict

func SpecUnmarshalYamlStrict(b []byte, spec *Spec) error

func UnmarshalJsonStrict

func UnmarshalJsonStrict(b []byte, out interface{}) error

func ValidateSpec

func ValidateSpec(schema string, spec interface{}) (*gojsonschema.Result, error)

Types

type Destination

type Destination struct {
	Name      string      `json:"name,omitempty"`
	Version   string      `json:"version,omitempty"`
	Path      string      `json:"path,omitempty"`
	Registry  Registry    `json:"registry,omitempty"`
	WriteMode WriteMode   `json:"write_mode,omitempty"`
	Spec      interface{} `json:"spec,omitempty"`
}

func (*Destination) SetDefaults

func (d *Destination) SetDefaults()

func (*Destination) UnmarshalSpec

func (d *Destination) UnmarshalSpec(out interface{}) error

type Kind

type Kind int

const (
	KindSource Kind = iota
	KindDestination
)

func KindFromString

func KindFromString(s string) (Kind, error)

func (Kind) MarshalJSON

func (k Kind) MarshalJSON() ([]byte, error)

func (Kind) String

func (k Kind) String() string

func (*Kind) UnmarshalJSON

func (k *Kind) UnmarshalJSON(data []byte) (err error)

type Registry

type Registry int

const (
	RegistryGithub Registry = iota
	RegistryLocal
	RegistryGrpc
)

func RegistryFromString

func RegistryFromString(s string) (Registry, error)

func (Registry) MarshalJSON

func (r Registry) MarshalJSON() ([]byte, error)

func (Registry) String

func (r Registry) String() string

func (*Registry) UnmarshalJSON

func (r *Registry) UnmarshalJSON(data []byte) (err error)

type Source

type Source struct {
	Name    string `json:"name,omitempty"`
	Version string `json:"version,omitempty"`
	// Path is the path in the registry
	Path string `json:"path,omitempty"`
	// Registry can be github,local,grpc. Might support things like https in the future.
	Registry      Registry    `json:"registry,omitempty"`
	MaxGoRoutines uint64      `json:"max_goroutines,omitempty"`
	Tables        []string    `json:"tables,omitempty"`
	SkipTables    []string    `json:"skip_tables,omitempty"`
	Destinations  []string    `json:"destinations,omitempty"`
	Spec          interface{} `json:"spec,omitempty"`
}

Source is the shared configuration for all source plugins

func (*Source) SetDefaults

func (s *Source) SetDefaults()

func (*Source) UnmarshalSpec

func (s *Source) UnmarshalSpec(out interface{}) error

func (*Source) Validate

func (*Source) Validate() (*gojsonschema.Result, error)

type Spec

type Spec struct {
	Kind Kind        `json:"kind"`
	Spec interface{} `json:"spec"`
}

func (*Spec) UnmarshalJSON

func (s *Spec) UnmarshalJSON(data []byte) error

type SpecReader

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

func NewSpecReader

func NewSpecReader(directory string) (*SpecReader, error)

func (*SpecReader) GetDestinatinoByName

func (s *SpecReader) GetDestinatinoByName(name string) *Destination

func (*SpecReader) GetSourceByName

func (s *SpecReader) GetSourceByName(name string) *Source

func (*SpecReader) GetSources

func (s *SpecReader) GetSources() []Source

type WriteMode

type WriteMode int

const (
	WriteModeAppend WriteMode = iota
	WriteModeOverwrite
)

func WriteModeFromString

func WriteModeFromString(s string) (WriteMode, error)

func (WriteMode) MarshalJSON

func (m WriteMode) MarshalJSON() ([]byte, error)

func (WriteMode) String

func (m WriteMode) String() string

func (*WriteMode) UnmarshalJSON

func (m *WriteMode) UnmarshalJSON(data []byte) (err error)