airbyte_source

Documentation

Index

• func CheckCommand(ch *Helper) *cobra.Command
• func DiscoverCommand(ch *Helper) *cobra.Command
• func Execute(ctx context.Context, ver, commit, buildDate string)
• func ReadCommand(ch *Helper) *cobra.Command
• func SpecCommand() *cobra.Command
• type FileReader
• type Helper
  • func DefaultHelper(w io.Writer) *Helper
  • func (h *Helper) EnsureDB(psc internal.PlanetScaleSource) error
• type State

Functions

func CheckCommand

func CheckCommand(ch *Helper) *cobra.Command

func DiscoverCommand

func DiscoverCommand(ch *Helper) *cobra.Command

func Execute

func Execute(ctx context.Context, ver, commit, buildDate string)

func ReadCommand

func ReadCommand(ch *Helper) *cobra.Command

func SpecCommand

func SpecCommand() *cobra.Command

Types

type FileReader

type FileReader interface {
	ReadFile(path string) ([]byte, error)
}

type Helper

type Helper struct {
	Database   internal.PlanetScaleDatabase
	FileReader FileReader
	Logger     internal.AirbyteLogger
}

func DefaultHelper

func DefaultHelper(w io.Writer) *Helper

func (*Helper) EnsureDB

func (h *Helper) EnsureDB(psc internal.PlanetScaleSource) error

type State

type State struct {
	Shards map[string]map[string]interface{} `json:"shards"`
}