execute

Documentation

Index

• func NewMigrationExecuteCmd() *cobra.Command
• type MigrationExecutor
  • func NewMigrationExecutor(opts MigrationExecutorOpts) *MigrationExecutor
  • func (m *MigrationExecutor) Run() error
• type MigrationExecutorOpts

Functions

func NewMigrationExecuteCmd

func NewMigrationExecuteCmd() *cobra.Command

Types

type MigrationExecutor

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

func NewMigrationExecutor

func NewMigrationExecutor(opts MigrationExecutorOpts) *MigrationExecutor

func (*MigrationExecutor) Run

func (m *MigrationExecutor) Run() error

type MigrationExecutorOpts

type MigrationExecutorOpts struct {
	MigrationStateFile    string
	MigrationState        types.MigrationState
	MigrationConfig       types.MigrationConfig
	LagThreshold          int64
	ClusterApiKey         string
	ClusterApiSecret      string
	ClusterBootstrap      string
	SourceBootstrap       string
	AWSRegion             string
	AuthType              types.AuthType
	SaslScramUsername     string
	SaslScramPassword     string
	SaslPlainUsername     string
	SaslPlainPassword     string
	TlsCaCert             string
	TlsClientCert         string
	TlsClientKey          string
	InsecureSkipTLSVerify bool
}