Class: Clusters::ClustersController

Inherits:
BaseController show all
Includes:
Metrics::Dashboard::PrometheusApiProxy, MetricsDashboard, RoutableActions
Defined in:
app/controllers/clusters/clusters_controller.rb

Constant Summary collapse

STATUS_POLLING_INTERVAL = 
10_000

Constants inherited from ApplicationController

ApplicationController::DEFAULT_GITLAB_CACHE_CONTROL

Constants included from Gitlab::Logging::CloudflareHelper

Gitlab::Logging::CloudflareHelper::CLOUDFLARE_CUSTOM_HEADERS

Constants included from Gitlab::NoCacheHeaders

Gitlab::NoCacheHeaders::DEFAULT_GITLAB_NO_CACHE_HEADERS

Instance Method Summary collapse

Methods included from MetricsDashboard

#metrics_dashboard

Methods included from EnvironmentsHelper

#can_destroy_environment?, #custom_metrics_available?, #environment_logs_data, #environments_folder_list_view_data, #environments_list_data, #metrics_data

Methods included from ChecksCollaboration

#can_collaborate_with_project?, #user_access

Methods included from RenderServiceResults

#continue_polling_response, #error_response, #success_response

Methods included from Metrics::Dashboard::PrometheusApiProxy

#prometheus_proxy

Methods included from RoutableActions

#ensure_canonical_path, #find_routable!, #not_found_actions, #perform_not_found_actions, #routable_authorized?

Methods inherited from ApplicationController

#not_found, #redirect_back_or_default, #render, #route_not_found

Methods included from Gitlab::Utils::StrongMemoize

#clear_memoization, #strong_memoize, #strong_memoized?

Methods included from Gitlab::Logging::CloudflareHelper

#store_cloudflare_headers!, #valid_cloudflare_header?

Methods included from Impersonation

#current_user

Methods included from InitializesCurrentUserMode

#current_user_mode

Methods included from Gitlab::Experimentation::ControllerConcern

#experiment_enabled?, #experiment_tracking_category_and_group, #frontend_experimentation_tracking_data, #record_experiment_user, #set_experimentation_subject_id_cookie, #track_experiment_event

Methods included from SessionsHelper

#limit_session_time, #unconfirmed_email?

Methods included from SessionlessAuthentication

#authenticate_sessionless_user!, #sessionless_bypass_admin_mode!, #sessionless_sign_in, #sessionless_user?

Methods included from Gitlab::SearchContext::ControllerConcern

#search_context

Methods included from EnforcesTwoFactorAuthentication

#check_two_factor_requirement, #current_user_requires_two_factor?, #skip_two_factor?, #two_factor_authentication_reason, #two_factor_authentication_required?, #two_factor_grace_period, #two_factor_grace_period_expired?, #two_factor_skippable?, #two_factor_verifier

Methods included from WorkhorseHelper

#send_artifacts_entry, #send_git_archive, #send_git_blob, #send_git_diff, #send_git_patch, #set_workhorse_internal_api_content_type, #workhorse_set_content_type!

Methods included from SafeParamsHelper

#safe_params

Methods included from PageLayoutHelper

#blank_container, #container_class, #favicon, #fluid_layout, #header_title, #nav, #page_card_attributes, #page_card_meta_tags, #page_description, #page_image, #page_title, #search_context, #sidebar

Methods included from GitlabRoutingHelper

#approve_access_request_group_member_path, #approve_access_request_project_member_path, #artifacts_action_path, #commit_url, #commits_url, #edit_milestone_path, #edit_pipeline_schedule_path, #environment_delete_path, #environment_metrics_path, #environment_path, #expose_fast_artifacts_path, #fast_browse_project_job_artifacts_path, #fast_download_project_job_artifacts_path, #fast_keep_project_job_artifacts_path, #gitlab_dashboard_snippets_path, #gitlab_raw_snippet_blob_path, #gitlab_raw_snippet_blob_url, #gitlab_raw_snippet_path, #gitlab_raw_snippet_url, #gitlab_snippet_note_path, #gitlab_snippet_note_url, #gitlab_snippet_notes_path, #gitlab_snippet_notes_url, #gitlab_snippet_path, #gitlab_snippet_url, #gitlab_toggle_award_emoji_snippet_note_path, #gitlab_toggle_award_emoji_snippet_note_url, #gitlab_toggle_award_emoji_snippet_path, #gitlab_toggle_award_emoji_snippet_url, #group_member_path, #group_members_url, #issue_path, #issue_url, #leave_group_members_path, #leave_project_members_path, #merge_request_path, #merge_request_url, #pipeline_job_url, #pipeline_path, #pipeline_schedule_path, #pipeline_schedules_path, #pipeline_url, #play_pipeline_schedule_path, #preview_markdown_path, #project_commits_path, #project_member_path, #project_members_url, #project_ref_path, #project_tree_path, #request_access_group_members_path, #request_access_project_members_path, #resend_invite_group_member_path, #resend_invite_project_member_path, #take_ownership_pipeline_schedule_path, #toggle_award_emoji_personal_snippet_path, #toggle_award_emoji_project_project_snippet_path, #toggle_award_emoji_project_project_snippet_url, #toggle_subscription_path, #wiki_page_path, #wiki_path

Methods included from API::Helpers::RelatedResourcesHelpers

#expose_path, #expose_url, #issues_available?, #mrs_available?

Methods included from Gitlab::NoCacheHeaders

#no_cache_headers

Methods included from Gitlab::GonHelper

#add_gon_variables, #default_avatar_url, #push_frontend_feature_flag

Methods included from WebpackHelper

#webpack_bundle_tag, #webpack_controller_bundle_tags, #webpack_entrypoint_paths, #webpack_public_host, #webpack_public_path

Methods included from StartupCssHelper

#use_startup_css?

Instance Method Details

#authorize_aws_role ⇒ Object 


145
146
147
148
149
150
151
152
 
# File 'app/controllers/clusters/clusters_controller.rb', line 145

def authorize_aws_role
  response = Clusters::Aws::AuthorizeRoleService.new(
    current_user,
    params: aws_role_params
  ).execute

  render json: response.body, status: response.status
end

#clear_cache ⇒ Object 


154
155
156
157
158
 
# File 'app/controllers/clusters/clusters_controller.rb', line 154

def clear_cache
  cluster.delete_cached_resources!

  redirect_to cluster.show_path, notice: _('Cluster cache cleared.')
end

#cluster_status ⇒ Object

Overridding ActionController::Metal#status is NOT a good idea


50
51
52
53
54
55
56
57
58
59
60
 
# File 'app/controllers/clusters/clusters_controller.rb', line 50

def cluster_status
  respond_to do |format|
    format.json do
      Gitlab::PollingInterval.set_header(response, interval: STATUS_POLLING_INTERVAL)

      render json: ClusterSerializer
        .new(current_user: @current_user)
        .represent_status(@cluster)
    end
  end
end

#create_aws ⇒ Object 


115
116
117
118
119
120
121
122
123
124
125
126
 
# File 'app/controllers/clusters/clusters_controller.rb', line 115

def create_aws
  @aws_cluster = ::Clusters::CreateService
    .new(current_user, create_aws_cluster_params)
    .execute
    .present(current_user: current_user)

  if @aws_cluster.persisted?
    head :created, location: @aws_cluster.show_path
  else
    render status: :unprocessable_entity, json: @aws_cluster.errors
  end
end

#create_gcp ⇒ Object 


97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
 
# File 'app/controllers/clusters/clusters_controller.rb', line 97

def create_gcp
  @gcp_cluster = ::Clusters::CreateService
    .new(current_user, create_gcp_cluster_params)
    .execute(access_token: token_in_session)
    .present(current_user: current_user)

  if @gcp_cluster.persisted?
    redirect_to @gcp_cluster.show_path
  else
    generate_gcp_authorize_url
    validate_gcp_token
    user_cluster
    params[:provider] = 'gcp'

    render :new, locals: { active_tab: 'create' }
  end
end

#create_user ⇒ Object 


128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
 
# File 'app/controllers/clusters/clusters_controller.rb', line 128

def create_user
  @user_cluster = ::Clusters::CreateService
    .new(current_user, create_user_cluster_params)
    .execute(access_token: token_in_session)
    .present(current_user: current_user)

  if @user_cluster.persisted?
    redirect_to @user_cluster.show_path
  else
    generate_gcp_authorize_url
    validate_gcp_token
    gcp_cluster

    render :new, locals: { active_tab: 'add' }
  end
end

#destroy ⇒ Object 


88
89
90
91
92
93
94
95
 
# File 'app/controllers/clusters/clusters_controller.rb', line 88

def destroy
  response = Clusters::DestroyService
    .new(current_user, destroy_params)
    .execute(cluster)

  flash[:notice] = response[:message]
  redirect_to clusterable.index_path, status: :found
end

#index ⇒ Object 


22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
 
# File 'app/controllers/clusters/clusters_controller.rb', line 22

def index
  @clusters = cluster_list

  respond_to do |format|
    format.html
    format.json do
      Gitlab::PollingInterval.set_header(response, interval: STATUS_POLLING_INTERVAL)
      serializer = ClusterSerializer.new(current_user: current_user)

      render json: {
        clusters: serializer.with_pagination(request, response).represent_list(@clusters),
        has_ancestor_clusters: @has_ancestor_clusters
      }
    end
  end
end

#new ⇒ Object 


39
40
41
42
43
44
45
46
47
 
# File 'app/controllers/clusters/clusters_controller.rb', line 39

def new
  if params[:provider] == 'aws'
    @aws_role = Aws::Role.create_or_find_by!(user: current_user)
    @instance_types = load_instance_types.to_json

  elsif params[:provider] == 'gcp'
    redirect_to @authorize_url if @authorize_url && !@valid_gcp_token
  end
end

#show ⇒ Object 


62
63
 
# File 'app/controllers/clusters/clusters_controller.rb', line 62

def show
end

#update ⇒ Object 


65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
 
# File 'app/controllers/clusters/clusters_controller.rb', line 65

def update
  Clusters::UpdateService
    .new(current_user, update_params)
    .execute(cluster)

  if cluster.valid?
    respond_to do |format|
      format.json do
        head :no_content
      end
      format.html do
        flash[:notice] = _('Kubernetes cluster was successfully updated.')
        redirect_to cluster.show_path
      end
    end
  else
    respond_to do |format|
      format.json { head :bad_request }
      format.html { render :show }
    end
  end
end