// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.5.1
// - protoc             v3.21.12
// source: kodex/agents/v1/agent_manager.proto

package agentsv1

import (
	context "context"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
)

// 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 (
	AgentManagerService_CreateFlow_FullMethodName                     = "/kodex.agents.v1.AgentManagerService/CreateFlow"
	AgentManagerService_UpdateFlow_FullMethodName                     = "/kodex.agents.v1.AgentManagerService/UpdateFlow"
	AgentManagerService_CreateFlowVersion_FullMethodName              = "/kodex.agents.v1.AgentManagerService/CreateFlowVersion"
	AgentManagerService_ActivateFlowVersion_FullMethodName            = "/kodex.agents.v1.AgentManagerService/ActivateFlowVersion"
	AgentManagerService_GetFlow_FullMethodName                        = "/kodex.agents.v1.AgentManagerService/GetFlow"
	AgentManagerService_ListFlows_FullMethodName                      = "/kodex.agents.v1.AgentManagerService/ListFlows"
	AgentManagerService_CreateRoleProfile_FullMethodName              = "/kodex.agents.v1.AgentManagerService/CreateRoleProfile"
	AgentManagerService_UpdateRoleProfile_FullMethodName              = "/kodex.agents.v1.AgentManagerService/UpdateRoleProfile"
	AgentManagerService_GetRoleProfile_FullMethodName                 = "/kodex.agents.v1.AgentManagerService/GetRoleProfile"
	AgentManagerService_ListRoleProfiles_FullMethodName               = "/kodex.agents.v1.AgentManagerService/ListRoleProfiles"
	AgentManagerService_GetPromptTemplate_FullMethodName              = "/kodex.agents.v1.AgentManagerService/GetPromptTemplate"
	AgentManagerService_ListPromptTemplates_FullMethodName            = "/kodex.agents.v1.AgentManagerService/ListPromptTemplates"
	AgentManagerService_CreatePromptTemplateVersion_FullMethodName    = "/kodex.agents.v1.AgentManagerService/CreatePromptTemplateVersion"
	AgentManagerService_ActivatePromptTemplateVersion_FullMethodName  = "/kodex.agents.v1.AgentManagerService/ActivatePromptTemplateVersion"
	AgentManagerService_GetPromptTemplateVersion_FullMethodName       = "/kodex.agents.v1.AgentManagerService/GetPromptTemplateVersion"
	AgentManagerService_ListPromptTemplateVersions_FullMethodName     = "/kodex.agents.v1.AgentManagerService/ListPromptTemplateVersions"
	AgentManagerService_StartAgentSession_FullMethodName              = "/kodex.agents.v1.AgentManagerService/StartAgentSession"
	AgentManagerService_StartAgentRun_FullMethodName                  = "/kodex.agents.v1.AgentManagerService/StartAgentRun"
	AgentManagerService_RecordRunState_FullMethodName                 = "/kodex.agents.v1.AgentManagerService/RecordRunState"
	AgentManagerService_ReportAgentRunState_FullMethodName            = "/kodex.agents.v1.AgentManagerService/ReportAgentRunState"
	AgentManagerService_GetAgentRunRuntimeStatus_FullMethodName       = "/kodex.agents.v1.AgentManagerService/GetAgentRunRuntimeStatus"
	AgentManagerService_RecordSessionStateSnapshot_FullMethodName     = "/kodex.agents.v1.AgentManagerService/RecordSessionStateSnapshot"
	AgentManagerService_RequestAcceptance_FullMethodName              = "/kodex.agents.v1.AgentManagerService/RequestAcceptance"
	AgentManagerService_RecordAcceptanceResult_FullMethodName         = "/kodex.agents.v1.AgentManagerService/RecordAcceptanceResult"
	AgentManagerService_GetAcceptanceResult_FullMethodName            = "/kodex.agents.v1.AgentManagerService/GetAcceptanceResult"
	AgentManagerService_ListAcceptanceResults_FullMethodName          = "/kodex.agents.v1.AgentManagerService/ListAcceptanceResults"
	AgentManagerService_CreateFollowUpIntent_FullMethodName           = "/kodex.agents.v1.AgentManagerService/CreateFollowUpIntent"
	AgentManagerService_DispatchFollowUpIntent_FullMethodName         = "/kodex.agents.v1.AgentManagerService/DispatchFollowUpIntent"
	AgentManagerService_RecordAgentActivity_FullMethodName            = "/kodex.agents.v1.AgentManagerService/RecordAgentActivity"
	AgentManagerService_ListAgentActivities_FullMethodName            = "/kodex.agents.v1.AgentManagerService/ListAgentActivities"
	AgentManagerService_RequestHumanGate_FullMethodName               = "/kodex.agents.v1.AgentManagerService/RequestHumanGate"
	AgentManagerService_RecordHumanGateDecision_FullMethodName        = "/kodex.agents.v1.AgentManagerService/RecordHumanGateDecision"
	AgentManagerService_GetHumanGateRequest_FullMethodName            = "/kodex.agents.v1.AgentManagerService/GetHumanGateRequest"
	AgentManagerService_ListHumanGateRequests_FullMethodName          = "/kodex.agents.v1.AgentManagerService/ListHumanGateRequests"
	AgentManagerService_GetAgentSession_FullMethodName                = "/kodex.agents.v1.AgentManagerService/GetAgentSession"
	AgentManagerService_ListAgentSessions_FullMethodName              = "/kodex.agents.v1.AgentManagerService/ListAgentSessions"
	AgentManagerService_ListAgentRuns_FullMethodName                  = "/kodex.agents.v1.AgentManagerService/ListAgentRuns"
	AgentManagerService_ListAgentRunSummaries_FullMethodName          = "/kodex.agents.v1.AgentManagerService/ListAgentRunSummaries"
	AgentManagerService_CreateSelfDeployPlan_FullMethodName           = "/kodex.agents.v1.AgentManagerService/CreateSelfDeployPlan"
	AgentManagerService_CreateSelfDeployPlanFromSignal_FullMethodName = "/kodex.agents.v1.AgentManagerService/CreateSelfDeployPlanFromSignal"
	AgentManagerService_GetSelfDeployPlan_FullMethodName              = "/kodex.agents.v1.AgentManagerService/GetSelfDeployPlan"
	AgentManagerService_ListSelfDeployPlans_FullMethodName            = "/kodex.agents.v1.AgentManagerService/ListSelfDeployPlans"
)

// AgentManagerServiceClient is the client API for AgentManagerService 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.
//
// AgentManagerService is the stable v1 inter-service contract for the agent
// orchestration domain. It owns flows, stages, roles, prompt templates, agent
// sessions, agent runs, acceptance state, follow-up intents and human gate refs.
type AgentManagerServiceClient interface {
	// CreateFlow creates a flow in the requested scope.
	CreateFlow(ctx context.Context, in *CreateFlowRequest, opts ...grpc.CallOption) (*FlowResponse, error)
	// UpdateFlow changes safe flow metadata without mutating immutable versions.
	UpdateFlow(ctx context.Context, in *UpdateFlowRequest, opts ...grpc.CallOption) (*FlowResponse, error)
	// CreateFlowVersion creates an immutable flow definition version.
	CreateFlowVersion(ctx context.Context, in *CreateFlowVersionRequest, opts ...grpc.CallOption) (*FlowVersionResponse, error)
	// ActivateFlowVersion activates one version for future sessions and runs.
	ActivateFlowVersion(ctx context.Context, in *ActivateFlowVersionRequest, opts ...grpc.CallOption) (*FlowVersionResponse, error)
	// GetFlow returns authoritative flow state.
	GetFlow(ctx context.Context, in *GetFlowRequest, opts ...grpc.CallOption) (*FlowResponse, error)
	// ListFlows returns flows by scope and status.
	ListFlows(ctx context.Context, in *ListFlowsRequest, opts ...grpc.CallOption) (*ListFlowsResponse, error)
	// CreateRoleProfile creates an agent role profile.
	CreateRoleProfile(ctx context.Context, in *CreateRoleProfileRequest, opts ...grpc.CallOption) (*RoleProfileResponse, error)
	// UpdateRoleProfile changes safe role metadata and policy refs.
	UpdateRoleProfile(ctx context.Context, in *UpdateRoleProfileRequest, opts ...grpc.CallOption) (*RoleProfileResponse, error)
	// GetRoleProfile returns authoritative role state.
	GetRoleProfile(ctx context.Context, in *GetRoleProfileRequest, opts ...grpc.CallOption) (*RoleProfileResponse, error)
	// ListRoleProfiles returns role profiles by scope, kind and status.
	ListRoleProfiles(ctx context.Context, in *ListRoleProfilesRequest, opts ...grpc.CallOption) (*ListRoleProfilesResponse, error)
	// GetPromptTemplate returns prompt template metadata without template body.
	GetPromptTemplate(ctx context.Context, in *GetPromptTemplateRequest, opts ...grpc.CallOption) (*PromptTemplateResponse, error)
	// ListPromptTemplates returns prompt templates by role and kind.
	ListPromptTemplates(ctx context.Context, in *ListPromptTemplatesRequest, opts ...grpc.CallOption) (*ListPromptTemplatesResponse, error)
	// CreatePromptTemplateVersion creates a prompt template version for a role.
	CreatePromptTemplateVersion(ctx context.Context, in *CreatePromptTemplateVersionRequest, opts ...grpc.CallOption) (*PromptTemplateVersionResponse, error)
	// ActivatePromptTemplateVersion activates one prompt version for future runs.
	ActivatePromptTemplateVersion(ctx context.Context, in *ActivatePromptTemplateVersionRequest, opts ...grpc.CallOption) (*PromptTemplateVersionResponse, error)
	// GetPromptTemplateVersion returns one prompt template version.
	GetPromptTemplateVersion(ctx context.Context, in *GetPromptTemplateVersionRequest, opts ...grpc.CallOption) (*PromptTemplateVersionResponse, error)
	// ListPromptTemplateVersions returns prompt versions by role and kind.
	ListPromptTemplateVersions(ctx context.Context, in *ListPromptTemplateVersionsRequest, opts ...grpc.CallOption) (*ListPromptTemplateVersionsResponse, error)
	// StartAgentSession creates or continues an agent session.
	StartAgentSession(ctx context.Context, in *StartAgentSessionRequest, opts ...grpc.CallOption) (*AgentSessionResponse, error)
	// StartAgentRun creates a role run and records immutable context refs.
	StartAgentRun(ctx context.Context, in *StartAgentRunRequest, opts ...grpc.CallOption) (*AgentRunResponse, error)
	// RecordRunState records a generic run lifecycle transition from runtime, MCP or hook ingress.
	RecordRunState(ctx context.Context, in *RecordRunStateRequest, opts ...grpc.CallOption) (*AgentRunResponse, error)
	// ReportAgentRunState records a bounded state report from an agent-runner bound to one runtime job.
	ReportAgentRunState(ctx context.Context, in *ReportAgentRunStateRequest, opts ...grpc.CallOption) (*AgentRunResponse, error)
	// GetAgentRunRuntimeStatus возвращает безопасное состояние runtime для одного run.
	GetAgentRunRuntimeStatus(ctx context.Context, in *GetAgentRunRuntimeStatusRequest, opts ...grpc.CallOption) (*AgentRunRuntimeStatusResponse, error)
	// RecordSessionStateSnapshot records metadata for a Codex session state object.
	RecordSessionStateSnapshot(ctx context.Context, in *RecordSessionStateSnapshotRequest, opts ...grpc.CallOption) (*AgentSessionStateSnapshotResponse, error)
	// RequestAcceptance requests acceptance checks for a session, run and stage.
	RequestAcceptance(ctx context.Context, in *RequestAcceptanceRequest, opts ...grpc.CallOption) (*AcceptanceResultResponse, error)
	// RecordAcceptanceResult records acceptance state after machine or role checks.
	RecordAcceptanceResult(ctx context.Context, in *RecordAcceptanceResultRequest, opts ...grpc.CallOption) (*AcceptanceResultResponse, error)
	// GetAcceptanceResult returns one acceptance result.
	GetAcceptanceResult(ctx context.Context, in *GetAcceptanceResultRequest, opts ...grpc.CallOption) (*AcceptanceResultResponse, error)
	// ListAcceptanceResults returns acceptance results by session, run, stage or status.
	ListAcceptanceResults(ctx context.Context, in *ListAcceptanceResultsRequest, opts ...grpc.CallOption) (*ListAcceptanceResultsResponse, error)
	// CreateFollowUpIntent records an intent for the next provider-native work item.
	CreateFollowUpIntent(ctx context.Context, in *CreateFollowUpIntentRequest, opts ...grpc.CallOption) (*FollowUpIntentResponse, error)
	// DispatchFollowUpIntent sends a requested follow-up intent to provider-hub as a typed provider command.
	DispatchFollowUpIntent(ctx context.Context, in *DispatchFollowUpIntentRequest, opts ...grpc.CallOption) (*FollowUpIntentResponse, error)
	// RecordAgentActivity records one safe timeline entry for a session or run.
	RecordAgentActivity(ctx context.Context, in *RecordAgentActivityRequest, opts ...grpc.CallOption) (*AgentActivityResponse, error)
	// ListAgentActivities returns safe timeline entries by session or run.
	ListAgentActivities(ctx context.Context, in *ListAgentActivitiesRequest, opts ...grpc.CallOption) (*ListAgentActivitiesResponse, error)
	// RequestHumanGate records an owner-decision wait and safe interaction/governance refs.
	RequestHumanGate(ctx context.Context, in *RequestHumanGateRequest, opts ...grpc.CallOption) (*HumanGateRequestResponse, error)
	// RecordHumanGateDecision records a normalized owner decision outcome.
	RecordHumanGateDecision(ctx context.Context, in *RecordHumanGateDecisionRequest, opts ...grpc.CallOption) (*HumanGateRequestResponse, error)
	// GetHumanGateRequest returns one owner-decision wait.
	GetHumanGateRequest(ctx context.Context, in *GetHumanGateRequestRequest, opts ...grpc.CallOption) (*HumanGateRequestResponse, error)
	// ListHumanGateRequests returns owner-decision waits by session, run, stage or state.
	ListHumanGateRequests(ctx context.Context, in *ListHumanGateRequestsRequest, opts ...grpc.CallOption) (*ListHumanGateRequestsResponse, error)
	// GetAgentSession returns authoritative session state.
	GetAgentSession(ctx context.Context, in *GetAgentSessionRequest, opts ...grpc.CallOption) (*AgentSessionResponse, error)
	// ListAgentSessions returns safe session summaries for operator read surfaces.
	ListAgentSessions(ctx context.Context, in *ListAgentSessionsRequest, opts ...grpc.CallOption) (*ListAgentSessionsResponse, error)
	// ListAgentRuns returns agent runs by session, role, status or provider target.
	ListAgentRuns(ctx context.Context, in *ListAgentRunsRequest, opts ...grpc.CallOption) (*ListAgentRunsResponse, error)
	// ListAgentRunSummaries returns safe run summaries for operator read surfaces.
	ListAgentRunSummaries(ctx context.Context, in *ListAgentRunSummariesRequest, opts ...grpc.CallOption) (*ListAgentRunSummariesResponse, error)
	// CreateSelfDeployPlan records a safe pending plan for self-deploy orchestration.
	CreateSelfDeployPlan(ctx context.Context, in *CreateSelfDeployPlanRequest, opts ...grpc.CallOption) (*SelfDeployPlanResponse, error)
	// CreateSelfDeployPlanFromSignal records a pending plan from a safe provider/project signal.
	CreateSelfDeployPlanFromSignal(ctx context.Context, in *CreateSelfDeployPlanFromSignalRequest, opts ...grpc.CallOption) (*SelfDeployPlanResponse, error)
	// GetSelfDeployPlan returns one safe self-deploy plan.
	GetSelfDeployPlan(ctx context.Context, in *GetSelfDeployPlanRequest, opts ...grpc.CallOption) (*SelfDeployPlanResponse, error)
	// ListSelfDeployPlans returns safe self-deploy plans by project, repository, signal or status.
	ListSelfDeployPlans(ctx context.Context, in *ListSelfDeployPlansRequest, opts ...grpc.CallOption) (*ListSelfDeployPlansResponse, error)
}

type agentManagerServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewAgentManagerServiceClient(cc grpc.ClientConnInterface) AgentManagerServiceClient {
	return &agentManagerServiceClient{cc}
}

func (c *agentManagerServiceClient) CreateFlow(ctx context.Context, in *CreateFlowRequest, opts ...grpc.CallOption) (*FlowResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(FlowResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_CreateFlow_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) UpdateFlow(ctx context.Context, in *UpdateFlowRequest, opts ...grpc.CallOption) (*FlowResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(FlowResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_UpdateFlow_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) CreateFlowVersion(ctx context.Context, in *CreateFlowVersionRequest, opts ...grpc.CallOption) (*FlowVersionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(FlowVersionResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_CreateFlowVersion_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) ActivateFlowVersion(ctx context.Context, in *ActivateFlowVersionRequest, opts ...grpc.CallOption) (*FlowVersionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(FlowVersionResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_ActivateFlowVersion_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) GetFlow(ctx context.Context, in *GetFlowRequest, opts ...grpc.CallOption) (*FlowResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(FlowResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_GetFlow_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) ListFlows(ctx context.Context, in *ListFlowsRequest, opts ...grpc.CallOption) (*ListFlowsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListFlowsResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_ListFlows_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) CreateRoleProfile(ctx context.Context, in *CreateRoleProfileRequest, opts ...grpc.CallOption) (*RoleProfileResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(RoleProfileResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_CreateRoleProfile_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) UpdateRoleProfile(ctx context.Context, in *UpdateRoleProfileRequest, opts ...grpc.CallOption) (*RoleProfileResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(RoleProfileResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_UpdateRoleProfile_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) GetRoleProfile(ctx context.Context, in *GetRoleProfileRequest, opts ...grpc.CallOption) (*RoleProfileResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(RoleProfileResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_GetRoleProfile_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) ListRoleProfiles(ctx context.Context, in *ListRoleProfilesRequest, opts ...grpc.CallOption) (*ListRoleProfilesResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListRoleProfilesResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_ListRoleProfiles_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) GetPromptTemplate(ctx context.Context, in *GetPromptTemplateRequest, opts ...grpc.CallOption) (*PromptTemplateResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(PromptTemplateResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_GetPromptTemplate_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) ListPromptTemplates(ctx context.Context, in *ListPromptTemplatesRequest, opts ...grpc.CallOption) (*ListPromptTemplatesResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListPromptTemplatesResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_ListPromptTemplates_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) CreatePromptTemplateVersion(ctx context.Context, in *CreatePromptTemplateVersionRequest, opts ...grpc.CallOption) (*PromptTemplateVersionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(PromptTemplateVersionResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_CreatePromptTemplateVersion_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) ActivatePromptTemplateVersion(ctx context.Context, in *ActivatePromptTemplateVersionRequest, opts ...grpc.CallOption) (*PromptTemplateVersionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(PromptTemplateVersionResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_ActivatePromptTemplateVersion_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) GetPromptTemplateVersion(ctx context.Context, in *GetPromptTemplateVersionRequest, opts ...grpc.CallOption) (*PromptTemplateVersionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(PromptTemplateVersionResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_GetPromptTemplateVersion_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) ListPromptTemplateVersions(ctx context.Context, in *ListPromptTemplateVersionsRequest, opts ...grpc.CallOption) (*ListPromptTemplateVersionsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListPromptTemplateVersionsResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_ListPromptTemplateVersions_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) StartAgentSession(ctx context.Context, in *StartAgentSessionRequest, opts ...grpc.CallOption) (*AgentSessionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(AgentSessionResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_StartAgentSession_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) StartAgentRun(ctx context.Context, in *StartAgentRunRequest, opts ...grpc.CallOption) (*AgentRunResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(AgentRunResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_StartAgentRun_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) RecordRunState(ctx context.Context, in *RecordRunStateRequest, opts ...grpc.CallOption) (*AgentRunResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(AgentRunResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_RecordRunState_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) ReportAgentRunState(ctx context.Context, in *ReportAgentRunStateRequest, opts ...grpc.CallOption) (*AgentRunResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(AgentRunResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_ReportAgentRunState_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) GetAgentRunRuntimeStatus(ctx context.Context, in *GetAgentRunRuntimeStatusRequest, opts ...grpc.CallOption) (*AgentRunRuntimeStatusResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(AgentRunRuntimeStatusResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_GetAgentRunRuntimeStatus_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) RecordSessionStateSnapshot(ctx context.Context, in *RecordSessionStateSnapshotRequest, opts ...grpc.CallOption) (*AgentSessionStateSnapshotResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(AgentSessionStateSnapshotResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_RecordSessionStateSnapshot_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) RequestAcceptance(ctx context.Context, in *RequestAcceptanceRequest, opts ...grpc.CallOption) (*AcceptanceResultResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(AcceptanceResultResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_RequestAcceptance_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) RecordAcceptanceResult(ctx context.Context, in *RecordAcceptanceResultRequest, opts ...grpc.CallOption) (*AcceptanceResultResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(AcceptanceResultResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_RecordAcceptanceResult_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) GetAcceptanceResult(ctx context.Context, in *GetAcceptanceResultRequest, opts ...grpc.CallOption) (*AcceptanceResultResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(AcceptanceResultResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_GetAcceptanceResult_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) ListAcceptanceResults(ctx context.Context, in *ListAcceptanceResultsRequest, opts ...grpc.CallOption) (*ListAcceptanceResultsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListAcceptanceResultsResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_ListAcceptanceResults_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) CreateFollowUpIntent(ctx context.Context, in *CreateFollowUpIntentRequest, opts ...grpc.CallOption) (*FollowUpIntentResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(FollowUpIntentResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_CreateFollowUpIntent_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) DispatchFollowUpIntent(ctx context.Context, in *DispatchFollowUpIntentRequest, opts ...grpc.CallOption) (*FollowUpIntentResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(FollowUpIntentResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_DispatchFollowUpIntent_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) RecordAgentActivity(ctx context.Context, in *RecordAgentActivityRequest, opts ...grpc.CallOption) (*AgentActivityResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(AgentActivityResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_RecordAgentActivity_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) ListAgentActivities(ctx context.Context, in *ListAgentActivitiesRequest, opts ...grpc.CallOption) (*ListAgentActivitiesResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListAgentActivitiesResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_ListAgentActivities_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) RequestHumanGate(ctx context.Context, in *RequestHumanGateRequest, opts ...grpc.CallOption) (*HumanGateRequestResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(HumanGateRequestResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_RequestHumanGate_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) RecordHumanGateDecision(ctx context.Context, in *RecordHumanGateDecisionRequest, opts ...grpc.CallOption) (*HumanGateRequestResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(HumanGateRequestResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_RecordHumanGateDecision_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) GetHumanGateRequest(ctx context.Context, in *GetHumanGateRequestRequest, opts ...grpc.CallOption) (*HumanGateRequestResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(HumanGateRequestResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_GetHumanGateRequest_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) ListHumanGateRequests(ctx context.Context, in *ListHumanGateRequestsRequest, opts ...grpc.CallOption) (*ListHumanGateRequestsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListHumanGateRequestsResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_ListHumanGateRequests_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) GetAgentSession(ctx context.Context, in *GetAgentSessionRequest, opts ...grpc.CallOption) (*AgentSessionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(AgentSessionResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_GetAgentSession_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) ListAgentSessions(ctx context.Context, in *ListAgentSessionsRequest, opts ...grpc.CallOption) (*ListAgentSessionsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListAgentSessionsResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_ListAgentSessions_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) ListAgentRuns(ctx context.Context, in *ListAgentRunsRequest, opts ...grpc.CallOption) (*ListAgentRunsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListAgentRunsResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_ListAgentRuns_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) ListAgentRunSummaries(ctx context.Context, in *ListAgentRunSummariesRequest, opts ...grpc.CallOption) (*ListAgentRunSummariesResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListAgentRunSummariesResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_ListAgentRunSummaries_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) CreateSelfDeployPlan(ctx context.Context, in *CreateSelfDeployPlanRequest, opts ...grpc.CallOption) (*SelfDeployPlanResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SelfDeployPlanResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_CreateSelfDeployPlan_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) CreateSelfDeployPlanFromSignal(ctx context.Context, in *CreateSelfDeployPlanFromSignalRequest, opts ...grpc.CallOption) (*SelfDeployPlanResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SelfDeployPlanResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_CreateSelfDeployPlanFromSignal_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) GetSelfDeployPlan(ctx context.Context, in *GetSelfDeployPlanRequest, opts ...grpc.CallOption) (*SelfDeployPlanResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SelfDeployPlanResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_GetSelfDeployPlan_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentManagerServiceClient) ListSelfDeployPlans(ctx context.Context, in *ListSelfDeployPlansRequest, opts ...grpc.CallOption) (*ListSelfDeployPlansResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListSelfDeployPlansResponse)
	err := c.cc.Invoke(ctx, AgentManagerService_ListSelfDeployPlans_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// AgentManagerServiceServer is the server API for AgentManagerService service.
// All implementations must embed UnimplementedAgentManagerServiceServer
// for forward compatibility.
//
// AgentManagerService is the stable v1 inter-service contract for the agent
// orchestration domain. It owns flows, stages, roles, prompt templates, agent
// sessions, agent runs, acceptance state, follow-up intents and human gate refs.
type AgentManagerServiceServer interface {
	// CreateFlow creates a flow in the requested scope.
	CreateFlow(context.Context, *CreateFlowRequest) (*FlowResponse, error)
	// UpdateFlow changes safe flow metadata without mutating immutable versions.
	UpdateFlow(context.Context, *UpdateFlowRequest) (*FlowResponse, error)
	// CreateFlowVersion creates an immutable flow definition version.
	CreateFlowVersion(context.Context, *CreateFlowVersionRequest) (*FlowVersionResponse, error)
	// ActivateFlowVersion activates one version for future sessions and runs.
	ActivateFlowVersion(context.Context, *ActivateFlowVersionRequest) (*FlowVersionResponse, error)
	// GetFlow returns authoritative flow state.
	GetFlow(context.Context, *GetFlowRequest) (*FlowResponse, error)
	// ListFlows returns flows by scope and status.
	ListFlows(context.Context, *ListFlowsRequest) (*ListFlowsResponse, error)
	// CreateRoleProfile creates an agent role profile.
	CreateRoleProfile(context.Context, *CreateRoleProfileRequest) (*RoleProfileResponse, error)
	// UpdateRoleProfile changes safe role metadata and policy refs.
	UpdateRoleProfile(context.Context, *UpdateRoleProfileRequest) (*RoleProfileResponse, error)
	// GetRoleProfile returns authoritative role state.
	GetRoleProfile(context.Context, *GetRoleProfileRequest) (*RoleProfileResponse, error)
	// ListRoleProfiles returns role profiles by scope, kind and status.
	ListRoleProfiles(context.Context, *ListRoleProfilesRequest) (*ListRoleProfilesResponse, error)
	// GetPromptTemplate returns prompt template metadata without template body.
	GetPromptTemplate(context.Context, *GetPromptTemplateRequest) (*PromptTemplateResponse, error)
	// ListPromptTemplates returns prompt templates by role and kind.
	ListPromptTemplates(context.Context, *ListPromptTemplatesRequest) (*ListPromptTemplatesResponse, error)
	// CreatePromptTemplateVersion creates a prompt template version for a role.
	CreatePromptTemplateVersion(context.Context, *CreatePromptTemplateVersionRequest) (*PromptTemplateVersionResponse, error)
	// ActivatePromptTemplateVersion activates one prompt version for future runs.
	ActivatePromptTemplateVersion(context.Context, *ActivatePromptTemplateVersionRequest) (*PromptTemplateVersionResponse, error)
	// GetPromptTemplateVersion returns one prompt template version.
	GetPromptTemplateVersion(context.Context, *GetPromptTemplateVersionRequest) (*PromptTemplateVersionResponse, error)
	// ListPromptTemplateVersions returns prompt versions by role and kind.
	ListPromptTemplateVersions(context.Context, *ListPromptTemplateVersionsRequest) (*ListPromptTemplateVersionsResponse, error)
	// StartAgentSession creates or continues an agent session.
	StartAgentSession(context.Context, *StartAgentSessionRequest) (*AgentSessionResponse, error)
	// StartAgentRun creates a role run and records immutable context refs.
	StartAgentRun(context.Context, *StartAgentRunRequest) (*AgentRunResponse, error)
	// RecordRunState records a generic run lifecycle transition from runtime, MCP or hook ingress.
	RecordRunState(context.Context, *RecordRunStateRequest) (*AgentRunResponse, error)
	// ReportAgentRunState records a bounded state report from an agent-runner bound to one runtime job.
	ReportAgentRunState(context.Context, *ReportAgentRunStateRequest) (*AgentRunResponse, error)
	// GetAgentRunRuntimeStatus возвращает безопасное состояние runtime для одного run.
	GetAgentRunRuntimeStatus(context.Context, *GetAgentRunRuntimeStatusRequest) (*AgentRunRuntimeStatusResponse, error)
	// RecordSessionStateSnapshot records metadata for a Codex session state object.
	RecordSessionStateSnapshot(context.Context, *RecordSessionStateSnapshotRequest) (*AgentSessionStateSnapshotResponse, error)
	// RequestAcceptance requests acceptance checks for a session, run and stage.
	RequestAcceptance(context.Context, *RequestAcceptanceRequest) (*AcceptanceResultResponse, error)
	// RecordAcceptanceResult records acceptance state after machine or role checks.
	RecordAcceptanceResult(context.Context, *RecordAcceptanceResultRequest) (*AcceptanceResultResponse, error)
	// GetAcceptanceResult returns one acceptance result.
	GetAcceptanceResult(context.Context, *GetAcceptanceResultRequest) (*AcceptanceResultResponse, error)
	// ListAcceptanceResults returns acceptance results by session, run, stage or status.
	ListAcceptanceResults(context.Context, *ListAcceptanceResultsRequest) (*ListAcceptanceResultsResponse, error)
	// CreateFollowUpIntent records an intent for the next provider-native work item.
	CreateFollowUpIntent(context.Context, *CreateFollowUpIntentRequest) (*FollowUpIntentResponse, error)
	// DispatchFollowUpIntent sends a requested follow-up intent to provider-hub as a typed provider command.
	DispatchFollowUpIntent(context.Context, *DispatchFollowUpIntentRequest) (*FollowUpIntentResponse, error)
	// RecordAgentActivity records one safe timeline entry for a session or run.
	RecordAgentActivity(context.Context, *RecordAgentActivityRequest) (*AgentActivityResponse, error)
	// ListAgentActivities returns safe timeline entries by session or run.
	ListAgentActivities(context.Context, *ListAgentActivitiesRequest) (*ListAgentActivitiesResponse, error)
	// RequestHumanGate records an owner-decision wait and safe interaction/governance refs.
	RequestHumanGate(context.Context, *RequestHumanGateRequest) (*HumanGateRequestResponse, error)
	// RecordHumanGateDecision records a normalized owner decision outcome.
	RecordHumanGateDecision(context.Context, *RecordHumanGateDecisionRequest) (*HumanGateRequestResponse, error)
	// GetHumanGateRequest returns one owner-decision wait.
	GetHumanGateRequest(context.Context, *GetHumanGateRequestRequest) (*HumanGateRequestResponse, error)
	// ListHumanGateRequests returns owner-decision waits by session, run, stage or state.
	ListHumanGateRequests(context.Context, *ListHumanGateRequestsRequest) (*ListHumanGateRequestsResponse, error)
	// GetAgentSession returns authoritative session state.
	GetAgentSession(context.Context, *GetAgentSessionRequest) (*AgentSessionResponse, error)
	// ListAgentSessions returns safe session summaries for operator read surfaces.
	ListAgentSessions(context.Context, *ListAgentSessionsRequest) (*ListAgentSessionsResponse, error)
	// ListAgentRuns returns agent runs by session, role, status or provider target.
	ListAgentRuns(context.Context, *ListAgentRunsRequest) (*ListAgentRunsResponse, error)
	// ListAgentRunSummaries returns safe run summaries for operator read surfaces.
	ListAgentRunSummaries(context.Context, *ListAgentRunSummariesRequest) (*ListAgentRunSummariesResponse, error)
	// CreateSelfDeployPlan records a safe pending plan for self-deploy orchestration.
	CreateSelfDeployPlan(context.Context, *CreateSelfDeployPlanRequest) (*SelfDeployPlanResponse, error)
	// CreateSelfDeployPlanFromSignal records a pending plan from a safe provider/project signal.
	CreateSelfDeployPlanFromSignal(context.Context, *CreateSelfDeployPlanFromSignalRequest) (*SelfDeployPlanResponse, error)
	// GetSelfDeployPlan returns one safe self-deploy plan.
	GetSelfDeployPlan(context.Context, *GetSelfDeployPlanRequest) (*SelfDeployPlanResponse, error)
	// ListSelfDeployPlans returns safe self-deploy plans by project, repository, signal or status.
	ListSelfDeployPlans(context.Context, *ListSelfDeployPlansRequest) (*ListSelfDeployPlansResponse, error)
	mustEmbedUnimplementedAgentManagerServiceServer()
}

// UnimplementedAgentManagerServiceServer 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 UnimplementedAgentManagerServiceServer struct{}

func (UnimplementedAgentManagerServiceServer) CreateFlow(context.Context, *CreateFlowRequest) (*FlowResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateFlow not implemented")
}
func (UnimplementedAgentManagerServiceServer) UpdateFlow(context.Context, *UpdateFlowRequest) (*FlowResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateFlow not implemented")
}
func (UnimplementedAgentManagerServiceServer) CreateFlowVersion(context.Context, *CreateFlowVersionRequest) (*FlowVersionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateFlowVersion not implemented")
}
func (UnimplementedAgentManagerServiceServer) ActivateFlowVersion(context.Context, *ActivateFlowVersionRequest) (*FlowVersionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ActivateFlowVersion not implemented")
}
func (UnimplementedAgentManagerServiceServer) GetFlow(context.Context, *GetFlowRequest) (*FlowResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetFlow not implemented")
}
func (UnimplementedAgentManagerServiceServer) ListFlows(context.Context, *ListFlowsRequest) (*ListFlowsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListFlows not implemented")
}
func (UnimplementedAgentManagerServiceServer) CreateRoleProfile(context.Context, *CreateRoleProfileRequest) (*RoleProfileResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateRoleProfile not implemented")
}
func (UnimplementedAgentManagerServiceServer) UpdateRoleProfile(context.Context, *UpdateRoleProfileRequest) (*RoleProfileResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateRoleProfile not implemented")
}
func (UnimplementedAgentManagerServiceServer) GetRoleProfile(context.Context, *GetRoleProfileRequest) (*RoleProfileResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetRoleProfile not implemented")
}
func (UnimplementedAgentManagerServiceServer) ListRoleProfiles(context.Context, *ListRoleProfilesRequest) (*ListRoleProfilesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListRoleProfiles not implemented")
}
func (UnimplementedAgentManagerServiceServer) GetPromptTemplate(context.Context, *GetPromptTemplateRequest) (*PromptTemplateResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetPromptTemplate not implemented")
}
func (UnimplementedAgentManagerServiceServer) ListPromptTemplates(context.Context, *ListPromptTemplatesRequest) (*ListPromptTemplatesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListPromptTemplates not implemented")
}
func (UnimplementedAgentManagerServiceServer) CreatePromptTemplateVersion(context.Context, *CreatePromptTemplateVersionRequest) (*PromptTemplateVersionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreatePromptTemplateVersion not implemented")
}
func (UnimplementedAgentManagerServiceServer) ActivatePromptTemplateVersion(context.Context, *ActivatePromptTemplateVersionRequest) (*PromptTemplateVersionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ActivatePromptTemplateVersion not implemented")
}
func (UnimplementedAgentManagerServiceServer) GetPromptTemplateVersion(context.Context, *GetPromptTemplateVersionRequest) (*PromptTemplateVersionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetPromptTemplateVersion not implemented")
}
func (UnimplementedAgentManagerServiceServer) ListPromptTemplateVersions(context.Context, *ListPromptTemplateVersionsRequest) (*ListPromptTemplateVersionsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListPromptTemplateVersions not implemented")
}
func (UnimplementedAgentManagerServiceServer) StartAgentSession(context.Context, *StartAgentSessionRequest) (*AgentSessionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method StartAgentSession not implemented")
}
func (UnimplementedAgentManagerServiceServer) StartAgentRun(context.Context, *StartAgentRunRequest) (*AgentRunResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method StartAgentRun not implemented")
}
func (UnimplementedAgentManagerServiceServer) RecordRunState(context.Context, *RecordRunStateRequest) (*AgentRunResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RecordRunState not implemented")
}
func (UnimplementedAgentManagerServiceServer) ReportAgentRunState(context.Context, *ReportAgentRunStateRequest) (*AgentRunResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ReportAgentRunState not implemented")
}
func (UnimplementedAgentManagerServiceServer) GetAgentRunRuntimeStatus(context.Context, *GetAgentRunRuntimeStatusRequest) (*AgentRunRuntimeStatusResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetAgentRunRuntimeStatus not implemented")
}
func (UnimplementedAgentManagerServiceServer) RecordSessionStateSnapshot(context.Context, *RecordSessionStateSnapshotRequest) (*AgentSessionStateSnapshotResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RecordSessionStateSnapshot not implemented")
}
func (UnimplementedAgentManagerServiceServer) RequestAcceptance(context.Context, *RequestAcceptanceRequest) (*AcceptanceResultResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RequestAcceptance not implemented")
}
func (UnimplementedAgentManagerServiceServer) RecordAcceptanceResult(context.Context, *RecordAcceptanceResultRequest) (*AcceptanceResultResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RecordAcceptanceResult not implemented")
}
func (UnimplementedAgentManagerServiceServer) GetAcceptanceResult(context.Context, *GetAcceptanceResultRequest) (*AcceptanceResultResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetAcceptanceResult not implemented")
}
func (UnimplementedAgentManagerServiceServer) ListAcceptanceResults(context.Context, *ListAcceptanceResultsRequest) (*ListAcceptanceResultsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListAcceptanceResults not implemented")
}
func (UnimplementedAgentManagerServiceServer) CreateFollowUpIntent(context.Context, *CreateFollowUpIntentRequest) (*FollowUpIntentResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateFollowUpIntent not implemented")
}
func (UnimplementedAgentManagerServiceServer) DispatchFollowUpIntent(context.Context, *DispatchFollowUpIntentRequest) (*FollowUpIntentResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DispatchFollowUpIntent not implemented")
}
func (UnimplementedAgentManagerServiceServer) RecordAgentActivity(context.Context, *RecordAgentActivityRequest) (*AgentActivityResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RecordAgentActivity not implemented")
}
func (UnimplementedAgentManagerServiceServer) ListAgentActivities(context.Context, *ListAgentActivitiesRequest) (*ListAgentActivitiesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListAgentActivities not implemented")
}
func (UnimplementedAgentManagerServiceServer) RequestHumanGate(context.Context, *RequestHumanGateRequest) (*HumanGateRequestResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RequestHumanGate not implemented")
}
func (UnimplementedAgentManagerServiceServer) RecordHumanGateDecision(context.Context, *RecordHumanGateDecisionRequest) (*HumanGateRequestResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RecordHumanGateDecision not implemented")
}
func (UnimplementedAgentManagerServiceServer) GetHumanGateRequest(context.Context, *GetHumanGateRequestRequest) (*HumanGateRequestResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetHumanGateRequest not implemented")
}
func (UnimplementedAgentManagerServiceServer) ListHumanGateRequests(context.Context, *ListHumanGateRequestsRequest) (*ListHumanGateRequestsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListHumanGateRequests not implemented")
}
func (UnimplementedAgentManagerServiceServer) GetAgentSession(context.Context, *GetAgentSessionRequest) (*AgentSessionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetAgentSession not implemented")
}
func (UnimplementedAgentManagerServiceServer) ListAgentSessions(context.Context, *ListAgentSessionsRequest) (*ListAgentSessionsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListAgentSessions not implemented")
}
func (UnimplementedAgentManagerServiceServer) ListAgentRuns(context.Context, *ListAgentRunsRequest) (*ListAgentRunsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListAgentRuns not implemented")
}
func (UnimplementedAgentManagerServiceServer) ListAgentRunSummaries(context.Context, *ListAgentRunSummariesRequest) (*ListAgentRunSummariesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListAgentRunSummaries not implemented")
}
func (UnimplementedAgentManagerServiceServer) CreateSelfDeployPlan(context.Context, *CreateSelfDeployPlanRequest) (*SelfDeployPlanResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateSelfDeployPlan not implemented")
}
func (UnimplementedAgentManagerServiceServer) CreateSelfDeployPlanFromSignal(context.Context, *CreateSelfDeployPlanFromSignalRequest) (*SelfDeployPlanResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateSelfDeployPlanFromSignal not implemented")
}
func (UnimplementedAgentManagerServiceServer) GetSelfDeployPlan(context.Context, *GetSelfDeployPlanRequest) (*SelfDeployPlanResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetSelfDeployPlan not implemented")
}
func (UnimplementedAgentManagerServiceServer) ListSelfDeployPlans(context.Context, *ListSelfDeployPlansRequest) (*ListSelfDeployPlansResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListSelfDeployPlans not implemented")
}
func (UnimplementedAgentManagerServiceServer) mustEmbedUnimplementedAgentManagerServiceServer() {}
func (UnimplementedAgentManagerServiceServer) testEmbeddedByValue()                             {}

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

func RegisterAgentManagerServiceServer(s grpc.ServiceRegistrar, srv AgentManagerServiceServer) {
	// If the following call pancis, it indicates UnimplementedAgentManagerServiceServer 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(&AgentManagerService_ServiceDesc, srv)
}

func _AgentManagerService_CreateFlow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateFlowRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).CreateFlow(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_CreateFlow_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).CreateFlow(ctx, req.(*CreateFlowRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_UpdateFlow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateFlowRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).UpdateFlow(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_UpdateFlow_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).UpdateFlow(ctx, req.(*UpdateFlowRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_CreateFlowVersion_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateFlowVersionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).CreateFlowVersion(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_CreateFlowVersion_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).CreateFlowVersion(ctx, req.(*CreateFlowVersionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_ActivateFlowVersion_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ActivateFlowVersionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).ActivateFlowVersion(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_ActivateFlowVersion_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).ActivateFlowVersion(ctx, req.(*ActivateFlowVersionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_GetFlow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetFlowRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).GetFlow(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_GetFlow_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).GetFlow(ctx, req.(*GetFlowRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_ListFlows_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListFlowsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).ListFlows(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_ListFlows_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).ListFlows(ctx, req.(*ListFlowsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_CreateRoleProfile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateRoleProfileRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).CreateRoleProfile(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_CreateRoleProfile_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).CreateRoleProfile(ctx, req.(*CreateRoleProfileRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_UpdateRoleProfile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateRoleProfileRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).UpdateRoleProfile(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_UpdateRoleProfile_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).UpdateRoleProfile(ctx, req.(*UpdateRoleProfileRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_GetRoleProfile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetRoleProfileRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).GetRoleProfile(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_GetRoleProfile_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).GetRoleProfile(ctx, req.(*GetRoleProfileRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_ListRoleProfiles_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListRoleProfilesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).ListRoleProfiles(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_ListRoleProfiles_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).ListRoleProfiles(ctx, req.(*ListRoleProfilesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_GetPromptTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetPromptTemplateRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).GetPromptTemplate(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_GetPromptTemplate_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).GetPromptTemplate(ctx, req.(*GetPromptTemplateRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_ListPromptTemplates_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListPromptTemplatesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).ListPromptTemplates(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_ListPromptTemplates_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).ListPromptTemplates(ctx, req.(*ListPromptTemplatesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_CreatePromptTemplateVersion_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreatePromptTemplateVersionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).CreatePromptTemplateVersion(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_CreatePromptTemplateVersion_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).CreatePromptTemplateVersion(ctx, req.(*CreatePromptTemplateVersionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_ActivatePromptTemplateVersion_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ActivatePromptTemplateVersionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).ActivatePromptTemplateVersion(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_ActivatePromptTemplateVersion_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).ActivatePromptTemplateVersion(ctx, req.(*ActivatePromptTemplateVersionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_GetPromptTemplateVersion_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetPromptTemplateVersionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).GetPromptTemplateVersion(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_GetPromptTemplateVersion_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).GetPromptTemplateVersion(ctx, req.(*GetPromptTemplateVersionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_ListPromptTemplateVersions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListPromptTemplateVersionsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).ListPromptTemplateVersions(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_ListPromptTemplateVersions_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).ListPromptTemplateVersions(ctx, req.(*ListPromptTemplateVersionsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_StartAgentSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(StartAgentSessionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).StartAgentSession(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_StartAgentSession_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).StartAgentSession(ctx, req.(*StartAgentSessionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_StartAgentRun_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(StartAgentRunRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).StartAgentRun(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_StartAgentRun_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).StartAgentRun(ctx, req.(*StartAgentRunRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_RecordRunState_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RecordRunStateRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).RecordRunState(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_RecordRunState_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).RecordRunState(ctx, req.(*RecordRunStateRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_ReportAgentRunState_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ReportAgentRunStateRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).ReportAgentRunState(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_ReportAgentRunState_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).ReportAgentRunState(ctx, req.(*ReportAgentRunStateRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_GetAgentRunRuntimeStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetAgentRunRuntimeStatusRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).GetAgentRunRuntimeStatus(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_GetAgentRunRuntimeStatus_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).GetAgentRunRuntimeStatus(ctx, req.(*GetAgentRunRuntimeStatusRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_RecordSessionStateSnapshot_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RecordSessionStateSnapshotRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).RecordSessionStateSnapshot(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_RecordSessionStateSnapshot_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).RecordSessionStateSnapshot(ctx, req.(*RecordSessionStateSnapshotRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_RequestAcceptance_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RequestAcceptanceRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).RequestAcceptance(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_RequestAcceptance_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).RequestAcceptance(ctx, req.(*RequestAcceptanceRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_RecordAcceptanceResult_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RecordAcceptanceResultRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).RecordAcceptanceResult(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_RecordAcceptanceResult_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).RecordAcceptanceResult(ctx, req.(*RecordAcceptanceResultRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_GetAcceptanceResult_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetAcceptanceResultRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).GetAcceptanceResult(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_GetAcceptanceResult_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).GetAcceptanceResult(ctx, req.(*GetAcceptanceResultRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_ListAcceptanceResults_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListAcceptanceResultsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).ListAcceptanceResults(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_ListAcceptanceResults_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).ListAcceptanceResults(ctx, req.(*ListAcceptanceResultsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_CreateFollowUpIntent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateFollowUpIntentRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).CreateFollowUpIntent(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_CreateFollowUpIntent_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).CreateFollowUpIntent(ctx, req.(*CreateFollowUpIntentRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_DispatchFollowUpIntent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DispatchFollowUpIntentRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).DispatchFollowUpIntent(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_DispatchFollowUpIntent_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).DispatchFollowUpIntent(ctx, req.(*DispatchFollowUpIntentRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_RecordAgentActivity_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RecordAgentActivityRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).RecordAgentActivity(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_RecordAgentActivity_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).RecordAgentActivity(ctx, req.(*RecordAgentActivityRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_ListAgentActivities_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListAgentActivitiesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).ListAgentActivities(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_ListAgentActivities_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).ListAgentActivities(ctx, req.(*ListAgentActivitiesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_RequestHumanGate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RequestHumanGateRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).RequestHumanGate(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_RequestHumanGate_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).RequestHumanGate(ctx, req.(*RequestHumanGateRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_RecordHumanGateDecision_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RecordHumanGateDecisionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).RecordHumanGateDecision(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_RecordHumanGateDecision_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).RecordHumanGateDecision(ctx, req.(*RecordHumanGateDecisionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_GetHumanGateRequest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetHumanGateRequestRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).GetHumanGateRequest(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_GetHumanGateRequest_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).GetHumanGateRequest(ctx, req.(*GetHumanGateRequestRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_ListHumanGateRequests_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListHumanGateRequestsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).ListHumanGateRequests(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_ListHumanGateRequests_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).ListHumanGateRequests(ctx, req.(*ListHumanGateRequestsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_GetAgentSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetAgentSessionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).GetAgentSession(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_GetAgentSession_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).GetAgentSession(ctx, req.(*GetAgentSessionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_ListAgentSessions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListAgentSessionsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).ListAgentSessions(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_ListAgentSessions_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).ListAgentSessions(ctx, req.(*ListAgentSessionsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_ListAgentRuns_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListAgentRunsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).ListAgentRuns(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_ListAgentRuns_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).ListAgentRuns(ctx, req.(*ListAgentRunsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_ListAgentRunSummaries_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListAgentRunSummariesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).ListAgentRunSummaries(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_ListAgentRunSummaries_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).ListAgentRunSummaries(ctx, req.(*ListAgentRunSummariesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_CreateSelfDeployPlan_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateSelfDeployPlanRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).CreateSelfDeployPlan(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_CreateSelfDeployPlan_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).CreateSelfDeployPlan(ctx, req.(*CreateSelfDeployPlanRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_CreateSelfDeployPlanFromSignal_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateSelfDeployPlanFromSignalRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).CreateSelfDeployPlanFromSignal(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_CreateSelfDeployPlanFromSignal_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).CreateSelfDeployPlanFromSignal(ctx, req.(*CreateSelfDeployPlanFromSignalRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_GetSelfDeployPlan_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetSelfDeployPlanRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).GetSelfDeployPlan(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_GetSelfDeployPlan_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).GetSelfDeployPlan(ctx, req.(*GetSelfDeployPlanRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentManagerService_ListSelfDeployPlans_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListSelfDeployPlansRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentManagerServiceServer).ListSelfDeployPlans(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentManagerService_ListSelfDeployPlans_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentManagerServiceServer).ListSelfDeployPlans(ctx, req.(*ListSelfDeployPlansRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// AgentManagerService_ServiceDesc is the grpc.ServiceDesc for AgentManagerService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var AgentManagerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kodex.agents.v1.AgentManagerService",
	HandlerType: (*AgentManagerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateFlow",
			Handler:    _AgentManagerService_CreateFlow_Handler,
		},
		{
			MethodName: "UpdateFlow",
			Handler:    _AgentManagerService_UpdateFlow_Handler,
		},
		{
			MethodName: "CreateFlowVersion",
			Handler:    _AgentManagerService_CreateFlowVersion_Handler,
		},
		{
			MethodName: "ActivateFlowVersion",
			Handler:    _AgentManagerService_ActivateFlowVersion_Handler,
		},
		{
			MethodName: "GetFlow",
			Handler:    _AgentManagerService_GetFlow_Handler,
		},
		{
			MethodName: "ListFlows",
			Handler:    _AgentManagerService_ListFlows_Handler,
		},
		{
			MethodName: "CreateRoleProfile",
			Handler:    _AgentManagerService_CreateRoleProfile_Handler,
		},
		{
			MethodName: "UpdateRoleProfile",
			Handler:    _AgentManagerService_UpdateRoleProfile_Handler,
		},
		{
			MethodName: "GetRoleProfile",
			Handler:    _AgentManagerService_GetRoleProfile_Handler,
		},
		{
			MethodName: "ListRoleProfiles",
			Handler:    _AgentManagerService_ListRoleProfiles_Handler,
		},
		{
			MethodName: "GetPromptTemplate",
			Handler:    _AgentManagerService_GetPromptTemplate_Handler,
		},
		{
			MethodName: "ListPromptTemplates",
			Handler:    _AgentManagerService_ListPromptTemplates_Handler,
		},
		{
			MethodName: "CreatePromptTemplateVersion",
			Handler:    _AgentManagerService_CreatePromptTemplateVersion_Handler,
		},
		{
			MethodName: "ActivatePromptTemplateVersion",
			Handler:    _AgentManagerService_ActivatePromptTemplateVersion_Handler,
		},
		{
			MethodName: "GetPromptTemplateVersion",
			Handler:    _AgentManagerService_GetPromptTemplateVersion_Handler,
		},
		{
			MethodName: "ListPromptTemplateVersions",
			Handler:    _AgentManagerService_ListPromptTemplateVersions_Handler,
		},
		{
			MethodName: "StartAgentSession",
			Handler:    _AgentManagerService_StartAgentSession_Handler,
		},
		{
			MethodName: "StartAgentRun",
			Handler:    _AgentManagerService_StartAgentRun_Handler,
		},
		{
			MethodName: "RecordRunState",
			Handler:    _AgentManagerService_RecordRunState_Handler,
		},
		{
			MethodName: "ReportAgentRunState",
			Handler:    _AgentManagerService_ReportAgentRunState_Handler,
		},
		{
			MethodName: "GetAgentRunRuntimeStatus",
			Handler:    _AgentManagerService_GetAgentRunRuntimeStatus_Handler,
		},
		{
			MethodName: "RecordSessionStateSnapshot",
			Handler:    _AgentManagerService_RecordSessionStateSnapshot_Handler,
		},
		{
			MethodName: "RequestAcceptance",
			Handler:    _AgentManagerService_RequestAcceptance_Handler,
		},
		{
			MethodName: "RecordAcceptanceResult",
			Handler:    _AgentManagerService_RecordAcceptanceResult_Handler,
		},
		{
			MethodName: "GetAcceptanceResult",
			Handler:    _AgentManagerService_GetAcceptanceResult_Handler,
		},
		{
			MethodName: "ListAcceptanceResults",
			Handler:    _AgentManagerService_ListAcceptanceResults_Handler,
		},
		{
			MethodName: "CreateFollowUpIntent",
			Handler:    _AgentManagerService_CreateFollowUpIntent_Handler,
		},
		{
			MethodName: "DispatchFollowUpIntent",
			Handler:    _AgentManagerService_DispatchFollowUpIntent_Handler,
		},
		{
			MethodName: "RecordAgentActivity",
			Handler:    _AgentManagerService_RecordAgentActivity_Handler,
		},
		{
			MethodName: "ListAgentActivities",
			Handler:    _AgentManagerService_ListAgentActivities_Handler,
		},
		{
			MethodName: "RequestHumanGate",
			Handler:    _AgentManagerService_RequestHumanGate_Handler,
		},
		{
			MethodName: "RecordHumanGateDecision",
			Handler:    _AgentManagerService_RecordHumanGateDecision_Handler,
		},
		{
			MethodName: "GetHumanGateRequest",
			Handler:    _AgentManagerService_GetHumanGateRequest_Handler,
		},
		{
			MethodName: "ListHumanGateRequests",
			Handler:    _AgentManagerService_ListHumanGateRequests_Handler,
		},
		{
			MethodName: "GetAgentSession",
			Handler:    _AgentManagerService_GetAgentSession_Handler,
		},
		{
			MethodName: "ListAgentSessions",
			Handler:    _AgentManagerService_ListAgentSessions_Handler,
		},
		{
			MethodName: "ListAgentRuns",
			Handler:    _AgentManagerService_ListAgentRuns_Handler,
		},
		{
			MethodName: "ListAgentRunSummaries",
			Handler:    _AgentManagerService_ListAgentRunSummaries_Handler,
		},
		{
			MethodName: "CreateSelfDeployPlan",
			Handler:    _AgentManagerService_CreateSelfDeployPlan_Handler,
		},
		{
			MethodName: "CreateSelfDeployPlanFromSignal",
			Handler:    _AgentManagerService_CreateSelfDeployPlanFromSignal_Handler,
		},
		{
			MethodName: "GetSelfDeployPlan",
			Handler:    _AgentManagerService_GetSelfDeployPlan_Handler,
		},
		{
			MethodName: "ListSelfDeployPlans",
			Handler:    _AgentManagerService_ListSelfDeployPlans_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "kodex/agents/v1/agent_manager.proto",
}
