execute

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

type MigrationExecutorOpts struct {
	MigrationStateFile    string
	MigrationState        migration.MigrationState
	MigrationConfig       migration.MigrationConfig
	LagThreshold          int64
	ClusterApiKey         string
	ClusterApiSecret      string
	ClusterBootstrap      string
	SourceBootstrap       string
	AWSRegion             string
	AuthType              types.AuthType
	SaslScramUsername     string
	SaslScramPassword     string
	SaslScramMechanism    string
	SaslPlainUsername     string
	SaslPlainPassword     string
	TlsCaCert             string
	TlsClientCert         string
	TlsClientKey          string
	InsecureSkipTLSVerify bool
	// RolloutTimeout bounds the gateway-readiness wait during fence and
	// switch. A value of 0 means no deadline — the wait runs until the
	// operator reports ready or the user cancels.
	RolloutTimeout time.Duration
}