controller

type AtlasExec interface {
	// MigrateApplySlice runs the `migrate apply` command and returns the successful runs.
	MigrateApplySlice(context.Context, *atlasexec.MigrateApplyParams) ([]*atlasexec.MigrateApply, error)
	// MigrateDown runs the `migrate down` command.
	MigrateDown(context.Context, *atlasexec.MigrateDownParams) (*atlasexec.MigrateDown, error)
	// MigrateStatus runs the `migrate status` command.
	MigrateStatus(context.Context, *atlasexec.MigrateStatusParams) (*atlasexec.MigrateStatus, error)
	// SchemaApplySlice runs the `schema apply` command and returns the successful runs.
	SchemaApplySlice(context.Context, *atlasexec.SchemaApplyParams) ([]*atlasexec.SchemaApply, error)
	// SchemaInspect runs the `schema inspect` command.
	SchemaInspect(ctx context.Context, params *atlasexec.SchemaInspectParams) (string, error)
	// SchemaPush runs the `schema push` command.
	SchemaPush(context.Context, *atlasexec.SchemaPushParams) (*atlasexec.SchemaPush, error)
	// SchemaPlan runs the `schema plan` command.
	SchemaPlan(context.Context, *atlasexec.SchemaPlanParams) (*atlasexec.SchemaPlan, error)
	// SchemaPlanList runs the `schema plan list` command.
	SchemaPlanList(context.Context, *atlasexec.SchemaPlanListParams) ([]atlasexec.SchemaPlanFile, error)
	// WhoAmI runs the `whoami` command.
	WhoAmI(context.Context, *atlasexec.WhoAmIParams) (*atlasexec.WhoAmI, error)
	// Login runs the `login` command (e.g. with --grant-only for offline tokens).
	Login(context.Context, *atlasexec.LoginParams) error
	// SetStdout specifies a writer to stream stdout to for every command.
	SetStdout(io.Writer)
	// SetStderr specifies a writer to stream stderr to for every command.
	SetStderr(io.Writer)
}

type AtlasExecFn func(dir string, c *Cloud, home string) (AtlasExec, error)

type AtlasMigrationReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

type AtlasSchemaReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

type Cloud struct {
	Token string
	Repo  string
	URL   string
}

type Manager interface {
	GetClient() client.Client
	GetScheme() *runtime.Scheme
	GetEventRecorderFor(name string) record.EventRecorder
}

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