cmd

Documentation

Index

• Variables
• func CLIDestinationSpecToPbSpec(spec specs.Destination) pbSpecs.Destination
• func CLIMigrateModeToPbMigrateMode(migrateMode specs.MigrateMode) pbSpecs.MigrateMode
• func CLIPkModeToPbPKMode(pkMode specs.PKMode) pbSpecs.PKMode
• func CLIRegistryToPbRegistry(registry specs.Registry) pbSpecs.Registry
• func CLISourceSpecToPbSpec(spec specs.Source) pbSpecs.Source
• func CLIWriteModeToPbWriteMode(writeMode specs.WriteMode) pbSpecs.WriteMode
• func CloseLogFile()
• func NewCmdMigrate() *cobra.Command
• func NewCmdRoot() *cobra.Command
• func NewCmdSync() *cobra.Command
• func NewCmdTables() *cobra.Command
• func SpecRegistryToPlugin(registry specs.Registry) managedplugin.Registry
• type AnalyticsClient
  • func (c *AnalyticsClient) Close() error
  • func (c *AnalyticsClient) Host() string
  • func (c *AnalyticsClient) SendSyncMetrics(ctx context.Context, sourceSpec specs.Source, ...) error
• type ExitReason

Variables

var (
	Version = "development"
)

Functions

func CLIDestinationSpecToPbSpec

func CLIDestinationSpecToPbSpec(spec specs.Destination) pbSpecs.Destination

func CLIMigrateModeToPbMigrateMode

func CLIMigrateModeToPbMigrateMode(migrateMode specs.MigrateMode) pbSpecs.MigrateMode

func CLIPkModeToPbPKMode

func CLIPkModeToPbPKMode(pkMode specs.PKMode) pbSpecs.PKMode

func CLIRegistryToPbRegistry

func CLIRegistryToPbRegistry(registry specs.Registry) pbSpecs.Registry

func CLISourceSpecToPbSpec

func CLISourceSpecToPbSpec(spec specs.Source) pbSpecs.Source

This converts CLI configuration to a source spec prior to V3 version when our spec wasn't decoupled from the over the wire protocol

func CLIWriteModeToPbWriteMode

func CLIWriteModeToPbWriteMode(writeMode specs.WriteMode) pbSpecs.WriteMode

func CloseLogFile

func CloseLogFile()

func NewCmdMigrate

func NewCmdMigrate() *cobra.Command

func NewCmdRoot

func NewCmdRoot() *cobra.Command

func NewCmdSync

func NewCmdSync() *cobra.Command

func NewCmdTables

func NewCmdTables() *cobra.Command

func SpecRegistryToPlugin

func SpecRegistryToPlugin(registry specs.Registry) managedplugin.Registry

Types

type AnalyticsClient

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

func (*AnalyticsClient) Close

func (c *AnalyticsClient) Close() error

func (*AnalyticsClient) Host

func (c *AnalyticsClient) Host() string

func (*AnalyticsClient) SendSyncMetrics

func (c *AnalyticsClient) SendSyncMetrics(ctx context.Context, sourceSpec specs.Source, destinationsSpecs []specs.Destination, invocationUUID string, m *metrics.Metrics, exitReason ExitReason) error

type ExitReason

type ExitReason string

const (
	ExitReasonUnset     ExitReason = ""
	ExitReasonStopped   ExitReason = "stopped"
	ExitReasonCompleted ExitReason = "completed"
)