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

package providersv1

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 (
	ProviderHubService_IngestWebhookEvent_FullMethodName                  = "/kodex.providers.v1.ProviderHubService/IngestWebhookEvent"
	ProviderHubService_GetWebhookEvent_FullMethodName                     = "/kodex.providers.v1.ProviderHubService/GetWebhookEvent"
	ProviderHubService_ListWebhookEvents_FullMethodName                   = "/kodex.providers.v1.ProviderHubService/ListWebhookEvents"
	ProviderHubService_RetryWebhookEventProcessing_FullMethodName         = "/kodex.providers.v1.ProviderHubService/RetryWebhookEventProcessing"
	ProviderHubService_CleanupExpiredWebhookPayloads_FullMethodName       = "/kodex.providers.v1.ProviderHubService/CleanupExpiredWebhookPayloads"
	ProviderHubService_GetWorkItemProjection_FullMethodName               = "/kodex.providers.v1.ProviderHubService/GetWorkItemProjection"
	ProviderHubService_FindWorkItemByProviderRef_FullMethodName           = "/kodex.providers.v1.ProviderHubService/FindWorkItemByProviderRef"
	ProviderHubService_ListWorkItemProjections_FullMethodName             = "/kodex.providers.v1.ProviderHubService/ListWorkItemProjections"
	ProviderHubService_ListComments_FullMethodName                        = "/kodex.providers.v1.ProviderHubService/ListComments"
	ProviderHubService_ListRelationships_FullMethodName                   = "/kodex.providers.v1.ProviderHubService/ListRelationships"
	ProviderHubService_GetRepositoryMergeSignal_FullMethodName            = "/kodex.providers.v1.ProviderHubService/GetRepositoryMergeSignal"
	ProviderHubService_ListRepositoryMergeSignals_FullMethodName          = "/kodex.providers.v1.ProviderHubService/ListRepositoryMergeSignals"
	ProviderHubService_GetRepositoryChangeSignal_FullMethodName           = "/kodex.providers.v1.ProviderHubService/GetRepositoryChangeSignal"
	ProviderHubService_ListRepositoryChangeSignals_FullMethodName         = "/kodex.providers.v1.ProviderHubService/ListRepositoryChangeSignals"
	ProviderHubService_GetRepositoryAdoptionScanSnapshot_FullMethodName   = "/kodex.providers.v1.ProviderHubService/GetRepositoryAdoptionScanSnapshot"
	ProviderHubService_ListRepositoryAdoptionScanSnapshots_FullMethodName = "/kodex.providers.v1.ProviderHubService/ListRepositoryAdoptionScanSnapshots"
	ProviderHubService_RegisterProviderArtifactSignal_FullMethodName      = "/kodex.providers.v1.ProviderHubService/RegisterProviderArtifactSignal"
	ProviderHubService_EnqueueReconciliation_FullMethodName               = "/kodex.providers.v1.ProviderHubService/EnqueueReconciliation"
	ProviderHubService_RunReconciliationBatch_FullMethodName              = "/kodex.providers.v1.ProviderHubService/RunReconciliationBatch"
	ProviderHubService_GetSyncCursor_FullMethodName                       = "/kodex.providers.v1.ProviderHubService/GetSyncCursor"
	ProviderHubService_ListSyncCursors_FullMethodName                     = "/kodex.providers.v1.ProviderHubService/ListSyncCursors"
	ProviderHubService_CreateIssue_FullMethodName                         = "/kodex.providers.v1.ProviderHubService/CreateIssue"
	ProviderHubService_UpdateIssue_FullMethodName                         = "/kodex.providers.v1.ProviderHubService/UpdateIssue"
	ProviderHubService_CreateComment_FullMethodName                       = "/kodex.providers.v1.ProviderHubService/CreateComment"
	ProviderHubService_UpdateComment_FullMethodName                       = "/kodex.providers.v1.ProviderHubService/UpdateComment"
	ProviderHubService_CreatePullRequest_FullMethodName                   = "/kodex.providers.v1.ProviderHubService/CreatePullRequest"
	ProviderHubService_CreateRepository_FullMethodName                    = "/kodex.providers.v1.ProviderHubService/CreateRepository"
	ProviderHubService_CreateBootstrapPullRequest_FullMethodName          = "/kodex.providers.v1.ProviderHubService/CreateBootstrapPullRequest"
	ProviderHubService_CreateAdoptionPullRequest_FullMethodName           = "/kodex.providers.v1.ProviderHubService/CreateAdoptionPullRequest"
	ProviderHubService_ScanRepositoryForAdoption_FullMethodName           = "/kodex.providers.v1.ProviderHubService/ScanRepositoryForAdoption"
	ProviderHubService_UpdatePullRequest_FullMethodName                   = "/kodex.providers.v1.ProviderHubService/UpdatePullRequest"
	ProviderHubService_CreateReviewSignal_FullMethodName                  = "/kodex.providers.v1.ProviderHubService/CreateReviewSignal"
	ProviderHubService_UpdateRelationship_FullMethodName                  = "/kodex.providers.v1.ProviderHubService/UpdateRelationship"
	ProviderHubService_GetProviderAccountRuntimeState_FullMethodName      = "/kodex.providers.v1.ProviderHubService/GetProviderAccountRuntimeState"
	ProviderHubService_ListProviderAccountRuntimeStates_FullMethodName    = "/kodex.providers.v1.ProviderHubService/ListProviderAccountRuntimeStates"
	ProviderHubService_RecordProviderLimitSnapshot_FullMethodName         = "/kodex.providers.v1.ProviderHubService/RecordProviderLimitSnapshot"
	ProviderHubService_ListProviderLimitSnapshots_FullMethodName          = "/kodex.providers.v1.ProviderHubService/ListProviderLimitSnapshots"
	ProviderHubService_ListProviderOperations_FullMethodName              = "/kodex.providers.v1.ProviderHubService/ListProviderOperations"
)

// ProviderHubServiceClient is the client API for ProviderHubService 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.
//
// ProviderHubService is the stable v1 inter-service contract for provider-native
// work items. It covers the command and read surface agreed in
// docs/domains/provider-native-work-items/architecture/api_contract.md.
type ProviderHubServiceClient interface {
	// IngestWebhookEvent stores a verified provider webhook from the edge gateway.
	IngestWebhookEvent(ctx context.Context, in *IngestWebhookEventRequest, opts ...grpc.CallOption) (*WebhookEventResponse, error)
	// GetWebhookEvent returns safe webhook diagnostics.
	GetWebhookEvent(ctx context.Context, in *GetWebhookEventRequest, opts ...grpc.CallOption) (*WebhookEventResponse, error)
	// ListWebhookEvents returns stored webhooks with operational filters.
	ListWebhookEvents(ctx context.Context, in *ListWebhookEventsRequest, opts ...grpc.CallOption) (*ListWebhookEventsResponse, error)
	// RetryWebhookEventProcessing enqueues a stored webhook for repeated normalization.
	RetryWebhookEventProcessing(ctx context.Context, in *RetryWebhookEventProcessingRequest, opts ...grpc.CallOption) (*WebhookEventResponse, error)
	// CleanupExpiredWebhookPayloads removes expired retryable provider payloads from the inbox.
	CleanupExpiredWebhookPayloads(ctx context.Context, in *CleanupExpiredWebhookPayloadsRequest, opts ...grpc.CallOption) (*CleanupExpiredWebhookPayloadsResponse, error)
	// GetWorkItemProjection returns a normalized Issue or PR/MR projection.
	GetWorkItemProjection(ctx context.Context, in *GetWorkItemProjectionRequest, opts ...grpc.CallOption) (*WorkItemProjectionResponse, error)
	// FindWorkItemByProviderRef finds a projection by provider-native reference.
	FindWorkItemByProviderRef(ctx context.Context, in *FindWorkItemByProviderRefRequest, opts ...grpc.CallOption) (*WorkItemProjectionResponse, error)
	// ListWorkItemProjections returns normalized work items by project, repository and state.
	ListWorkItemProjections(ctx context.Context, in *ListWorkItemProjectionsRequest, opts ...grpc.CallOption) (*ListWorkItemProjectionsResponse, error)
	// ListComments returns normalized comments, mentions and review signals for a work item.
	ListComments(ctx context.Context, in *ListCommentsRequest, opts ...grpc.CallOption) (*ListCommentsResponse, error)
	// ListRelationships returns normalized provider-native relationships.
	ListRelationships(ctx context.Context, in *ListRelationshipsRequest, opts ...grpc.CallOption) (*ListRelationshipsResponse, error)
	// GetRepositoryMergeSignal returns one safe provider-owned bootstrap/adoption merge signal.
	GetRepositoryMergeSignal(ctx context.Context, in *GetRepositoryMergeSignalRequest, opts ...grpc.CallOption) (*RepositoryMergeSignalResponse, error)
	// ListRepositoryMergeSignals returns safe provider-owned merge signals by repository/project context.
	ListRepositoryMergeSignals(ctx context.Context, in *ListRepositoryMergeSignalsRequest, opts ...grpc.CallOption) (*ListRepositoryMergeSignalsResponse, error)
	// GetRepositoryChangeSignal returns one safe provider-owned repository change signal.
	GetRepositoryChangeSignal(ctx context.Context, in *GetRepositoryChangeSignalRequest, opts ...grpc.CallOption) (*RepositoryChangeSignalResponse, error)
	// ListRepositoryChangeSignals returns safe provider-owned repository change signals by repository/project context.
	ListRepositoryChangeSignals(ctx context.Context, in *ListRepositoryChangeSignalsRequest, opts ...grpc.CallOption) (*ListRepositoryChangeSignalsResponse, error)
	// GetRepositoryAdoptionScanSnapshot returns one safe provider-side adoption scan snapshot.
	GetRepositoryAdoptionScanSnapshot(ctx context.Context, in *GetRepositoryAdoptionScanSnapshotRequest, opts ...grpc.CallOption) (*RepositoryAdoptionScanSnapshotResponse, error)
	// ListRepositoryAdoptionScanSnapshots returns safe provider-side adoption scan snapshots by repository context.
	ListRepositoryAdoptionScanSnapshots(ctx context.Context, in *ListRepositoryAdoptionScanSnapshotsRequest, opts ...grpc.CallOption) (*ListRepositoryAdoptionScanSnapshotsResponse, error)
	// RegisterProviderArtifactSignal accepts an accelerating signal from an agent or manager.
	RegisterProviderArtifactSignal(ctx context.Context, in *RegisterProviderArtifactSignalRequest, opts ...grpc.CallOption) (*ProviderArtifactSignalResponse, error)
	// EnqueueReconciliation schedules a reconciliation scope.
	EnqueueReconciliation(ctx context.Context, in *EnqueueReconciliationRequest, opts ...grpc.CallOption) (*ReconciliationRequestResponse, error)
	// RunReconciliationBatch processes a leased reconciliation scope.
	RunReconciliationBatch(ctx context.Context, in *RunReconciliationBatchRequest, opts ...grpc.CallOption) (*RunReconciliationBatchResponse, error)
	// GetSyncCursor returns reconciliation cursor state.
	GetSyncCursor(ctx context.Context, in *GetSyncCursorRequest, opts ...grpc.CallOption) (*SyncCursorResponse, error)
	// ListSyncCursors returns reconciliation cursors by scope and health.
	ListSyncCursors(ctx context.Context, in *ListSyncCursorsRequest, opts ...grpc.CallOption) (*ListSyncCursorsResponse, error)
	// CreateIssue creates a provider-native Issue through a managed external account.
	CreateIssue(ctx context.Context, in *CreateIssueRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error)
	// UpdateIssue updates allowed Issue fields through a managed external account.
	UpdateIssue(ctx context.Context, in *UpdateIssueRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error)
	// CreateComment creates a provider-native comment.
	CreateComment(ctx context.Context, in *CreateCommentRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error)
	// UpdateComment updates a platform-owned comment when policy allows it.
	UpdateComment(ctx context.Context, in *UpdateCommentRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error)
	// CreatePullRequest creates a provider-native PR/MR for a platform scenario.
	CreatePullRequest(ctx context.Context, in *CreatePullRequestRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error)
	// CreateRepository creates a provider-native repository and prepares an initial provider default branch.
	CreateRepository(ctx context.Context, in *CreateRepositoryRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error)
	// CreateBootstrapPullRequest creates or updates bootstrap branch/PR for an existing bootstrap-ready repository.
	CreateBootstrapPullRequest(ctx context.Context, in *CreateBootstrapPullRequestRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error)
	// CreateAdoptionPullRequest creates or updates adoption branch/PR for an existing repository.
	CreateAdoptionPullRequest(ctx context.Context, in *CreateAdoptionPullRequestRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error)
	// ScanRepositoryForAdoption records a lightweight provider-side repository snapshot for adoption planning.
	ScanRepositoryForAdoption(ctx context.Context, in *ScanRepositoryForAdoptionRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error)
	// UpdatePullRequest updates allowed PR/MR fields through a managed external account.
	UpdatePullRequest(ctx context.Context, in *UpdatePullRequestRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error)
	// CreateReviewSignal creates a review comment, approval or changes-request signal.
	CreateReviewSignal(ctx context.Context, in *CreateReviewSignalRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error)
	// UpdateRelationship stores or updates a provider-native relationship where supported.
	UpdateRelationship(ctx context.Context, in *UpdateRelationshipRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error)
	// GetProviderAccountRuntimeState returns provider runtime state for one external account.
	GetProviderAccountRuntimeState(ctx context.Context, in *GetProviderAccountRuntimeStateRequest, opts ...grpc.CallOption) (*ProviderAccountRuntimeStateResponse, error)
	// ListProviderAccountRuntimeStates returns provider runtime states by provider or scope.
	ListProviderAccountRuntimeStates(ctx context.Context, in *ListProviderAccountRuntimeStatesRequest, opts ...grpc.CallOption) (*ListProviderAccountRuntimeStatesResponse, error)
	// RecordProviderLimitSnapshot records known provider limits after an operation or signal.
	RecordProviderLimitSnapshot(ctx context.Context, in *RecordProviderLimitSnapshotRequest, opts ...grpc.CallOption) (*ProviderLimitSnapshotResponse, error)
	// ListProviderLimitSnapshots returns recorded provider limit snapshots.
	ListProviderLimitSnapshots(ctx context.Context, in *ListProviderLimitSnapshotsRequest, opts ...grpc.CallOption) (*ListProviderLimitSnapshotsResponse, error)
	// ListProviderOperations returns the operation log for diagnostics and audit.
	ListProviderOperations(ctx context.Context, in *ListProviderOperationsRequest, opts ...grpc.CallOption) (*ListProviderOperationsResponse, error)
}

type providerHubServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewProviderHubServiceClient(cc grpc.ClientConnInterface) ProviderHubServiceClient {
	return &providerHubServiceClient{cc}
}

func (c *providerHubServiceClient) IngestWebhookEvent(ctx context.Context, in *IngestWebhookEventRequest, opts ...grpc.CallOption) (*WebhookEventResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(WebhookEventResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_IngestWebhookEvent_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) GetWebhookEvent(ctx context.Context, in *GetWebhookEventRequest, opts ...grpc.CallOption) (*WebhookEventResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(WebhookEventResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_GetWebhookEvent_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) ListWebhookEvents(ctx context.Context, in *ListWebhookEventsRequest, opts ...grpc.CallOption) (*ListWebhookEventsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListWebhookEventsResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_ListWebhookEvents_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) RetryWebhookEventProcessing(ctx context.Context, in *RetryWebhookEventProcessingRequest, opts ...grpc.CallOption) (*WebhookEventResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(WebhookEventResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_RetryWebhookEventProcessing_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) CleanupExpiredWebhookPayloads(ctx context.Context, in *CleanupExpiredWebhookPayloadsRequest, opts ...grpc.CallOption) (*CleanupExpiredWebhookPayloadsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(CleanupExpiredWebhookPayloadsResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_CleanupExpiredWebhookPayloads_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) GetWorkItemProjection(ctx context.Context, in *GetWorkItemProjectionRequest, opts ...grpc.CallOption) (*WorkItemProjectionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(WorkItemProjectionResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_GetWorkItemProjection_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) FindWorkItemByProviderRef(ctx context.Context, in *FindWorkItemByProviderRefRequest, opts ...grpc.CallOption) (*WorkItemProjectionResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(WorkItemProjectionResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_FindWorkItemByProviderRef_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) ListWorkItemProjections(ctx context.Context, in *ListWorkItemProjectionsRequest, opts ...grpc.CallOption) (*ListWorkItemProjectionsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListWorkItemProjectionsResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_ListWorkItemProjections_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) ListComments(ctx context.Context, in *ListCommentsRequest, opts ...grpc.CallOption) (*ListCommentsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListCommentsResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_ListComments_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) ListRelationships(ctx context.Context, in *ListRelationshipsRequest, opts ...grpc.CallOption) (*ListRelationshipsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListRelationshipsResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_ListRelationships_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) GetRepositoryMergeSignal(ctx context.Context, in *GetRepositoryMergeSignalRequest, opts ...grpc.CallOption) (*RepositoryMergeSignalResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(RepositoryMergeSignalResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_GetRepositoryMergeSignal_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) ListRepositoryMergeSignals(ctx context.Context, in *ListRepositoryMergeSignalsRequest, opts ...grpc.CallOption) (*ListRepositoryMergeSignalsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListRepositoryMergeSignalsResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_ListRepositoryMergeSignals_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) GetRepositoryChangeSignal(ctx context.Context, in *GetRepositoryChangeSignalRequest, opts ...grpc.CallOption) (*RepositoryChangeSignalResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(RepositoryChangeSignalResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_GetRepositoryChangeSignal_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) ListRepositoryChangeSignals(ctx context.Context, in *ListRepositoryChangeSignalsRequest, opts ...grpc.CallOption) (*ListRepositoryChangeSignalsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListRepositoryChangeSignalsResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_ListRepositoryChangeSignals_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) GetRepositoryAdoptionScanSnapshot(ctx context.Context, in *GetRepositoryAdoptionScanSnapshotRequest, opts ...grpc.CallOption) (*RepositoryAdoptionScanSnapshotResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(RepositoryAdoptionScanSnapshotResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_GetRepositoryAdoptionScanSnapshot_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) ListRepositoryAdoptionScanSnapshots(ctx context.Context, in *ListRepositoryAdoptionScanSnapshotsRequest, opts ...grpc.CallOption) (*ListRepositoryAdoptionScanSnapshotsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListRepositoryAdoptionScanSnapshotsResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_ListRepositoryAdoptionScanSnapshots_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) RegisterProviderArtifactSignal(ctx context.Context, in *RegisterProviderArtifactSignalRequest, opts ...grpc.CallOption) (*ProviderArtifactSignalResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProviderArtifactSignalResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_RegisterProviderArtifactSignal_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) EnqueueReconciliation(ctx context.Context, in *EnqueueReconciliationRequest, opts ...grpc.CallOption) (*ReconciliationRequestResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ReconciliationRequestResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_EnqueueReconciliation_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) RunReconciliationBatch(ctx context.Context, in *RunReconciliationBatchRequest, opts ...grpc.CallOption) (*RunReconciliationBatchResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(RunReconciliationBatchResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_RunReconciliationBatch_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) GetSyncCursor(ctx context.Context, in *GetSyncCursorRequest, opts ...grpc.CallOption) (*SyncCursorResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SyncCursorResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_GetSyncCursor_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) ListSyncCursors(ctx context.Context, in *ListSyncCursorsRequest, opts ...grpc.CallOption) (*ListSyncCursorsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListSyncCursorsResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_ListSyncCursors_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) CreateIssue(ctx context.Context, in *CreateIssueRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProviderOperationResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_CreateIssue_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) UpdateIssue(ctx context.Context, in *UpdateIssueRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProviderOperationResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_UpdateIssue_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) CreateComment(ctx context.Context, in *CreateCommentRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProviderOperationResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_CreateComment_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) UpdateComment(ctx context.Context, in *UpdateCommentRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProviderOperationResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_UpdateComment_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) CreatePullRequest(ctx context.Context, in *CreatePullRequestRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProviderOperationResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_CreatePullRequest_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) CreateRepository(ctx context.Context, in *CreateRepositoryRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProviderOperationResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_CreateRepository_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) CreateBootstrapPullRequest(ctx context.Context, in *CreateBootstrapPullRequestRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProviderOperationResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_CreateBootstrapPullRequest_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) CreateAdoptionPullRequest(ctx context.Context, in *CreateAdoptionPullRequestRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProviderOperationResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_CreateAdoptionPullRequest_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) ScanRepositoryForAdoption(ctx context.Context, in *ScanRepositoryForAdoptionRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProviderOperationResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_ScanRepositoryForAdoption_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) UpdatePullRequest(ctx context.Context, in *UpdatePullRequestRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProviderOperationResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_UpdatePullRequest_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) CreateReviewSignal(ctx context.Context, in *CreateReviewSignalRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProviderOperationResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_CreateReviewSignal_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) UpdateRelationship(ctx context.Context, in *UpdateRelationshipRequest, opts ...grpc.CallOption) (*ProviderOperationResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProviderOperationResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_UpdateRelationship_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) GetProviderAccountRuntimeState(ctx context.Context, in *GetProviderAccountRuntimeStateRequest, opts ...grpc.CallOption) (*ProviderAccountRuntimeStateResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProviderAccountRuntimeStateResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_GetProviderAccountRuntimeState_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) ListProviderAccountRuntimeStates(ctx context.Context, in *ListProviderAccountRuntimeStatesRequest, opts ...grpc.CallOption) (*ListProviderAccountRuntimeStatesResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListProviderAccountRuntimeStatesResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_ListProviderAccountRuntimeStates_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) RecordProviderLimitSnapshot(ctx context.Context, in *RecordProviderLimitSnapshotRequest, opts ...grpc.CallOption) (*ProviderLimitSnapshotResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ProviderLimitSnapshotResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_RecordProviderLimitSnapshot_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) ListProviderLimitSnapshots(ctx context.Context, in *ListProviderLimitSnapshotsRequest, opts ...grpc.CallOption) (*ListProviderLimitSnapshotsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListProviderLimitSnapshotsResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_ListProviderLimitSnapshots_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *providerHubServiceClient) ListProviderOperations(ctx context.Context, in *ListProviderOperationsRequest, opts ...grpc.CallOption) (*ListProviderOperationsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListProviderOperationsResponse)
	err := c.cc.Invoke(ctx, ProviderHubService_ListProviderOperations_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// ProviderHubServiceServer is the server API for ProviderHubService service.
// All implementations must embed UnimplementedProviderHubServiceServer
// for forward compatibility.
//
// ProviderHubService is the stable v1 inter-service contract for provider-native
// work items. It covers the command and read surface agreed in
// docs/domains/provider-native-work-items/architecture/api_contract.md.
type ProviderHubServiceServer interface {
	// IngestWebhookEvent stores a verified provider webhook from the edge gateway.
	IngestWebhookEvent(context.Context, *IngestWebhookEventRequest) (*WebhookEventResponse, error)
	// GetWebhookEvent returns safe webhook diagnostics.
	GetWebhookEvent(context.Context, *GetWebhookEventRequest) (*WebhookEventResponse, error)
	// ListWebhookEvents returns stored webhooks with operational filters.
	ListWebhookEvents(context.Context, *ListWebhookEventsRequest) (*ListWebhookEventsResponse, error)
	// RetryWebhookEventProcessing enqueues a stored webhook for repeated normalization.
	RetryWebhookEventProcessing(context.Context, *RetryWebhookEventProcessingRequest) (*WebhookEventResponse, error)
	// CleanupExpiredWebhookPayloads removes expired retryable provider payloads from the inbox.
	CleanupExpiredWebhookPayloads(context.Context, *CleanupExpiredWebhookPayloadsRequest) (*CleanupExpiredWebhookPayloadsResponse, error)
	// GetWorkItemProjection returns a normalized Issue or PR/MR projection.
	GetWorkItemProjection(context.Context, *GetWorkItemProjectionRequest) (*WorkItemProjectionResponse, error)
	// FindWorkItemByProviderRef finds a projection by provider-native reference.
	FindWorkItemByProviderRef(context.Context, *FindWorkItemByProviderRefRequest) (*WorkItemProjectionResponse, error)
	// ListWorkItemProjections returns normalized work items by project, repository and state.
	ListWorkItemProjections(context.Context, *ListWorkItemProjectionsRequest) (*ListWorkItemProjectionsResponse, error)
	// ListComments returns normalized comments, mentions and review signals for a work item.
	ListComments(context.Context, *ListCommentsRequest) (*ListCommentsResponse, error)
	// ListRelationships returns normalized provider-native relationships.
	ListRelationships(context.Context, *ListRelationshipsRequest) (*ListRelationshipsResponse, error)
	// GetRepositoryMergeSignal returns one safe provider-owned bootstrap/adoption merge signal.
	GetRepositoryMergeSignal(context.Context, *GetRepositoryMergeSignalRequest) (*RepositoryMergeSignalResponse, error)
	// ListRepositoryMergeSignals returns safe provider-owned merge signals by repository/project context.
	ListRepositoryMergeSignals(context.Context, *ListRepositoryMergeSignalsRequest) (*ListRepositoryMergeSignalsResponse, error)
	// GetRepositoryChangeSignal returns one safe provider-owned repository change signal.
	GetRepositoryChangeSignal(context.Context, *GetRepositoryChangeSignalRequest) (*RepositoryChangeSignalResponse, error)
	// ListRepositoryChangeSignals returns safe provider-owned repository change signals by repository/project context.
	ListRepositoryChangeSignals(context.Context, *ListRepositoryChangeSignalsRequest) (*ListRepositoryChangeSignalsResponse, error)
	// GetRepositoryAdoptionScanSnapshot returns one safe provider-side adoption scan snapshot.
	GetRepositoryAdoptionScanSnapshot(context.Context, *GetRepositoryAdoptionScanSnapshotRequest) (*RepositoryAdoptionScanSnapshotResponse, error)
	// ListRepositoryAdoptionScanSnapshots returns safe provider-side adoption scan snapshots by repository context.
	ListRepositoryAdoptionScanSnapshots(context.Context, *ListRepositoryAdoptionScanSnapshotsRequest) (*ListRepositoryAdoptionScanSnapshotsResponse, error)
	// RegisterProviderArtifactSignal accepts an accelerating signal from an agent or manager.
	RegisterProviderArtifactSignal(context.Context, *RegisterProviderArtifactSignalRequest) (*ProviderArtifactSignalResponse, error)
	// EnqueueReconciliation schedules a reconciliation scope.
	EnqueueReconciliation(context.Context, *EnqueueReconciliationRequest) (*ReconciliationRequestResponse, error)
	// RunReconciliationBatch processes a leased reconciliation scope.
	RunReconciliationBatch(context.Context, *RunReconciliationBatchRequest) (*RunReconciliationBatchResponse, error)
	// GetSyncCursor returns reconciliation cursor state.
	GetSyncCursor(context.Context, *GetSyncCursorRequest) (*SyncCursorResponse, error)
	// ListSyncCursors returns reconciliation cursors by scope and health.
	ListSyncCursors(context.Context, *ListSyncCursorsRequest) (*ListSyncCursorsResponse, error)
	// CreateIssue creates a provider-native Issue through a managed external account.
	CreateIssue(context.Context, *CreateIssueRequest) (*ProviderOperationResponse, error)
	// UpdateIssue updates allowed Issue fields through a managed external account.
	UpdateIssue(context.Context, *UpdateIssueRequest) (*ProviderOperationResponse, error)
	// CreateComment creates a provider-native comment.
	CreateComment(context.Context, *CreateCommentRequest) (*ProviderOperationResponse, error)
	// UpdateComment updates a platform-owned comment when policy allows it.
	UpdateComment(context.Context, *UpdateCommentRequest) (*ProviderOperationResponse, error)
	// CreatePullRequest creates a provider-native PR/MR for a platform scenario.
	CreatePullRequest(context.Context, *CreatePullRequestRequest) (*ProviderOperationResponse, error)
	// CreateRepository creates a provider-native repository and prepares an initial provider default branch.
	CreateRepository(context.Context, *CreateRepositoryRequest) (*ProviderOperationResponse, error)
	// CreateBootstrapPullRequest creates or updates bootstrap branch/PR for an existing bootstrap-ready repository.
	CreateBootstrapPullRequest(context.Context, *CreateBootstrapPullRequestRequest) (*ProviderOperationResponse, error)
	// CreateAdoptionPullRequest creates or updates adoption branch/PR for an existing repository.
	CreateAdoptionPullRequest(context.Context, *CreateAdoptionPullRequestRequest) (*ProviderOperationResponse, error)
	// ScanRepositoryForAdoption records a lightweight provider-side repository snapshot for adoption planning.
	ScanRepositoryForAdoption(context.Context, *ScanRepositoryForAdoptionRequest) (*ProviderOperationResponse, error)
	// UpdatePullRequest updates allowed PR/MR fields through a managed external account.
	UpdatePullRequest(context.Context, *UpdatePullRequestRequest) (*ProviderOperationResponse, error)
	// CreateReviewSignal creates a review comment, approval or changes-request signal.
	CreateReviewSignal(context.Context, *CreateReviewSignalRequest) (*ProviderOperationResponse, error)
	// UpdateRelationship stores or updates a provider-native relationship where supported.
	UpdateRelationship(context.Context, *UpdateRelationshipRequest) (*ProviderOperationResponse, error)
	// GetProviderAccountRuntimeState returns provider runtime state for one external account.
	GetProviderAccountRuntimeState(context.Context, *GetProviderAccountRuntimeStateRequest) (*ProviderAccountRuntimeStateResponse, error)
	// ListProviderAccountRuntimeStates returns provider runtime states by provider or scope.
	ListProviderAccountRuntimeStates(context.Context, *ListProviderAccountRuntimeStatesRequest) (*ListProviderAccountRuntimeStatesResponse, error)
	// RecordProviderLimitSnapshot records known provider limits after an operation or signal.
	RecordProviderLimitSnapshot(context.Context, *RecordProviderLimitSnapshotRequest) (*ProviderLimitSnapshotResponse, error)
	// ListProviderLimitSnapshots returns recorded provider limit snapshots.
	ListProviderLimitSnapshots(context.Context, *ListProviderLimitSnapshotsRequest) (*ListProviderLimitSnapshotsResponse, error)
	// ListProviderOperations returns the operation log for diagnostics and audit.
	ListProviderOperations(context.Context, *ListProviderOperationsRequest) (*ListProviderOperationsResponse, error)
	mustEmbedUnimplementedProviderHubServiceServer()
}

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

func (UnimplementedProviderHubServiceServer) IngestWebhookEvent(context.Context, *IngestWebhookEventRequest) (*WebhookEventResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method IngestWebhookEvent not implemented")
}
func (UnimplementedProviderHubServiceServer) GetWebhookEvent(context.Context, *GetWebhookEventRequest) (*WebhookEventResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetWebhookEvent not implemented")
}
func (UnimplementedProviderHubServiceServer) ListWebhookEvents(context.Context, *ListWebhookEventsRequest) (*ListWebhookEventsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListWebhookEvents not implemented")
}
func (UnimplementedProviderHubServiceServer) RetryWebhookEventProcessing(context.Context, *RetryWebhookEventProcessingRequest) (*WebhookEventResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RetryWebhookEventProcessing not implemented")
}
func (UnimplementedProviderHubServiceServer) CleanupExpiredWebhookPayloads(context.Context, *CleanupExpiredWebhookPayloadsRequest) (*CleanupExpiredWebhookPayloadsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CleanupExpiredWebhookPayloads not implemented")
}
func (UnimplementedProviderHubServiceServer) GetWorkItemProjection(context.Context, *GetWorkItemProjectionRequest) (*WorkItemProjectionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetWorkItemProjection not implemented")
}
func (UnimplementedProviderHubServiceServer) FindWorkItemByProviderRef(context.Context, *FindWorkItemByProviderRefRequest) (*WorkItemProjectionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method FindWorkItemByProviderRef not implemented")
}
func (UnimplementedProviderHubServiceServer) ListWorkItemProjections(context.Context, *ListWorkItemProjectionsRequest) (*ListWorkItemProjectionsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListWorkItemProjections not implemented")
}
func (UnimplementedProviderHubServiceServer) ListComments(context.Context, *ListCommentsRequest) (*ListCommentsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListComments not implemented")
}
func (UnimplementedProviderHubServiceServer) ListRelationships(context.Context, *ListRelationshipsRequest) (*ListRelationshipsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListRelationships not implemented")
}
func (UnimplementedProviderHubServiceServer) GetRepositoryMergeSignal(context.Context, *GetRepositoryMergeSignalRequest) (*RepositoryMergeSignalResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetRepositoryMergeSignal not implemented")
}
func (UnimplementedProviderHubServiceServer) ListRepositoryMergeSignals(context.Context, *ListRepositoryMergeSignalsRequest) (*ListRepositoryMergeSignalsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListRepositoryMergeSignals not implemented")
}
func (UnimplementedProviderHubServiceServer) GetRepositoryChangeSignal(context.Context, *GetRepositoryChangeSignalRequest) (*RepositoryChangeSignalResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetRepositoryChangeSignal not implemented")
}
func (UnimplementedProviderHubServiceServer) ListRepositoryChangeSignals(context.Context, *ListRepositoryChangeSignalsRequest) (*ListRepositoryChangeSignalsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListRepositoryChangeSignals not implemented")
}
func (UnimplementedProviderHubServiceServer) GetRepositoryAdoptionScanSnapshot(context.Context, *GetRepositoryAdoptionScanSnapshotRequest) (*RepositoryAdoptionScanSnapshotResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetRepositoryAdoptionScanSnapshot not implemented")
}
func (UnimplementedProviderHubServiceServer) ListRepositoryAdoptionScanSnapshots(context.Context, *ListRepositoryAdoptionScanSnapshotsRequest) (*ListRepositoryAdoptionScanSnapshotsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListRepositoryAdoptionScanSnapshots not implemented")
}
func (UnimplementedProviderHubServiceServer) RegisterProviderArtifactSignal(context.Context, *RegisterProviderArtifactSignalRequest) (*ProviderArtifactSignalResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RegisterProviderArtifactSignal not implemented")
}
func (UnimplementedProviderHubServiceServer) EnqueueReconciliation(context.Context, *EnqueueReconciliationRequest) (*ReconciliationRequestResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method EnqueueReconciliation not implemented")
}
func (UnimplementedProviderHubServiceServer) RunReconciliationBatch(context.Context, *RunReconciliationBatchRequest) (*RunReconciliationBatchResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RunReconciliationBatch not implemented")
}
func (UnimplementedProviderHubServiceServer) GetSyncCursor(context.Context, *GetSyncCursorRequest) (*SyncCursorResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetSyncCursor not implemented")
}
func (UnimplementedProviderHubServiceServer) ListSyncCursors(context.Context, *ListSyncCursorsRequest) (*ListSyncCursorsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListSyncCursors not implemented")
}
func (UnimplementedProviderHubServiceServer) CreateIssue(context.Context, *CreateIssueRequest) (*ProviderOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateIssue not implemented")
}
func (UnimplementedProviderHubServiceServer) UpdateIssue(context.Context, *UpdateIssueRequest) (*ProviderOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateIssue not implemented")
}
func (UnimplementedProviderHubServiceServer) CreateComment(context.Context, *CreateCommentRequest) (*ProviderOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateComment not implemented")
}
func (UnimplementedProviderHubServiceServer) UpdateComment(context.Context, *UpdateCommentRequest) (*ProviderOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateComment not implemented")
}
func (UnimplementedProviderHubServiceServer) CreatePullRequest(context.Context, *CreatePullRequestRequest) (*ProviderOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreatePullRequest not implemented")
}
func (UnimplementedProviderHubServiceServer) CreateRepository(context.Context, *CreateRepositoryRequest) (*ProviderOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateRepository not implemented")
}
func (UnimplementedProviderHubServiceServer) CreateBootstrapPullRequest(context.Context, *CreateBootstrapPullRequestRequest) (*ProviderOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateBootstrapPullRequest not implemented")
}
func (UnimplementedProviderHubServiceServer) CreateAdoptionPullRequest(context.Context, *CreateAdoptionPullRequestRequest) (*ProviderOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateAdoptionPullRequest not implemented")
}
func (UnimplementedProviderHubServiceServer) ScanRepositoryForAdoption(context.Context, *ScanRepositoryForAdoptionRequest) (*ProviderOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ScanRepositoryForAdoption not implemented")
}
func (UnimplementedProviderHubServiceServer) UpdatePullRequest(context.Context, *UpdatePullRequestRequest) (*ProviderOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdatePullRequest not implemented")
}
func (UnimplementedProviderHubServiceServer) CreateReviewSignal(context.Context, *CreateReviewSignalRequest) (*ProviderOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateReviewSignal not implemented")
}
func (UnimplementedProviderHubServiceServer) UpdateRelationship(context.Context, *UpdateRelationshipRequest) (*ProviderOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateRelationship not implemented")
}
func (UnimplementedProviderHubServiceServer) GetProviderAccountRuntimeState(context.Context, *GetProviderAccountRuntimeStateRequest) (*ProviderAccountRuntimeStateResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetProviderAccountRuntimeState not implemented")
}
func (UnimplementedProviderHubServiceServer) ListProviderAccountRuntimeStates(context.Context, *ListProviderAccountRuntimeStatesRequest) (*ListProviderAccountRuntimeStatesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListProviderAccountRuntimeStates not implemented")
}
func (UnimplementedProviderHubServiceServer) RecordProviderLimitSnapshot(context.Context, *RecordProviderLimitSnapshotRequest) (*ProviderLimitSnapshotResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RecordProviderLimitSnapshot not implemented")
}
func (UnimplementedProviderHubServiceServer) ListProviderLimitSnapshots(context.Context, *ListProviderLimitSnapshotsRequest) (*ListProviderLimitSnapshotsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListProviderLimitSnapshots not implemented")
}
func (UnimplementedProviderHubServiceServer) ListProviderOperations(context.Context, *ListProviderOperationsRequest) (*ListProviderOperationsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListProviderOperations not implemented")
}
func (UnimplementedProviderHubServiceServer) mustEmbedUnimplementedProviderHubServiceServer() {}
func (UnimplementedProviderHubServiceServer) testEmbeddedByValue()                            {}

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

func RegisterProviderHubServiceServer(s grpc.ServiceRegistrar, srv ProviderHubServiceServer) {
	// If the following call pancis, it indicates UnimplementedProviderHubServiceServer 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(&ProviderHubService_ServiceDesc, srv)
}

func _ProviderHubService_IngestWebhookEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IngestWebhookEventRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).IngestWebhookEvent(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_IngestWebhookEvent_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).IngestWebhookEvent(ctx, req.(*IngestWebhookEventRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_GetWebhookEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetWebhookEventRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).GetWebhookEvent(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_GetWebhookEvent_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).GetWebhookEvent(ctx, req.(*GetWebhookEventRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_ListWebhookEvents_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListWebhookEventsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).ListWebhookEvents(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_ListWebhookEvents_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).ListWebhookEvents(ctx, req.(*ListWebhookEventsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_RetryWebhookEventProcessing_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RetryWebhookEventProcessingRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).RetryWebhookEventProcessing(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_RetryWebhookEventProcessing_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).RetryWebhookEventProcessing(ctx, req.(*RetryWebhookEventProcessingRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_CleanupExpiredWebhookPayloads_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CleanupExpiredWebhookPayloadsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).CleanupExpiredWebhookPayloads(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_CleanupExpiredWebhookPayloads_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).CleanupExpiredWebhookPayloads(ctx, req.(*CleanupExpiredWebhookPayloadsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_GetWorkItemProjection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetWorkItemProjectionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).GetWorkItemProjection(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_GetWorkItemProjection_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).GetWorkItemProjection(ctx, req.(*GetWorkItemProjectionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_FindWorkItemByProviderRef_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(FindWorkItemByProviderRefRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).FindWorkItemByProviderRef(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_FindWorkItemByProviderRef_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).FindWorkItemByProviderRef(ctx, req.(*FindWorkItemByProviderRefRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_ListWorkItemProjections_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListWorkItemProjectionsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).ListWorkItemProjections(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_ListWorkItemProjections_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).ListWorkItemProjections(ctx, req.(*ListWorkItemProjectionsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_ListComments_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListCommentsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).ListComments(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_ListComments_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).ListComments(ctx, req.(*ListCommentsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_ListRelationships_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListRelationshipsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).ListRelationships(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_ListRelationships_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).ListRelationships(ctx, req.(*ListRelationshipsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_GetRepositoryMergeSignal_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetRepositoryMergeSignalRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).GetRepositoryMergeSignal(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_GetRepositoryMergeSignal_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).GetRepositoryMergeSignal(ctx, req.(*GetRepositoryMergeSignalRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_ListRepositoryMergeSignals_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListRepositoryMergeSignalsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).ListRepositoryMergeSignals(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_ListRepositoryMergeSignals_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).ListRepositoryMergeSignals(ctx, req.(*ListRepositoryMergeSignalsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_GetRepositoryChangeSignal_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetRepositoryChangeSignalRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).GetRepositoryChangeSignal(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_GetRepositoryChangeSignal_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).GetRepositoryChangeSignal(ctx, req.(*GetRepositoryChangeSignalRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_ListRepositoryChangeSignals_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListRepositoryChangeSignalsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).ListRepositoryChangeSignals(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_ListRepositoryChangeSignals_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).ListRepositoryChangeSignals(ctx, req.(*ListRepositoryChangeSignalsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_GetRepositoryAdoptionScanSnapshot_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetRepositoryAdoptionScanSnapshotRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).GetRepositoryAdoptionScanSnapshot(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_GetRepositoryAdoptionScanSnapshot_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).GetRepositoryAdoptionScanSnapshot(ctx, req.(*GetRepositoryAdoptionScanSnapshotRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_ListRepositoryAdoptionScanSnapshots_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListRepositoryAdoptionScanSnapshotsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).ListRepositoryAdoptionScanSnapshots(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_ListRepositoryAdoptionScanSnapshots_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).ListRepositoryAdoptionScanSnapshots(ctx, req.(*ListRepositoryAdoptionScanSnapshotsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_RegisterProviderArtifactSignal_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RegisterProviderArtifactSignalRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).RegisterProviderArtifactSignal(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_RegisterProviderArtifactSignal_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).RegisterProviderArtifactSignal(ctx, req.(*RegisterProviderArtifactSignalRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_EnqueueReconciliation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(EnqueueReconciliationRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).EnqueueReconciliation(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_EnqueueReconciliation_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).EnqueueReconciliation(ctx, req.(*EnqueueReconciliationRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_RunReconciliationBatch_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RunReconciliationBatchRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).RunReconciliationBatch(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_RunReconciliationBatch_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).RunReconciliationBatch(ctx, req.(*RunReconciliationBatchRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_GetSyncCursor_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetSyncCursorRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).GetSyncCursor(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_GetSyncCursor_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).GetSyncCursor(ctx, req.(*GetSyncCursorRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_ListSyncCursors_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListSyncCursorsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).ListSyncCursors(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_ListSyncCursors_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).ListSyncCursors(ctx, req.(*ListSyncCursorsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_CreateIssue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateIssueRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).CreateIssue(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_CreateIssue_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).CreateIssue(ctx, req.(*CreateIssueRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_UpdateIssue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateIssueRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).UpdateIssue(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_UpdateIssue_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).UpdateIssue(ctx, req.(*UpdateIssueRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_CreateComment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateCommentRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).CreateComment(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_CreateComment_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).CreateComment(ctx, req.(*CreateCommentRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_UpdateComment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateCommentRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).UpdateComment(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_UpdateComment_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).UpdateComment(ctx, req.(*UpdateCommentRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_CreatePullRequest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreatePullRequestRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).CreatePullRequest(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_CreatePullRequest_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).CreatePullRequest(ctx, req.(*CreatePullRequestRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_CreateRepository_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateRepositoryRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).CreateRepository(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_CreateRepository_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).CreateRepository(ctx, req.(*CreateRepositoryRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_CreateBootstrapPullRequest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateBootstrapPullRequestRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).CreateBootstrapPullRequest(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_CreateBootstrapPullRequest_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).CreateBootstrapPullRequest(ctx, req.(*CreateBootstrapPullRequestRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_CreateAdoptionPullRequest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateAdoptionPullRequestRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).CreateAdoptionPullRequest(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_CreateAdoptionPullRequest_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).CreateAdoptionPullRequest(ctx, req.(*CreateAdoptionPullRequestRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_ScanRepositoryForAdoption_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ScanRepositoryForAdoptionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).ScanRepositoryForAdoption(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_ScanRepositoryForAdoption_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).ScanRepositoryForAdoption(ctx, req.(*ScanRepositoryForAdoptionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_UpdatePullRequest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdatePullRequestRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).UpdatePullRequest(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_UpdatePullRequest_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).UpdatePullRequest(ctx, req.(*UpdatePullRequestRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_CreateReviewSignal_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateReviewSignalRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).CreateReviewSignal(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_CreateReviewSignal_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).CreateReviewSignal(ctx, req.(*CreateReviewSignalRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_UpdateRelationship_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateRelationshipRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).UpdateRelationship(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_UpdateRelationship_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).UpdateRelationship(ctx, req.(*UpdateRelationshipRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_GetProviderAccountRuntimeState_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetProviderAccountRuntimeStateRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).GetProviderAccountRuntimeState(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_GetProviderAccountRuntimeState_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).GetProviderAccountRuntimeState(ctx, req.(*GetProviderAccountRuntimeStateRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_ListProviderAccountRuntimeStates_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListProviderAccountRuntimeStatesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).ListProviderAccountRuntimeStates(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_ListProviderAccountRuntimeStates_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).ListProviderAccountRuntimeStates(ctx, req.(*ListProviderAccountRuntimeStatesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_RecordProviderLimitSnapshot_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RecordProviderLimitSnapshotRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).RecordProviderLimitSnapshot(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_RecordProviderLimitSnapshot_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).RecordProviderLimitSnapshot(ctx, req.(*RecordProviderLimitSnapshotRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_ListProviderLimitSnapshots_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListProviderLimitSnapshotsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).ListProviderLimitSnapshots(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_ListProviderLimitSnapshots_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).ListProviderLimitSnapshots(ctx, req.(*ListProviderLimitSnapshotsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _ProviderHubService_ListProviderOperations_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListProviderOperationsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ProviderHubServiceServer).ListProviderOperations(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ProviderHubService_ListProviderOperations_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ProviderHubServiceServer).ListProviderOperations(ctx, req.(*ListProviderOperationsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// ProviderHubService_ServiceDesc is the grpc.ServiceDesc for ProviderHubService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var ProviderHubService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kodex.providers.v1.ProviderHubService",
	HandlerType: (*ProviderHubServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IngestWebhookEvent",
			Handler:    _ProviderHubService_IngestWebhookEvent_Handler,
		},
		{
			MethodName: "GetWebhookEvent",
			Handler:    _ProviderHubService_GetWebhookEvent_Handler,
		},
		{
			MethodName: "ListWebhookEvents",
			Handler:    _ProviderHubService_ListWebhookEvents_Handler,
		},
		{
			MethodName: "RetryWebhookEventProcessing",
			Handler:    _ProviderHubService_RetryWebhookEventProcessing_Handler,
		},
		{
			MethodName: "CleanupExpiredWebhookPayloads",
			Handler:    _ProviderHubService_CleanupExpiredWebhookPayloads_Handler,
		},
		{
			MethodName: "GetWorkItemProjection",
			Handler:    _ProviderHubService_GetWorkItemProjection_Handler,
		},
		{
			MethodName: "FindWorkItemByProviderRef",
			Handler:    _ProviderHubService_FindWorkItemByProviderRef_Handler,
		},
		{
			MethodName: "ListWorkItemProjections",
			Handler:    _ProviderHubService_ListWorkItemProjections_Handler,
		},
		{
			MethodName: "ListComments",
			Handler:    _ProviderHubService_ListComments_Handler,
		},
		{
			MethodName: "ListRelationships",
			Handler:    _ProviderHubService_ListRelationships_Handler,
		},
		{
			MethodName: "GetRepositoryMergeSignal",
			Handler:    _ProviderHubService_GetRepositoryMergeSignal_Handler,
		},
		{
			MethodName: "ListRepositoryMergeSignals",
			Handler:    _ProviderHubService_ListRepositoryMergeSignals_Handler,
		},
		{
			MethodName: "GetRepositoryChangeSignal",
			Handler:    _ProviderHubService_GetRepositoryChangeSignal_Handler,
		},
		{
			MethodName: "ListRepositoryChangeSignals",
			Handler:    _ProviderHubService_ListRepositoryChangeSignals_Handler,
		},
		{
			MethodName: "GetRepositoryAdoptionScanSnapshot",
			Handler:    _ProviderHubService_GetRepositoryAdoptionScanSnapshot_Handler,
		},
		{
			MethodName: "ListRepositoryAdoptionScanSnapshots",
			Handler:    _ProviderHubService_ListRepositoryAdoptionScanSnapshots_Handler,
		},
		{
			MethodName: "RegisterProviderArtifactSignal",
			Handler:    _ProviderHubService_RegisterProviderArtifactSignal_Handler,
		},
		{
			MethodName: "EnqueueReconciliation",
			Handler:    _ProviderHubService_EnqueueReconciliation_Handler,
		},
		{
			MethodName: "RunReconciliationBatch",
			Handler:    _ProviderHubService_RunReconciliationBatch_Handler,
		},
		{
			MethodName: "GetSyncCursor",
			Handler:    _ProviderHubService_GetSyncCursor_Handler,
		},
		{
			MethodName: "ListSyncCursors",
			Handler:    _ProviderHubService_ListSyncCursors_Handler,
		},
		{
			MethodName: "CreateIssue",
			Handler:    _ProviderHubService_CreateIssue_Handler,
		},
		{
			MethodName: "UpdateIssue",
			Handler:    _ProviderHubService_UpdateIssue_Handler,
		},
		{
			MethodName: "CreateComment",
			Handler:    _ProviderHubService_CreateComment_Handler,
		},
		{
			MethodName: "UpdateComment",
			Handler:    _ProviderHubService_UpdateComment_Handler,
		},
		{
			MethodName: "CreatePullRequest",
			Handler:    _ProviderHubService_CreatePullRequest_Handler,
		},
		{
			MethodName: "CreateRepository",
			Handler:    _ProviderHubService_CreateRepository_Handler,
		},
		{
			MethodName: "CreateBootstrapPullRequest",
			Handler:    _ProviderHubService_CreateBootstrapPullRequest_Handler,
		},
		{
			MethodName: "CreateAdoptionPullRequest",
			Handler:    _ProviderHubService_CreateAdoptionPullRequest_Handler,
		},
		{
			MethodName: "ScanRepositoryForAdoption",
			Handler:    _ProviderHubService_ScanRepositoryForAdoption_Handler,
		},
		{
			MethodName: "UpdatePullRequest",
			Handler:    _ProviderHubService_UpdatePullRequest_Handler,
		},
		{
			MethodName: "CreateReviewSignal",
			Handler:    _ProviderHubService_CreateReviewSignal_Handler,
		},
		{
			MethodName: "UpdateRelationship",
			Handler:    _ProviderHubService_UpdateRelationship_Handler,
		},
		{
			MethodName: "GetProviderAccountRuntimeState",
			Handler:    _ProviderHubService_GetProviderAccountRuntimeState_Handler,
		},
		{
			MethodName: "ListProviderAccountRuntimeStates",
			Handler:    _ProviderHubService_ListProviderAccountRuntimeStates_Handler,
		},
		{
			MethodName: "RecordProviderLimitSnapshot",
			Handler:    _ProviderHubService_RecordProviderLimitSnapshot_Handler,
		},
		{
			MethodName: "ListProviderLimitSnapshots",
			Handler:    _ProviderHubService_ListProviderLimitSnapshots_Handler,
		},
		{
			MethodName: "ListProviderOperations",
			Handler:    _ProviderHubService_ListProviderOperations_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "kodex/providers/v1/provider_hub.proto",
}
