// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.5.1
// - protoc             v6.32.1
// source: kodex/controlplane/v1/controlplane.proto

package controlplanev1

import (
	context "context"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
	emptypb "google.golang.org/protobuf/types/known/emptypb"
)

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.64.0 or later.
const _ = grpc.SupportPackageIsVersion9

const (
	ControlPlaneService_IngestGitHubWebhook_FullMethodName                  = "/kodex.controlplane.v1.ControlPlaneService/IngestGitHubWebhook"
	ControlPlaneService_ResolveStaffByEmail_FullMethodName                  = "/kodex.controlplane.v1.ControlPlaneService/ResolveStaffByEmail"
	ControlPlaneService_AuthorizeOAuthUser_FullMethodName                   = "/kodex.controlplane.v1.ControlPlaneService/AuthorizeOAuthUser"
	ControlPlaneService_ListProjects_FullMethodName                         = "/kodex.controlplane.v1.ControlPlaneService/ListProjects"
	ControlPlaneService_UpsertProject_FullMethodName                        = "/kodex.controlplane.v1.ControlPlaneService/UpsertProject"
	ControlPlaneService_GetProject_FullMethodName                           = "/kodex.controlplane.v1.ControlPlaneService/GetProject"
	ControlPlaneService_DeleteProject_FullMethodName                        = "/kodex.controlplane.v1.ControlPlaneService/DeleteProject"
	ControlPlaneService_ListRuns_FullMethodName                             = "/kodex.controlplane.v1.ControlPlaneService/ListRuns"
	ControlPlaneService_ListRunWaits_FullMethodName                         = "/kodex.controlplane.v1.ControlPlaneService/ListRunWaits"
	ControlPlaneService_GetRun_FullMethodName                               = "/kodex.controlplane.v1.ControlPlaneService/GetRun"
	ControlPlaneService_CancelRun_FullMethodName                            = "/kodex.controlplane.v1.ControlPlaneService/CancelRun"
	ControlPlaneService_GetRunLogs_FullMethodName                           = "/kodex.controlplane.v1.ControlPlaneService/GetRunLogs"
	ControlPlaneService_ListPendingApprovals_FullMethodName                 = "/kodex.controlplane.v1.ControlPlaneService/ListPendingApprovals"
	ControlPlaneService_ResolveApprovalDecision_FullMethodName              = "/kodex.controlplane.v1.ControlPlaneService/ResolveApprovalDecision"
	ControlPlaneService_ListRunEvents_FullMethodName                        = "/kodex.controlplane.v1.ControlPlaneService/ListRunEvents"
	ControlPlaneService_ListRunLearningFeedback_FullMethodName              = "/kodex.controlplane.v1.ControlPlaneService/ListRunLearningFeedback"
	ControlPlaneService_ListSystemSettings_FullMethodName                   = "/kodex.controlplane.v1.ControlPlaneService/ListSystemSettings"
	ControlPlaneService_GetSystemSetting_FullMethodName                     = "/kodex.controlplane.v1.ControlPlaneService/GetSystemSetting"
	ControlPlaneService_UpdateSystemSettingBoolean_FullMethodName           = "/kodex.controlplane.v1.ControlPlaneService/UpdateSystemSettingBoolean"
	ControlPlaneService_ResetSystemSetting_FullMethodName                   = "/kodex.controlplane.v1.ControlPlaneService/ResetSystemSetting"
	ControlPlaneService_ListUsers_FullMethodName                            = "/kodex.controlplane.v1.ControlPlaneService/ListUsers"
	ControlPlaneService_CreateUser_FullMethodName                           = "/kodex.controlplane.v1.ControlPlaneService/CreateUser"
	ControlPlaneService_DeleteUser_FullMethodName                           = "/kodex.controlplane.v1.ControlPlaneService/DeleteUser"
	ControlPlaneService_ListProjectMembers_FullMethodName                   = "/kodex.controlplane.v1.ControlPlaneService/ListProjectMembers"
	ControlPlaneService_UpsertProjectMember_FullMethodName                  = "/kodex.controlplane.v1.ControlPlaneService/UpsertProjectMember"
	ControlPlaneService_DeleteProjectMember_FullMethodName                  = "/kodex.controlplane.v1.ControlPlaneService/DeleteProjectMember"
	ControlPlaneService_SetProjectMemberLearningModeOverride_FullMethodName = "/kodex.controlplane.v1.ControlPlaneService/SetProjectMemberLearningModeOverride"
	ControlPlaneService_ListProjectRepositories_FullMethodName              = "/kodex.controlplane.v1.ControlPlaneService/ListProjectRepositories"
	ControlPlaneService_UpsertProjectRepository_FullMethodName              = "/kodex.controlplane.v1.ControlPlaneService/UpsertProjectRepository"
	ControlPlaneService_DeleteProjectRepository_FullMethodName              = "/kodex.controlplane.v1.ControlPlaneService/DeleteProjectRepository"
	ControlPlaneService_UpsertRepositoryBotParams_FullMethodName            = "/kodex.controlplane.v1.ControlPlaneService/UpsertRepositoryBotParams"
	ControlPlaneService_RunRepositoryPreflight_FullMethodName               = "/kodex.controlplane.v1.ControlPlaneService/RunRepositoryPreflight"
	ControlPlaneService_GetProjectGitHubTokens_FullMethodName               = "/kodex.controlplane.v1.ControlPlaneService/GetProjectGitHubTokens"
	ControlPlaneService_UpsertProjectGitHubTokens_FullMethodName            = "/kodex.controlplane.v1.ControlPlaneService/UpsertProjectGitHubTokens"
	ControlPlaneService_PreviewNextStepAction_FullMethodName                = "/kodex.controlplane.v1.ControlPlaneService/PreviewNextStepAction"
	ControlPlaneService_ExecuteNextStepAction_FullMethodName                = "/kodex.controlplane.v1.ControlPlaneService/ExecuteNextStepAction"
	ControlPlaneService_ListDocsetGroups_FullMethodName                     = "/kodex.controlplane.v1.ControlPlaneService/ListDocsetGroups"
	ControlPlaneService_ImportDocset_FullMethodName                         = "/kodex.controlplane.v1.ControlPlaneService/ImportDocset"
	ControlPlaneService_SyncDocset_FullMethodName                           = "/kodex.controlplane.v1.ControlPlaneService/SyncDocset"
	ControlPlaneService_IssueRunMCPToken_FullMethodName                     = "/kodex.controlplane.v1.ControlPlaneService/IssueRunMCPToken"
	ControlPlaneService_PrepareRunEnvironment_FullMethodName                = "/kodex.controlplane.v1.ControlPlaneService/PrepareRunEnvironment"
	ControlPlaneService_EvaluateRuntimeReuse_FullMethodName                 = "/kodex.controlplane.v1.ControlPlaneService/EvaluateRuntimeReuse"
	ControlPlaneService_ClaimNextInteractionDispatch_FullMethodName         = "/kodex.controlplane.v1.ControlPlaneService/ClaimNextInteractionDispatch"
	ControlPlaneService_CompleteInteractionDispatch_FullMethodName          = "/kodex.controlplane.v1.ControlPlaneService/CompleteInteractionDispatch"
	ControlPlaneService_ExpireNextInteraction_FullMethodName                = "/kodex.controlplane.v1.ControlPlaneService/ExpireNextInteraction"
	ControlPlaneService_ProcessNextGitHubRateLimitWait_FullMethodName       = "/kodex.controlplane.v1.ControlPlaneService/ProcessNextGitHubRateLimitWait"
	ControlPlaneService_ReportGitHubRateLimitSignal_FullMethodName          = "/kodex.controlplane.v1.ControlPlaneService/ReportGitHubRateLimitSignal"
	ControlPlaneService_ReportChangeGovernanceDraftSignal_FullMethodName    = "/kodex.controlplane.v1.ControlPlaneService/ReportChangeGovernanceDraftSignal"
	ControlPlaneService_PublishChangeGovernanceWaveMap_FullMethodName       = "/kodex.controlplane.v1.ControlPlaneService/PublishChangeGovernanceWaveMap"
	ControlPlaneService_UpsertChangeGovernanceEvidenceSignal_FullMethodName = "/kodex.controlplane.v1.ControlPlaneService/UpsertChangeGovernanceEvidenceSignal"
	ControlPlaneService_GetMissionControlWorkspace_FullMethodName           = "/kodex.controlplane.v1.ControlPlaneService/GetMissionControlWorkspace"
	ControlPlaneService_GetMissionControlNode_FullMethodName                = "/kodex.controlplane.v1.ControlPlaneService/GetMissionControlNode"
	ControlPlaneService_ListMissionControlNodeActivity_FullMethodName       = "/kodex.controlplane.v1.ControlPlaneService/ListMissionControlNodeActivity"
	ControlPlaneService_PreviewMissionControlLaunch_FullMethodName          = "/kodex.controlplane.v1.ControlPlaneService/PreviewMissionControlLaunch"
	ControlPlaneService_GetMissionControlSnapshot_FullMethodName            = "/kodex.controlplane.v1.ControlPlaneService/GetMissionControlSnapshot"
	ControlPlaneService_GetMissionControlEntity_FullMethodName              = "/kodex.controlplane.v1.ControlPlaneService/GetMissionControlEntity"
	ControlPlaneService_ListMissionControlTimeline_FullMethodName           = "/kodex.controlplane.v1.ControlPlaneService/ListMissionControlTimeline"
	ControlPlaneService_ListMissionControlWarmupProjects_FullMethodName     = "/kodex.controlplane.v1.ControlPlaneService/ListMissionControlWarmupProjects"
	ControlPlaneService_RunMissionControlWarmup_FullMethodName              = "/kodex.controlplane.v1.ControlPlaneService/RunMissionControlWarmup"
	ControlPlaneService_SubmitMissionControlCommand_FullMethodName          = "/kodex.controlplane.v1.ControlPlaneService/SubmitMissionControlCommand"
	ControlPlaneService_GetMissionControlCommand_FullMethodName             = "/kodex.controlplane.v1.ControlPlaneService/GetMissionControlCommand"
	ControlPlaneService_ClaimMissionControlPendingCommands_FullMethodName   = "/kodex.controlplane.v1.ControlPlaneService/ClaimMissionControlPendingCommands"
	ControlPlaneService_QueueMissionControlCommand_FullMethodName           = "/kodex.controlplane.v1.ControlPlaneService/QueueMissionControlCommand"
	ControlPlaneService_MarkMissionControlCommandPendingSync_FullMethodName = "/kodex.controlplane.v1.ControlPlaneService/MarkMissionControlCommandPendingSync"
	ControlPlaneService_MarkMissionControlCommandReconciled_FullMethodName  = "/kodex.controlplane.v1.ControlPlaneService/MarkMissionControlCommandReconciled"
	ControlPlaneService_MarkMissionControlCommandFailed_FullMethodName      = "/kodex.controlplane.v1.ControlPlaneService/MarkMissionControlCommandFailed"
	ControlPlaneService_SubmitInteractionCallback_FullMethodName            = "/kodex.controlplane.v1.ControlPlaneService/SubmitInteractionCallback"
	ControlPlaneService_SubmitAdapterInteractionCallback_FullMethodName     = "/kodex.controlplane.v1.ControlPlaneService/SubmitAdapterInteractionCallback"
	ControlPlaneService_ListRuntimeDeployTasks_FullMethodName               = "/kodex.controlplane.v1.ControlPlaneService/ListRuntimeDeployTasks"
	ControlPlaneService_GetRuntimeDeployTask_FullMethodName                 = "/kodex.controlplane.v1.ControlPlaneService/GetRuntimeDeployTask"
	ControlPlaneService_CancelRuntimeDeployTask_FullMethodName              = "/kodex.controlplane.v1.ControlPlaneService/CancelRuntimeDeployTask"
	ControlPlaneService_StopRuntimeDeployTask_FullMethodName                = "/kodex.controlplane.v1.ControlPlaneService/StopRuntimeDeployTask"
	ControlPlaneService_ListRuntimeErrors_FullMethodName                    = "/kodex.controlplane.v1.ControlPlaneService/ListRuntimeErrors"
	ControlPlaneService_MarkRuntimeErrorViewed_FullMethodName               = "/kodex.controlplane.v1.ControlPlaneService/MarkRuntimeErrorViewed"
	ControlPlaneService_UpsertAgentSession_FullMethodName                   = "/kodex.controlplane.v1.ControlPlaneService/UpsertAgentSession"
	ControlPlaneService_GetLatestAgentSession_FullMethodName                = "/kodex.controlplane.v1.ControlPlaneService/GetLatestAgentSession"
	ControlPlaneService_GetRunInteractionResumePayload_FullMethodName       = "/kodex.controlplane.v1.ControlPlaneService/GetRunInteractionResumePayload"
	ControlPlaneService_GetRunGitHubRateLimitResumePayload_FullMethodName   = "/kodex.controlplane.v1.ControlPlaneService/GetRunGitHubRateLimitResumePayload"
	ControlPlaneService_LookupRunPullRequest_FullMethodName                 = "/kodex.controlplane.v1.ControlPlaneService/LookupRunPullRequest"
	ControlPlaneService_InsertRunFlowEvent_FullMethodName                   = "/kodex.controlplane.v1.ControlPlaneService/InsertRunFlowEvent"
	ControlPlaneService_UpsertRunStatusComment_FullMethodName               = "/kodex.controlplane.v1.ControlPlaneService/UpsertRunStatusComment"
	ControlPlaneService_GetCodexAuth_FullMethodName                         = "/kodex.controlplane.v1.ControlPlaneService/GetCodexAuth"
	ControlPlaneService_UpsertCodexAuth_FullMethodName                      = "/kodex.controlplane.v1.ControlPlaneService/UpsertCodexAuth"
	ControlPlaneService_DeleteRunNamespace_FullMethodName                   = "/kodex.controlplane.v1.ControlPlaneService/DeleteRunNamespace"
)

// ControlPlaneServiceClient is the client API for ControlPlaneService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type ControlPlaneServiceClient interface {
	IngestGitHubWebhook(ctx context.Context, in *IngestGitHubWebhookRequest, opts ...grpc.CallOption) (*IngestGitHubWebhookResponse, error)
	// Used by api-gateway staff auth when oauth2-proxy injects identity headers.
	ResolveStaffByEmail(ctx context.Context, in *ResolveStaffByEmailRequest, opts ...grpc.CallOption) (*ResolveStaffByEmailResponse, error)
	// Used by api-gateway OAuth callback to enforce allowlist and persist GitHub identity.
	AuthorizeOAuthUser(ctx context.Context, in *AuthorizeOAuthUserRequest, opts ...grpc.CallOption) (*AuthorizeOAuthUserResponse, error)
	ListProjects(ctx context.Context, in *ListProjectsRequest, opts ...grpc.CallOption) (*ListProjectsResponse, error)
	UpsertProject(ctx context.Context, in *UpsertProjectRequest, opts ...grpc.CallOption) (*Project, error)
	GetProject(ctx context.Context, in *GetProjectRequest, opts ...grpc.CallOption) (*Project, error)
	DeleteProject(ctx context.Context, in *DeleteProjectRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListRuns(ctx context.Context, in *ListRunsRequest, opts ...grpc.CallOption) (*ListRunsResponse, error)
	ListRunWaits(ctx context.Context, in *ListRunWaitsRequest, opts ...grpc.CallOption) (*ListRunWaitsResponse, error)
	GetRun(ctx context.Context, in *GetRunRequest, opts ...grpc.CallOption) (*Run, error)
	CancelRun(ctx context.Context, in *CancelRunRequest, opts ...grpc.CallOption) (*RunActionResponse, error)
	GetRunLogs(ctx context.Context, in *GetRunLogsRequest, opts ...grpc.CallOption) (*RunLogs, error)
	ListPendingApprovals(ctx context.Context, in *ListPendingApprovalsRequest, opts ...grpc.CallOption) (*ListPendingApprovalsResponse, error)
	ResolveApprovalDecision(ctx context.Context, in *ResolveApprovalDecisionRequest, opts ...grpc.CallOption) (*ResolveApprovalDecisionResponse, error)
	ListRunEvents(ctx context.Context, in *ListRunEventsRequest, opts ...grpc.CallOption) (*ListRunEventsResponse, error)
	ListRunLearningFeedback(ctx context.Context, in *ListRunLearningFeedbackRequest, opts ...grpc.CallOption) (*ListRunLearningFeedbackResponse, error)
	ListSystemSettings(ctx context.Context, in *ListSystemSettingsRequest, opts ...grpc.CallOption) (*ListSystemSettingsResponse, error)
	GetSystemSetting(ctx context.Context, in *GetSystemSettingRequest, opts ...grpc.CallOption) (*SystemSetting, error)
	UpdateSystemSettingBoolean(ctx context.Context, in *UpdateSystemSettingBooleanRequest, opts ...grpc.CallOption) (*SystemSetting, error)
	ResetSystemSetting(ctx context.Context, in *ResetSystemSettingRequest, opts ...grpc.CallOption) (*SystemSetting, error)
	ListUsers(ctx context.Context, in *ListUsersRequest, opts ...grpc.CallOption) (*ListUsersResponse, error)
	CreateUser(ctx context.Context, in *CreateUserRequest, opts ...grpc.CallOption) (*User, error)
	DeleteUser(ctx context.Context, in *DeleteUserRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListProjectMembers(ctx context.Context, in *ListProjectMembersRequest, opts ...grpc.CallOption) (*ListProjectMembersResponse, error)
	UpsertProjectMember(ctx context.Context, in *UpsertProjectMemberRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteProjectMember(ctx context.Context, in *DeleteProjectMemberRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SetProjectMemberLearningModeOverride(ctx context.Context, in *SetProjectMemberLearningModeOverrideRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListProjectRepositories(ctx context.Context, in *ListProjectRepositoriesRequest, opts ...grpc.CallOption) (*ListProjectRepositoriesResponse, error)
	UpsertProjectRepository(ctx context.Context, in *UpsertProjectRepositoryRequest, opts ...grpc.CallOption) (*RepositoryBinding, error)
	DeleteProjectRepository(ctx context.Context, in *DeleteProjectRepositoryRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	UpsertRepositoryBotParams(ctx context.Context, in *UpsertRepositoryBotParamsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RunRepositoryPreflight(ctx context.Context, in *RunRepositoryPreflightRequest, opts ...grpc.CallOption) (*RunRepositoryPreflightResponse, error)
	GetProjectGitHubTokens(ctx context.Context, in *GetProjectGitHubTokensRequest, opts ...grpc.CallOption) (*ProjectGitHubTokens, error)
	UpsertProjectGitHubTokens(ctx context.Context, in *UpsertProjectGitHubTokensRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PreviewNextStepAction(ctx context.Context, in *NextStepActionRequest, opts ...grpc.CallOption) (*NextStepActionResponse, error)
	ExecuteNextStepAction(ctx context.Context, in *NextStepActionRequest, opts ...grpc.CallOption) (*NextStepActionResponse, error)
	ListDocsetGroups(ctx context.Context, in *ListDocsetGroupsRequest, opts ...grpc.CallOption) (*ListDocsetGroupsResponse, error)
	ImportDocset(ctx context.Context, in *ImportDocsetRequest, opts ...grpc.CallOption) (*ImportDocsetResponse, error)
	SyncDocset(ctx context.Context, in *SyncDocsetRequest, opts ...grpc.CallOption) (*SyncDocsetResponse, error)
	IssueRunMCPToken(ctx context.Context, in *IssueRunMCPTokenRequest, opts ...grpc.CallOption) (*IssueRunMCPTokenResponse, error)
	PrepareRunEnvironment(ctx context.Context, in *PrepareRunEnvironmentRequest, opts ...grpc.CallOption) (*PrepareRunEnvironmentResponse, error)
	EvaluateRuntimeReuse(ctx context.Context, in *EvaluateRuntimeReuseRequest, opts ...grpc.CallOption) (*EvaluateRuntimeReuseResponse, error)
	ClaimNextInteractionDispatch(ctx context.Context, in *ClaimNextInteractionDispatchRequest, opts ...grpc.CallOption) (*ClaimNextInteractionDispatchResponse, error)
	CompleteInteractionDispatch(ctx context.Context, in *CompleteInteractionDispatchRequest, opts ...grpc.CallOption) (*CompleteInteractionDispatchResponse, error)
	ExpireNextInteraction(ctx context.Context, in *ExpireNextInteractionRequest, opts ...grpc.CallOption) (*ExpireNextInteractionResponse, error)
	ProcessNextGitHubRateLimitWait(ctx context.Context, in *ProcessNextGitHubRateLimitWaitRequest, opts ...grpc.CallOption) (*ProcessNextGitHubRateLimitWaitResponse, error)
	ReportGitHubRateLimitSignal(ctx context.Context, in *ReportGitHubRateLimitSignalRequest, opts ...grpc.CallOption) (*ReportGitHubRateLimitSignalResponse, error)
	ReportChangeGovernanceDraftSignal(ctx context.Context, in *ReportChangeGovernanceDraftSignalRequest, opts ...grpc.CallOption) (*ReportChangeGovernanceDraftSignalResponse, error)
	PublishChangeGovernanceWaveMap(ctx context.Context, in *PublishChangeGovernanceWaveMapRequest, opts ...grpc.CallOption) (*PublishChangeGovernanceWaveMapResponse, error)
	UpsertChangeGovernanceEvidenceSignal(ctx context.Context, in *UpsertChangeGovernanceEvidenceSignalRequest, opts ...grpc.CallOption) (*UpsertChangeGovernanceEvidenceSignalResponse, error)
	GetMissionControlWorkspace(ctx context.Context, in *GetMissionControlWorkspaceRequest, opts ...grpc.CallOption) (*GetMissionControlWorkspaceResponse, error)
	GetMissionControlNode(ctx context.Context, in *GetMissionControlNodeRequest, opts ...grpc.CallOption) (*MissionControlNodeDetails, error)
	ListMissionControlNodeActivity(ctx context.Context, in *ListMissionControlNodeActivityRequest, opts ...grpc.CallOption) (*ListMissionControlNodeActivityResponse, error)
	PreviewMissionControlLaunch(ctx context.Context, in *PreviewMissionControlLaunchRequest, opts ...grpc.CallOption) (*MissionControlLaunchPreview, error)
	GetMissionControlSnapshot(ctx context.Context, in *GetMissionControlSnapshotRequest, opts ...grpc.CallOption) (*GetMissionControlSnapshotResponse, error)
	GetMissionControlEntity(ctx context.Context, in *GetMissionControlEntityRequest, opts ...grpc.CallOption) (*MissionControlEntityDetails, error)
	ListMissionControlTimeline(ctx context.Context, in *ListMissionControlTimelineRequest, opts ...grpc.CallOption) (*ListMissionControlTimelineResponse, error)
	ListMissionControlWarmupProjects(ctx context.Context, in *ListMissionControlWarmupProjectsRequest, opts ...grpc.CallOption) (*ListMissionControlWarmupProjectsResponse, error)
	RunMissionControlWarmup(ctx context.Context, in *RunMissionControlWarmupRequest, opts ...grpc.CallOption) (*RunMissionControlWarmupResponse, error)
	SubmitMissionControlCommand(ctx context.Context, in *SubmitMissionControlCommandRequest, opts ...grpc.CallOption) (*MissionControlCommandState, error)
	GetMissionControlCommand(ctx context.Context, in *GetMissionControlCommandRequest, opts ...grpc.CallOption) (*MissionControlCommandState, error)
	ClaimMissionControlPendingCommands(ctx context.Context, in *ClaimMissionControlPendingCommandsRequest, opts ...grpc.CallOption) (*ClaimMissionControlPendingCommandsResponse, error)
	QueueMissionControlCommand(ctx context.Context, in *QueueMissionControlCommandRequest, opts ...grpc.CallOption) (*MissionControlCommandState, error)
	MarkMissionControlCommandPendingSync(ctx context.Context, in *MarkMissionControlCommandPendingSyncRequest, opts ...grpc.CallOption) (*MissionControlCommandState, error)
	MarkMissionControlCommandReconciled(ctx context.Context, in *MarkMissionControlCommandReconciledRequest, opts ...grpc.CallOption) (*MissionControlCommandState, error)
	MarkMissionControlCommandFailed(ctx context.Context, in *MarkMissionControlCommandFailedRequest, opts ...grpc.CallOption) (*MissionControlCommandState, error)
	SubmitInteractionCallback(ctx context.Context, in *SubmitInteractionCallbackRequest, opts ...grpc.CallOption) (*SubmitInteractionCallbackResponse, error)
	SubmitAdapterInteractionCallback(ctx context.Context, in *SubmitInteractionCallbackRequest, opts ...grpc.CallOption) (*SubmitInteractionCallbackResponse, error)
	ListRuntimeDeployTasks(ctx context.Context, in *ListRuntimeDeployTasksRequest, opts ...grpc.CallOption) (*ListRuntimeDeployTasksResponse, error)
	GetRuntimeDeployTask(ctx context.Context, in *GetRuntimeDeployTaskRequest, opts ...grpc.CallOption) (*RuntimeDeployTask, error)
	CancelRuntimeDeployTask(ctx context.Context, in *CancelRuntimeDeployTaskRequest, opts ...grpc.CallOption) (*RuntimeDeployTaskActionResponse, error)
	StopRuntimeDeployTask(ctx context.Context, in *StopRuntimeDeployTaskRequest, opts ...grpc.CallOption) (*RuntimeDeployTaskActionResponse, error)
	ListRuntimeErrors(ctx context.Context, in *ListRuntimeErrorsRequest, opts ...grpc.CallOption) (*ListRuntimeErrorsResponse, error)
	MarkRuntimeErrorViewed(ctx context.Context, in *MarkRuntimeErrorViewedRequest, opts ...grpc.CallOption) (*RuntimeError, error)
	// Used by agent-runner for run-bound session persistence and event callbacks.
	UpsertAgentSession(ctx context.Context, in *UpsertAgentSessionRequest, opts ...grpc.CallOption) (*UpsertAgentSessionResponse, error)
	GetLatestAgentSession(ctx context.Context, in *GetLatestAgentSessionRequest, opts ...grpc.CallOption) (*GetLatestAgentSessionResponse, error)
	GetRunInteractionResumePayload(ctx context.Context, in *GetRunInteractionResumePayloadRequest, opts ...grpc.CallOption) (*GetRunInteractionResumePayloadResponse, error)
	GetRunGitHubRateLimitResumePayload(ctx context.Context, in *GetRunGitHubRateLimitResumePayloadRequest, opts ...grpc.CallOption) (*GetRunGitHubRateLimitResumePayloadResponse, error)
	LookupRunPullRequest(ctx context.Context, in *LookupRunPullRequestRequest, opts ...grpc.CallOption) (*LookupRunPullRequestResponse, error)
	InsertRunFlowEvent(ctx context.Context, in *InsertRunFlowEventRequest, opts ...grpc.CallOption) (*InsertRunFlowEventResponse, error)
	UpsertRunStatusComment(ctx context.Context, in *UpsertRunStatusCommentRequest, opts ...grpc.CallOption) (*UpsertRunStatusCommentResponse, error)
	GetCodexAuth(ctx context.Context, in *GetCodexAuthRequest, opts ...grpc.CallOption) (*GetCodexAuthResponse, error)
	UpsertCodexAuth(ctx context.Context, in *UpsertCodexAuthRequest, opts ...grpc.CallOption) (*UpsertCodexAuthResponse, error)
	DeleteRunNamespace(ctx context.Context, in *DeleteRunNamespaceRequest, opts ...grpc.CallOption) (*DeleteRunNamespaceResponse, error)
}

type controlPlaneServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewControlPlaneServiceClient(cc grpc.ClientConnInterface) ControlPlaneServiceClient {
	return &controlPlaneServiceClient{cc}
}

func (c *controlPlaneServiceClient) IngestGitHubWebhook(ctx context.Context, in *IngestGitHubWebhookRequest, opts ...grpc.CallOption) (*IngestGitHubWebhookResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(IngestGitHubWebhookResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_IngestGitHubWebhook_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ResolveStaffByEmail(ctx context.Context, in *ResolveStaffByEmailRequest, opts ...grpc.CallOption) (*ResolveStaffByEmailResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ResolveStaffByEmailResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ResolveStaffByEmail_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) AuthorizeOAuthUser(ctx context.Context, in *AuthorizeOAuthUserRequest, opts ...grpc.CallOption) (*AuthorizeOAuthUserResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(AuthorizeOAuthUserResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_AuthorizeOAuthUser_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ListProjects(ctx context.Context, in *ListProjectsRequest, opts ...grpc.CallOption) (*ListProjectsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListProjectsResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ListProjects_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) UpsertProject(ctx context.Context, in *UpsertProjectRequest, opts ...grpc.CallOption) (*Project, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Project)
	err := c.cc.Invoke(ctx, ControlPlaneService_UpsertProject_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) GetProject(ctx context.Context, in *GetProjectRequest, opts ...grpc.CallOption) (*Project, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Project)
	err := c.cc.Invoke(ctx, ControlPlaneService_GetProject_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) DeleteProject(ctx context.Context, in *DeleteProjectRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, ControlPlaneService_DeleteProject_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ListRuns(ctx context.Context, in *ListRunsRequest, opts ...grpc.CallOption) (*ListRunsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListRunsResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ListRuns_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ListRunWaits(ctx context.Context, in *ListRunWaitsRequest, opts ...grpc.CallOption) (*ListRunWaitsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListRunWaitsResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ListRunWaits_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) GetRun(ctx context.Context, in *GetRunRequest, opts ...grpc.CallOption) (*Run, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Run)
	err := c.cc.Invoke(ctx, ControlPlaneService_GetRun_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) CancelRun(ctx context.Context, in *CancelRunRequest, opts ...grpc.CallOption) (*RunActionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(RunActionResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_CancelRun_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) GetRunLogs(ctx context.Context, in *GetRunLogsRequest, opts ...grpc.CallOption) (*RunLogs, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(RunLogs)
	err := c.cc.Invoke(ctx, ControlPlaneService_GetRunLogs_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ListPendingApprovals(ctx context.Context, in *ListPendingApprovalsRequest, opts ...grpc.CallOption) (*ListPendingApprovalsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListPendingApprovalsResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ListPendingApprovals_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ResolveApprovalDecision(ctx context.Context, in *ResolveApprovalDecisionRequest, opts ...grpc.CallOption) (*ResolveApprovalDecisionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ResolveApprovalDecisionResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ResolveApprovalDecision_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ListRunEvents(ctx context.Context, in *ListRunEventsRequest, opts ...grpc.CallOption) (*ListRunEventsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListRunEventsResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ListRunEvents_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ListRunLearningFeedback(ctx context.Context, in *ListRunLearningFeedbackRequest, opts ...grpc.CallOption) (*ListRunLearningFeedbackResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListRunLearningFeedbackResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ListRunLearningFeedback_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ListSystemSettings(ctx context.Context, in *ListSystemSettingsRequest, opts ...grpc.CallOption) (*ListSystemSettingsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListSystemSettingsResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ListSystemSettings_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) GetSystemSetting(ctx context.Context, in *GetSystemSettingRequest, opts ...grpc.CallOption) (*SystemSetting, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SystemSetting)
	err := c.cc.Invoke(ctx, ControlPlaneService_GetSystemSetting_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) UpdateSystemSettingBoolean(ctx context.Context, in *UpdateSystemSettingBooleanRequest, opts ...grpc.CallOption) (*SystemSetting, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SystemSetting)
	err := c.cc.Invoke(ctx, ControlPlaneService_UpdateSystemSettingBoolean_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ResetSystemSetting(ctx context.Context, in *ResetSystemSettingRequest, opts ...grpc.CallOption) (*SystemSetting, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SystemSetting)
	err := c.cc.Invoke(ctx, ControlPlaneService_ResetSystemSetting_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ListUsers(ctx context.Context, in *ListUsersRequest, opts ...grpc.CallOption) (*ListUsersResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListUsersResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ListUsers_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) CreateUser(ctx context.Context, in *CreateUserRequest, opts ...grpc.CallOption) (*User, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(User)
	err := c.cc.Invoke(ctx, ControlPlaneService_CreateUser_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) DeleteUser(ctx context.Context, in *DeleteUserRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, ControlPlaneService_DeleteUser_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ListProjectMembers(ctx context.Context, in *ListProjectMembersRequest, opts ...grpc.CallOption) (*ListProjectMembersResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListProjectMembersResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ListProjectMembers_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) UpsertProjectMember(ctx context.Context, in *UpsertProjectMemberRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, ControlPlaneService_UpsertProjectMember_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) DeleteProjectMember(ctx context.Context, in *DeleteProjectMemberRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, ControlPlaneService_DeleteProjectMember_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) SetProjectMemberLearningModeOverride(ctx context.Context, in *SetProjectMemberLearningModeOverrideRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, ControlPlaneService_SetProjectMemberLearningModeOverride_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ListProjectRepositories(ctx context.Context, in *ListProjectRepositoriesRequest, opts ...grpc.CallOption) (*ListProjectRepositoriesResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListProjectRepositoriesResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ListProjectRepositories_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) UpsertProjectRepository(ctx context.Context, in *UpsertProjectRepositoryRequest, opts ...grpc.CallOption) (*RepositoryBinding, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(RepositoryBinding)
	err := c.cc.Invoke(ctx, ControlPlaneService_UpsertProjectRepository_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) DeleteProjectRepository(ctx context.Context, in *DeleteProjectRepositoryRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, ControlPlaneService_DeleteProjectRepository_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) UpsertRepositoryBotParams(ctx context.Context, in *UpsertRepositoryBotParamsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, ControlPlaneService_UpsertRepositoryBotParams_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) RunRepositoryPreflight(ctx context.Context, in *RunRepositoryPreflightRequest, opts ...grpc.CallOption) (*RunRepositoryPreflightResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(RunRepositoryPreflightResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_RunRepositoryPreflight_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) GetProjectGitHubTokens(ctx context.Context, in *GetProjectGitHubTokensRequest, opts ...grpc.CallOption) (*ProjectGitHubTokens, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProjectGitHubTokens)
	err := c.cc.Invoke(ctx, ControlPlaneService_GetProjectGitHubTokens_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) UpsertProjectGitHubTokens(ctx context.Context, in *UpsertProjectGitHubTokensRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, ControlPlaneService_UpsertProjectGitHubTokens_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) PreviewNextStepAction(ctx context.Context, in *NextStepActionRequest, opts ...grpc.CallOption) (*NextStepActionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(NextStepActionResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_PreviewNextStepAction_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ExecuteNextStepAction(ctx context.Context, in *NextStepActionRequest, opts ...grpc.CallOption) (*NextStepActionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(NextStepActionResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ExecuteNextStepAction_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ListDocsetGroups(ctx context.Context, in *ListDocsetGroupsRequest, opts ...grpc.CallOption) (*ListDocsetGroupsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListDocsetGroupsResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ListDocsetGroups_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ImportDocset(ctx context.Context, in *ImportDocsetRequest, opts ...grpc.CallOption) (*ImportDocsetResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ImportDocsetResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ImportDocset_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) SyncDocset(ctx context.Context, in *SyncDocsetRequest, opts ...grpc.CallOption) (*SyncDocsetResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SyncDocsetResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_SyncDocset_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) IssueRunMCPToken(ctx context.Context, in *IssueRunMCPTokenRequest, opts ...grpc.CallOption) (*IssueRunMCPTokenResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(IssueRunMCPTokenResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_IssueRunMCPToken_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) PrepareRunEnvironment(ctx context.Context, in *PrepareRunEnvironmentRequest, opts ...grpc.CallOption) (*PrepareRunEnvironmentResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(PrepareRunEnvironmentResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_PrepareRunEnvironment_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) EvaluateRuntimeReuse(ctx context.Context, in *EvaluateRuntimeReuseRequest, opts ...grpc.CallOption) (*EvaluateRuntimeReuseResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(EvaluateRuntimeReuseResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_EvaluateRuntimeReuse_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ClaimNextInteractionDispatch(ctx context.Context, in *ClaimNextInteractionDispatchRequest, opts ...grpc.CallOption) (*ClaimNextInteractionDispatchResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ClaimNextInteractionDispatchResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ClaimNextInteractionDispatch_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) CompleteInteractionDispatch(ctx context.Context, in *CompleteInteractionDispatchRequest, opts ...grpc.CallOption) (*CompleteInteractionDispatchResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(CompleteInteractionDispatchResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_CompleteInteractionDispatch_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ExpireNextInteraction(ctx context.Context, in *ExpireNextInteractionRequest, opts ...grpc.CallOption) (*ExpireNextInteractionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ExpireNextInteractionResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ExpireNextInteraction_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ProcessNextGitHubRateLimitWait(ctx context.Context, in *ProcessNextGitHubRateLimitWaitRequest, opts ...grpc.CallOption) (*ProcessNextGitHubRateLimitWaitResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProcessNextGitHubRateLimitWaitResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ProcessNextGitHubRateLimitWait_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ReportGitHubRateLimitSignal(ctx context.Context, in *ReportGitHubRateLimitSignalRequest, opts ...grpc.CallOption) (*ReportGitHubRateLimitSignalResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ReportGitHubRateLimitSignalResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ReportGitHubRateLimitSignal_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ReportChangeGovernanceDraftSignal(ctx context.Context, in *ReportChangeGovernanceDraftSignalRequest, opts ...grpc.CallOption) (*ReportChangeGovernanceDraftSignalResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ReportChangeGovernanceDraftSignalResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ReportChangeGovernanceDraftSignal_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) PublishChangeGovernanceWaveMap(ctx context.Context, in *PublishChangeGovernanceWaveMapRequest, opts ...grpc.CallOption) (*PublishChangeGovernanceWaveMapResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(PublishChangeGovernanceWaveMapResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_PublishChangeGovernanceWaveMap_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) UpsertChangeGovernanceEvidenceSignal(ctx context.Context, in *UpsertChangeGovernanceEvidenceSignalRequest, opts ...grpc.CallOption) (*UpsertChangeGovernanceEvidenceSignalResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(UpsertChangeGovernanceEvidenceSignalResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_UpsertChangeGovernanceEvidenceSignal_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) GetMissionControlWorkspace(ctx context.Context, in *GetMissionControlWorkspaceRequest, opts ...grpc.CallOption) (*GetMissionControlWorkspaceResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetMissionControlWorkspaceResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_GetMissionControlWorkspace_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) GetMissionControlNode(ctx context.Context, in *GetMissionControlNodeRequest, opts ...grpc.CallOption) (*MissionControlNodeDetails, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(MissionControlNodeDetails)
	err := c.cc.Invoke(ctx, ControlPlaneService_GetMissionControlNode_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ListMissionControlNodeActivity(ctx context.Context, in *ListMissionControlNodeActivityRequest, opts ...grpc.CallOption) (*ListMissionControlNodeActivityResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListMissionControlNodeActivityResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ListMissionControlNodeActivity_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) PreviewMissionControlLaunch(ctx context.Context, in *PreviewMissionControlLaunchRequest, opts ...grpc.CallOption) (*MissionControlLaunchPreview, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(MissionControlLaunchPreview)
	err := c.cc.Invoke(ctx, ControlPlaneService_PreviewMissionControlLaunch_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) GetMissionControlSnapshot(ctx context.Context, in *GetMissionControlSnapshotRequest, opts ...grpc.CallOption) (*GetMissionControlSnapshotResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetMissionControlSnapshotResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_GetMissionControlSnapshot_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) GetMissionControlEntity(ctx context.Context, in *GetMissionControlEntityRequest, opts ...grpc.CallOption) (*MissionControlEntityDetails, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(MissionControlEntityDetails)
	err := c.cc.Invoke(ctx, ControlPlaneService_GetMissionControlEntity_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ListMissionControlTimeline(ctx context.Context, in *ListMissionControlTimelineRequest, opts ...grpc.CallOption) (*ListMissionControlTimelineResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListMissionControlTimelineResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ListMissionControlTimeline_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ListMissionControlWarmupProjects(ctx context.Context, in *ListMissionControlWarmupProjectsRequest, opts ...grpc.CallOption) (*ListMissionControlWarmupProjectsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListMissionControlWarmupProjectsResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ListMissionControlWarmupProjects_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) RunMissionControlWarmup(ctx context.Context, in *RunMissionControlWarmupRequest, opts ...grpc.CallOption) (*RunMissionControlWarmupResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(RunMissionControlWarmupResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_RunMissionControlWarmup_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) SubmitMissionControlCommand(ctx context.Context, in *SubmitMissionControlCommandRequest, opts ...grpc.CallOption) (*MissionControlCommandState, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(MissionControlCommandState)
	err := c.cc.Invoke(ctx, ControlPlaneService_SubmitMissionControlCommand_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) GetMissionControlCommand(ctx context.Context, in *GetMissionControlCommandRequest, opts ...grpc.CallOption) (*MissionControlCommandState, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(MissionControlCommandState)
	err := c.cc.Invoke(ctx, ControlPlaneService_GetMissionControlCommand_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ClaimMissionControlPendingCommands(ctx context.Context, in *ClaimMissionControlPendingCommandsRequest, opts ...grpc.CallOption) (*ClaimMissionControlPendingCommandsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ClaimMissionControlPendingCommandsResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ClaimMissionControlPendingCommands_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) QueueMissionControlCommand(ctx context.Context, in *QueueMissionControlCommandRequest, opts ...grpc.CallOption) (*MissionControlCommandState, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(MissionControlCommandState)
	err := c.cc.Invoke(ctx, ControlPlaneService_QueueMissionControlCommand_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) MarkMissionControlCommandPendingSync(ctx context.Context, in *MarkMissionControlCommandPendingSyncRequest, opts ...grpc.CallOption) (*MissionControlCommandState, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(MissionControlCommandState)
	err := c.cc.Invoke(ctx, ControlPlaneService_MarkMissionControlCommandPendingSync_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) MarkMissionControlCommandReconciled(ctx context.Context, in *MarkMissionControlCommandReconciledRequest, opts ...grpc.CallOption) (*MissionControlCommandState, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(MissionControlCommandState)
	err := c.cc.Invoke(ctx, ControlPlaneService_MarkMissionControlCommandReconciled_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) MarkMissionControlCommandFailed(ctx context.Context, in *MarkMissionControlCommandFailedRequest, opts ...grpc.CallOption) (*MissionControlCommandState, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(MissionControlCommandState)
	err := c.cc.Invoke(ctx, ControlPlaneService_MarkMissionControlCommandFailed_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) SubmitInteractionCallback(ctx context.Context, in *SubmitInteractionCallbackRequest, opts ...grpc.CallOption) (*SubmitInteractionCallbackResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SubmitInteractionCallbackResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_SubmitInteractionCallback_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) SubmitAdapterInteractionCallback(ctx context.Context, in *SubmitInteractionCallbackRequest, opts ...grpc.CallOption) (*SubmitInteractionCallbackResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SubmitInteractionCallbackResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_SubmitAdapterInteractionCallback_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ListRuntimeDeployTasks(ctx context.Context, in *ListRuntimeDeployTasksRequest, opts ...grpc.CallOption) (*ListRuntimeDeployTasksResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListRuntimeDeployTasksResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ListRuntimeDeployTasks_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) GetRuntimeDeployTask(ctx context.Context, in *GetRuntimeDeployTaskRequest, opts ...grpc.CallOption) (*RuntimeDeployTask, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(RuntimeDeployTask)
	err := c.cc.Invoke(ctx, ControlPlaneService_GetRuntimeDeployTask_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) CancelRuntimeDeployTask(ctx context.Context, in *CancelRuntimeDeployTaskRequest, opts ...grpc.CallOption) (*RuntimeDeployTaskActionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(RuntimeDeployTaskActionResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_CancelRuntimeDeployTask_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) StopRuntimeDeployTask(ctx context.Context, in *StopRuntimeDeployTaskRequest, opts ...grpc.CallOption) (*RuntimeDeployTaskActionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(RuntimeDeployTaskActionResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_StopRuntimeDeployTask_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) ListRuntimeErrors(ctx context.Context, in *ListRuntimeErrorsRequest, opts ...grpc.CallOption) (*ListRuntimeErrorsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListRuntimeErrorsResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_ListRuntimeErrors_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) MarkRuntimeErrorViewed(ctx context.Context, in *MarkRuntimeErrorViewedRequest, opts ...grpc.CallOption) (*RuntimeError, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(RuntimeError)
	err := c.cc.Invoke(ctx, ControlPlaneService_MarkRuntimeErrorViewed_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) UpsertAgentSession(ctx context.Context, in *UpsertAgentSessionRequest, opts ...grpc.CallOption) (*UpsertAgentSessionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(UpsertAgentSessionResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_UpsertAgentSession_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) GetLatestAgentSession(ctx context.Context, in *GetLatestAgentSessionRequest, opts ...grpc.CallOption) (*GetLatestAgentSessionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetLatestAgentSessionResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_GetLatestAgentSession_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) GetRunInteractionResumePayload(ctx context.Context, in *GetRunInteractionResumePayloadRequest, opts ...grpc.CallOption) (*GetRunInteractionResumePayloadResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetRunInteractionResumePayloadResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_GetRunInteractionResumePayload_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) GetRunGitHubRateLimitResumePayload(ctx context.Context, in *GetRunGitHubRateLimitResumePayloadRequest, opts ...grpc.CallOption) (*GetRunGitHubRateLimitResumePayloadResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetRunGitHubRateLimitResumePayloadResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_GetRunGitHubRateLimitResumePayload_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) LookupRunPullRequest(ctx context.Context, in *LookupRunPullRequestRequest, opts ...grpc.CallOption) (*LookupRunPullRequestResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(LookupRunPullRequestResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_LookupRunPullRequest_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) InsertRunFlowEvent(ctx context.Context, in *InsertRunFlowEventRequest, opts ...grpc.CallOption) (*InsertRunFlowEventResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(InsertRunFlowEventResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_InsertRunFlowEvent_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) UpsertRunStatusComment(ctx context.Context, in *UpsertRunStatusCommentRequest, opts ...grpc.CallOption) (*UpsertRunStatusCommentResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(UpsertRunStatusCommentResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_UpsertRunStatusComment_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) GetCodexAuth(ctx context.Context, in *GetCodexAuthRequest, opts ...grpc.CallOption) (*GetCodexAuthResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetCodexAuthResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_GetCodexAuth_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) UpsertCodexAuth(ctx context.Context, in *UpsertCodexAuthRequest, opts ...grpc.CallOption) (*UpsertCodexAuthResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(UpsertCodexAuthResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_UpsertCodexAuth_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *controlPlaneServiceClient) DeleteRunNamespace(ctx context.Context, in *DeleteRunNamespaceRequest, opts ...grpc.CallOption) (*DeleteRunNamespaceResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(DeleteRunNamespaceResponse)
	err := c.cc.Invoke(ctx, ControlPlaneService_DeleteRunNamespace_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// ControlPlaneServiceServer is the server API for ControlPlaneService service.
// All implementations must embed UnimplementedControlPlaneServiceServer
// for forward compatibility.
type ControlPlaneServiceServer interface {
	IngestGitHubWebhook(context.Context, *IngestGitHubWebhookRequest) (*IngestGitHubWebhookResponse, error)
	// Used by api-gateway staff auth when oauth2-proxy injects identity headers.
	ResolveStaffByEmail(context.Context, *ResolveStaffByEmailRequest) (*ResolveStaffByEmailResponse, error)
	// Used by api-gateway OAuth callback to enforce allowlist and persist GitHub identity.
	AuthorizeOAuthUser(context.Context, *AuthorizeOAuthUserRequest) (*AuthorizeOAuthUserResponse, error)
	ListProjects(context.Context, *ListProjectsRequest) (*ListProjectsResponse, error)
	UpsertProject(context.Context, *UpsertProjectRequest) (*Project, error)
	GetProject(context.Context, *GetProjectRequest) (*Project, error)
	DeleteProject(context.Context, *DeleteProjectRequest) (*emptypb.Empty, error)
	ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error)
	ListRunWaits(context.Context, *ListRunWaitsRequest) (*ListRunWaitsResponse, error)
	GetRun(context.Context, *GetRunRequest) (*Run, error)
	CancelRun(context.Context, *CancelRunRequest) (*RunActionResponse, error)
	GetRunLogs(context.Context, *GetRunLogsRequest) (*RunLogs, error)
	ListPendingApprovals(context.Context, *ListPendingApprovalsRequest) (*ListPendingApprovalsResponse, error)
	ResolveApprovalDecision(context.Context, *ResolveApprovalDecisionRequest) (*ResolveApprovalDecisionResponse, error)
	ListRunEvents(context.Context, *ListRunEventsRequest) (*ListRunEventsResponse, error)
	ListRunLearningFeedback(context.Context, *ListRunLearningFeedbackRequest) (*ListRunLearningFeedbackResponse, error)
	ListSystemSettings(context.Context, *ListSystemSettingsRequest) (*ListSystemSettingsResponse, error)
	GetSystemSetting(context.Context, *GetSystemSettingRequest) (*SystemSetting, error)
	UpdateSystemSettingBoolean(context.Context, *UpdateSystemSettingBooleanRequest) (*SystemSetting, error)
	ResetSystemSetting(context.Context, *ResetSystemSettingRequest) (*SystemSetting, error)
	ListUsers(context.Context, *ListUsersRequest) (*ListUsersResponse, error)
	CreateUser(context.Context, *CreateUserRequest) (*User, error)
	DeleteUser(context.Context, *DeleteUserRequest) (*emptypb.Empty, error)
	ListProjectMembers(context.Context, *ListProjectMembersRequest) (*ListProjectMembersResponse, error)
	UpsertProjectMember(context.Context, *UpsertProjectMemberRequest) (*emptypb.Empty, error)
	DeleteProjectMember(context.Context, *DeleteProjectMemberRequest) (*emptypb.Empty, error)
	SetProjectMemberLearningModeOverride(context.Context, *SetProjectMemberLearningModeOverrideRequest) (*emptypb.Empty, error)
	ListProjectRepositories(context.Context, *ListProjectRepositoriesRequest) (*ListProjectRepositoriesResponse, error)
	UpsertProjectRepository(context.Context, *UpsertProjectRepositoryRequest) (*RepositoryBinding, error)
	DeleteProjectRepository(context.Context, *DeleteProjectRepositoryRequest) (*emptypb.Empty, error)
	UpsertRepositoryBotParams(context.Context, *UpsertRepositoryBotParamsRequest) (*emptypb.Empty, error)
	RunRepositoryPreflight(context.Context, *RunRepositoryPreflightRequest) (*RunRepositoryPreflightResponse, error)
	GetProjectGitHubTokens(context.Context, *GetProjectGitHubTokensRequest) (*ProjectGitHubTokens, error)
	UpsertProjectGitHubTokens(context.Context, *UpsertProjectGitHubTokensRequest) (*emptypb.Empty, error)
	PreviewNextStepAction(context.Context, *NextStepActionRequest) (*NextStepActionResponse, error)
	ExecuteNextStepAction(context.Context, *NextStepActionRequest) (*NextStepActionResponse, error)
	ListDocsetGroups(context.Context, *ListDocsetGroupsRequest) (*ListDocsetGroupsResponse, error)
	ImportDocset(context.Context, *ImportDocsetRequest) (*ImportDocsetResponse, error)
	SyncDocset(context.Context, *SyncDocsetRequest) (*SyncDocsetResponse, error)
	IssueRunMCPToken(context.Context, *IssueRunMCPTokenRequest) (*IssueRunMCPTokenResponse, error)
	PrepareRunEnvironment(context.Context, *PrepareRunEnvironmentRequest) (*PrepareRunEnvironmentResponse, error)
	EvaluateRuntimeReuse(context.Context, *EvaluateRuntimeReuseRequest) (*EvaluateRuntimeReuseResponse, error)
	ClaimNextInteractionDispatch(context.Context, *ClaimNextInteractionDispatchRequest) (*ClaimNextInteractionDispatchResponse, error)
	CompleteInteractionDispatch(context.Context, *CompleteInteractionDispatchRequest) (*CompleteInteractionDispatchResponse, error)
	ExpireNextInteraction(context.Context, *ExpireNextInteractionRequest) (*ExpireNextInteractionResponse, error)
	ProcessNextGitHubRateLimitWait(context.Context, *ProcessNextGitHubRateLimitWaitRequest) (*ProcessNextGitHubRateLimitWaitResponse, error)
	ReportGitHubRateLimitSignal(context.Context, *ReportGitHubRateLimitSignalRequest) (*ReportGitHubRateLimitSignalResponse, error)
	ReportChangeGovernanceDraftSignal(context.Context, *ReportChangeGovernanceDraftSignalRequest) (*ReportChangeGovernanceDraftSignalResponse, error)
	PublishChangeGovernanceWaveMap(context.Context, *PublishChangeGovernanceWaveMapRequest) (*PublishChangeGovernanceWaveMapResponse, error)
	UpsertChangeGovernanceEvidenceSignal(context.Context, *UpsertChangeGovernanceEvidenceSignalRequest) (*UpsertChangeGovernanceEvidenceSignalResponse, error)
	GetMissionControlWorkspace(context.Context, *GetMissionControlWorkspaceRequest) (*GetMissionControlWorkspaceResponse, error)
	GetMissionControlNode(context.Context, *GetMissionControlNodeRequest) (*MissionControlNodeDetails, error)
	ListMissionControlNodeActivity(context.Context, *ListMissionControlNodeActivityRequest) (*ListMissionControlNodeActivityResponse, error)
	PreviewMissionControlLaunch(context.Context, *PreviewMissionControlLaunchRequest) (*MissionControlLaunchPreview, error)
	GetMissionControlSnapshot(context.Context, *GetMissionControlSnapshotRequest) (*GetMissionControlSnapshotResponse, error)
	GetMissionControlEntity(context.Context, *GetMissionControlEntityRequest) (*MissionControlEntityDetails, error)
	ListMissionControlTimeline(context.Context, *ListMissionControlTimelineRequest) (*ListMissionControlTimelineResponse, error)
	ListMissionControlWarmupProjects(context.Context, *ListMissionControlWarmupProjectsRequest) (*ListMissionControlWarmupProjectsResponse, error)
	RunMissionControlWarmup(context.Context, *RunMissionControlWarmupRequest) (*RunMissionControlWarmupResponse, error)
	SubmitMissionControlCommand(context.Context, *SubmitMissionControlCommandRequest) (*MissionControlCommandState, error)
	GetMissionControlCommand(context.Context, *GetMissionControlCommandRequest) (*MissionControlCommandState, error)
	ClaimMissionControlPendingCommands(context.Context, *ClaimMissionControlPendingCommandsRequest) (*ClaimMissionControlPendingCommandsResponse, error)
	QueueMissionControlCommand(context.Context, *QueueMissionControlCommandRequest) (*MissionControlCommandState, error)
	MarkMissionControlCommandPendingSync(context.Context, *MarkMissionControlCommandPendingSyncRequest) (*MissionControlCommandState, error)
	MarkMissionControlCommandReconciled(context.Context, *MarkMissionControlCommandReconciledRequest) (*MissionControlCommandState, error)
	MarkMissionControlCommandFailed(context.Context, *MarkMissionControlCommandFailedRequest) (*MissionControlCommandState, error)
	SubmitInteractionCallback(context.Context, *SubmitInteractionCallbackRequest) (*SubmitInteractionCallbackResponse, error)
	SubmitAdapterInteractionCallback(context.Context, *SubmitInteractionCallbackRequest) (*SubmitInteractionCallbackResponse, error)
	ListRuntimeDeployTasks(context.Context, *ListRuntimeDeployTasksRequest) (*ListRuntimeDeployTasksResponse, error)
	GetRuntimeDeployTask(context.Context, *GetRuntimeDeployTaskRequest) (*RuntimeDeployTask, error)
	CancelRuntimeDeployTask(context.Context, *CancelRuntimeDeployTaskRequest) (*RuntimeDeployTaskActionResponse, error)
	StopRuntimeDeployTask(context.Context, *StopRuntimeDeployTaskRequest) (*RuntimeDeployTaskActionResponse, error)
	ListRuntimeErrors(context.Context, *ListRuntimeErrorsRequest) (*ListRuntimeErrorsResponse, error)
	MarkRuntimeErrorViewed(context.Context, *MarkRuntimeErrorViewedRequest) (*RuntimeError, error)
	// Used by agent-runner for run-bound session persistence and event callbacks.
	UpsertAgentSession(context.Context, *UpsertAgentSessionRequest) (*UpsertAgentSessionResponse, error)
	GetLatestAgentSession(context.Context, *GetLatestAgentSessionRequest) (*GetLatestAgentSessionResponse, error)
	GetRunInteractionResumePayload(context.Context, *GetRunInteractionResumePayloadRequest) (*GetRunInteractionResumePayloadResponse, error)
	GetRunGitHubRateLimitResumePayload(context.Context, *GetRunGitHubRateLimitResumePayloadRequest) (*GetRunGitHubRateLimitResumePayloadResponse, error)
	LookupRunPullRequest(context.Context, *LookupRunPullRequestRequest) (*LookupRunPullRequestResponse, error)
	InsertRunFlowEvent(context.Context, *InsertRunFlowEventRequest) (*InsertRunFlowEventResponse, error)
	UpsertRunStatusComment(context.Context, *UpsertRunStatusCommentRequest) (*UpsertRunStatusCommentResponse, error)
	GetCodexAuth(context.Context, *GetCodexAuthRequest) (*GetCodexAuthResponse, error)
	UpsertCodexAuth(context.Context, *UpsertCodexAuthRequest) (*UpsertCodexAuthResponse, error)
	DeleteRunNamespace(context.Context, *DeleteRunNamespaceRequest) (*DeleteRunNamespaceResponse, error)
	mustEmbedUnimplementedControlPlaneServiceServer()
}

// UnimplementedControlPlaneServiceServer must be embedded to have
// forward compatible implementations.
//
// NOTE: this should be embedded by value instead of pointer to avoid a nil
// pointer dereference when methods are called.
type UnimplementedControlPlaneServiceServer struct{}

func (UnimplementedControlPlaneServiceServer) IngestGitHubWebhook(context.Context, *IngestGitHubWebhookRequest) (*IngestGitHubWebhookResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method IngestGitHubWebhook not implemented")
}
func (UnimplementedControlPlaneServiceServer) ResolveStaffByEmail(context.Context, *ResolveStaffByEmailRequest) (*ResolveStaffByEmailResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ResolveStaffByEmail not implemented")
}
func (UnimplementedControlPlaneServiceServer) AuthorizeOAuthUser(context.Context, *AuthorizeOAuthUserRequest) (*AuthorizeOAuthUserResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method AuthorizeOAuthUser not implemented")
}
func (UnimplementedControlPlaneServiceServer) ListProjects(context.Context, *ListProjectsRequest) (*ListProjectsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListProjects not implemented")
}
func (UnimplementedControlPlaneServiceServer) UpsertProject(context.Context, *UpsertProjectRequest) (*Project, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpsertProject not implemented")
}
func (UnimplementedControlPlaneServiceServer) GetProject(context.Context, *GetProjectRequest) (*Project, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetProject not implemented")
}
func (UnimplementedControlPlaneServiceServer) DeleteProject(context.Context, *DeleteProjectRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteProject not implemented")
}
func (UnimplementedControlPlaneServiceServer) ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListRuns not implemented")
}
func (UnimplementedControlPlaneServiceServer) ListRunWaits(context.Context, *ListRunWaitsRequest) (*ListRunWaitsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListRunWaits not implemented")
}
func (UnimplementedControlPlaneServiceServer) GetRun(context.Context, *GetRunRequest) (*Run, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetRun not implemented")
}
func (UnimplementedControlPlaneServiceServer) CancelRun(context.Context, *CancelRunRequest) (*RunActionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CancelRun not implemented")
}
func (UnimplementedControlPlaneServiceServer) GetRunLogs(context.Context, *GetRunLogsRequest) (*RunLogs, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetRunLogs not implemented")
}
func (UnimplementedControlPlaneServiceServer) ListPendingApprovals(context.Context, *ListPendingApprovalsRequest) (*ListPendingApprovalsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListPendingApprovals not implemented")
}
func (UnimplementedControlPlaneServiceServer) ResolveApprovalDecision(context.Context, *ResolveApprovalDecisionRequest) (*ResolveApprovalDecisionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ResolveApprovalDecision not implemented")
}
func (UnimplementedControlPlaneServiceServer) ListRunEvents(context.Context, *ListRunEventsRequest) (*ListRunEventsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListRunEvents not implemented")
}
func (UnimplementedControlPlaneServiceServer) ListRunLearningFeedback(context.Context, *ListRunLearningFeedbackRequest) (*ListRunLearningFeedbackResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListRunLearningFeedback not implemented")
}
func (UnimplementedControlPlaneServiceServer) ListSystemSettings(context.Context, *ListSystemSettingsRequest) (*ListSystemSettingsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListSystemSettings not implemented")
}
func (UnimplementedControlPlaneServiceServer) GetSystemSetting(context.Context, *GetSystemSettingRequest) (*SystemSetting, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetSystemSetting not implemented")
}
func (UnimplementedControlPlaneServiceServer) UpdateSystemSettingBoolean(context.Context, *UpdateSystemSettingBooleanRequest) (*SystemSetting, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateSystemSettingBoolean not implemented")
}
func (UnimplementedControlPlaneServiceServer) ResetSystemSetting(context.Context, *ResetSystemSettingRequest) (*SystemSetting, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ResetSystemSetting not implemented")
}
func (UnimplementedControlPlaneServiceServer) ListUsers(context.Context, *ListUsersRequest) (*ListUsersResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListUsers not implemented")
}
func (UnimplementedControlPlaneServiceServer) CreateUser(context.Context, *CreateUserRequest) (*User, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateUser not implemented")
}
func (UnimplementedControlPlaneServiceServer) DeleteUser(context.Context, *DeleteUserRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteUser not implemented")
}
func (UnimplementedControlPlaneServiceServer) ListProjectMembers(context.Context, *ListProjectMembersRequest) (*ListProjectMembersResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListProjectMembers not implemented")
}
func (UnimplementedControlPlaneServiceServer) UpsertProjectMember(context.Context, *UpsertProjectMemberRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpsertProjectMember not implemented")
}
func (UnimplementedControlPlaneServiceServer) DeleteProjectMember(context.Context, *DeleteProjectMemberRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteProjectMember not implemented")
}
func (UnimplementedControlPlaneServiceServer) SetProjectMemberLearningModeOverride(context.Context, *SetProjectMemberLearningModeOverrideRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SetProjectMemberLearningModeOverride not implemented")
}
func (UnimplementedControlPlaneServiceServer) ListProjectRepositories(context.Context, *ListProjectRepositoriesRequest) (*ListProjectRepositoriesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListProjectRepositories not implemented")
}
func (UnimplementedControlPlaneServiceServer) UpsertProjectRepository(context.Context, *UpsertProjectRepositoryRequest) (*RepositoryBinding, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpsertProjectRepository not implemented")
}
func (UnimplementedControlPlaneServiceServer) DeleteProjectRepository(context.Context, *DeleteProjectRepositoryRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteProjectRepository not implemented")
}
func (UnimplementedControlPlaneServiceServer) UpsertRepositoryBotParams(context.Context, *UpsertRepositoryBotParamsRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpsertRepositoryBotParams not implemented")
}
func (UnimplementedControlPlaneServiceServer) RunRepositoryPreflight(context.Context, *RunRepositoryPreflightRequest) (*RunRepositoryPreflightResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RunRepositoryPreflight not implemented")
}
func (UnimplementedControlPlaneServiceServer) GetProjectGitHubTokens(context.Context, *GetProjectGitHubTokensRequest) (*ProjectGitHubTokens, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetProjectGitHubTokens not implemented")
}
func (UnimplementedControlPlaneServiceServer) UpsertProjectGitHubTokens(context.Context, *UpsertProjectGitHubTokensRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpsertProjectGitHubTokens not implemented")
}
func (UnimplementedControlPlaneServiceServer) PreviewNextStepAction(context.Context, *NextStepActionRequest) (*NextStepActionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method PreviewNextStepAction not implemented")
}
func (UnimplementedControlPlaneServiceServer) ExecuteNextStepAction(context.Context, *NextStepActionRequest) (*NextStepActionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ExecuteNextStepAction not implemented")
}
func (UnimplementedControlPlaneServiceServer) ListDocsetGroups(context.Context, *ListDocsetGroupsRequest) (*ListDocsetGroupsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListDocsetGroups not implemented")
}
func (UnimplementedControlPlaneServiceServer) ImportDocset(context.Context, *ImportDocsetRequest) (*ImportDocsetResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ImportDocset not implemented")
}
func (UnimplementedControlPlaneServiceServer) SyncDocset(context.Context, *SyncDocsetRequest) (*SyncDocsetResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SyncDocset not implemented")
}
func (UnimplementedControlPlaneServiceServer) IssueRunMCPToken(context.Context, *IssueRunMCPTokenRequest) (*IssueRunMCPTokenResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method IssueRunMCPToken not implemented")
}
func (UnimplementedControlPlaneServiceServer) PrepareRunEnvironment(context.Context, *PrepareRunEnvironmentRequest) (*PrepareRunEnvironmentResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method PrepareRunEnvironment not implemented")
}
func (UnimplementedControlPlaneServiceServer) EvaluateRuntimeReuse(context.Context, *EvaluateRuntimeReuseRequest) (*EvaluateRuntimeReuseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method EvaluateRuntimeReuse not implemented")
}
func (UnimplementedControlPlaneServiceServer) ClaimNextInteractionDispatch(context.Context, *ClaimNextInteractionDispatchRequest) (*ClaimNextInteractionDispatchResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ClaimNextInteractionDispatch not implemented")
}
func (UnimplementedControlPlaneServiceServer) CompleteInteractionDispatch(context.Context, *CompleteInteractionDispatchRequest) (*CompleteInteractionDispatchResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CompleteInteractionDispatch not implemented")
}
func (UnimplementedControlPlaneServiceServer) ExpireNextInteraction(context.Context, *ExpireNextInteractionRequest) (*ExpireNextInteractionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ExpireNextInteraction not implemented")
}
func (UnimplementedControlPlaneServiceServer) ProcessNextGitHubRateLimitWait(context.Context, *ProcessNextGitHubRateLimitWaitRequest) (*ProcessNextGitHubRateLimitWaitResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ProcessNextGitHubRateLimitWait not implemented")
}
func (UnimplementedControlPlaneServiceServer) ReportGitHubRateLimitSignal(context.Context, *ReportGitHubRateLimitSignalRequest) (*ReportGitHubRateLimitSignalResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ReportGitHubRateLimitSignal not implemented")
}
func (UnimplementedControlPlaneServiceServer) ReportChangeGovernanceDraftSignal(context.Context, *ReportChangeGovernanceDraftSignalRequest) (*ReportChangeGovernanceDraftSignalResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ReportChangeGovernanceDraftSignal not implemented")
}
func (UnimplementedControlPlaneServiceServer) PublishChangeGovernanceWaveMap(context.Context, *PublishChangeGovernanceWaveMapRequest) (*PublishChangeGovernanceWaveMapResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method PublishChangeGovernanceWaveMap not implemented")
}
func (UnimplementedControlPlaneServiceServer) UpsertChangeGovernanceEvidenceSignal(context.Context, *UpsertChangeGovernanceEvidenceSignalRequest) (*UpsertChangeGovernanceEvidenceSignalResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpsertChangeGovernanceEvidenceSignal not implemented")
}
func (UnimplementedControlPlaneServiceServer) GetMissionControlWorkspace(context.Context, *GetMissionControlWorkspaceRequest) (*GetMissionControlWorkspaceResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetMissionControlWorkspace not implemented")
}
func (UnimplementedControlPlaneServiceServer) GetMissionControlNode(context.Context, *GetMissionControlNodeRequest) (*MissionControlNodeDetails, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetMissionControlNode not implemented")
}
func (UnimplementedControlPlaneServiceServer) ListMissionControlNodeActivity(context.Context, *ListMissionControlNodeActivityRequest) (*ListMissionControlNodeActivityResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListMissionControlNodeActivity not implemented")
}
func (UnimplementedControlPlaneServiceServer) PreviewMissionControlLaunch(context.Context, *PreviewMissionControlLaunchRequest) (*MissionControlLaunchPreview, error) {
	return nil, status.Errorf(codes.Unimplemented, "method PreviewMissionControlLaunch not implemented")
}
func (UnimplementedControlPlaneServiceServer) GetMissionControlSnapshot(context.Context, *GetMissionControlSnapshotRequest) (*GetMissionControlSnapshotResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetMissionControlSnapshot not implemented")
}
func (UnimplementedControlPlaneServiceServer) GetMissionControlEntity(context.Context, *GetMissionControlEntityRequest) (*MissionControlEntityDetails, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetMissionControlEntity not implemented")
}
func (UnimplementedControlPlaneServiceServer) ListMissionControlTimeline(context.Context, *ListMissionControlTimelineRequest) (*ListMissionControlTimelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListMissionControlTimeline not implemented")
}
func (UnimplementedControlPlaneServiceServer) ListMissionControlWarmupProjects(context.Context, *ListMissionControlWarmupProjectsRequest) (*ListMissionControlWarmupProjectsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListMissionControlWarmupProjects not implemented")
}
func (UnimplementedControlPlaneServiceServer) RunMissionControlWarmup(context.Context, *RunMissionControlWarmupRequest) (*RunMissionControlWarmupResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RunMissionControlWarmup not implemented")
}
func (UnimplementedControlPlaneServiceServer) SubmitMissionControlCommand(context.Context, *SubmitMissionControlCommandRequest) (*MissionControlCommandState, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SubmitMissionControlCommand not implemented")
}
func (UnimplementedControlPlaneServiceServer) GetMissionControlCommand(context.Context, *GetMissionControlCommandRequest) (*MissionControlCommandState, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetMissionControlCommand not implemented")
}
func (UnimplementedControlPlaneServiceServer) ClaimMissionControlPendingCommands(context.Context, *ClaimMissionControlPendingCommandsRequest) (*ClaimMissionControlPendingCommandsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ClaimMissionControlPendingCommands not implemented")
}
func (UnimplementedControlPlaneServiceServer) QueueMissionControlCommand(context.Context, *QueueMissionControlCommandRequest) (*MissionControlCommandState, error) {
	return nil, status.Errorf(codes.Unimplemented, "method QueueMissionControlCommand not implemented")
}
func (UnimplementedControlPlaneServiceServer) MarkMissionControlCommandPendingSync(context.Context, *MarkMissionControlCommandPendingSyncRequest) (*MissionControlCommandState, error) {
	return nil, status.Errorf(codes.Unimplemented, "method MarkMissionControlCommandPendingSync not implemented")
}
func (UnimplementedControlPlaneServiceServer) MarkMissionControlCommandReconciled(context.Context, *MarkMissionControlCommandReconciledRequest) (*MissionControlCommandState, error) {
	return nil, status.Errorf(codes.Unimplemented, "method MarkMissionControlCommandReconciled not implemented")
}
func (UnimplementedControlPlaneServiceServer) MarkMissionControlCommandFailed(context.Context, *MarkMissionControlCommandFailedRequest) (*MissionControlCommandState, error) {
	return nil, status.Errorf(codes.Unimplemented, "method MarkMissionControlCommandFailed not implemented")
}
func (UnimplementedControlPlaneServiceServer) SubmitInteractionCallback(context.Context, *SubmitInteractionCallbackRequest) (*SubmitInteractionCallbackResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SubmitInteractionCallback not implemented")
}
func (UnimplementedControlPlaneServiceServer) SubmitAdapterInteractionCallback(context.Context, *SubmitInteractionCallbackRequest) (*SubmitInteractionCallbackResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SubmitAdapterInteractionCallback not implemented")
}
func (UnimplementedControlPlaneServiceServer) ListRuntimeDeployTasks(context.Context, *ListRuntimeDeployTasksRequest) (*ListRuntimeDeployTasksResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListRuntimeDeployTasks not implemented")
}
func (UnimplementedControlPlaneServiceServer) GetRuntimeDeployTask(context.Context, *GetRuntimeDeployTaskRequest) (*RuntimeDeployTask, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetRuntimeDeployTask not implemented")
}
func (UnimplementedControlPlaneServiceServer) CancelRuntimeDeployTask(context.Context, *CancelRuntimeDeployTaskRequest) (*RuntimeDeployTaskActionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CancelRuntimeDeployTask not implemented")
}
func (UnimplementedControlPlaneServiceServer) StopRuntimeDeployTask(context.Context, *StopRuntimeDeployTaskRequest) (*RuntimeDeployTaskActionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method StopRuntimeDeployTask not implemented")
}
func (UnimplementedControlPlaneServiceServer) ListRuntimeErrors(context.Context, *ListRuntimeErrorsRequest) (*ListRuntimeErrorsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListRuntimeErrors not implemented")
}
func (UnimplementedControlPlaneServiceServer) MarkRuntimeErrorViewed(context.Context, *MarkRuntimeErrorViewedRequest) (*RuntimeError, error) {
	return nil, status.Errorf(codes.Unimplemented, "method MarkRuntimeErrorViewed not implemented")
}
func (UnimplementedControlPlaneServiceServer) UpsertAgentSession(context.Context, *UpsertAgentSessionRequest) (*UpsertAgentSessionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpsertAgentSession not implemented")
}
func (UnimplementedControlPlaneServiceServer) GetLatestAgentSession(context.Context, *GetLatestAgentSessionRequest) (*GetLatestAgentSessionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetLatestAgentSession not implemented")
}
func (UnimplementedControlPlaneServiceServer) GetRunInteractionResumePayload(context.Context, *GetRunInteractionResumePayloadRequest) (*GetRunInteractionResumePayloadResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetRunInteractionResumePayload not implemented")
}
func (UnimplementedControlPlaneServiceServer) GetRunGitHubRateLimitResumePayload(context.Context, *GetRunGitHubRateLimitResumePayloadRequest) (*GetRunGitHubRateLimitResumePayloadResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetRunGitHubRateLimitResumePayload not implemented")
}
func (UnimplementedControlPlaneServiceServer) LookupRunPullRequest(context.Context, *LookupRunPullRequestRequest) (*LookupRunPullRequestResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method LookupRunPullRequest not implemented")
}
func (UnimplementedControlPlaneServiceServer) InsertRunFlowEvent(context.Context, *InsertRunFlowEventRequest) (*InsertRunFlowEventResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method InsertRunFlowEvent not implemented")
}
func (UnimplementedControlPlaneServiceServer) UpsertRunStatusComment(context.Context, *UpsertRunStatusCommentRequest) (*UpsertRunStatusCommentResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpsertRunStatusComment not implemented")
}
func (UnimplementedControlPlaneServiceServer) GetCodexAuth(context.Context, *GetCodexAuthRequest) (*GetCodexAuthResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetCodexAuth not implemented")
}
func (UnimplementedControlPlaneServiceServer) UpsertCodexAuth(context.Context, *UpsertCodexAuthRequest) (*UpsertCodexAuthResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpsertCodexAuth not implemented")
}
func (UnimplementedControlPlaneServiceServer) DeleteRunNamespace(context.Context, *DeleteRunNamespaceRequest) (*DeleteRunNamespaceResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteRunNamespace not implemented")
}
func (UnimplementedControlPlaneServiceServer) mustEmbedUnimplementedControlPlaneServiceServer() {}
func (UnimplementedControlPlaneServiceServer) testEmbeddedByValue()                             {}

// UnsafeControlPlaneServiceServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to ControlPlaneServiceServer will
// result in compilation errors.
type UnsafeControlPlaneServiceServer interface {
	mustEmbedUnimplementedControlPlaneServiceServer()
}

func RegisterControlPlaneServiceServer(s grpc.ServiceRegistrar, srv ControlPlaneServiceServer) {
	// If the following call pancis, it indicates UnimplementedControlPlaneServiceServer was
	// embedded by pointer and is nil.  This will cause panics if an
	// unimplemented method is ever invoked, so we test this at initialization
	// time to prevent it from happening at runtime later due to I/O.
	if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
		t.testEmbeddedByValue()
	}
	s.RegisterService(&ControlPlaneService_ServiceDesc, srv)
}

func _ControlPlaneService_IngestGitHubWebhook_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IngestGitHubWebhookRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).IngestGitHubWebhook(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_IngestGitHubWebhook_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).IngestGitHubWebhook(ctx, req.(*IngestGitHubWebhookRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ResolveStaffByEmail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ResolveStaffByEmailRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ResolveStaffByEmail(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ResolveStaffByEmail_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ResolveStaffByEmail(ctx, req.(*ResolveStaffByEmailRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_AuthorizeOAuthUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(AuthorizeOAuthUserRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).AuthorizeOAuthUser(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_AuthorizeOAuthUser_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).AuthorizeOAuthUser(ctx, req.(*AuthorizeOAuthUserRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ListProjects_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListProjectsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ListProjects(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ListProjects_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ListProjects(ctx, req.(*ListProjectsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_UpsertProject_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpsertProjectRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).UpsertProject(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_UpsertProject_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).UpsertProject(ctx, req.(*UpsertProjectRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_GetProject_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetProjectRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).GetProject(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_GetProject_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).GetProject(ctx, req.(*GetProjectRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_DeleteProject_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteProjectRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).DeleteProject(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_DeleteProject_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).DeleteProject(ctx, req.(*DeleteProjectRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ListRuns_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListRunsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ListRuns(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ListRuns_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ListRuns(ctx, req.(*ListRunsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ListRunWaits_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListRunWaitsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ListRunWaits(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ListRunWaits_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ListRunWaits(ctx, req.(*ListRunWaitsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_GetRun_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetRunRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).GetRun(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_GetRun_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).GetRun(ctx, req.(*GetRunRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_CancelRun_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CancelRunRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).CancelRun(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_CancelRun_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).CancelRun(ctx, req.(*CancelRunRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_GetRunLogs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetRunLogsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).GetRunLogs(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_GetRunLogs_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).GetRunLogs(ctx, req.(*GetRunLogsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ListPendingApprovals_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListPendingApprovalsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ListPendingApprovals(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ListPendingApprovals_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ListPendingApprovals(ctx, req.(*ListPendingApprovalsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ResolveApprovalDecision_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ResolveApprovalDecisionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ResolveApprovalDecision(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ResolveApprovalDecision_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ResolveApprovalDecision(ctx, req.(*ResolveApprovalDecisionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ListRunEvents_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListRunEventsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ListRunEvents(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ListRunEvents_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ListRunEvents(ctx, req.(*ListRunEventsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ListRunLearningFeedback_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListRunLearningFeedbackRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ListRunLearningFeedback(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ListRunLearningFeedback_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ListRunLearningFeedback(ctx, req.(*ListRunLearningFeedbackRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ListSystemSettings_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListSystemSettingsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ListSystemSettings(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ListSystemSettings_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ListSystemSettings(ctx, req.(*ListSystemSettingsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_GetSystemSetting_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetSystemSettingRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).GetSystemSetting(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_GetSystemSetting_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).GetSystemSetting(ctx, req.(*GetSystemSettingRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_UpdateSystemSettingBoolean_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateSystemSettingBooleanRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).UpdateSystemSettingBoolean(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_UpdateSystemSettingBoolean_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).UpdateSystemSettingBoolean(ctx, req.(*UpdateSystemSettingBooleanRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ResetSystemSetting_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ResetSystemSettingRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ResetSystemSetting(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ResetSystemSetting_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ResetSystemSetting(ctx, req.(*ResetSystemSettingRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ListUsers_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListUsersRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ListUsers(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ListUsers_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ListUsers(ctx, req.(*ListUsersRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_CreateUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateUserRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).CreateUser(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_CreateUser_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).CreateUser(ctx, req.(*CreateUserRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_DeleteUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteUserRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).DeleteUser(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_DeleteUser_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).DeleteUser(ctx, req.(*DeleteUserRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ListProjectMembers_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListProjectMembersRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ListProjectMembers(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ListProjectMembers_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ListProjectMembers(ctx, req.(*ListProjectMembersRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_UpsertProjectMember_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpsertProjectMemberRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).UpsertProjectMember(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_UpsertProjectMember_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).UpsertProjectMember(ctx, req.(*UpsertProjectMemberRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_DeleteProjectMember_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteProjectMemberRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).DeleteProjectMember(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_DeleteProjectMember_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).DeleteProjectMember(ctx, req.(*DeleteProjectMemberRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_SetProjectMemberLearningModeOverride_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SetProjectMemberLearningModeOverrideRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).SetProjectMemberLearningModeOverride(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_SetProjectMemberLearningModeOverride_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).SetProjectMemberLearningModeOverride(ctx, req.(*SetProjectMemberLearningModeOverrideRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ListProjectRepositories_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListProjectRepositoriesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ListProjectRepositories(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ListProjectRepositories_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ListProjectRepositories(ctx, req.(*ListProjectRepositoriesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_UpsertProjectRepository_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpsertProjectRepositoryRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).UpsertProjectRepository(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_UpsertProjectRepository_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).UpsertProjectRepository(ctx, req.(*UpsertProjectRepositoryRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_DeleteProjectRepository_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteProjectRepositoryRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).DeleteProjectRepository(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_DeleteProjectRepository_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).DeleteProjectRepository(ctx, req.(*DeleteProjectRepositoryRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_UpsertRepositoryBotParams_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpsertRepositoryBotParamsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).UpsertRepositoryBotParams(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_UpsertRepositoryBotParams_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).UpsertRepositoryBotParams(ctx, req.(*UpsertRepositoryBotParamsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_RunRepositoryPreflight_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RunRepositoryPreflightRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).RunRepositoryPreflight(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_RunRepositoryPreflight_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).RunRepositoryPreflight(ctx, req.(*RunRepositoryPreflightRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_GetProjectGitHubTokens_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetProjectGitHubTokensRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).GetProjectGitHubTokens(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_GetProjectGitHubTokens_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).GetProjectGitHubTokens(ctx, req.(*GetProjectGitHubTokensRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_UpsertProjectGitHubTokens_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpsertProjectGitHubTokensRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).UpsertProjectGitHubTokens(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_UpsertProjectGitHubTokens_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).UpsertProjectGitHubTokens(ctx, req.(*UpsertProjectGitHubTokensRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_PreviewNextStepAction_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(NextStepActionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).PreviewNextStepAction(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_PreviewNextStepAction_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).PreviewNextStepAction(ctx, req.(*NextStepActionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ExecuteNextStepAction_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(NextStepActionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ExecuteNextStepAction(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ExecuteNextStepAction_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ExecuteNextStepAction(ctx, req.(*NextStepActionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ListDocsetGroups_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListDocsetGroupsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ListDocsetGroups(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ListDocsetGroups_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ListDocsetGroups(ctx, req.(*ListDocsetGroupsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ImportDocset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ImportDocsetRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ImportDocset(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ImportDocset_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ImportDocset(ctx, req.(*ImportDocsetRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_SyncDocset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SyncDocsetRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).SyncDocset(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_SyncDocset_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).SyncDocset(ctx, req.(*SyncDocsetRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_IssueRunMCPToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IssueRunMCPTokenRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).IssueRunMCPToken(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_IssueRunMCPToken_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).IssueRunMCPToken(ctx, req.(*IssueRunMCPTokenRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_PrepareRunEnvironment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PrepareRunEnvironmentRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).PrepareRunEnvironment(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_PrepareRunEnvironment_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).PrepareRunEnvironment(ctx, req.(*PrepareRunEnvironmentRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_EvaluateRuntimeReuse_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(EvaluateRuntimeReuseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).EvaluateRuntimeReuse(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_EvaluateRuntimeReuse_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).EvaluateRuntimeReuse(ctx, req.(*EvaluateRuntimeReuseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ClaimNextInteractionDispatch_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ClaimNextInteractionDispatchRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ClaimNextInteractionDispatch(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ClaimNextInteractionDispatch_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ClaimNextInteractionDispatch(ctx, req.(*ClaimNextInteractionDispatchRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_CompleteInteractionDispatch_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CompleteInteractionDispatchRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).CompleteInteractionDispatch(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_CompleteInteractionDispatch_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).CompleteInteractionDispatch(ctx, req.(*CompleteInteractionDispatchRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ExpireNextInteraction_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ExpireNextInteractionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ExpireNextInteraction(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ExpireNextInteraction_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ExpireNextInteraction(ctx, req.(*ExpireNextInteractionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ProcessNextGitHubRateLimitWait_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ProcessNextGitHubRateLimitWaitRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ProcessNextGitHubRateLimitWait(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ProcessNextGitHubRateLimitWait_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ProcessNextGitHubRateLimitWait(ctx, req.(*ProcessNextGitHubRateLimitWaitRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ReportGitHubRateLimitSignal_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ReportGitHubRateLimitSignalRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ReportGitHubRateLimitSignal(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ReportGitHubRateLimitSignal_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ReportGitHubRateLimitSignal(ctx, req.(*ReportGitHubRateLimitSignalRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ReportChangeGovernanceDraftSignal_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ReportChangeGovernanceDraftSignalRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ReportChangeGovernanceDraftSignal(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ReportChangeGovernanceDraftSignal_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ReportChangeGovernanceDraftSignal(ctx, req.(*ReportChangeGovernanceDraftSignalRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_PublishChangeGovernanceWaveMap_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PublishChangeGovernanceWaveMapRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).PublishChangeGovernanceWaveMap(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_PublishChangeGovernanceWaveMap_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).PublishChangeGovernanceWaveMap(ctx, req.(*PublishChangeGovernanceWaveMapRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_UpsertChangeGovernanceEvidenceSignal_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpsertChangeGovernanceEvidenceSignalRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).UpsertChangeGovernanceEvidenceSignal(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_UpsertChangeGovernanceEvidenceSignal_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).UpsertChangeGovernanceEvidenceSignal(ctx, req.(*UpsertChangeGovernanceEvidenceSignalRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_GetMissionControlWorkspace_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetMissionControlWorkspaceRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).GetMissionControlWorkspace(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_GetMissionControlWorkspace_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).GetMissionControlWorkspace(ctx, req.(*GetMissionControlWorkspaceRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_GetMissionControlNode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetMissionControlNodeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).GetMissionControlNode(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_GetMissionControlNode_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).GetMissionControlNode(ctx, req.(*GetMissionControlNodeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ListMissionControlNodeActivity_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListMissionControlNodeActivityRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ListMissionControlNodeActivity(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ListMissionControlNodeActivity_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ListMissionControlNodeActivity(ctx, req.(*ListMissionControlNodeActivityRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_PreviewMissionControlLaunch_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PreviewMissionControlLaunchRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).PreviewMissionControlLaunch(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_PreviewMissionControlLaunch_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).PreviewMissionControlLaunch(ctx, req.(*PreviewMissionControlLaunchRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_GetMissionControlSnapshot_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetMissionControlSnapshotRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).GetMissionControlSnapshot(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_GetMissionControlSnapshot_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).GetMissionControlSnapshot(ctx, req.(*GetMissionControlSnapshotRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_GetMissionControlEntity_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetMissionControlEntityRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).GetMissionControlEntity(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_GetMissionControlEntity_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).GetMissionControlEntity(ctx, req.(*GetMissionControlEntityRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ListMissionControlTimeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListMissionControlTimelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ListMissionControlTimeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ListMissionControlTimeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ListMissionControlTimeline(ctx, req.(*ListMissionControlTimelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ListMissionControlWarmupProjects_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListMissionControlWarmupProjectsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ListMissionControlWarmupProjects(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ListMissionControlWarmupProjects_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ListMissionControlWarmupProjects(ctx, req.(*ListMissionControlWarmupProjectsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_RunMissionControlWarmup_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RunMissionControlWarmupRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).RunMissionControlWarmup(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_RunMissionControlWarmup_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).RunMissionControlWarmup(ctx, req.(*RunMissionControlWarmupRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_SubmitMissionControlCommand_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SubmitMissionControlCommandRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).SubmitMissionControlCommand(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_SubmitMissionControlCommand_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).SubmitMissionControlCommand(ctx, req.(*SubmitMissionControlCommandRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_GetMissionControlCommand_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetMissionControlCommandRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).GetMissionControlCommand(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_GetMissionControlCommand_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).GetMissionControlCommand(ctx, req.(*GetMissionControlCommandRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ClaimMissionControlPendingCommands_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ClaimMissionControlPendingCommandsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ClaimMissionControlPendingCommands(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ClaimMissionControlPendingCommands_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ClaimMissionControlPendingCommands(ctx, req.(*ClaimMissionControlPendingCommandsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_QueueMissionControlCommand_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(QueueMissionControlCommandRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).QueueMissionControlCommand(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_QueueMissionControlCommand_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).QueueMissionControlCommand(ctx, req.(*QueueMissionControlCommandRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_MarkMissionControlCommandPendingSync_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(MarkMissionControlCommandPendingSyncRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).MarkMissionControlCommandPendingSync(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_MarkMissionControlCommandPendingSync_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).MarkMissionControlCommandPendingSync(ctx, req.(*MarkMissionControlCommandPendingSyncRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_MarkMissionControlCommandReconciled_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(MarkMissionControlCommandReconciledRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).MarkMissionControlCommandReconciled(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_MarkMissionControlCommandReconciled_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).MarkMissionControlCommandReconciled(ctx, req.(*MarkMissionControlCommandReconciledRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_MarkMissionControlCommandFailed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(MarkMissionControlCommandFailedRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).MarkMissionControlCommandFailed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_MarkMissionControlCommandFailed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).MarkMissionControlCommandFailed(ctx, req.(*MarkMissionControlCommandFailedRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_SubmitInteractionCallback_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SubmitInteractionCallbackRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).SubmitInteractionCallback(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_SubmitInteractionCallback_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).SubmitInteractionCallback(ctx, req.(*SubmitInteractionCallbackRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_SubmitAdapterInteractionCallback_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SubmitInteractionCallbackRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).SubmitAdapterInteractionCallback(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_SubmitAdapterInteractionCallback_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).SubmitAdapterInteractionCallback(ctx, req.(*SubmitInteractionCallbackRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ListRuntimeDeployTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListRuntimeDeployTasksRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ListRuntimeDeployTasks(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ListRuntimeDeployTasks_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ListRuntimeDeployTasks(ctx, req.(*ListRuntimeDeployTasksRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_GetRuntimeDeployTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetRuntimeDeployTaskRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).GetRuntimeDeployTask(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_GetRuntimeDeployTask_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).GetRuntimeDeployTask(ctx, req.(*GetRuntimeDeployTaskRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_CancelRuntimeDeployTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CancelRuntimeDeployTaskRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).CancelRuntimeDeployTask(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_CancelRuntimeDeployTask_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).CancelRuntimeDeployTask(ctx, req.(*CancelRuntimeDeployTaskRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_StopRuntimeDeployTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(StopRuntimeDeployTaskRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).StopRuntimeDeployTask(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_StopRuntimeDeployTask_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).StopRuntimeDeployTask(ctx, req.(*StopRuntimeDeployTaskRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_ListRuntimeErrors_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListRuntimeErrorsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).ListRuntimeErrors(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_ListRuntimeErrors_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).ListRuntimeErrors(ctx, req.(*ListRuntimeErrorsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_MarkRuntimeErrorViewed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(MarkRuntimeErrorViewedRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).MarkRuntimeErrorViewed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_MarkRuntimeErrorViewed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).MarkRuntimeErrorViewed(ctx, req.(*MarkRuntimeErrorViewedRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_UpsertAgentSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpsertAgentSessionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).UpsertAgentSession(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_UpsertAgentSession_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).UpsertAgentSession(ctx, req.(*UpsertAgentSessionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_GetLatestAgentSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetLatestAgentSessionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).GetLatestAgentSession(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_GetLatestAgentSession_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).GetLatestAgentSession(ctx, req.(*GetLatestAgentSessionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_GetRunInteractionResumePayload_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetRunInteractionResumePayloadRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).GetRunInteractionResumePayload(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_GetRunInteractionResumePayload_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).GetRunInteractionResumePayload(ctx, req.(*GetRunInteractionResumePayloadRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_GetRunGitHubRateLimitResumePayload_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetRunGitHubRateLimitResumePayloadRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).GetRunGitHubRateLimitResumePayload(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_GetRunGitHubRateLimitResumePayload_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).GetRunGitHubRateLimitResumePayload(ctx, req.(*GetRunGitHubRateLimitResumePayloadRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_LookupRunPullRequest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(LookupRunPullRequestRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).LookupRunPullRequest(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_LookupRunPullRequest_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).LookupRunPullRequest(ctx, req.(*LookupRunPullRequestRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_InsertRunFlowEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(InsertRunFlowEventRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).InsertRunFlowEvent(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_InsertRunFlowEvent_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).InsertRunFlowEvent(ctx, req.(*InsertRunFlowEventRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_UpsertRunStatusComment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpsertRunStatusCommentRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).UpsertRunStatusComment(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_UpsertRunStatusComment_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).UpsertRunStatusComment(ctx, req.(*UpsertRunStatusCommentRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_GetCodexAuth_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetCodexAuthRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).GetCodexAuth(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_GetCodexAuth_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).GetCodexAuth(ctx, req.(*GetCodexAuthRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_UpsertCodexAuth_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpsertCodexAuthRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).UpsertCodexAuth(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_UpsertCodexAuth_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).UpsertCodexAuth(ctx, req.(*UpsertCodexAuthRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ControlPlaneService_DeleteRunNamespace_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteRunNamespaceRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ControlPlaneServiceServer).DeleteRunNamespace(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ControlPlaneService_DeleteRunNamespace_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ControlPlaneServiceServer).DeleteRunNamespace(ctx, req.(*DeleteRunNamespaceRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// ControlPlaneService_ServiceDesc is the grpc.ServiceDesc for ControlPlaneService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var ControlPlaneService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kodex.controlplane.v1.ControlPlaneService",
	HandlerType: (*ControlPlaneServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IngestGitHubWebhook",
			Handler:    _ControlPlaneService_IngestGitHubWebhook_Handler,
		},
		{
			MethodName: "ResolveStaffByEmail",
			Handler:    _ControlPlaneService_ResolveStaffByEmail_Handler,
		},
		{
			MethodName: "AuthorizeOAuthUser",
			Handler:    _ControlPlaneService_AuthorizeOAuthUser_Handler,
		},
		{
			MethodName: "ListProjects",
			Handler:    _ControlPlaneService_ListProjects_Handler,
		},
		{
			MethodName: "UpsertProject",
			Handler:    _ControlPlaneService_UpsertProject_Handler,
		},
		{
			MethodName: "GetProject",
			Handler:    _ControlPlaneService_GetProject_Handler,
		},
		{
			MethodName: "DeleteProject",
			Handler:    _ControlPlaneService_DeleteProject_Handler,
		},
		{
			MethodName: "ListRuns",
			Handler:    _ControlPlaneService_ListRuns_Handler,
		},
		{
			MethodName: "ListRunWaits",
			Handler:    _ControlPlaneService_ListRunWaits_Handler,
		},
		{
			MethodName: "GetRun",
			Handler:    _ControlPlaneService_GetRun_Handler,
		},
		{
			MethodName: "CancelRun",
			Handler:    _ControlPlaneService_CancelRun_Handler,
		},
		{
			MethodName: "GetRunLogs",
			Handler:    _ControlPlaneService_GetRunLogs_Handler,
		},
		{
			MethodName: "ListPendingApprovals",
			Handler:    _ControlPlaneService_ListPendingApprovals_Handler,
		},
		{
			MethodName: "ResolveApprovalDecision",
			Handler:    _ControlPlaneService_ResolveApprovalDecision_Handler,
		},
		{
			MethodName: "ListRunEvents",
			Handler:    _ControlPlaneService_ListRunEvents_Handler,
		},
		{
			MethodName: "ListRunLearningFeedback",
			Handler:    _ControlPlaneService_ListRunLearningFeedback_Handler,
		},
		{
			MethodName: "ListSystemSettings",
			Handler:    _ControlPlaneService_ListSystemSettings_Handler,
		},
		{
			MethodName: "GetSystemSetting",
			Handler:    _ControlPlaneService_GetSystemSetting_Handler,
		},
		{
			MethodName: "UpdateSystemSettingBoolean",
			Handler:    _ControlPlaneService_UpdateSystemSettingBoolean_Handler,
		},
		{
			MethodName: "ResetSystemSetting",
			Handler:    _ControlPlaneService_ResetSystemSetting_Handler,
		},
		{
			MethodName: "ListUsers",
			Handler:    _ControlPlaneService_ListUsers_Handler,
		},
		{
			MethodName: "CreateUser",
			Handler:    _ControlPlaneService_CreateUser_Handler,
		},
		{
			MethodName: "DeleteUser",
			Handler:    _ControlPlaneService_DeleteUser_Handler,
		},
		{
			MethodName: "ListProjectMembers",
			Handler:    _ControlPlaneService_ListProjectMembers_Handler,
		},
		{
			MethodName: "UpsertProjectMember",
			Handler:    _ControlPlaneService_UpsertProjectMember_Handler,
		},
		{
			MethodName: "DeleteProjectMember",
			Handler:    _ControlPlaneService_DeleteProjectMember_Handler,
		},
		{
			MethodName: "SetProjectMemberLearningModeOverride",
			Handler:    _ControlPlaneService_SetProjectMemberLearningModeOverride_Handler,
		},
		{
			MethodName: "ListProjectRepositories",
			Handler:    _ControlPlaneService_ListProjectRepositories_Handler,
		},
		{
			MethodName: "UpsertProjectRepository",
			Handler:    _ControlPlaneService_UpsertProjectRepository_Handler,
		},
		{
			MethodName: "DeleteProjectRepository",
			Handler:    _ControlPlaneService_DeleteProjectRepository_Handler,
		},
		{
			MethodName: "UpsertRepositoryBotParams",
			Handler:    _ControlPlaneService_UpsertRepositoryBotParams_Handler,
		},
		{
			MethodName: "RunRepositoryPreflight",
			Handler:    _ControlPlaneService_RunRepositoryPreflight_Handler,
		},
		{
			MethodName: "GetProjectGitHubTokens",
			Handler:    _ControlPlaneService_GetProjectGitHubTokens_Handler,
		},
		{
			MethodName: "UpsertProjectGitHubTokens",
			Handler:    _ControlPlaneService_UpsertProjectGitHubTokens_Handler,
		},
		{
			MethodName: "PreviewNextStepAction",
			Handler:    _ControlPlaneService_PreviewNextStepAction_Handler,
		},
		{
			MethodName: "ExecuteNextStepAction",
			Handler:    _ControlPlaneService_ExecuteNextStepAction_Handler,
		},
		{
			MethodName: "ListDocsetGroups",
			Handler:    _ControlPlaneService_ListDocsetGroups_Handler,
		},
		{
			MethodName: "ImportDocset",
			Handler:    _ControlPlaneService_ImportDocset_Handler,
		},
		{
			MethodName: "SyncDocset",
			Handler:    _ControlPlaneService_SyncDocset_Handler,
		},
		{
			MethodName: "IssueRunMCPToken",
			Handler:    _ControlPlaneService_IssueRunMCPToken_Handler,
		},
		{
			MethodName: "PrepareRunEnvironment",
			Handler:    _ControlPlaneService_PrepareRunEnvironment_Handler,
		},
		{
			MethodName: "EvaluateRuntimeReuse",
			Handler:    _ControlPlaneService_EvaluateRuntimeReuse_Handler,
		},
		{
			MethodName: "ClaimNextInteractionDispatch",
			Handler:    _ControlPlaneService_ClaimNextInteractionDispatch_Handler,
		},
		{
			MethodName: "CompleteInteractionDispatch",
			Handler:    _ControlPlaneService_CompleteInteractionDispatch_Handler,
		},
		{
			MethodName: "ExpireNextInteraction",
			Handler:    _ControlPlaneService_ExpireNextInteraction_Handler,
		},
		{
			MethodName: "ProcessNextGitHubRateLimitWait",
			Handler:    _ControlPlaneService_ProcessNextGitHubRateLimitWait_Handler,
		},
		{
			MethodName: "ReportGitHubRateLimitSignal",
			Handler:    _ControlPlaneService_ReportGitHubRateLimitSignal_Handler,
		},
		{
			MethodName: "ReportChangeGovernanceDraftSignal",
			Handler:    _ControlPlaneService_ReportChangeGovernanceDraftSignal_Handler,
		},
		{
			MethodName: "PublishChangeGovernanceWaveMap",
			Handler:    _ControlPlaneService_PublishChangeGovernanceWaveMap_Handler,
		},
		{
			MethodName: "UpsertChangeGovernanceEvidenceSignal",
			Handler:    _ControlPlaneService_UpsertChangeGovernanceEvidenceSignal_Handler,
		},
		{
			MethodName: "GetMissionControlWorkspace",
			Handler:    _ControlPlaneService_GetMissionControlWorkspace_Handler,
		},
		{
			MethodName: "GetMissionControlNode",
			Handler:    _ControlPlaneService_GetMissionControlNode_Handler,
		},
		{
			MethodName: "ListMissionControlNodeActivity",
			Handler:    _ControlPlaneService_ListMissionControlNodeActivity_Handler,
		},
		{
			MethodName: "PreviewMissionControlLaunch",
			Handler:    _ControlPlaneService_PreviewMissionControlLaunch_Handler,
		},
		{
			MethodName: "GetMissionControlSnapshot",
			Handler:    _ControlPlaneService_GetMissionControlSnapshot_Handler,
		},
		{
			MethodName: "GetMissionControlEntity",
			Handler:    _ControlPlaneService_GetMissionControlEntity_Handler,
		},
		{
			MethodName: "ListMissionControlTimeline",
			Handler:    _ControlPlaneService_ListMissionControlTimeline_Handler,
		},
		{
			MethodName: "ListMissionControlWarmupProjects",
			Handler:    _ControlPlaneService_ListMissionControlWarmupProjects_Handler,
		},
		{
			MethodName: "RunMissionControlWarmup",
			Handler:    _ControlPlaneService_RunMissionControlWarmup_Handler,
		},
		{
			MethodName: "SubmitMissionControlCommand",
			Handler:    _ControlPlaneService_SubmitMissionControlCommand_Handler,
		},
		{
			MethodName: "GetMissionControlCommand",
			Handler:    _ControlPlaneService_GetMissionControlCommand_Handler,
		},
		{
			MethodName: "ClaimMissionControlPendingCommands",
			Handler:    _ControlPlaneService_ClaimMissionControlPendingCommands_Handler,
		},
		{
			MethodName: "QueueMissionControlCommand",
			Handler:    _ControlPlaneService_QueueMissionControlCommand_Handler,
		},
		{
			MethodName: "MarkMissionControlCommandPendingSync",
			Handler:    _ControlPlaneService_MarkMissionControlCommandPendingSync_Handler,
		},
		{
			MethodName: "MarkMissionControlCommandReconciled",
			Handler:    _ControlPlaneService_MarkMissionControlCommandReconciled_Handler,
		},
		{
			MethodName: "MarkMissionControlCommandFailed",
			Handler:    _ControlPlaneService_MarkMissionControlCommandFailed_Handler,
		},
		{
			MethodName: "SubmitInteractionCallback",
			Handler:    _ControlPlaneService_SubmitInteractionCallback_Handler,
		},
		{
			MethodName: "SubmitAdapterInteractionCallback",
			Handler:    _ControlPlaneService_SubmitAdapterInteractionCallback_Handler,
		},
		{
			MethodName: "ListRuntimeDeployTasks",
			Handler:    _ControlPlaneService_ListRuntimeDeployTasks_Handler,
		},
		{
			MethodName: "GetRuntimeDeployTask",
			Handler:    _ControlPlaneService_GetRuntimeDeployTask_Handler,
		},
		{
			MethodName: "CancelRuntimeDeployTask",
			Handler:    _ControlPlaneService_CancelRuntimeDeployTask_Handler,
		},
		{
			MethodName: "StopRuntimeDeployTask",
			Handler:    _ControlPlaneService_StopRuntimeDeployTask_Handler,
		},
		{
			MethodName: "ListRuntimeErrors",
			Handler:    _ControlPlaneService_ListRuntimeErrors_Handler,
		},
		{
			MethodName: "MarkRuntimeErrorViewed",
			Handler:    _ControlPlaneService_MarkRuntimeErrorViewed_Handler,
		},
		{
			MethodName: "UpsertAgentSession",
			Handler:    _ControlPlaneService_UpsertAgentSession_Handler,
		},
		{
			MethodName: "GetLatestAgentSession",
			Handler:    _ControlPlaneService_GetLatestAgentSession_Handler,
		},
		{
			MethodName: "GetRunInteractionResumePayload",
			Handler:    _ControlPlaneService_GetRunInteractionResumePayload_Handler,
		},
		{
			MethodName: "GetRunGitHubRateLimitResumePayload",
			Handler:    _ControlPlaneService_GetRunGitHubRateLimitResumePayload_Handler,
		},
		{
			MethodName: "LookupRunPullRequest",
			Handler:    _ControlPlaneService_LookupRunPullRequest_Handler,
		},
		{
			MethodName: "InsertRunFlowEvent",
			Handler:    _ControlPlaneService_InsertRunFlowEvent_Handler,
		},
		{
			MethodName: "UpsertRunStatusComment",
			Handler:    _ControlPlaneService_UpsertRunStatusComment_Handler,
		},
		{
			MethodName: "GetCodexAuth",
			Handler:    _ControlPlaneService_GetCodexAuth_Handler,
		},
		{
			MethodName: "UpsertCodexAuth",
			Handler:    _ControlPlaneService_UpsertCodexAuth_Handler,
		},
		{
			MethodName: "DeleteRunNamespace",
			Handler:    _ControlPlaneService_DeleteRunNamespace_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "kodex/controlplane/v1/controlplane.proto",
}
