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

package fleetv1

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 (
	FleetManagerService_CreateFleetScope_FullMethodName            = "/kodex.fleet.v1.FleetManagerService/CreateFleetScope"
	FleetManagerService_UpdateFleetScope_FullMethodName            = "/kodex.fleet.v1.FleetManagerService/UpdateFleetScope"
	FleetManagerService_DisableFleetScope_FullMethodName           = "/kodex.fleet.v1.FleetManagerService/DisableFleetScope"
	FleetManagerService_EnableFleetScope_FullMethodName            = "/kodex.fleet.v1.FleetManagerService/EnableFleetScope"
	FleetManagerService_GetFleetScope_FullMethodName               = "/kodex.fleet.v1.FleetManagerService/GetFleetScope"
	FleetManagerService_ListFleetScopes_FullMethodName             = "/kodex.fleet.v1.FleetManagerService/ListFleetScopes"
	FleetManagerService_RegisterServer_FullMethodName              = "/kodex.fleet.v1.FleetManagerService/RegisterServer"
	FleetManagerService_UpdateServer_FullMethodName                = "/kodex.fleet.v1.FleetManagerService/UpdateServer"
	FleetManagerService_DisableServer_FullMethodName               = "/kodex.fleet.v1.FleetManagerService/DisableServer"
	FleetManagerService_EnableServer_FullMethodName                = "/kodex.fleet.v1.FleetManagerService/EnableServer"
	FleetManagerService_GetServer_FullMethodName                   = "/kodex.fleet.v1.FleetManagerService/GetServer"
	FleetManagerService_ListServers_FullMethodName                 = "/kodex.fleet.v1.FleetManagerService/ListServers"
	FleetManagerService_RegisterKubernetesCluster_FullMethodName   = "/kodex.fleet.v1.FleetManagerService/RegisterKubernetesCluster"
	FleetManagerService_UpdateKubernetesCluster_FullMethodName     = "/kodex.fleet.v1.FleetManagerService/UpdateKubernetesCluster"
	FleetManagerService_DisableKubernetesCluster_FullMethodName    = "/kodex.fleet.v1.FleetManagerService/DisableKubernetesCluster"
	FleetManagerService_EnableKubernetesCluster_FullMethodName     = "/kodex.fleet.v1.FleetManagerService/EnableKubernetesCluster"
	FleetManagerService_GetKubernetesCluster_FullMethodName        = "/kodex.fleet.v1.FleetManagerService/GetKubernetesCluster"
	FleetManagerService_ListKubernetesClusters_FullMethodName      = "/kodex.fleet.v1.FleetManagerService/ListKubernetesClusters"
	FleetManagerService_RunClusterConnectivityCheck_FullMethodName = "/kodex.fleet.v1.FleetManagerService/RunClusterConnectivityCheck"
	FleetManagerService_GetClusterHealthSnapshot_FullMethodName    = "/kodex.fleet.v1.FleetManagerService/GetClusterHealthSnapshot"
	FleetManagerService_ListClusterHealthSnapshots_FullMethodName  = "/kodex.fleet.v1.FleetManagerService/ListClusterHealthSnapshots"
	FleetManagerService_PutPlacementRule_FullMethodName            = "/kodex.fleet.v1.FleetManagerService/PutPlacementRule"
	FleetManagerService_GetPlacementRule_FullMethodName            = "/kodex.fleet.v1.FleetManagerService/GetPlacementRule"
	FleetManagerService_ListPlacementRules_FullMethodName          = "/kodex.fleet.v1.FleetManagerService/ListPlacementRules"
	FleetManagerService_ResolvePlacement_FullMethodName            = "/kodex.fleet.v1.FleetManagerService/ResolvePlacement"
	FleetManagerService_GetPlacementDecision_FullMethodName        = "/kodex.fleet.v1.FleetManagerService/GetPlacementDecision"
	FleetManagerService_ListPlacementDecisions_FullMethodName      = "/kodex.fleet.v1.FleetManagerService/ListPlacementDecisions"
)

// FleetManagerServiceClient is the client API for FleetManagerService 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.
//
// FleetManagerService is the stable v1 inter-service contract for the
// server and Kubernetes cluster registry. Fleet-manager owns fleet scopes,
// servers, clusters, connectivity, health and placement decisions.
type FleetManagerServiceClient interface {
	// CreateFleetScope creates a logical placement scope.
	CreateFleetScope(ctx context.Context, in *CreateFleetScopeRequest, opts ...grpc.CallOption) (*FleetScopeResponse, error)
	// UpdateFleetScope changes safe scope fields and lifecycle status.
	UpdateFleetScope(ctx context.Context, in *UpdateFleetScopeRequest, opts ...grpc.CallOption) (*FleetScopeResponse, error)
	// DisableFleetScope disables new placements in a scope.
	DisableFleetScope(ctx context.Context, in *DisableFleetScopeRequest, opts ...grpc.CallOption) (*FleetScopeResponse, error)
	// EnableFleetScope allows new placements in a previously disabled scope.
	EnableFleetScope(ctx context.Context, in *EnableFleetScopeRequest, opts ...grpc.CallOption) (*FleetScopeResponse, error)
	// GetFleetScope returns authoritative scope state.
	GetFleetScope(ctx context.Context, in *GetFleetScopeRequest, opts ...grpc.CallOption) (*FleetScopeResponse, error)
	// ListFleetScopes returns scopes by type, owner, status or default flag.
	ListFleetScopes(ctx context.Context, in *ListFleetScopesRequest, opts ...grpc.CallOption) (*ListFleetScopesResponse, error)
	// RegisterServer registers a server or external host reference.
	RegisterServer(ctx context.Context, in *RegisterServerRequest, opts ...grpc.CallOption) (*ServerResponse, error)
	// UpdateServer changes safe server metadata and lifecycle status.
	UpdateServer(ctx context.Context, in *UpdateServerRequest, opts ...grpc.CallOption) (*ServerResponse, error)
	// DisableServer disables server use for new placements.
	DisableServer(ctx context.Context, in *DisableServerRequest, opts ...grpc.CallOption) (*ServerResponse, error)
	// EnableServer allows new placements through a previously disabled server.
	EnableServer(ctx context.Context, in *EnableServerRequest, opts ...grpc.CallOption) (*ServerResponse, error)
	// GetServer returns authoritative server state.
	GetServer(ctx context.Context, in *GetServerRequest, opts ...grpc.CallOption) (*ServerResponse, error)
	// ListServers returns servers by status, provider, region or capacity class.
	ListServers(ctx context.Context, in *ListServersRequest, opts ...grpc.CallOption) (*ListServersResponse, error)
	// RegisterKubernetesCluster registers one Kubernetes cluster in a fleet scope.
	RegisterKubernetesCluster(ctx context.Context, in *RegisterKubernetesClusterRequest, opts ...grpc.CallOption) (*KubernetesClusterResponse, error)
	// UpdateKubernetesCluster changes safe cluster metadata and lifecycle status.
	UpdateKubernetesCluster(ctx context.Context, in *UpdateKubernetesClusterRequest, opts ...grpc.CallOption) (*KubernetesClusterResponse, error)
	// DisableKubernetesCluster disables new placements in a cluster.
	DisableKubernetesCluster(ctx context.Context, in *DisableKubernetesClusterRequest, opts ...grpc.CallOption) (*KubernetesClusterResponse, error)
	// EnableKubernetesCluster allows new placements in a previously disabled cluster.
	EnableKubernetesCluster(ctx context.Context, in *EnableKubernetesClusterRequest, opts ...grpc.CallOption) (*KubernetesClusterResponse, error)
	// GetKubernetesCluster returns authoritative cluster state.
	GetKubernetesCluster(ctx context.Context, in *GetKubernetesClusterRequest, opts ...grpc.CallOption) (*KubernetesClusterResponse, error)
	// ListKubernetesClusters returns clusters by scope, server, status, region or health.
	ListKubernetesClusters(ctx context.Context, in *ListKubernetesClustersRequest, opts ...grpc.CallOption) (*ListKubernetesClustersResponse, error)
	// RunClusterConnectivityCheck requests a future connectivity check.
	RunClusterConnectivityCheck(ctx context.Context, in *RunClusterConnectivityCheckRequest, opts ...grpc.CallOption) (*ClusterConnectivityCheckResponse, error)
	// GetClusterHealthSnapshot returns the latest or a concrete health snapshot.
	GetClusterHealthSnapshot(ctx context.Context, in *GetClusterHealthSnapshotRequest, opts ...grpc.CallOption) (*ClusterHealthSnapshotResponse, error)
	// ListClusterHealthSnapshots returns health snapshot history for a cluster.
	ListClusterHealthSnapshots(ctx context.Context, in *ListClusterHealthSnapshotsRequest, opts ...grpc.CallOption) (*ListClusterHealthSnapshotsResponse, error)
	// PutPlacementRule creates or updates a placement rule.
	PutPlacementRule(ctx context.Context, in *PutPlacementRuleRequest, opts ...grpc.CallOption) (*PlacementRuleResponse, error)
	// GetPlacementRule returns a placement rule.
	GetPlacementRule(ctx context.Context, in *GetPlacementRuleRequest, opts ...grpc.CallOption) (*PlacementRuleResponse, error)
	// ListPlacementRules returns placement rules by scope and status.
	ListPlacementRules(ctx context.Context, in *ListPlacementRulesRequest, opts ...grpc.CallOption) (*ListPlacementRulesResponse, error)
	// ResolvePlacement selects an active cluster from the registry for a runtime request.
	ResolvePlacement(ctx context.Context, in *ResolvePlacementRequest, opts ...grpc.CallOption) (*ResolvePlacementResponse, error)
	// GetPlacementDecision returns a recorded placement decision.
	GetPlacementDecision(ctx context.Context, in *GetPlacementDecisionRequest, opts ...grpc.CallOption) (*PlacementDecisionResponse, error)
	// ListPlacementDecisions returns placement decisions by project, repository, scope or cluster.
	ListPlacementDecisions(ctx context.Context, in *ListPlacementDecisionsRequest, opts ...grpc.CallOption) (*ListPlacementDecisionsResponse, error)
}

type fleetManagerServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewFleetManagerServiceClient(cc grpc.ClientConnInterface) FleetManagerServiceClient {
	return &fleetManagerServiceClient{cc}
}

func (c *fleetManagerServiceClient) CreateFleetScope(ctx context.Context, in *CreateFleetScopeRequest, opts ...grpc.CallOption) (*FleetScopeResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(FleetScopeResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_CreateFleetScope_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) UpdateFleetScope(ctx context.Context, in *UpdateFleetScopeRequest, opts ...grpc.CallOption) (*FleetScopeResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(FleetScopeResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_UpdateFleetScope_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) DisableFleetScope(ctx context.Context, in *DisableFleetScopeRequest, opts ...grpc.CallOption) (*FleetScopeResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(FleetScopeResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_DisableFleetScope_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) EnableFleetScope(ctx context.Context, in *EnableFleetScopeRequest, opts ...grpc.CallOption) (*FleetScopeResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(FleetScopeResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_EnableFleetScope_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) GetFleetScope(ctx context.Context, in *GetFleetScopeRequest, opts ...grpc.CallOption) (*FleetScopeResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(FleetScopeResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_GetFleetScope_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) ListFleetScopes(ctx context.Context, in *ListFleetScopesRequest, opts ...grpc.CallOption) (*ListFleetScopesResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListFleetScopesResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_ListFleetScopes_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) RegisterServer(ctx context.Context, in *RegisterServerRequest, opts ...grpc.CallOption) (*ServerResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ServerResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_RegisterServer_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) UpdateServer(ctx context.Context, in *UpdateServerRequest, opts ...grpc.CallOption) (*ServerResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ServerResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_UpdateServer_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) DisableServer(ctx context.Context, in *DisableServerRequest, opts ...grpc.CallOption) (*ServerResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ServerResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_DisableServer_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) EnableServer(ctx context.Context, in *EnableServerRequest, opts ...grpc.CallOption) (*ServerResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ServerResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_EnableServer_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) GetServer(ctx context.Context, in *GetServerRequest, opts ...grpc.CallOption) (*ServerResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ServerResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_GetServer_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) ListServers(ctx context.Context, in *ListServersRequest, opts ...grpc.CallOption) (*ListServersResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListServersResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_ListServers_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) RegisterKubernetesCluster(ctx context.Context, in *RegisterKubernetesClusterRequest, opts ...grpc.CallOption) (*KubernetesClusterResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(KubernetesClusterResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_RegisterKubernetesCluster_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) UpdateKubernetesCluster(ctx context.Context, in *UpdateKubernetesClusterRequest, opts ...grpc.CallOption) (*KubernetesClusterResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(KubernetesClusterResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_UpdateKubernetesCluster_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) DisableKubernetesCluster(ctx context.Context, in *DisableKubernetesClusterRequest, opts ...grpc.CallOption) (*KubernetesClusterResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(KubernetesClusterResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_DisableKubernetesCluster_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) EnableKubernetesCluster(ctx context.Context, in *EnableKubernetesClusterRequest, opts ...grpc.CallOption) (*KubernetesClusterResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(KubernetesClusterResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_EnableKubernetesCluster_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) GetKubernetesCluster(ctx context.Context, in *GetKubernetesClusterRequest, opts ...grpc.CallOption) (*KubernetesClusterResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(KubernetesClusterResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_GetKubernetesCluster_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) ListKubernetesClusters(ctx context.Context, in *ListKubernetesClustersRequest, opts ...grpc.CallOption) (*ListKubernetesClustersResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListKubernetesClustersResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_ListKubernetesClusters_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) RunClusterConnectivityCheck(ctx context.Context, in *RunClusterConnectivityCheckRequest, opts ...grpc.CallOption) (*ClusterConnectivityCheckResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ClusterConnectivityCheckResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_RunClusterConnectivityCheck_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) GetClusterHealthSnapshot(ctx context.Context, in *GetClusterHealthSnapshotRequest, opts ...grpc.CallOption) (*ClusterHealthSnapshotResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ClusterHealthSnapshotResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_GetClusterHealthSnapshot_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) ListClusterHealthSnapshots(ctx context.Context, in *ListClusterHealthSnapshotsRequest, opts ...grpc.CallOption) (*ListClusterHealthSnapshotsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListClusterHealthSnapshotsResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_ListClusterHealthSnapshots_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) PutPlacementRule(ctx context.Context, in *PutPlacementRuleRequest, opts ...grpc.CallOption) (*PlacementRuleResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(PlacementRuleResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_PutPlacementRule_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) GetPlacementRule(ctx context.Context, in *GetPlacementRuleRequest, opts ...grpc.CallOption) (*PlacementRuleResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(PlacementRuleResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_GetPlacementRule_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) ListPlacementRules(ctx context.Context, in *ListPlacementRulesRequest, opts ...grpc.CallOption) (*ListPlacementRulesResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListPlacementRulesResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_ListPlacementRules_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) ResolvePlacement(ctx context.Context, in *ResolvePlacementRequest, opts ...grpc.CallOption) (*ResolvePlacementResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ResolvePlacementResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_ResolvePlacement_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) GetPlacementDecision(ctx context.Context, in *GetPlacementDecisionRequest, opts ...grpc.CallOption) (*PlacementDecisionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(PlacementDecisionResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_GetPlacementDecision_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *fleetManagerServiceClient) ListPlacementDecisions(ctx context.Context, in *ListPlacementDecisionsRequest, opts ...grpc.CallOption) (*ListPlacementDecisionsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListPlacementDecisionsResponse)
	err := c.cc.Invoke(ctx, FleetManagerService_ListPlacementDecisions_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// FleetManagerServiceServer is the server API for FleetManagerService service.
// All implementations must embed UnimplementedFleetManagerServiceServer
// for forward compatibility.
//
// FleetManagerService is the stable v1 inter-service contract for the
// server and Kubernetes cluster registry. Fleet-manager owns fleet scopes,
// servers, clusters, connectivity, health and placement decisions.
type FleetManagerServiceServer interface {
	// CreateFleetScope creates a logical placement scope.
	CreateFleetScope(context.Context, *CreateFleetScopeRequest) (*FleetScopeResponse, error)
	// UpdateFleetScope changes safe scope fields and lifecycle status.
	UpdateFleetScope(context.Context, *UpdateFleetScopeRequest) (*FleetScopeResponse, error)
	// DisableFleetScope disables new placements in a scope.
	DisableFleetScope(context.Context, *DisableFleetScopeRequest) (*FleetScopeResponse, error)
	// EnableFleetScope allows new placements in a previously disabled scope.
	EnableFleetScope(context.Context, *EnableFleetScopeRequest) (*FleetScopeResponse, error)
	// GetFleetScope returns authoritative scope state.
	GetFleetScope(context.Context, *GetFleetScopeRequest) (*FleetScopeResponse, error)
	// ListFleetScopes returns scopes by type, owner, status or default flag.
	ListFleetScopes(context.Context, *ListFleetScopesRequest) (*ListFleetScopesResponse, error)
	// RegisterServer registers a server or external host reference.
	RegisterServer(context.Context, *RegisterServerRequest) (*ServerResponse, error)
	// UpdateServer changes safe server metadata and lifecycle status.
	UpdateServer(context.Context, *UpdateServerRequest) (*ServerResponse, error)
	// DisableServer disables server use for new placements.
	DisableServer(context.Context, *DisableServerRequest) (*ServerResponse, error)
	// EnableServer allows new placements through a previously disabled server.
	EnableServer(context.Context, *EnableServerRequest) (*ServerResponse, error)
	// GetServer returns authoritative server state.
	GetServer(context.Context, *GetServerRequest) (*ServerResponse, error)
	// ListServers returns servers by status, provider, region or capacity class.
	ListServers(context.Context, *ListServersRequest) (*ListServersResponse, error)
	// RegisterKubernetesCluster registers one Kubernetes cluster in a fleet scope.
	RegisterKubernetesCluster(context.Context, *RegisterKubernetesClusterRequest) (*KubernetesClusterResponse, error)
	// UpdateKubernetesCluster changes safe cluster metadata and lifecycle status.
	UpdateKubernetesCluster(context.Context, *UpdateKubernetesClusterRequest) (*KubernetesClusterResponse, error)
	// DisableKubernetesCluster disables new placements in a cluster.
	DisableKubernetesCluster(context.Context, *DisableKubernetesClusterRequest) (*KubernetesClusterResponse, error)
	// EnableKubernetesCluster allows new placements in a previously disabled cluster.
	EnableKubernetesCluster(context.Context, *EnableKubernetesClusterRequest) (*KubernetesClusterResponse, error)
	// GetKubernetesCluster returns authoritative cluster state.
	GetKubernetesCluster(context.Context, *GetKubernetesClusterRequest) (*KubernetesClusterResponse, error)
	// ListKubernetesClusters returns clusters by scope, server, status, region or health.
	ListKubernetesClusters(context.Context, *ListKubernetesClustersRequest) (*ListKubernetesClustersResponse, error)
	// RunClusterConnectivityCheck requests a future connectivity check.
	RunClusterConnectivityCheck(context.Context, *RunClusterConnectivityCheckRequest) (*ClusterConnectivityCheckResponse, error)
	// GetClusterHealthSnapshot returns the latest or a concrete health snapshot.
	GetClusterHealthSnapshot(context.Context, *GetClusterHealthSnapshotRequest) (*ClusterHealthSnapshotResponse, error)
	// ListClusterHealthSnapshots returns health snapshot history for a cluster.
	ListClusterHealthSnapshots(context.Context, *ListClusterHealthSnapshotsRequest) (*ListClusterHealthSnapshotsResponse, error)
	// PutPlacementRule creates or updates a placement rule.
	PutPlacementRule(context.Context, *PutPlacementRuleRequest) (*PlacementRuleResponse, error)
	// GetPlacementRule returns a placement rule.
	GetPlacementRule(context.Context, *GetPlacementRuleRequest) (*PlacementRuleResponse, error)
	// ListPlacementRules returns placement rules by scope and status.
	ListPlacementRules(context.Context, *ListPlacementRulesRequest) (*ListPlacementRulesResponse, error)
	// ResolvePlacement selects an active cluster from the registry for a runtime request.
	ResolvePlacement(context.Context, *ResolvePlacementRequest) (*ResolvePlacementResponse, error)
	// GetPlacementDecision returns a recorded placement decision.
	GetPlacementDecision(context.Context, *GetPlacementDecisionRequest) (*PlacementDecisionResponse, error)
	// ListPlacementDecisions returns placement decisions by project, repository, scope or cluster.
	ListPlacementDecisions(context.Context, *ListPlacementDecisionsRequest) (*ListPlacementDecisionsResponse, error)
	mustEmbedUnimplementedFleetManagerServiceServer()
}

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

func (UnimplementedFleetManagerServiceServer) CreateFleetScope(context.Context, *CreateFleetScopeRequest) (*FleetScopeResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateFleetScope not implemented")
}
func (UnimplementedFleetManagerServiceServer) UpdateFleetScope(context.Context, *UpdateFleetScopeRequest) (*FleetScopeResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateFleetScope not implemented")
}
func (UnimplementedFleetManagerServiceServer) DisableFleetScope(context.Context, *DisableFleetScopeRequest) (*FleetScopeResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DisableFleetScope not implemented")
}
func (UnimplementedFleetManagerServiceServer) EnableFleetScope(context.Context, *EnableFleetScopeRequest) (*FleetScopeResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method EnableFleetScope not implemented")
}
func (UnimplementedFleetManagerServiceServer) GetFleetScope(context.Context, *GetFleetScopeRequest) (*FleetScopeResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetFleetScope not implemented")
}
func (UnimplementedFleetManagerServiceServer) ListFleetScopes(context.Context, *ListFleetScopesRequest) (*ListFleetScopesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListFleetScopes not implemented")
}
func (UnimplementedFleetManagerServiceServer) RegisterServer(context.Context, *RegisterServerRequest) (*ServerResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RegisterServer not implemented")
}
func (UnimplementedFleetManagerServiceServer) UpdateServer(context.Context, *UpdateServerRequest) (*ServerResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateServer not implemented")
}
func (UnimplementedFleetManagerServiceServer) DisableServer(context.Context, *DisableServerRequest) (*ServerResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DisableServer not implemented")
}
func (UnimplementedFleetManagerServiceServer) EnableServer(context.Context, *EnableServerRequest) (*ServerResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method EnableServer not implemented")
}
func (UnimplementedFleetManagerServiceServer) GetServer(context.Context, *GetServerRequest) (*ServerResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetServer not implemented")
}
func (UnimplementedFleetManagerServiceServer) ListServers(context.Context, *ListServersRequest) (*ListServersResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListServers not implemented")
}
func (UnimplementedFleetManagerServiceServer) RegisterKubernetesCluster(context.Context, *RegisterKubernetesClusterRequest) (*KubernetesClusterResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RegisterKubernetesCluster not implemented")
}
func (UnimplementedFleetManagerServiceServer) UpdateKubernetesCluster(context.Context, *UpdateKubernetesClusterRequest) (*KubernetesClusterResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateKubernetesCluster not implemented")
}
func (UnimplementedFleetManagerServiceServer) DisableKubernetesCluster(context.Context, *DisableKubernetesClusterRequest) (*KubernetesClusterResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DisableKubernetesCluster not implemented")
}
func (UnimplementedFleetManagerServiceServer) EnableKubernetesCluster(context.Context, *EnableKubernetesClusterRequest) (*KubernetesClusterResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method EnableKubernetesCluster not implemented")
}
func (UnimplementedFleetManagerServiceServer) GetKubernetesCluster(context.Context, *GetKubernetesClusterRequest) (*KubernetesClusterResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetKubernetesCluster not implemented")
}
func (UnimplementedFleetManagerServiceServer) ListKubernetesClusters(context.Context, *ListKubernetesClustersRequest) (*ListKubernetesClustersResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListKubernetesClusters not implemented")
}
func (UnimplementedFleetManagerServiceServer) RunClusterConnectivityCheck(context.Context, *RunClusterConnectivityCheckRequest) (*ClusterConnectivityCheckResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RunClusterConnectivityCheck not implemented")
}
func (UnimplementedFleetManagerServiceServer) GetClusterHealthSnapshot(context.Context, *GetClusterHealthSnapshotRequest) (*ClusterHealthSnapshotResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetClusterHealthSnapshot not implemented")
}
func (UnimplementedFleetManagerServiceServer) ListClusterHealthSnapshots(context.Context, *ListClusterHealthSnapshotsRequest) (*ListClusterHealthSnapshotsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListClusterHealthSnapshots not implemented")
}
func (UnimplementedFleetManagerServiceServer) PutPlacementRule(context.Context, *PutPlacementRuleRequest) (*PlacementRuleResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method PutPlacementRule not implemented")
}
func (UnimplementedFleetManagerServiceServer) GetPlacementRule(context.Context, *GetPlacementRuleRequest) (*PlacementRuleResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetPlacementRule not implemented")
}
func (UnimplementedFleetManagerServiceServer) ListPlacementRules(context.Context, *ListPlacementRulesRequest) (*ListPlacementRulesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListPlacementRules not implemented")
}
func (UnimplementedFleetManagerServiceServer) ResolvePlacement(context.Context, *ResolvePlacementRequest) (*ResolvePlacementResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ResolvePlacement not implemented")
}
func (UnimplementedFleetManagerServiceServer) GetPlacementDecision(context.Context, *GetPlacementDecisionRequest) (*PlacementDecisionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetPlacementDecision not implemented")
}
func (UnimplementedFleetManagerServiceServer) ListPlacementDecisions(context.Context, *ListPlacementDecisionsRequest) (*ListPlacementDecisionsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListPlacementDecisions not implemented")
}
func (UnimplementedFleetManagerServiceServer) mustEmbedUnimplementedFleetManagerServiceServer() {}
func (UnimplementedFleetManagerServiceServer) testEmbeddedByValue()                             {}

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

func RegisterFleetManagerServiceServer(s grpc.ServiceRegistrar, srv FleetManagerServiceServer) {
	// If the following call pancis, it indicates UnimplementedFleetManagerServiceServer 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(&FleetManagerService_ServiceDesc, srv)
}

func _FleetManagerService_CreateFleetScope_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateFleetScopeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).CreateFleetScope(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_CreateFleetScope_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).CreateFleetScope(ctx, req.(*CreateFleetScopeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_UpdateFleetScope_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateFleetScopeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).UpdateFleetScope(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_UpdateFleetScope_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).UpdateFleetScope(ctx, req.(*UpdateFleetScopeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_DisableFleetScope_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DisableFleetScopeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).DisableFleetScope(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_DisableFleetScope_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).DisableFleetScope(ctx, req.(*DisableFleetScopeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_EnableFleetScope_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(EnableFleetScopeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).EnableFleetScope(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_EnableFleetScope_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).EnableFleetScope(ctx, req.(*EnableFleetScopeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_GetFleetScope_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetFleetScopeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).GetFleetScope(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_GetFleetScope_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).GetFleetScope(ctx, req.(*GetFleetScopeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_ListFleetScopes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListFleetScopesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).ListFleetScopes(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_ListFleetScopes_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).ListFleetScopes(ctx, req.(*ListFleetScopesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_RegisterServer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RegisterServerRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).RegisterServer(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_RegisterServer_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).RegisterServer(ctx, req.(*RegisterServerRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_UpdateServer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateServerRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).UpdateServer(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_UpdateServer_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).UpdateServer(ctx, req.(*UpdateServerRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_DisableServer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DisableServerRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).DisableServer(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_DisableServer_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).DisableServer(ctx, req.(*DisableServerRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_EnableServer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(EnableServerRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).EnableServer(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_EnableServer_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).EnableServer(ctx, req.(*EnableServerRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_GetServer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetServerRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).GetServer(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_GetServer_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).GetServer(ctx, req.(*GetServerRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_ListServers_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListServersRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).ListServers(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_ListServers_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).ListServers(ctx, req.(*ListServersRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_RegisterKubernetesCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RegisterKubernetesClusterRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).RegisterKubernetesCluster(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_RegisterKubernetesCluster_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).RegisterKubernetesCluster(ctx, req.(*RegisterKubernetesClusterRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_UpdateKubernetesCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateKubernetesClusterRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).UpdateKubernetesCluster(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_UpdateKubernetesCluster_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).UpdateKubernetesCluster(ctx, req.(*UpdateKubernetesClusterRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_DisableKubernetesCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DisableKubernetesClusterRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).DisableKubernetesCluster(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_DisableKubernetesCluster_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).DisableKubernetesCluster(ctx, req.(*DisableKubernetesClusterRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_EnableKubernetesCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(EnableKubernetesClusterRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).EnableKubernetesCluster(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_EnableKubernetesCluster_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).EnableKubernetesCluster(ctx, req.(*EnableKubernetesClusterRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_GetKubernetesCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetKubernetesClusterRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).GetKubernetesCluster(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_GetKubernetesCluster_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).GetKubernetesCluster(ctx, req.(*GetKubernetesClusterRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_ListKubernetesClusters_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListKubernetesClustersRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).ListKubernetesClusters(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_ListKubernetesClusters_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).ListKubernetesClusters(ctx, req.(*ListKubernetesClustersRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_RunClusterConnectivityCheck_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RunClusterConnectivityCheckRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).RunClusterConnectivityCheck(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_RunClusterConnectivityCheck_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).RunClusterConnectivityCheck(ctx, req.(*RunClusterConnectivityCheckRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_GetClusterHealthSnapshot_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetClusterHealthSnapshotRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).GetClusterHealthSnapshot(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_GetClusterHealthSnapshot_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).GetClusterHealthSnapshot(ctx, req.(*GetClusterHealthSnapshotRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_ListClusterHealthSnapshots_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListClusterHealthSnapshotsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).ListClusterHealthSnapshots(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_ListClusterHealthSnapshots_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).ListClusterHealthSnapshots(ctx, req.(*ListClusterHealthSnapshotsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_PutPlacementRule_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PutPlacementRuleRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).PutPlacementRule(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_PutPlacementRule_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).PutPlacementRule(ctx, req.(*PutPlacementRuleRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_GetPlacementRule_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetPlacementRuleRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).GetPlacementRule(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_GetPlacementRule_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).GetPlacementRule(ctx, req.(*GetPlacementRuleRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_ListPlacementRules_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListPlacementRulesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).ListPlacementRules(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_ListPlacementRules_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).ListPlacementRules(ctx, req.(*ListPlacementRulesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_ResolvePlacement_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ResolvePlacementRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).ResolvePlacement(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_ResolvePlacement_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).ResolvePlacement(ctx, req.(*ResolvePlacementRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_GetPlacementDecision_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetPlacementDecisionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).GetPlacementDecision(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_GetPlacementDecision_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).GetPlacementDecision(ctx, req.(*GetPlacementDecisionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _FleetManagerService_ListPlacementDecisions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListPlacementDecisionsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(FleetManagerServiceServer).ListPlacementDecisions(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: FleetManagerService_ListPlacementDecisions_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(FleetManagerServiceServer).ListPlacementDecisions(ctx, req.(*ListPlacementDecisionsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// FleetManagerService_ServiceDesc is the grpc.ServiceDesc for FleetManagerService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var FleetManagerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kodex.fleet.v1.FleetManagerService",
	HandlerType: (*FleetManagerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateFleetScope",
			Handler:    _FleetManagerService_CreateFleetScope_Handler,
		},
		{
			MethodName: "UpdateFleetScope",
			Handler:    _FleetManagerService_UpdateFleetScope_Handler,
		},
		{
			MethodName: "DisableFleetScope",
			Handler:    _FleetManagerService_DisableFleetScope_Handler,
		},
		{
			MethodName: "EnableFleetScope",
			Handler:    _FleetManagerService_EnableFleetScope_Handler,
		},
		{
			MethodName: "GetFleetScope",
			Handler:    _FleetManagerService_GetFleetScope_Handler,
		},
		{
			MethodName: "ListFleetScopes",
			Handler:    _FleetManagerService_ListFleetScopes_Handler,
		},
		{
			MethodName: "RegisterServer",
			Handler:    _FleetManagerService_RegisterServer_Handler,
		},
		{
			MethodName: "UpdateServer",
			Handler:    _FleetManagerService_UpdateServer_Handler,
		},
		{
			MethodName: "DisableServer",
			Handler:    _FleetManagerService_DisableServer_Handler,
		},
		{
			MethodName: "EnableServer",
			Handler:    _FleetManagerService_EnableServer_Handler,
		},
		{
			MethodName: "GetServer",
			Handler:    _FleetManagerService_GetServer_Handler,
		},
		{
			MethodName: "ListServers",
			Handler:    _FleetManagerService_ListServers_Handler,
		},
		{
			MethodName: "RegisterKubernetesCluster",
			Handler:    _FleetManagerService_RegisterKubernetesCluster_Handler,
		},
		{
			MethodName: "UpdateKubernetesCluster",
			Handler:    _FleetManagerService_UpdateKubernetesCluster_Handler,
		},
		{
			MethodName: "DisableKubernetesCluster",
			Handler:    _FleetManagerService_DisableKubernetesCluster_Handler,
		},
		{
			MethodName: "EnableKubernetesCluster",
			Handler:    _FleetManagerService_EnableKubernetesCluster_Handler,
		},
		{
			MethodName: "GetKubernetesCluster",
			Handler:    _FleetManagerService_GetKubernetesCluster_Handler,
		},
		{
			MethodName: "ListKubernetesClusters",
			Handler:    _FleetManagerService_ListKubernetesClusters_Handler,
		},
		{
			MethodName: "RunClusterConnectivityCheck",
			Handler:    _FleetManagerService_RunClusterConnectivityCheck_Handler,
		},
		{
			MethodName: "GetClusterHealthSnapshot",
			Handler:    _FleetManagerService_GetClusterHealthSnapshot_Handler,
		},
		{
			MethodName: "ListClusterHealthSnapshots",
			Handler:    _FleetManagerService_ListClusterHealthSnapshots_Handler,
		},
		{
			MethodName: "PutPlacementRule",
			Handler:    _FleetManagerService_PutPlacementRule_Handler,
		},
		{
			MethodName: "GetPlacementRule",
			Handler:    _FleetManagerService_GetPlacementRule_Handler,
		},
		{
			MethodName: "ListPlacementRules",
			Handler:    _FleetManagerService_ListPlacementRules_Handler,
		},
		{
			MethodName: "ResolvePlacement",
			Handler:    _FleetManagerService_ResolvePlacement_Handler,
		},
		{
			MethodName: "GetPlacementDecision",
			Handler:    _FleetManagerService_GetPlacementDecision_Handler,
		},
		{
			MethodName: "ListPlacementDecisions",
			Handler:    _FleetManagerService_ListPlacementDecisions_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "kodex/fleet/v1/fleet_manager.proto",
}
