pipeline_public_service_grpc.pb.go

// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc             (unknown)
// source: vdp/pipeline/v1beta/pipeline_public_service.proto

package pipelinev1beta

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.32.0 or later.
const _ = grpc.SupportPackageIsVersion7

const (
	PipelinePublicService_Liveness_FullMethodName                                = "/vdp.pipeline.v1beta.PipelinePublicService/Liveness"
	PipelinePublicService_Readiness_FullMethodName                               = "/vdp.pipeline.v1beta.PipelinePublicService/Readiness"
	PipelinePublicService_ListPipelines_FullMethodName                           = "/vdp.pipeline.v1beta.PipelinePublicService/ListPipelines"
	PipelinePublicService_LookUpPipeline_FullMethodName                          = "/vdp.pipeline.v1beta.PipelinePublicService/LookUpPipeline"
	PipelinePublicService_CreateUserPipeline_FullMethodName                      = "/vdp.pipeline.v1beta.PipelinePublicService/CreateUserPipeline"
	PipelinePublicService_ListUserPipelines_FullMethodName                       = "/vdp.pipeline.v1beta.PipelinePublicService/ListUserPipelines"
	PipelinePublicService_GetUserPipeline_FullMethodName                         = "/vdp.pipeline.v1beta.PipelinePublicService/GetUserPipeline"
	PipelinePublicService_UpdateUserPipeline_FullMethodName                      = "/vdp.pipeline.v1beta.PipelinePublicService/UpdateUserPipeline"
	PipelinePublicService_DeleteUserPipeline_FullMethodName                      = "/vdp.pipeline.v1beta.PipelinePublicService/DeleteUserPipeline"
	PipelinePublicService_ValidateUserPipeline_FullMethodName                    = "/vdp.pipeline.v1beta.PipelinePublicService/ValidateUserPipeline"
	PipelinePublicService_RenameUserPipeline_FullMethodName                      = "/vdp.pipeline.v1beta.PipelinePublicService/RenameUserPipeline"
	PipelinePublicService_CloneUserPipeline_FullMethodName                       = "/vdp.pipeline.v1beta.PipelinePublicService/CloneUserPipeline"
	PipelinePublicService_TriggerUserPipeline_FullMethodName                     = "/vdp.pipeline.v1beta.PipelinePublicService/TriggerUserPipeline"
	PipelinePublicService_TriggerAsyncUserPipeline_FullMethodName                = "/vdp.pipeline.v1beta.PipelinePublicService/TriggerAsyncUserPipeline"
	PipelinePublicService_CreateUserPipelineRelease_FullMethodName               = "/vdp.pipeline.v1beta.PipelinePublicService/CreateUserPipelineRelease"
	PipelinePublicService_ListUserPipelineReleases_FullMethodName                = "/vdp.pipeline.v1beta.PipelinePublicService/ListUserPipelineReleases"
	PipelinePublicService_GetUserPipelineRelease_FullMethodName                  = "/vdp.pipeline.v1beta.PipelinePublicService/GetUserPipelineRelease"
	PipelinePublicService_UpdateUserPipelineRelease_FullMethodName               = "/vdp.pipeline.v1beta.PipelinePublicService/UpdateUserPipelineRelease"
	PipelinePublicService_DeleteUserPipelineRelease_FullMethodName               = "/vdp.pipeline.v1beta.PipelinePublicService/DeleteUserPipelineRelease"
	PipelinePublicService_RestoreUserPipelineRelease_FullMethodName              = "/vdp.pipeline.v1beta.PipelinePublicService/RestoreUserPipelineRelease"
	PipelinePublicService_RenameUserPipelineRelease_FullMethodName               = "/vdp.pipeline.v1beta.PipelinePublicService/RenameUserPipelineRelease"
	PipelinePublicService_TriggerUserPipelineRelease_FullMethodName              = "/vdp.pipeline.v1beta.PipelinePublicService/TriggerUserPipelineRelease"
	PipelinePublicService_TriggerAsyncUserPipelineRelease_FullMethodName         = "/vdp.pipeline.v1beta.PipelinePublicService/TriggerAsyncUserPipelineRelease"
	PipelinePublicService_CreateOrganizationPipeline_FullMethodName              = "/vdp.pipeline.v1beta.PipelinePublicService/CreateOrganizationPipeline"
	PipelinePublicService_ListOrganizationPipelines_FullMethodName               = "/vdp.pipeline.v1beta.PipelinePublicService/ListOrganizationPipelines"
	PipelinePublicService_GetOrganizationPipeline_FullMethodName                 = "/vdp.pipeline.v1beta.PipelinePublicService/GetOrganizationPipeline"
	PipelinePublicService_UpdateOrganizationPipeline_FullMethodName              = "/vdp.pipeline.v1beta.PipelinePublicService/UpdateOrganizationPipeline"
	PipelinePublicService_DeleteOrganizationPipeline_FullMethodName              = "/vdp.pipeline.v1beta.PipelinePublicService/DeleteOrganizationPipeline"
	PipelinePublicService_ValidateOrganizationPipeline_FullMethodName            = "/vdp.pipeline.v1beta.PipelinePublicService/ValidateOrganizationPipeline"
	PipelinePublicService_RenameOrganizationPipeline_FullMethodName              = "/vdp.pipeline.v1beta.PipelinePublicService/RenameOrganizationPipeline"
	PipelinePublicService_CloneOrganizationPipeline_FullMethodName               = "/vdp.pipeline.v1beta.PipelinePublicService/CloneOrganizationPipeline"
	PipelinePublicService_TriggerOrganizationPipeline_FullMethodName             = "/vdp.pipeline.v1beta.PipelinePublicService/TriggerOrganizationPipeline"
	PipelinePublicService_TriggerAsyncOrganizationPipeline_FullMethodName        = "/vdp.pipeline.v1beta.PipelinePublicService/TriggerAsyncOrganizationPipeline"
	PipelinePublicService_CreateOrganizationPipelineRelease_FullMethodName       = "/vdp.pipeline.v1beta.PipelinePublicService/CreateOrganizationPipelineRelease"
	PipelinePublicService_ListOrganizationPipelineReleases_FullMethodName        = "/vdp.pipeline.v1beta.PipelinePublicService/ListOrganizationPipelineReleases"
	PipelinePublicService_GetOrganizationPipelineRelease_FullMethodName          = "/vdp.pipeline.v1beta.PipelinePublicService/GetOrganizationPipelineRelease"
	PipelinePublicService_UpdateOrganizationPipelineRelease_FullMethodName       = "/vdp.pipeline.v1beta.PipelinePublicService/UpdateOrganizationPipelineRelease"
	PipelinePublicService_DeleteOrganizationPipelineRelease_FullMethodName       = "/vdp.pipeline.v1beta.PipelinePublicService/DeleteOrganizationPipelineRelease"
	PipelinePublicService_RestoreOrganizationPipelineRelease_FullMethodName      = "/vdp.pipeline.v1beta.PipelinePublicService/RestoreOrganizationPipelineRelease"
	PipelinePublicService_RenameOrganizationPipelineRelease_FullMethodName       = "/vdp.pipeline.v1beta.PipelinePublicService/RenameOrganizationPipelineRelease"
	PipelinePublicService_TriggerOrganizationPipelineRelease_FullMethodName      = "/vdp.pipeline.v1beta.PipelinePublicService/TriggerOrganizationPipelineRelease"
	PipelinePublicService_TriggerAsyncOrganizationPipelineRelease_FullMethodName = "/vdp.pipeline.v1beta.PipelinePublicService/TriggerAsyncOrganizationPipelineRelease"
	PipelinePublicService_GetOperation_FullMethodName                            = "/vdp.pipeline.v1beta.PipelinePublicService/GetOperation"
	PipelinePublicService_ListConnectorDefinitions_FullMethodName                = "/vdp.pipeline.v1beta.PipelinePublicService/ListConnectorDefinitions"
	PipelinePublicService_GetConnectorDefinition_FullMethodName                  = "/vdp.pipeline.v1beta.PipelinePublicService/GetConnectorDefinition"
	PipelinePublicService_ListOperatorDefinitions_FullMethodName                 = "/vdp.pipeline.v1beta.PipelinePublicService/ListOperatorDefinitions"
	PipelinePublicService_ListComponentDefinitions_FullMethodName                = "/vdp.pipeline.v1beta.PipelinePublicService/ListComponentDefinitions"
	PipelinePublicService_GetOperatorDefinition_FullMethodName                   = "/vdp.pipeline.v1beta.PipelinePublicService/GetOperatorDefinition"
	PipelinePublicService_CheckName_FullMethodName                               = "/vdp.pipeline.v1beta.PipelinePublicService/CheckName"
	PipelinePublicService_CreateUserSecret_FullMethodName                        = "/vdp.pipeline.v1beta.PipelinePublicService/CreateUserSecret"
	PipelinePublicService_ListUserSecrets_FullMethodName                         = "/vdp.pipeline.v1beta.PipelinePublicService/ListUserSecrets"
	PipelinePublicService_GetUserSecret_FullMethodName                           = "/vdp.pipeline.v1beta.PipelinePublicService/GetUserSecret"
	PipelinePublicService_UpdateUserSecret_FullMethodName                        = "/vdp.pipeline.v1beta.PipelinePublicService/UpdateUserSecret"
	PipelinePublicService_DeleteUserSecret_FullMethodName                        = "/vdp.pipeline.v1beta.PipelinePublicService/DeleteUserSecret"
	PipelinePublicService_CreateOrganizationSecret_FullMethodName                = "/vdp.pipeline.v1beta.PipelinePublicService/CreateOrganizationSecret"
	PipelinePublicService_ListOrganizationSecrets_FullMethodName                 = "/vdp.pipeline.v1beta.PipelinePublicService/ListOrganizationSecrets"
	PipelinePublicService_GetOrganizationSecret_FullMethodName                   = "/vdp.pipeline.v1beta.PipelinePublicService/GetOrganizationSecret"
	PipelinePublicService_UpdateOrganizationSecret_FullMethodName                = "/vdp.pipeline.v1beta.PipelinePublicService/UpdateOrganizationSecret"
	PipelinePublicService_DeleteOrganizationSecret_FullMethodName                = "/vdp.pipeline.v1beta.PipelinePublicService/DeleteOrganizationSecret"
)

// PipelinePublicServiceClient is the client API for PipelinePublicService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type PipelinePublicServiceClient interface {
	// Check if the pipeline server is alive
	//
	// See https://github.com/grpc/grpc/blob/master/doc/health-checking.md.
	Liveness(ctx context.Context, in *LivenessRequest, opts ...grpc.CallOption) (*LivenessResponse, error)
	// Check if the pipeline server is ready
	//
	// See https://github.com/grpc/grpc/blob/master/doc/health-checking.md
	Readiness(ctx context.Context, in *ReadinessRequest, opts ...grpc.CallOption) (*ReadinessResponse, error)
	// List accessible pipelines
	//
	// Returns a paginated list of pipelines that are visible to the requester.
	ListPipelines(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (*ListPipelinesResponse, error)
	// Get a pipeline by UID
	//
	// Returns the details of a pipeline by a permalink defined by the resource
	// UID.
	LookUpPipeline(ctx context.Context, in *LookUpPipelineRequest, opts ...grpc.CallOption) (*LookUpPipelineResponse, error)
	// Create a new user pipeline
	//
	// Creates a new pipeline under the parenthood of a user. Users can only
	// create a pipeline as the parent of that resource (i.e. the authenticated
	// user must match the `parent` path parameter).
	CreateUserPipeline(ctx context.Context, in *CreateUserPipelineRequest, opts ...grpc.CallOption) (*CreateUserPipelineResponse, error)
	// List user pipelines
	//
	// Returns a paginated list of pipelines that belong to the specified user.
	// The parent user may be different from the authenticated user, in which
	// case the results will contain the pipelines that are visible to the
	// latter.
	ListUserPipelines(ctx context.Context, in *ListUserPipelinesRequest, opts ...grpc.CallOption) (*ListUserPipelinesResponse, error)
	// Get a pipeline owned by a user
	//
	// Returns the details of a user-owned pipeline by its resource name, which is defined
	// by the parent user and the ID of the pipeline.
	GetUserPipeline(ctx context.Context, in *GetUserPipelineRequest, opts ...grpc.CallOption) (*GetUserPipelineResponse, error)
	// Update a pipeline owned by a user
	//
	// Udpates a pipeline, accessing it by its resource name, which is defined by
	// the parent user and the ID of the pipeline. The authenticated user must be
	// the parent of the pipeline in order to modify it.
	//
	// In REST requests, only the supplied pipeline fields will be taken into
	// account when updating the resource.
	UpdateUserPipeline(ctx context.Context, in *UpdateUserPipelineRequest, opts ...grpc.CallOption) (*UpdateUserPipelineResponse, error)
	// Delete a pipeline owned by a user
	//
	// Deletes a pipeline, accesing it by its resource name, which is defined by
	// the parent user and the ID of the pipeline. The authenticated user must be
	// the parent of the pipeline in order to delete it.
	DeleteUserPipeline(ctx context.Context, in *DeleteUserPipelineRequest, opts ...grpc.CallOption) (*DeleteUserPipelineResponse, error)
	// Validate a pipeline a pipeline owned by a user
	//
	// Validates a pipeline by its resource name, which is defined by the parent
	// user and the ID of the pipeline.
	//
	// Validation checks the recipe of the pipeline and the status of its components.
	ValidateUserPipeline(ctx context.Context, in *ValidateUserPipelineRequest, opts ...grpc.CallOption) (*ValidateUserPipelineResponse, error)
	// Rename a pipeline owned by a user
	//
	// Updates the ID of a pipeline. Since this is an output-only field, a custom
	// method is required to modify it.
	//
	// The pipeline name will be updated accordingly, as it is  composed by the
	// parent user and ID of the pipeline (e.g.
	// `users/luigi/pipelines/pizza-recipe-generator`).
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	RenameUserPipeline(ctx context.Context, in *RenameUserPipelineRequest, opts ...grpc.CallOption) (*RenameUserPipelineResponse, error)
	// Clone a pipeline owned by a user
	//
	// Clones a pipeline owned by a user. The new pipeline may have a different
	// parent, and this can be either a user or an organization.
	CloneUserPipeline(ctx context.Context, in *CloneUserPipelineRequest, opts ...grpc.CallOption) (*CloneUserPipelineResponse, error)
	// Trigger a pipeline owned by a user
	//
	// Triggers the execution of a pipeline synchronously, i.e., the result is
	// sent back to the user right after the data is processed. This method is
	// intended for real-time inference when low latency is of concern.
	//
	// The pipeline is identified by its resource name, formed by the parent user
	// and ID of the pipeline.
	//
	// For more information, see [Trigger
	// Pipeline](https://www.instill.tech/docs/latest/core/concepts/pipeline#trigger-pipeline).
	TriggerUserPipeline(ctx context.Context, in *TriggerUserPipelineRequest, opts ...grpc.CallOption) (*TriggerUserPipelineResponse, error)
	// Trigger a pipeline owned by a user asynchronously
	//
	// Triggers the execution of a pipeline asynchronously, i.e., the result
	// contains the necessary information to access the result and status of the
	// operation. This method is intended for cases that require long-running
	// workloads.
	//
	// The pipeline is identified by its resource name, formed by the parent user
	// and ID of the pipeline.
	//
	// For more information, see [Trigger
	// Pipeline](https://www.instill.tech/docs/latest/core/concepts/pipeline#trigger-pipeline).
	TriggerAsyncUserPipeline(ctx context.Context, in *TriggerAsyncUserPipelineRequest, opts ...grpc.CallOption) (*TriggerAsyncUserPipelineResponse, error)
	// Release a version of a pipeline owned by a user
	//
	// Commits the version of a pipeline, identified by its resource name, which
	// is formed by the parent user and ID of the pipeline.
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	CreateUserPipelineRelease(ctx context.Context, in *CreateUserPipelineReleaseRequest, opts ...grpc.CallOption) (*CreateUserPipelineReleaseResponse, error)
	// List the releases in a pipeline owned by a user
	//
	// Lists the commited versions of a pipeline, identified by its resource
	// name, which is formed by the parent user and ID of the pipeline.
	ListUserPipelineReleases(ctx context.Context, in *ListUserPipelineReleasesRequest, opts ...grpc.CallOption) (*ListUserPipelineReleasesResponse, error)
	// Get a release in a pipeline owned by a user
	//
	// Gets the details of a pipeline release, where the pipeline is identified
	// by its resource name, formed by its parent user and ID.
	GetUserPipelineRelease(ctx context.Context, in *GetUserPipelineReleaseRequest, opts ...grpc.CallOption) (*GetUserPipelineReleaseResponse, error)
	// Update a release in a pipeline owned by a user
	//
	// Updates the details of a pipeline release, where the pipeline is
	// identified by its resource name, formed by its parent user and ID.
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	UpdateUserPipelineRelease(ctx context.Context, in *UpdateUserPipelineReleaseRequest, opts ...grpc.CallOption) (*UpdateUserPipelineReleaseResponse, error)
	// Delete a release in a pipeline owned by a user
	//
	// Deletes a pipeline release, where the pipeline is identified by its
	// resource name, formed by its parent user and ID.
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	DeleteUserPipelineRelease(ctx context.Context, in *DeleteUserPipelineReleaseRequest, opts ...grpc.CallOption) (*DeleteUserPipelineReleaseResponse, error)
	// Set the version of a pipeline owned by a user to a pinned release
	//
	// Sets the pipeline configuration to a pinned version defined by a release.
	//
	// The pipeline is identified by its resource name, formed by its parent user
	// and ID.
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	RestoreUserPipelineRelease(ctx context.Context, in *RestoreUserPipelineReleaseRequest, opts ...grpc.CallOption) (*RestoreUserPipelineReleaseResponse, error)
	// Rename a release in a pipeline owned by a user
	//
	// Updates the ID of a pipeline release, where the pipeline is identified by
	// its resource name, formed by the parent user and ID. Since this is an
	// output-only field, a custom method is required to modify it.
	//
	// The pipeline release name will be updated accordingly, as it is  composed
	// by the pipeline name and the ID of the release (e.g.
	// `users/luigi/pipelines/pizza-recipe-generator/releases/v0.2.1`).
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	RenameUserPipelineRelease(ctx context.Context, in *RenameUserPipelineReleaseRequest, opts ...grpc.CallOption) (*RenameUserPipelineReleaseResponse, error)
	// Trigger a version of a pipeline owned by a user
	//
	// Triggers the synchronous execution of of a pipeline. While the trigger
	// endpoint (where the release version isn't specified) triggers the pipeline
	// at its latest release, this method allows the client to specified any
	// committed release.
	//
	// The pipeline is identified by its resource name, formed by its parent user
	// and ID.
	TriggerUserPipelineRelease(ctx context.Context, in *TriggerUserPipelineReleaseRequest, opts ...grpc.CallOption) (*TriggerUserPipelineReleaseResponse, error)
	// Trigger a version of a pipeline owned by a user asynchronously
	//
	// Triggers the asynchronous execution of of a pipeline. While the trigger
	// endpoint (where the release version isn't specified) triggers the pipeline
	// at its latest release, this method allows the client to specified any
	// committed release.
	//
	// The pipeline is identified by its resource name, formed by its parent user
	// and ID.
	TriggerAsyncUserPipelineRelease(ctx context.Context, in *TriggerAsyncUserPipelineReleaseRequest, opts ...grpc.CallOption) (*TriggerAsyncUserPipelineReleaseResponse, error)
	// Create a new organization pipeline
	//
	// Creates a new pipeline under the parenthood of an organization.
	CreateOrganizationPipeline(ctx context.Context, in *CreateOrganizationPipelineRequest, opts ...grpc.CallOption) (*CreateOrganizationPipelineResponse, error)
	// List organization pipelines
	//
	// Returns a paginated list of pipelines that belong to the specified
	// organization.
	ListOrganizationPipelines(ctx context.Context, in *ListOrganizationPipelinesRequest, opts ...grpc.CallOption) (*ListOrganizationPipelinesResponse, error)
	// Get a pipeline owned by an organization
	//
	// Returns the details of an organization-owned pipeline by its resource name,
	// which is defined by the parent organization and the ID of the pipeline.
	GetOrganizationPipeline(ctx context.Context, in *GetOrganizationPipelineRequest, opts ...grpc.CallOption) (*GetOrganizationPipelineResponse, error)
	// Update a pipeline owned by an organization
	//
	// # Udpates a pipeline, accessing it by its resource name, which is defined by
	//
	// In REST requests, only the supplied pipeline fields will be taken into
	// account when updating the resource.
	UpdateOrganizationPipeline(ctx context.Context, in *UpdateOrganizationPipelineRequest, opts ...grpc.CallOption) (*UpdateOrganizationPipelineResponse, error)
	// Delete a pipeline owned by an organization
	//
	// Deletes a pipeline, accesing it by its resource name, which is defined by
	// the parent organization and the ID of the pipeline.
	DeleteOrganizationPipeline(ctx context.Context, in *DeleteOrganizationPipelineRequest, opts ...grpc.CallOption) (*DeleteOrganizationPipelineResponse, error)
	// Validate a pipeline a pipeline owned by an organization
	//
	// Validates a pipeline by its resource name, which is defined by the parent
	// organization and the ID of the pipeline.
	//
	// Validation checks the recipe of the pipeline and the status of its
	// components.
	ValidateOrganizationPipeline(ctx context.Context, in *ValidateOrganizationPipelineRequest, opts ...grpc.CallOption) (*ValidateOrganizationPipelineResponse, error)
	// Rename a pipeline owned by an organization
	//
	// Updates the ID of a pipeline. Since this is an output-only field, a custom
	// method is required to modify it.
	//
	// The pipeline name will be updated accordingly, as it is  composed by the
	// parent organization and ID of the pipeline (e.g.
	// `organizations/luigi/pipelines/pizza-recipe-generator`).
	RenameOrganizationPipeline(ctx context.Context, in *RenameOrganizationPipelineRequest, opts ...grpc.CallOption) (*RenameOrganizationPipelineResponse, error)
	// Clone a pipeline owned by an organization
	//
	// Clones a pipeline owned by an organization. The new pipeline may have a
	// different parent, and this can be either a user or an organization.
	CloneOrganizationPipeline(ctx context.Context, in *CloneOrganizationPipelineRequest, opts ...grpc.CallOption) (*CloneOrganizationPipelineResponse, error)
	// Trigger a pipeline owned by an organization
	//
	// Triggers the execution of a pipeline synchronously, i.e., the result is sent
	// back to the organization right after the data is processed. This method is
	// intended for real-time inference when low latency is of concern.
	//
	// The pipeline is identified by its resource name, formed by the parent
	// organization and ID of the pipeline.
	//
	// For more information, see [Trigger
	// Pipeline](https://www.instill.tech/docs/latest/core/concepts/pipeline#trigger-pipeline).
	TriggerOrganizationPipeline(ctx context.Context, in *TriggerOrganizationPipelineRequest, opts ...grpc.CallOption) (*TriggerOrganizationPipelineResponse, error)
	// Trigger a pipeline owned by an organization asynchronously
	//
	// Triggers the execution of a pipeline asynchronously, i.e., the result
	// contains the necessary information to access the result and status of the
	// operation. This method is intended for cases that require long-running
	// workloads.
	//
	// The pipeline is identified by its resource name, formed by the parent
	// organization and ID of the pipeline.
	//
	// For more information, see [Trigger
	// Pipeline](https://www.instill.tech/docs/latest/core/concepts/pipeline#trigger-pipeline).
	TriggerAsyncOrganizationPipeline(ctx context.Context, in *TriggerAsyncOrganizationPipelineRequest, opts ...grpc.CallOption) (*TriggerAsyncOrganizationPipelineResponse, error)
	// Release a version of a pipeline owned by an organization
	//
	// Commits the version of a pipeline, identified by its resource name, which is
	// formed by the parent organization and ID of the pipeline.
	CreateOrganizationPipelineRelease(ctx context.Context, in *CreateOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*CreateOrganizationPipelineReleaseResponse, error)
	// List the releases in a pipeline owned by an organization
	//
	// Lists the commited versions of a pipeline, identified by its resource name,
	// which is formed by the parent organization and ID of the pipeline.
	ListOrganizationPipelineReleases(ctx context.Context, in *ListOrganizationPipelineReleasesRequest, opts ...grpc.CallOption) (*ListOrganizationPipelineReleasesResponse, error)
	// Get a release in a pipeline owned by an organization
	//
	// Gets the details of a pipeline release, where the pipeline is identified by
	// its resource name, formed by its parent organization and ID.
	GetOrganizationPipelineRelease(ctx context.Context, in *GetOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*GetOrganizationPipelineReleaseResponse, error)
	// Update a release in a pipeline owned by an organization
	//
	// Updates the details of a pipeline release, where the pipeline is identified
	// by its resource name, formed by its parent organization and ID.
	UpdateOrganizationPipelineRelease(ctx context.Context, in *UpdateOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*UpdateOrganizationPipelineReleaseResponse, error)
	// Delete a release in a pipeline owned by an organization
	//
	// Deletes a pipeline release, where the pipeline is identified by its resource
	// name, formed by its parent organization and ID.
	DeleteOrganizationPipelineRelease(ctx context.Context, in *DeleteOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*DeleteOrganizationPipelineReleaseResponse, error)
	// Set the version of a pipeline owned by an organization to a pinned release
	//
	// Sets the pipeline configuration to a pinned version defined by a release.
	//
	// The pipeline is identified by its resource name, formed by its parent
	// organization and ID.
	RestoreOrganizationPipelineRelease(ctx context.Context, in *RestoreOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*RestoreOrganizationPipelineReleaseResponse, error)
	// Rename a release in a pipeline owned by an organization
	//
	// Updates the ID of a pipeline release, where the pipeline is identified by
	// its resource name, formed by the parent organization and ID. Since this is
	// an output-only field, a custom method is required to modify it.
	//
	// The pipeline release name will be updated accordingly, as it is  composed by
	// the pipeline name and the ID of the release (e.g.
	// `organizations/luigi/pipelines/pizza-recipe-generator/releases/v0.2.1`).
	RenameOrganizationPipelineRelease(ctx context.Context, in *RenameOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*RenameOrganizationPipelineReleaseResponse, error)
	// Trigger a version of a pipeline owned by an organization
	//
	// Triggers the synchronous execution of of a pipeline. While the trigger
	// endpoint (where the release version isn't specified) triggers the pipeline
	// at its latest release, this method allows the client to specified any
	// committed release.
	//
	// The pipeline is identified by its resource name, formed by its parent
	// organization and ID.
	TriggerOrganizationPipelineRelease(ctx context.Context, in *TriggerOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*TriggerOrganizationPipelineReleaseResponse, error)
	// Trigger a version of a pipeline owned by an organization asynchronously
	//
	// Triggers the asynchronous execution of of a pipeline. While the trigger
	// endpoint (where the release version isn't specified) triggers the pipeline
	// at its latest release, this method allows the client to specified any
	// committed release.
	//
	// The pipeline is identified by its resource name, formed by its parent
	// organization and ID.
	TriggerAsyncOrganizationPipelineRelease(ctx context.Context, in *TriggerAsyncOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*TriggerAsyncOrganizationPipelineReleaseResponse, error)
	// Get the details of a long-running operation
	//
	// This method allows requesters to request the status and outcome of
	// long-running operations such as asynchronous pipeline triggers.
	GetOperation(ctx context.Context, in *GetOperationRequest, opts ...grpc.CallOption) (*GetOperationResponse, error)
	// List connector definitions
	//
	// Returns a paginated list of connector definitions.
	ListConnectorDefinitions(ctx context.Context, in *ListConnectorDefinitionsRequest, opts ...grpc.CallOption) (*ListConnectorDefinitionsResponse, error)
	// Get connector definition
	//
	// Returns the details of a connector definition.
	GetConnectorDefinition(ctx context.Context, in *GetConnectorDefinitionRequest, opts ...grpc.CallOption) (*GetConnectorDefinitionResponse, error)
	// List operator definitions
	//
	// Returns a paginated list of operator definitions.
	ListOperatorDefinitions(ctx context.Context, in *ListOperatorDefinitionsRequest, opts ...grpc.CallOption) (*ListOperatorDefinitionsResponse, error)
	// List component definitions
	//
	// Returns a paginated list of component definitions, regardless their type.
	// This offers a single source of truth, with pagination and filter
	// capabilities, for the components that might be used in a VDP pipeline.
	ListComponentDefinitions(ctx context.Context, in *ListComponentDefinitionsRequest, opts ...grpc.CallOption) (*ListComponentDefinitionsResponse, error)
	// Get operator definition
	//
	// Returns the details of an operator definition.
	GetOperatorDefinition(ctx context.Context, in *GetOperatorDefinitionRequest, opts ...grpc.CallOption) (*GetOperatorDefinitionResponse, error)
	// Check the availibity of a resource name
	//
	// Check whether a resource name is already in use. Currently this endpoint
	// only supports pipeline and connector resource names.
	CheckName(ctx context.Context, in *CheckNameRequest, opts ...grpc.CallOption) (*CheckNameResponse, error)
	// Create a new user secret
	//
	// Creates a new secret under the parenthood of an user.
	CreateUserSecret(ctx context.Context, in *CreateUserSecretRequest, opts ...grpc.CallOption) (*CreateUserSecretResponse, error)
	// List user secrets
	//
	// Returns a paginated list of secrets that belong to the specified
	// user.
	ListUserSecrets(ctx context.Context, in *ListUserSecretsRequest, opts ...grpc.CallOption) (*ListUserSecretsResponse, error)
	// Get a secret owned by an user
	//
	// Returns the details of an user-owned secret by its resource name,
	// which is defined by the parent user and the ID of the secret.
	GetUserSecret(ctx context.Context, in *GetUserSecretRequest, opts ...grpc.CallOption) (*GetUserSecretResponse, error)
	// Update a secret owned by an user
	//
	// # Udpates a secret, accessing it by its resource name, which is defined by
	//
	// In REST requests, only the supplied secret fields will be taken into
	// account when updating the resource.
	UpdateUserSecret(ctx context.Context, in *UpdateUserSecretRequest, opts ...grpc.CallOption) (*UpdateUserSecretResponse, error)
	// Delete a secret owned by an user
	//
	// Deletes a secret, accesing it by its resource name, which is defined by
	// the parent user and the ID of the secret.
	DeleteUserSecret(ctx context.Context, in *DeleteUserSecretRequest, opts ...grpc.CallOption) (*DeleteUserSecretResponse, error)
	// Create a new organization secret
	//
	// Creates a new secret under the parenthood of an organization.
	CreateOrganizationSecret(ctx context.Context, in *CreateOrganizationSecretRequest, opts ...grpc.CallOption) (*CreateOrganizationSecretResponse, error)
	// List organization secrets
	//
	// Returns a paginated list of secrets that belong to the specified
	// organization.
	ListOrganizationSecrets(ctx context.Context, in *ListOrganizationSecretsRequest, opts ...grpc.CallOption) (*ListOrganizationSecretsResponse, error)
	// Get a secret owned by an organization
	//
	// Returns the details of an organization-owned secret by its resource name,
	// which is defined by the parent organization and the ID of the secret.
	GetOrganizationSecret(ctx context.Context, in *GetOrganizationSecretRequest, opts ...grpc.CallOption) (*GetOrganizationSecretResponse, error)
	// Update a secret owned by an organization
	//
	// # Udpates a secret, accessing it by its resource name, which is defined by
	//
	// In REST requests, only the supplied secret fields will be taken into
	// account when updating the resource.
	UpdateOrganizationSecret(ctx context.Context, in *UpdateOrganizationSecretRequest, opts ...grpc.CallOption) (*UpdateOrganizationSecretResponse, error)
	// Delete a secret owned by an organization
	//
	// Deletes a secret, accesing it by its resource name, which is defined by
	// the parent organization and the ID of the secret.
	DeleteOrganizationSecret(ctx context.Context, in *DeleteOrganizationSecretRequest, opts ...grpc.CallOption) (*DeleteOrganizationSecretResponse, error)
}

type pipelinePublicServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewPipelinePublicServiceClient(cc grpc.ClientConnInterface) PipelinePublicServiceClient {
	return &pipelinePublicServiceClient{cc}
}

func (c *pipelinePublicServiceClient) Liveness(ctx context.Context, in *LivenessRequest, opts ...grpc.CallOption) (*LivenessResponse, error) {
	out := new(LivenessResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_Liveness_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) Readiness(ctx context.Context, in *ReadinessRequest, opts ...grpc.CallOption) (*ReadinessResponse, error) {
	out := new(ReadinessResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_Readiness_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) ListPipelines(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (*ListPipelinesResponse, error) {
	out := new(ListPipelinesResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_ListPipelines_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) LookUpPipeline(ctx context.Context, in *LookUpPipelineRequest, opts ...grpc.CallOption) (*LookUpPipelineResponse, error) {
	out := new(LookUpPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_LookUpPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) CreateUserPipeline(ctx context.Context, in *CreateUserPipelineRequest, opts ...grpc.CallOption) (*CreateUserPipelineResponse, error) {
	out := new(CreateUserPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_CreateUserPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) ListUserPipelines(ctx context.Context, in *ListUserPipelinesRequest, opts ...grpc.CallOption) (*ListUserPipelinesResponse, error) {
	out := new(ListUserPipelinesResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_ListUserPipelines_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) GetUserPipeline(ctx context.Context, in *GetUserPipelineRequest, opts ...grpc.CallOption) (*GetUserPipelineResponse, error) {
	out := new(GetUserPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_GetUserPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) UpdateUserPipeline(ctx context.Context, in *UpdateUserPipelineRequest, opts ...grpc.CallOption) (*UpdateUserPipelineResponse, error) {
	out := new(UpdateUserPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_UpdateUserPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) DeleteUserPipeline(ctx context.Context, in *DeleteUserPipelineRequest, opts ...grpc.CallOption) (*DeleteUserPipelineResponse, error) {
	out := new(DeleteUserPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_DeleteUserPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) ValidateUserPipeline(ctx context.Context, in *ValidateUserPipelineRequest, opts ...grpc.CallOption) (*ValidateUserPipelineResponse, error) {
	out := new(ValidateUserPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_ValidateUserPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) RenameUserPipeline(ctx context.Context, in *RenameUserPipelineRequest, opts ...grpc.CallOption) (*RenameUserPipelineResponse, error) {
	out := new(RenameUserPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_RenameUserPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) CloneUserPipeline(ctx context.Context, in *CloneUserPipelineRequest, opts ...grpc.CallOption) (*CloneUserPipelineResponse, error) {
	out := new(CloneUserPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_CloneUserPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) TriggerUserPipeline(ctx context.Context, in *TriggerUserPipelineRequest, opts ...grpc.CallOption) (*TriggerUserPipelineResponse, error) {
	out := new(TriggerUserPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_TriggerUserPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) TriggerAsyncUserPipeline(ctx context.Context, in *TriggerAsyncUserPipelineRequest, opts ...grpc.CallOption) (*TriggerAsyncUserPipelineResponse, error) {
	out := new(TriggerAsyncUserPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_TriggerAsyncUserPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) CreateUserPipelineRelease(ctx context.Context, in *CreateUserPipelineReleaseRequest, opts ...grpc.CallOption) (*CreateUserPipelineReleaseResponse, error) {
	out := new(CreateUserPipelineReleaseResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_CreateUserPipelineRelease_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) ListUserPipelineReleases(ctx context.Context, in *ListUserPipelineReleasesRequest, opts ...grpc.CallOption) (*ListUserPipelineReleasesResponse, error) {
	out := new(ListUserPipelineReleasesResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_ListUserPipelineReleases_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) GetUserPipelineRelease(ctx context.Context, in *GetUserPipelineReleaseRequest, opts ...grpc.CallOption) (*GetUserPipelineReleaseResponse, error) {
	out := new(GetUserPipelineReleaseResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_GetUserPipelineRelease_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) UpdateUserPipelineRelease(ctx context.Context, in *UpdateUserPipelineReleaseRequest, opts ...grpc.CallOption) (*UpdateUserPipelineReleaseResponse, error) {
	out := new(UpdateUserPipelineReleaseResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_UpdateUserPipelineRelease_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) DeleteUserPipelineRelease(ctx context.Context, in *DeleteUserPipelineReleaseRequest, opts ...grpc.CallOption) (*DeleteUserPipelineReleaseResponse, error) {
	out := new(DeleteUserPipelineReleaseResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_DeleteUserPipelineRelease_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) RestoreUserPipelineRelease(ctx context.Context, in *RestoreUserPipelineReleaseRequest, opts ...grpc.CallOption) (*RestoreUserPipelineReleaseResponse, error) {
	out := new(RestoreUserPipelineReleaseResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_RestoreUserPipelineRelease_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) RenameUserPipelineRelease(ctx context.Context, in *RenameUserPipelineReleaseRequest, opts ...grpc.CallOption) (*RenameUserPipelineReleaseResponse, error) {
	out := new(RenameUserPipelineReleaseResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_RenameUserPipelineRelease_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) TriggerUserPipelineRelease(ctx context.Context, in *TriggerUserPipelineReleaseRequest, opts ...grpc.CallOption) (*TriggerUserPipelineReleaseResponse, error) {
	out := new(TriggerUserPipelineReleaseResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_TriggerUserPipelineRelease_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) TriggerAsyncUserPipelineRelease(ctx context.Context, in *TriggerAsyncUserPipelineReleaseRequest, opts ...grpc.CallOption) (*TriggerAsyncUserPipelineReleaseResponse, error) {
	out := new(TriggerAsyncUserPipelineReleaseResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_TriggerAsyncUserPipelineRelease_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) CreateOrganizationPipeline(ctx context.Context, in *CreateOrganizationPipelineRequest, opts ...grpc.CallOption) (*CreateOrganizationPipelineResponse, error) {
	out := new(CreateOrganizationPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_CreateOrganizationPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) ListOrganizationPipelines(ctx context.Context, in *ListOrganizationPipelinesRequest, opts ...grpc.CallOption) (*ListOrganizationPipelinesResponse, error) {
	out := new(ListOrganizationPipelinesResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_ListOrganizationPipelines_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) GetOrganizationPipeline(ctx context.Context, in *GetOrganizationPipelineRequest, opts ...grpc.CallOption) (*GetOrganizationPipelineResponse, error) {
	out := new(GetOrganizationPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_GetOrganizationPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) UpdateOrganizationPipeline(ctx context.Context, in *UpdateOrganizationPipelineRequest, opts ...grpc.CallOption) (*UpdateOrganizationPipelineResponse, error) {
	out := new(UpdateOrganizationPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_UpdateOrganizationPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) DeleteOrganizationPipeline(ctx context.Context, in *DeleteOrganizationPipelineRequest, opts ...grpc.CallOption) (*DeleteOrganizationPipelineResponse, error) {
	out := new(DeleteOrganizationPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_DeleteOrganizationPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) ValidateOrganizationPipeline(ctx context.Context, in *ValidateOrganizationPipelineRequest, opts ...grpc.CallOption) (*ValidateOrganizationPipelineResponse, error) {
	out := new(ValidateOrganizationPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_ValidateOrganizationPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) RenameOrganizationPipeline(ctx context.Context, in *RenameOrganizationPipelineRequest, opts ...grpc.CallOption) (*RenameOrganizationPipelineResponse, error) {
	out := new(RenameOrganizationPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_RenameOrganizationPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) CloneOrganizationPipeline(ctx context.Context, in *CloneOrganizationPipelineRequest, opts ...grpc.CallOption) (*CloneOrganizationPipelineResponse, error) {
	out := new(CloneOrganizationPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_CloneOrganizationPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) TriggerOrganizationPipeline(ctx context.Context, in *TriggerOrganizationPipelineRequest, opts ...grpc.CallOption) (*TriggerOrganizationPipelineResponse, error) {
	out := new(TriggerOrganizationPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_TriggerOrganizationPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) TriggerAsyncOrganizationPipeline(ctx context.Context, in *TriggerAsyncOrganizationPipelineRequest, opts ...grpc.CallOption) (*TriggerAsyncOrganizationPipelineResponse, error) {
	out := new(TriggerAsyncOrganizationPipelineResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_TriggerAsyncOrganizationPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) CreateOrganizationPipelineRelease(ctx context.Context, in *CreateOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*CreateOrganizationPipelineReleaseResponse, error) {
	out := new(CreateOrganizationPipelineReleaseResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_CreateOrganizationPipelineRelease_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) ListOrganizationPipelineReleases(ctx context.Context, in *ListOrganizationPipelineReleasesRequest, opts ...grpc.CallOption) (*ListOrganizationPipelineReleasesResponse, error) {
	out := new(ListOrganizationPipelineReleasesResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_ListOrganizationPipelineReleases_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) GetOrganizationPipelineRelease(ctx context.Context, in *GetOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*GetOrganizationPipelineReleaseResponse, error) {
	out := new(GetOrganizationPipelineReleaseResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_GetOrganizationPipelineRelease_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) UpdateOrganizationPipelineRelease(ctx context.Context, in *UpdateOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*UpdateOrganizationPipelineReleaseResponse, error) {
	out := new(UpdateOrganizationPipelineReleaseResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_UpdateOrganizationPipelineRelease_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) DeleteOrganizationPipelineRelease(ctx context.Context, in *DeleteOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*DeleteOrganizationPipelineReleaseResponse, error) {
	out := new(DeleteOrganizationPipelineReleaseResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_DeleteOrganizationPipelineRelease_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) RestoreOrganizationPipelineRelease(ctx context.Context, in *RestoreOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*RestoreOrganizationPipelineReleaseResponse, error) {
	out := new(RestoreOrganizationPipelineReleaseResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_RestoreOrganizationPipelineRelease_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) RenameOrganizationPipelineRelease(ctx context.Context, in *RenameOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*RenameOrganizationPipelineReleaseResponse, error) {
	out := new(RenameOrganizationPipelineReleaseResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_RenameOrganizationPipelineRelease_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) TriggerOrganizationPipelineRelease(ctx context.Context, in *TriggerOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*TriggerOrganizationPipelineReleaseResponse, error) {
	out := new(TriggerOrganizationPipelineReleaseResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_TriggerOrganizationPipelineRelease_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) TriggerAsyncOrganizationPipelineRelease(ctx context.Context, in *TriggerAsyncOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*TriggerAsyncOrganizationPipelineReleaseResponse, error) {
	out := new(TriggerAsyncOrganizationPipelineReleaseResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_TriggerAsyncOrganizationPipelineRelease_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) GetOperation(ctx context.Context, in *GetOperationRequest, opts ...grpc.CallOption) (*GetOperationResponse, error) {
	out := new(GetOperationResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_GetOperation_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) ListConnectorDefinitions(ctx context.Context, in *ListConnectorDefinitionsRequest, opts ...grpc.CallOption) (*ListConnectorDefinitionsResponse, error) {
	out := new(ListConnectorDefinitionsResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_ListConnectorDefinitions_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) GetConnectorDefinition(ctx context.Context, in *GetConnectorDefinitionRequest, opts ...grpc.CallOption) (*GetConnectorDefinitionResponse, error) {
	out := new(GetConnectorDefinitionResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_GetConnectorDefinition_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) ListOperatorDefinitions(ctx context.Context, in *ListOperatorDefinitionsRequest, opts ...grpc.CallOption) (*ListOperatorDefinitionsResponse, error) {
	out := new(ListOperatorDefinitionsResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_ListOperatorDefinitions_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) ListComponentDefinitions(ctx context.Context, in *ListComponentDefinitionsRequest, opts ...grpc.CallOption) (*ListComponentDefinitionsResponse, error) {
	out := new(ListComponentDefinitionsResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_ListComponentDefinitions_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) GetOperatorDefinition(ctx context.Context, in *GetOperatorDefinitionRequest, opts ...grpc.CallOption) (*GetOperatorDefinitionResponse, error) {
	out := new(GetOperatorDefinitionResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_GetOperatorDefinition_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) CheckName(ctx context.Context, in *CheckNameRequest, opts ...grpc.CallOption) (*CheckNameResponse, error) {
	out := new(CheckNameResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_CheckName_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) CreateUserSecret(ctx context.Context, in *CreateUserSecretRequest, opts ...grpc.CallOption) (*CreateUserSecretResponse, error) {
	out := new(CreateUserSecretResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_CreateUserSecret_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) ListUserSecrets(ctx context.Context, in *ListUserSecretsRequest, opts ...grpc.CallOption) (*ListUserSecretsResponse, error) {
	out := new(ListUserSecretsResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_ListUserSecrets_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) GetUserSecret(ctx context.Context, in *GetUserSecretRequest, opts ...grpc.CallOption) (*GetUserSecretResponse, error) {
	out := new(GetUserSecretResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_GetUserSecret_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) UpdateUserSecret(ctx context.Context, in *UpdateUserSecretRequest, opts ...grpc.CallOption) (*UpdateUserSecretResponse, error) {
	out := new(UpdateUserSecretResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_UpdateUserSecret_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) DeleteUserSecret(ctx context.Context, in *DeleteUserSecretRequest, opts ...grpc.CallOption) (*DeleteUserSecretResponse, error) {
	out := new(DeleteUserSecretResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_DeleteUserSecret_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) CreateOrganizationSecret(ctx context.Context, in *CreateOrganizationSecretRequest, opts ...grpc.CallOption) (*CreateOrganizationSecretResponse, error) {
	out := new(CreateOrganizationSecretResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_CreateOrganizationSecret_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) ListOrganizationSecrets(ctx context.Context, in *ListOrganizationSecretsRequest, opts ...grpc.CallOption) (*ListOrganizationSecretsResponse, error) {
	out := new(ListOrganizationSecretsResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_ListOrganizationSecrets_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) GetOrganizationSecret(ctx context.Context, in *GetOrganizationSecretRequest, opts ...grpc.CallOption) (*GetOrganizationSecretResponse, error) {
	out := new(GetOrganizationSecretResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_GetOrganizationSecret_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) UpdateOrganizationSecret(ctx context.Context, in *UpdateOrganizationSecretRequest, opts ...grpc.CallOption) (*UpdateOrganizationSecretResponse, error) {
	out := new(UpdateOrganizationSecretResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_UpdateOrganizationSecret_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePublicServiceClient) DeleteOrganizationSecret(ctx context.Context, in *DeleteOrganizationSecretRequest, opts ...grpc.CallOption) (*DeleteOrganizationSecretResponse, error) {
	out := new(DeleteOrganizationSecretResponse)
	err := c.cc.Invoke(ctx, PipelinePublicService_DeleteOrganizationSecret_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// PipelinePublicServiceServer is the server API for PipelinePublicService service.
// All implementations should embed UnimplementedPipelinePublicServiceServer
// for forward compatibility
type PipelinePublicServiceServer interface {
	// Check if the pipeline server is alive
	//
	// See https://github.com/grpc/grpc/blob/master/doc/health-checking.md.
	Liveness(context.Context, *LivenessRequest) (*LivenessResponse, error)
	// Check if the pipeline server is ready
	//
	// See https://github.com/grpc/grpc/blob/master/doc/health-checking.md
	Readiness(context.Context, *ReadinessRequest) (*ReadinessResponse, error)
	// List accessible pipelines
	//
	// Returns a paginated list of pipelines that are visible to the requester.
	ListPipelines(context.Context, *ListPipelinesRequest) (*ListPipelinesResponse, error)
	// Get a pipeline by UID
	//
	// Returns the details of a pipeline by a permalink defined by the resource
	// UID.
	LookUpPipeline(context.Context, *LookUpPipelineRequest) (*LookUpPipelineResponse, error)
	// Create a new user pipeline
	//
	// Creates a new pipeline under the parenthood of a user. Users can only
	// create a pipeline as the parent of that resource (i.e. the authenticated
	// user must match the `parent` path parameter).
	CreateUserPipeline(context.Context, *CreateUserPipelineRequest) (*CreateUserPipelineResponse, error)
	// List user pipelines
	//
	// Returns a paginated list of pipelines that belong to the specified user.
	// The parent user may be different from the authenticated user, in which
	// case the results will contain the pipelines that are visible to the
	// latter.
	ListUserPipelines(context.Context, *ListUserPipelinesRequest) (*ListUserPipelinesResponse, error)
	// Get a pipeline owned by a user
	//
	// Returns the details of a user-owned pipeline by its resource name, which is defined
	// by the parent user and the ID of the pipeline.
	GetUserPipeline(context.Context, *GetUserPipelineRequest) (*GetUserPipelineResponse, error)
	// Update a pipeline owned by a user
	//
	// Udpates a pipeline, accessing it by its resource name, which is defined by
	// the parent user and the ID of the pipeline. The authenticated user must be
	// the parent of the pipeline in order to modify it.
	//
	// In REST requests, only the supplied pipeline fields will be taken into
	// account when updating the resource.
	UpdateUserPipeline(context.Context, *UpdateUserPipelineRequest) (*UpdateUserPipelineResponse, error)
	// Delete a pipeline owned by a user
	//
	// Deletes a pipeline, accesing it by its resource name, which is defined by
	// the parent user and the ID of the pipeline. The authenticated user must be
	// the parent of the pipeline in order to delete it.
	DeleteUserPipeline(context.Context, *DeleteUserPipelineRequest) (*DeleteUserPipelineResponse, error)
	// Validate a pipeline a pipeline owned by a user
	//
	// Validates a pipeline by its resource name, which is defined by the parent
	// user and the ID of the pipeline.
	//
	// Validation checks the recipe of the pipeline and the status of its components.
	ValidateUserPipeline(context.Context, *ValidateUserPipelineRequest) (*ValidateUserPipelineResponse, error)
	// Rename a pipeline owned by a user
	//
	// Updates the ID of a pipeline. Since this is an output-only field, a custom
	// method is required to modify it.
	//
	// The pipeline name will be updated accordingly, as it is  composed by the
	// parent user and ID of the pipeline (e.g.
	// `users/luigi/pipelines/pizza-recipe-generator`).
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	RenameUserPipeline(context.Context, *RenameUserPipelineRequest) (*RenameUserPipelineResponse, error)
	// Clone a pipeline owned by a user
	//
	// Clones a pipeline owned by a user. The new pipeline may have a different
	// parent, and this can be either a user or an organization.
	CloneUserPipeline(context.Context, *CloneUserPipelineRequest) (*CloneUserPipelineResponse, error)
	// Trigger a pipeline owned by a user
	//
	// Triggers the execution of a pipeline synchronously, i.e., the result is
	// sent back to the user right after the data is processed. This method is
	// intended for real-time inference when low latency is of concern.
	//
	// The pipeline is identified by its resource name, formed by the parent user
	// and ID of the pipeline.
	//
	// For more information, see [Trigger
	// Pipeline](https://www.instill.tech/docs/latest/core/concepts/pipeline#trigger-pipeline).
	TriggerUserPipeline(context.Context, *TriggerUserPipelineRequest) (*TriggerUserPipelineResponse, error)
	// Trigger a pipeline owned by a user asynchronously
	//
	// Triggers the execution of a pipeline asynchronously, i.e., the result
	// contains the necessary information to access the result and status of the
	// operation. This method is intended for cases that require long-running
	// workloads.
	//
	// The pipeline is identified by its resource name, formed by the parent user
	// and ID of the pipeline.
	//
	// For more information, see [Trigger
	// Pipeline](https://www.instill.tech/docs/latest/core/concepts/pipeline#trigger-pipeline).
	TriggerAsyncUserPipeline(context.Context, *TriggerAsyncUserPipelineRequest) (*TriggerAsyncUserPipelineResponse, error)
	// Release a version of a pipeline owned by a user
	//
	// Commits the version of a pipeline, identified by its resource name, which
	// is formed by the parent user and ID of the pipeline.
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	CreateUserPipelineRelease(context.Context, *CreateUserPipelineReleaseRequest) (*CreateUserPipelineReleaseResponse, error)
	// List the releases in a pipeline owned by a user
	//
	// Lists the commited versions of a pipeline, identified by its resource
	// name, which is formed by the parent user and ID of the pipeline.
	ListUserPipelineReleases(context.Context, *ListUserPipelineReleasesRequest) (*ListUserPipelineReleasesResponse, error)
	// Get a release in a pipeline owned by a user
	//
	// Gets the details of a pipeline release, where the pipeline is identified
	// by its resource name, formed by its parent user and ID.
	GetUserPipelineRelease(context.Context, *GetUserPipelineReleaseRequest) (*GetUserPipelineReleaseResponse, error)
	// Update a release in a pipeline owned by a user
	//
	// Updates the details of a pipeline release, where the pipeline is
	// identified by its resource name, formed by its parent user and ID.
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	UpdateUserPipelineRelease(context.Context, *UpdateUserPipelineReleaseRequest) (*UpdateUserPipelineReleaseResponse, error)
	// Delete a release in a pipeline owned by a user
	//
	// Deletes a pipeline release, where the pipeline is identified by its
	// resource name, formed by its parent user and ID.
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	DeleteUserPipelineRelease(context.Context, *DeleteUserPipelineReleaseRequest) (*DeleteUserPipelineReleaseResponse, error)
	// Set the version of a pipeline owned by a user to a pinned release
	//
	// Sets the pipeline configuration to a pinned version defined by a release.
	//
	// The pipeline is identified by its resource name, formed by its parent user
	// and ID.
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	RestoreUserPipelineRelease(context.Context, *RestoreUserPipelineReleaseRequest) (*RestoreUserPipelineReleaseResponse, error)
	// Rename a release in a pipeline owned by a user
	//
	// Updates the ID of a pipeline release, where the pipeline is identified by
	// its resource name, formed by the parent user and ID. Since this is an
	// output-only field, a custom method is required to modify it.
	//
	// The pipeline release name will be updated accordingly, as it is  composed
	// by the pipeline name and the ID of the release (e.g.
	// `users/luigi/pipelines/pizza-recipe-generator/releases/v0.2.1`).
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	RenameUserPipelineRelease(context.Context, *RenameUserPipelineReleaseRequest) (*RenameUserPipelineReleaseResponse, error)
	// Trigger a version of a pipeline owned by a user
	//
	// Triggers the synchronous execution of of a pipeline. While the trigger
	// endpoint (where the release version isn't specified) triggers the pipeline
	// at its latest release, this method allows the client to specified any
	// committed release.
	//
	// The pipeline is identified by its resource name, formed by its parent user
	// and ID.
	TriggerUserPipelineRelease(context.Context, *TriggerUserPipelineReleaseRequest) (*TriggerUserPipelineReleaseResponse, error)
	// Trigger a version of a pipeline owned by a user asynchronously
	//
	// Triggers the asynchronous execution of of a pipeline. While the trigger
	// endpoint (where the release version isn't specified) triggers the pipeline
	// at its latest release, this method allows the client to specified any
	// committed release.
	//
	// The pipeline is identified by its resource name, formed by its parent user
	// and ID.
	TriggerAsyncUserPipelineRelease(context.Context, *TriggerAsyncUserPipelineReleaseRequest) (*TriggerAsyncUserPipelineReleaseResponse, error)
	// Create a new organization pipeline
	//
	// Creates a new pipeline under the parenthood of an organization.
	CreateOrganizationPipeline(context.Context, *CreateOrganizationPipelineRequest) (*CreateOrganizationPipelineResponse, error)
	// List organization pipelines
	//
	// Returns a paginated list of pipelines that belong to the specified
	// organization.
	ListOrganizationPipelines(context.Context, *ListOrganizationPipelinesRequest) (*ListOrganizationPipelinesResponse, error)
	// Get a pipeline owned by an organization
	//
	// Returns the details of an organization-owned pipeline by its resource name,
	// which is defined by the parent organization and the ID of the pipeline.
	GetOrganizationPipeline(context.Context, *GetOrganizationPipelineRequest) (*GetOrganizationPipelineResponse, error)
	// Update a pipeline owned by an organization
	//
	// # Udpates a pipeline, accessing it by its resource name, which is defined by
	//
	// In REST requests, only the supplied pipeline fields will be taken into
	// account when updating the resource.
	UpdateOrganizationPipeline(context.Context, *UpdateOrganizationPipelineRequest) (*UpdateOrganizationPipelineResponse, error)
	// Delete a pipeline owned by an organization
	//
	// Deletes a pipeline, accesing it by its resource name, which is defined by
	// the parent organization and the ID of the pipeline.
	DeleteOrganizationPipeline(context.Context, *DeleteOrganizationPipelineRequest) (*DeleteOrganizationPipelineResponse, error)
	// Validate a pipeline a pipeline owned by an organization
	//
	// Validates a pipeline by its resource name, which is defined by the parent
	// organization and the ID of the pipeline.
	//
	// Validation checks the recipe of the pipeline and the status of its
	// components.
	ValidateOrganizationPipeline(context.Context, *ValidateOrganizationPipelineRequest) (*ValidateOrganizationPipelineResponse, error)
	// Rename a pipeline owned by an organization
	//
	// Updates the ID of a pipeline. Since this is an output-only field, a custom
	// method is required to modify it.
	//
	// The pipeline name will be updated accordingly, as it is  composed by the
	// parent organization and ID of the pipeline (e.g.
	// `organizations/luigi/pipelines/pizza-recipe-generator`).
	RenameOrganizationPipeline(context.Context, *RenameOrganizationPipelineRequest) (*RenameOrganizationPipelineResponse, error)
	// Clone a pipeline owned by an organization
	//
	// Clones a pipeline owned by an organization. The new pipeline may have a
	// different parent, and this can be either a user or an organization.
	CloneOrganizationPipeline(context.Context, *CloneOrganizationPipelineRequest) (*CloneOrganizationPipelineResponse, error)
	// Trigger a pipeline owned by an organization
	//
	// Triggers the execution of a pipeline synchronously, i.e., the result is sent
	// back to the organization right after the data is processed. This method is
	// intended for real-time inference when low latency is of concern.
	//
	// The pipeline is identified by its resource name, formed by the parent
	// organization and ID of the pipeline.
	//
	// For more information, see [Trigger
	// Pipeline](https://www.instill.tech/docs/latest/core/concepts/pipeline#trigger-pipeline).
	TriggerOrganizationPipeline(context.Context, *TriggerOrganizationPipelineRequest) (*TriggerOrganizationPipelineResponse, error)
	// Trigger a pipeline owned by an organization asynchronously
	//
	// Triggers the execution of a pipeline asynchronously, i.e., the result
	// contains the necessary information to access the result and status of the
	// operation. This method is intended for cases that require long-running
	// workloads.
	//
	// The pipeline is identified by its resource name, formed by the parent
	// organization and ID of the pipeline.
	//
	// For more information, see [Trigger
	// Pipeline](https://www.instill.tech/docs/latest/core/concepts/pipeline#trigger-pipeline).
	TriggerAsyncOrganizationPipeline(context.Context, *TriggerAsyncOrganizationPipelineRequest) (*TriggerAsyncOrganizationPipelineResponse, error)
	// Release a version of a pipeline owned by an organization
	//
	// Commits the version of a pipeline, identified by its resource name, which is
	// formed by the parent organization and ID of the pipeline.
	CreateOrganizationPipelineRelease(context.Context, *CreateOrganizationPipelineReleaseRequest) (*CreateOrganizationPipelineReleaseResponse, error)
	// List the releases in a pipeline owned by an organization
	//
	// Lists the commited versions of a pipeline, identified by its resource name,
	// which is formed by the parent organization and ID of the pipeline.
	ListOrganizationPipelineReleases(context.Context, *ListOrganizationPipelineReleasesRequest) (*ListOrganizationPipelineReleasesResponse, error)
	// Get a release in a pipeline owned by an organization
	//
	// Gets the details of a pipeline release, where the pipeline is identified by
	// its resource name, formed by its parent organization and ID.
	GetOrganizationPipelineRelease(context.Context, *GetOrganizationPipelineReleaseRequest) (*GetOrganizationPipelineReleaseResponse, error)
	// Update a release in a pipeline owned by an organization
	//
	// Updates the details of a pipeline release, where the pipeline is identified
	// by its resource name, formed by its parent organization and ID.
	UpdateOrganizationPipelineRelease(context.Context, *UpdateOrganizationPipelineReleaseRequest) (*UpdateOrganizationPipelineReleaseResponse, error)
	// Delete a release in a pipeline owned by an organization
	//
	// Deletes a pipeline release, where the pipeline is identified by its resource
	// name, formed by its parent organization and ID.
	DeleteOrganizationPipelineRelease(context.Context, *DeleteOrganizationPipelineReleaseRequest) (*DeleteOrganizationPipelineReleaseResponse, error)
	// Set the version of a pipeline owned by an organization to a pinned release
	//
	// Sets the pipeline configuration to a pinned version defined by a release.
	//
	// The pipeline is identified by its resource name, formed by its parent
	// organization and ID.
	RestoreOrganizationPipelineRelease(context.Context, *RestoreOrganizationPipelineReleaseRequest) (*RestoreOrganizationPipelineReleaseResponse, error)
	// Rename a release in a pipeline owned by an organization
	//
	// Updates the ID of a pipeline release, where the pipeline is identified by
	// its resource name, formed by the parent organization and ID. Since this is
	// an output-only field, a custom method is required to modify it.
	//
	// The pipeline release name will be updated accordingly, as it is  composed by
	// the pipeline name and the ID of the release (e.g.
	// `organizations/luigi/pipelines/pizza-recipe-generator/releases/v0.2.1`).
	RenameOrganizationPipelineRelease(context.Context, *RenameOrganizationPipelineReleaseRequest) (*RenameOrganizationPipelineReleaseResponse, error)
	// Trigger a version of a pipeline owned by an organization
	//
	// Triggers the synchronous execution of of a pipeline. While the trigger
	// endpoint (where the release version isn't specified) triggers the pipeline
	// at its latest release, this method allows the client to specified any
	// committed release.
	//
	// The pipeline is identified by its resource name, formed by its parent
	// organization and ID.
	TriggerOrganizationPipelineRelease(context.Context, *TriggerOrganizationPipelineReleaseRequest) (*TriggerOrganizationPipelineReleaseResponse, error)
	// Trigger a version of a pipeline owned by an organization asynchronously
	//
	// Triggers the asynchronous execution of of a pipeline. While the trigger
	// endpoint (where the release version isn't specified) triggers the pipeline
	// at its latest release, this method allows the client to specified any
	// committed release.
	//
	// The pipeline is identified by its resource name, formed by its parent
	// organization and ID.
	TriggerAsyncOrganizationPipelineRelease(context.Context, *TriggerAsyncOrganizationPipelineReleaseRequest) (*TriggerAsyncOrganizationPipelineReleaseResponse, error)
	// Get the details of a long-running operation
	//
	// This method allows requesters to request the status and outcome of
	// long-running operations such as asynchronous pipeline triggers.
	GetOperation(context.Context, *GetOperationRequest) (*GetOperationResponse, error)
	// List connector definitions
	//
	// Returns a paginated list of connector definitions.
	ListConnectorDefinitions(context.Context, *ListConnectorDefinitionsRequest) (*ListConnectorDefinitionsResponse, error)
	// Get connector definition
	//
	// Returns the details of a connector definition.
	GetConnectorDefinition(context.Context, *GetConnectorDefinitionRequest) (*GetConnectorDefinitionResponse, error)
	// List operator definitions
	//
	// Returns a paginated list of operator definitions.
	ListOperatorDefinitions(context.Context, *ListOperatorDefinitionsRequest) (*ListOperatorDefinitionsResponse, error)
	// List component definitions
	//
	// Returns a paginated list of component definitions, regardless their type.
	// This offers a single source of truth, with pagination and filter
	// capabilities, for the components that might be used in a VDP pipeline.
	ListComponentDefinitions(context.Context, *ListComponentDefinitionsRequest) (*ListComponentDefinitionsResponse, error)
	// Get operator definition
	//
	// Returns the details of an operator definition.
	GetOperatorDefinition(context.Context, *GetOperatorDefinitionRequest) (*GetOperatorDefinitionResponse, error)
	// Check the availibity of a resource name
	//
	// Check whether a resource name is already in use. Currently this endpoint
	// only supports pipeline and connector resource names.
	CheckName(context.Context, *CheckNameRequest) (*CheckNameResponse, error)
	// Create a new user secret
	//
	// Creates a new secret under the parenthood of an user.
	CreateUserSecret(context.Context, *CreateUserSecretRequest) (*CreateUserSecretResponse, error)
	// List user secrets
	//
	// Returns a paginated list of secrets that belong to the specified
	// user.
	ListUserSecrets(context.Context, *ListUserSecretsRequest) (*ListUserSecretsResponse, error)
	// Get a secret owned by an user
	//
	// Returns the details of an user-owned secret by its resource name,
	// which is defined by the parent user and the ID of the secret.
	GetUserSecret(context.Context, *GetUserSecretRequest) (*GetUserSecretResponse, error)
	// Update a secret owned by an user
	//
	// # Udpates a secret, accessing it by its resource name, which is defined by
	//
	// In REST requests, only the supplied secret fields will be taken into
	// account when updating the resource.
	UpdateUserSecret(context.Context, *UpdateUserSecretRequest) (*UpdateUserSecretResponse, error)
	// Delete a secret owned by an user
	//
	// Deletes a secret, accesing it by its resource name, which is defined by
	// the parent user and the ID of the secret.
	DeleteUserSecret(context.Context, *DeleteUserSecretRequest) (*DeleteUserSecretResponse, error)
	// Create a new organization secret
	//
	// Creates a new secret under the parenthood of an organization.
	CreateOrganizationSecret(context.Context, *CreateOrganizationSecretRequest) (*CreateOrganizationSecretResponse, error)
	// List organization secrets
	//
	// Returns a paginated list of secrets that belong to the specified
	// organization.
	ListOrganizationSecrets(context.Context, *ListOrganizationSecretsRequest) (*ListOrganizationSecretsResponse, error)
	// Get a secret owned by an organization
	//
	// Returns the details of an organization-owned secret by its resource name,
	// which is defined by the parent organization and the ID of the secret.
	GetOrganizationSecret(context.Context, *GetOrganizationSecretRequest) (*GetOrganizationSecretResponse, error)
	// Update a secret owned by an organization
	//
	// # Udpates a secret, accessing it by its resource name, which is defined by
	//
	// In REST requests, only the supplied secret fields will be taken into
	// account when updating the resource.
	UpdateOrganizationSecret(context.Context, *UpdateOrganizationSecretRequest) (*UpdateOrganizationSecretResponse, error)
	// Delete a secret owned by an organization
	//
	// Deletes a secret, accesing it by its resource name, which is defined by
	// the parent organization and the ID of the secret.
	DeleteOrganizationSecret(context.Context, *DeleteOrganizationSecretRequest) (*DeleteOrganizationSecretResponse, error)
}

// UnimplementedPipelinePublicServiceServer should be embedded to have forward compatible implementations.
type UnimplementedPipelinePublicServiceServer struct {
}

func (UnimplementedPipelinePublicServiceServer) Liveness(context.Context, *LivenessRequest) (*LivenessResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Liveness not implemented")
}
func (UnimplementedPipelinePublicServiceServer) Readiness(context.Context, *ReadinessRequest) (*ReadinessResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Readiness not implemented")
}
func (UnimplementedPipelinePublicServiceServer) ListPipelines(context.Context, *ListPipelinesRequest) (*ListPipelinesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListPipelines not implemented")
}
func (UnimplementedPipelinePublicServiceServer) LookUpPipeline(context.Context, *LookUpPipelineRequest) (*LookUpPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method LookUpPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) CreateUserPipeline(context.Context, *CreateUserPipelineRequest) (*CreateUserPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateUserPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) ListUserPipelines(context.Context, *ListUserPipelinesRequest) (*ListUserPipelinesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListUserPipelines not implemented")
}
func (UnimplementedPipelinePublicServiceServer) GetUserPipeline(context.Context, *GetUserPipelineRequest) (*GetUserPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetUserPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) UpdateUserPipeline(context.Context, *UpdateUserPipelineRequest) (*UpdateUserPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateUserPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) DeleteUserPipeline(context.Context, *DeleteUserPipelineRequest) (*DeleteUserPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteUserPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) ValidateUserPipeline(context.Context, *ValidateUserPipelineRequest) (*ValidateUserPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ValidateUserPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) RenameUserPipeline(context.Context, *RenameUserPipelineRequest) (*RenameUserPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RenameUserPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) CloneUserPipeline(context.Context, *CloneUserPipelineRequest) (*CloneUserPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CloneUserPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) TriggerUserPipeline(context.Context, *TriggerUserPipelineRequest) (*TriggerUserPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method TriggerUserPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) TriggerAsyncUserPipeline(context.Context, *TriggerAsyncUserPipelineRequest) (*TriggerAsyncUserPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method TriggerAsyncUserPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) CreateUserPipelineRelease(context.Context, *CreateUserPipelineReleaseRequest) (*CreateUserPipelineReleaseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateUserPipelineRelease not implemented")
}
func (UnimplementedPipelinePublicServiceServer) ListUserPipelineReleases(context.Context, *ListUserPipelineReleasesRequest) (*ListUserPipelineReleasesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListUserPipelineReleases not implemented")
}
func (UnimplementedPipelinePublicServiceServer) GetUserPipelineRelease(context.Context, *GetUserPipelineReleaseRequest) (*GetUserPipelineReleaseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetUserPipelineRelease not implemented")
}
func (UnimplementedPipelinePublicServiceServer) UpdateUserPipelineRelease(context.Context, *UpdateUserPipelineReleaseRequest) (*UpdateUserPipelineReleaseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateUserPipelineRelease not implemented")
}
func (UnimplementedPipelinePublicServiceServer) DeleteUserPipelineRelease(context.Context, *DeleteUserPipelineReleaseRequest) (*DeleteUserPipelineReleaseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteUserPipelineRelease not implemented")
}
func (UnimplementedPipelinePublicServiceServer) RestoreUserPipelineRelease(context.Context, *RestoreUserPipelineReleaseRequest) (*RestoreUserPipelineReleaseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RestoreUserPipelineRelease not implemented")
}
func (UnimplementedPipelinePublicServiceServer) RenameUserPipelineRelease(context.Context, *RenameUserPipelineReleaseRequest) (*RenameUserPipelineReleaseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RenameUserPipelineRelease not implemented")
}
func (UnimplementedPipelinePublicServiceServer) TriggerUserPipelineRelease(context.Context, *TriggerUserPipelineReleaseRequest) (*TriggerUserPipelineReleaseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method TriggerUserPipelineRelease not implemented")
}
func (UnimplementedPipelinePublicServiceServer) TriggerAsyncUserPipelineRelease(context.Context, *TriggerAsyncUserPipelineReleaseRequest) (*TriggerAsyncUserPipelineReleaseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method TriggerAsyncUserPipelineRelease not implemented")
}
func (UnimplementedPipelinePublicServiceServer) CreateOrganizationPipeline(context.Context, *CreateOrganizationPipelineRequest) (*CreateOrganizationPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateOrganizationPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) ListOrganizationPipelines(context.Context, *ListOrganizationPipelinesRequest) (*ListOrganizationPipelinesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListOrganizationPipelines not implemented")
}
func (UnimplementedPipelinePublicServiceServer) GetOrganizationPipeline(context.Context, *GetOrganizationPipelineRequest) (*GetOrganizationPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetOrganizationPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) UpdateOrganizationPipeline(context.Context, *UpdateOrganizationPipelineRequest) (*UpdateOrganizationPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateOrganizationPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) DeleteOrganizationPipeline(context.Context, *DeleteOrganizationPipelineRequest) (*DeleteOrganizationPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteOrganizationPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) ValidateOrganizationPipeline(context.Context, *ValidateOrganizationPipelineRequest) (*ValidateOrganizationPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ValidateOrganizationPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) RenameOrganizationPipeline(context.Context, *RenameOrganizationPipelineRequest) (*RenameOrganizationPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RenameOrganizationPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) CloneOrganizationPipeline(context.Context, *CloneOrganizationPipelineRequest) (*CloneOrganizationPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CloneOrganizationPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) TriggerOrganizationPipeline(context.Context, *TriggerOrganizationPipelineRequest) (*TriggerOrganizationPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method TriggerOrganizationPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) TriggerAsyncOrganizationPipeline(context.Context, *TriggerAsyncOrganizationPipelineRequest) (*TriggerAsyncOrganizationPipelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method TriggerAsyncOrganizationPipeline not implemented")
}
func (UnimplementedPipelinePublicServiceServer) CreateOrganizationPipelineRelease(context.Context, *CreateOrganizationPipelineReleaseRequest) (*CreateOrganizationPipelineReleaseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateOrganizationPipelineRelease not implemented")
}
func (UnimplementedPipelinePublicServiceServer) ListOrganizationPipelineReleases(context.Context, *ListOrganizationPipelineReleasesRequest) (*ListOrganizationPipelineReleasesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListOrganizationPipelineReleases not implemented")
}
func (UnimplementedPipelinePublicServiceServer) GetOrganizationPipelineRelease(context.Context, *GetOrganizationPipelineReleaseRequest) (*GetOrganizationPipelineReleaseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetOrganizationPipelineRelease not implemented")
}
func (UnimplementedPipelinePublicServiceServer) UpdateOrganizationPipelineRelease(context.Context, *UpdateOrganizationPipelineReleaseRequest) (*UpdateOrganizationPipelineReleaseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateOrganizationPipelineRelease not implemented")
}
func (UnimplementedPipelinePublicServiceServer) DeleteOrganizationPipelineRelease(context.Context, *DeleteOrganizationPipelineReleaseRequest) (*DeleteOrganizationPipelineReleaseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteOrganizationPipelineRelease not implemented")
}
func (UnimplementedPipelinePublicServiceServer) RestoreOrganizationPipelineRelease(context.Context, *RestoreOrganizationPipelineReleaseRequest) (*RestoreOrganizationPipelineReleaseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RestoreOrganizationPipelineRelease not implemented")
}
func (UnimplementedPipelinePublicServiceServer) RenameOrganizationPipelineRelease(context.Context, *RenameOrganizationPipelineReleaseRequest) (*RenameOrganizationPipelineReleaseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RenameOrganizationPipelineRelease not implemented")
}
func (UnimplementedPipelinePublicServiceServer) TriggerOrganizationPipelineRelease(context.Context, *TriggerOrganizationPipelineReleaseRequest) (*TriggerOrganizationPipelineReleaseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method TriggerOrganizationPipelineRelease not implemented")
}
func (UnimplementedPipelinePublicServiceServer) TriggerAsyncOrganizationPipelineRelease(context.Context, *TriggerAsyncOrganizationPipelineReleaseRequest) (*TriggerAsyncOrganizationPipelineReleaseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method TriggerAsyncOrganizationPipelineRelease not implemented")
}
func (UnimplementedPipelinePublicServiceServer) GetOperation(context.Context, *GetOperationRequest) (*GetOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetOperation not implemented")
}
func (UnimplementedPipelinePublicServiceServer) ListConnectorDefinitions(context.Context, *ListConnectorDefinitionsRequest) (*ListConnectorDefinitionsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListConnectorDefinitions not implemented")
}
func (UnimplementedPipelinePublicServiceServer) GetConnectorDefinition(context.Context, *GetConnectorDefinitionRequest) (*GetConnectorDefinitionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetConnectorDefinition not implemented")
}
func (UnimplementedPipelinePublicServiceServer) ListOperatorDefinitions(context.Context, *ListOperatorDefinitionsRequest) (*ListOperatorDefinitionsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListOperatorDefinitions not implemented")
}
func (UnimplementedPipelinePublicServiceServer) ListComponentDefinitions(context.Context, *ListComponentDefinitionsRequest) (*ListComponentDefinitionsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListComponentDefinitions not implemented")
}
func (UnimplementedPipelinePublicServiceServer) GetOperatorDefinition(context.Context, *GetOperatorDefinitionRequest) (*GetOperatorDefinitionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetOperatorDefinition not implemented")
}
func (UnimplementedPipelinePublicServiceServer) CheckName(context.Context, *CheckNameRequest) (*CheckNameResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CheckName not implemented")
}
func (UnimplementedPipelinePublicServiceServer) CreateUserSecret(context.Context, *CreateUserSecretRequest) (*CreateUserSecretResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateUserSecret not implemented")
}
func (UnimplementedPipelinePublicServiceServer) ListUserSecrets(context.Context, *ListUserSecretsRequest) (*ListUserSecretsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListUserSecrets not implemented")
}
func (UnimplementedPipelinePublicServiceServer) GetUserSecret(context.Context, *GetUserSecretRequest) (*GetUserSecretResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetUserSecret not implemented")
}
func (UnimplementedPipelinePublicServiceServer) UpdateUserSecret(context.Context, *UpdateUserSecretRequest) (*UpdateUserSecretResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateUserSecret not implemented")
}
func (UnimplementedPipelinePublicServiceServer) DeleteUserSecret(context.Context, *DeleteUserSecretRequest) (*DeleteUserSecretResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteUserSecret not implemented")
}
func (UnimplementedPipelinePublicServiceServer) CreateOrganizationSecret(context.Context, *CreateOrganizationSecretRequest) (*CreateOrganizationSecretResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateOrganizationSecret not implemented")
}
func (UnimplementedPipelinePublicServiceServer) ListOrganizationSecrets(context.Context, *ListOrganizationSecretsRequest) (*ListOrganizationSecretsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListOrganizationSecrets not implemented")
}
func (UnimplementedPipelinePublicServiceServer) GetOrganizationSecret(context.Context, *GetOrganizationSecretRequest) (*GetOrganizationSecretResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetOrganizationSecret not implemented")
}
func (UnimplementedPipelinePublicServiceServer) UpdateOrganizationSecret(context.Context, *UpdateOrganizationSecretRequest) (*UpdateOrganizationSecretResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateOrganizationSecret not implemented")
}
func (UnimplementedPipelinePublicServiceServer) DeleteOrganizationSecret(context.Context, *DeleteOrganizationSecretRequest) (*DeleteOrganizationSecretResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteOrganizationSecret not implemented")
}

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

func RegisterPipelinePublicServiceServer(s grpc.ServiceRegistrar, srv PipelinePublicServiceServer) {
	s.RegisterService(&PipelinePublicService_ServiceDesc, srv)
}

func _PipelinePublicService_Liveness_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(LivenessRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).Liveness(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_Liveness_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).Liveness(ctx, req.(*LivenessRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_Readiness_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ReadinessRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).Readiness(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_Readiness_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).Readiness(ctx, req.(*ReadinessRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_ListPipelines_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListPipelinesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).ListPipelines(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_ListPipelines_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).ListPipelines(ctx, req.(*ListPipelinesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_LookUpPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(LookUpPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).LookUpPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_LookUpPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).LookUpPipeline(ctx, req.(*LookUpPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_CreateUserPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateUserPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).CreateUserPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_CreateUserPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).CreateUserPipeline(ctx, req.(*CreateUserPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_ListUserPipelines_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListUserPipelinesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).ListUserPipelines(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_ListUserPipelines_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).ListUserPipelines(ctx, req.(*ListUserPipelinesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_GetUserPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetUserPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).GetUserPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_GetUserPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).GetUserPipeline(ctx, req.(*GetUserPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_UpdateUserPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateUserPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).UpdateUserPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_UpdateUserPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).UpdateUserPipeline(ctx, req.(*UpdateUserPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_DeleteUserPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteUserPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).DeleteUserPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_DeleteUserPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).DeleteUserPipeline(ctx, req.(*DeleteUserPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_ValidateUserPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ValidateUserPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).ValidateUserPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_ValidateUserPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).ValidateUserPipeline(ctx, req.(*ValidateUserPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_RenameUserPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RenameUserPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).RenameUserPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_RenameUserPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).RenameUserPipeline(ctx, req.(*RenameUserPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_CloneUserPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CloneUserPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).CloneUserPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_CloneUserPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).CloneUserPipeline(ctx, req.(*CloneUserPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_TriggerUserPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TriggerUserPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).TriggerUserPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_TriggerUserPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).TriggerUserPipeline(ctx, req.(*TriggerUserPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_TriggerAsyncUserPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TriggerAsyncUserPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).TriggerAsyncUserPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_TriggerAsyncUserPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).TriggerAsyncUserPipeline(ctx, req.(*TriggerAsyncUserPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_CreateUserPipelineRelease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateUserPipelineReleaseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).CreateUserPipelineRelease(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_CreateUserPipelineRelease_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).CreateUserPipelineRelease(ctx, req.(*CreateUserPipelineReleaseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_ListUserPipelineReleases_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListUserPipelineReleasesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).ListUserPipelineReleases(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_ListUserPipelineReleases_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).ListUserPipelineReleases(ctx, req.(*ListUserPipelineReleasesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_GetUserPipelineRelease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetUserPipelineReleaseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).GetUserPipelineRelease(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_GetUserPipelineRelease_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).GetUserPipelineRelease(ctx, req.(*GetUserPipelineReleaseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_UpdateUserPipelineRelease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateUserPipelineReleaseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).UpdateUserPipelineRelease(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_UpdateUserPipelineRelease_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).UpdateUserPipelineRelease(ctx, req.(*UpdateUserPipelineReleaseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_DeleteUserPipelineRelease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteUserPipelineReleaseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).DeleteUserPipelineRelease(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_DeleteUserPipelineRelease_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).DeleteUserPipelineRelease(ctx, req.(*DeleteUserPipelineReleaseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_RestoreUserPipelineRelease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RestoreUserPipelineReleaseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).RestoreUserPipelineRelease(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_RestoreUserPipelineRelease_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).RestoreUserPipelineRelease(ctx, req.(*RestoreUserPipelineReleaseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_RenameUserPipelineRelease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RenameUserPipelineReleaseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).RenameUserPipelineRelease(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_RenameUserPipelineRelease_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).RenameUserPipelineRelease(ctx, req.(*RenameUserPipelineReleaseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_TriggerUserPipelineRelease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TriggerUserPipelineReleaseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).TriggerUserPipelineRelease(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_TriggerUserPipelineRelease_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).TriggerUserPipelineRelease(ctx, req.(*TriggerUserPipelineReleaseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_TriggerAsyncUserPipelineRelease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TriggerAsyncUserPipelineReleaseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).TriggerAsyncUserPipelineRelease(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_TriggerAsyncUserPipelineRelease_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).TriggerAsyncUserPipelineRelease(ctx, req.(*TriggerAsyncUserPipelineReleaseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_CreateOrganizationPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateOrganizationPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).CreateOrganizationPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_CreateOrganizationPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).CreateOrganizationPipeline(ctx, req.(*CreateOrganizationPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_ListOrganizationPipelines_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListOrganizationPipelinesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).ListOrganizationPipelines(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_ListOrganizationPipelines_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).ListOrganizationPipelines(ctx, req.(*ListOrganizationPipelinesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_GetOrganizationPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetOrganizationPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).GetOrganizationPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_GetOrganizationPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).GetOrganizationPipeline(ctx, req.(*GetOrganizationPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_UpdateOrganizationPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateOrganizationPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).UpdateOrganizationPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_UpdateOrganizationPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).UpdateOrganizationPipeline(ctx, req.(*UpdateOrganizationPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_DeleteOrganizationPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteOrganizationPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).DeleteOrganizationPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_DeleteOrganizationPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).DeleteOrganizationPipeline(ctx, req.(*DeleteOrganizationPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_ValidateOrganizationPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ValidateOrganizationPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).ValidateOrganizationPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_ValidateOrganizationPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).ValidateOrganizationPipeline(ctx, req.(*ValidateOrganizationPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_RenameOrganizationPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RenameOrganizationPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).RenameOrganizationPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_RenameOrganizationPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).RenameOrganizationPipeline(ctx, req.(*RenameOrganizationPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_CloneOrganizationPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CloneOrganizationPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).CloneOrganizationPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_CloneOrganizationPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).CloneOrganizationPipeline(ctx, req.(*CloneOrganizationPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_TriggerOrganizationPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TriggerOrganizationPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).TriggerOrganizationPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_TriggerOrganizationPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).TriggerOrganizationPipeline(ctx, req.(*TriggerOrganizationPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_TriggerAsyncOrganizationPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TriggerAsyncOrganizationPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).TriggerAsyncOrganizationPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_TriggerAsyncOrganizationPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).TriggerAsyncOrganizationPipeline(ctx, req.(*TriggerAsyncOrganizationPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_CreateOrganizationPipelineRelease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateOrganizationPipelineReleaseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).CreateOrganizationPipelineRelease(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_CreateOrganizationPipelineRelease_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).CreateOrganizationPipelineRelease(ctx, req.(*CreateOrganizationPipelineReleaseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_ListOrganizationPipelineReleases_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListOrganizationPipelineReleasesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).ListOrganizationPipelineReleases(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_ListOrganizationPipelineReleases_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).ListOrganizationPipelineReleases(ctx, req.(*ListOrganizationPipelineReleasesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_GetOrganizationPipelineRelease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetOrganizationPipelineReleaseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).GetOrganizationPipelineRelease(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_GetOrganizationPipelineRelease_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).GetOrganizationPipelineRelease(ctx, req.(*GetOrganizationPipelineReleaseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_UpdateOrganizationPipelineRelease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateOrganizationPipelineReleaseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).UpdateOrganizationPipelineRelease(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_UpdateOrganizationPipelineRelease_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).UpdateOrganizationPipelineRelease(ctx, req.(*UpdateOrganizationPipelineReleaseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_DeleteOrganizationPipelineRelease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteOrganizationPipelineReleaseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).DeleteOrganizationPipelineRelease(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_DeleteOrganizationPipelineRelease_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).DeleteOrganizationPipelineRelease(ctx, req.(*DeleteOrganizationPipelineReleaseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_RestoreOrganizationPipelineRelease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RestoreOrganizationPipelineReleaseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).RestoreOrganizationPipelineRelease(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_RestoreOrganizationPipelineRelease_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).RestoreOrganizationPipelineRelease(ctx, req.(*RestoreOrganizationPipelineReleaseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_RenameOrganizationPipelineRelease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RenameOrganizationPipelineReleaseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).RenameOrganizationPipelineRelease(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_RenameOrganizationPipelineRelease_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).RenameOrganizationPipelineRelease(ctx, req.(*RenameOrganizationPipelineReleaseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_TriggerOrganizationPipelineRelease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TriggerOrganizationPipelineReleaseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).TriggerOrganizationPipelineRelease(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_TriggerOrganizationPipelineRelease_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).TriggerOrganizationPipelineRelease(ctx, req.(*TriggerOrganizationPipelineReleaseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_TriggerAsyncOrganizationPipelineRelease_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TriggerAsyncOrganizationPipelineReleaseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).TriggerAsyncOrganizationPipelineRelease(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_TriggerAsyncOrganizationPipelineRelease_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).TriggerAsyncOrganizationPipelineRelease(ctx, req.(*TriggerAsyncOrganizationPipelineReleaseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_GetOperation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetOperationRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).GetOperation(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_GetOperation_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).GetOperation(ctx, req.(*GetOperationRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_ListConnectorDefinitions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListConnectorDefinitionsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).ListConnectorDefinitions(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_ListConnectorDefinitions_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).ListConnectorDefinitions(ctx, req.(*ListConnectorDefinitionsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_GetConnectorDefinition_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetConnectorDefinitionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).GetConnectorDefinition(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_GetConnectorDefinition_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).GetConnectorDefinition(ctx, req.(*GetConnectorDefinitionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_ListOperatorDefinitions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListOperatorDefinitionsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).ListOperatorDefinitions(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_ListOperatorDefinitions_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).ListOperatorDefinitions(ctx, req.(*ListOperatorDefinitionsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_ListComponentDefinitions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListComponentDefinitionsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).ListComponentDefinitions(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_ListComponentDefinitions_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).ListComponentDefinitions(ctx, req.(*ListComponentDefinitionsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_GetOperatorDefinition_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetOperatorDefinitionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).GetOperatorDefinition(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_GetOperatorDefinition_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).GetOperatorDefinition(ctx, req.(*GetOperatorDefinitionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_CheckName_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CheckNameRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).CheckName(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_CheckName_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).CheckName(ctx, req.(*CheckNameRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_CreateUserSecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateUserSecretRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).CreateUserSecret(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_CreateUserSecret_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).CreateUserSecret(ctx, req.(*CreateUserSecretRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_ListUserSecrets_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListUserSecretsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).ListUserSecrets(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_ListUserSecrets_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).ListUserSecrets(ctx, req.(*ListUserSecretsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_GetUserSecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetUserSecretRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).GetUserSecret(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_GetUserSecret_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).GetUserSecret(ctx, req.(*GetUserSecretRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_UpdateUserSecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateUserSecretRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).UpdateUserSecret(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_UpdateUserSecret_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).UpdateUserSecret(ctx, req.(*UpdateUserSecretRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_DeleteUserSecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteUserSecretRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).DeleteUserSecret(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_DeleteUserSecret_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).DeleteUserSecret(ctx, req.(*DeleteUserSecretRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_CreateOrganizationSecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateOrganizationSecretRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).CreateOrganizationSecret(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_CreateOrganizationSecret_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).CreateOrganizationSecret(ctx, req.(*CreateOrganizationSecretRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_ListOrganizationSecrets_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListOrganizationSecretsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).ListOrganizationSecrets(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_ListOrganizationSecrets_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).ListOrganizationSecrets(ctx, req.(*ListOrganizationSecretsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_GetOrganizationSecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetOrganizationSecretRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).GetOrganizationSecret(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_GetOrganizationSecret_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).GetOrganizationSecret(ctx, req.(*GetOrganizationSecretRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_UpdateOrganizationSecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateOrganizationSecretRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).UpdateOrganizationSecret(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_UpdateOrganizationSecret_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).UpdateOrganizationSecret(ctx, req.(*UpdateOrganizationSecretRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePublicService_DeleteOrganizationSecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteOrganizationSecretRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePublicServiceServer).DeleteOrganizationSecret(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePublicService_DeleteOrganizationSecret_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePublicServiceServer).DeleteOrganizationSecret(ctx, req.(*DeleteOrganizationSecretRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// PipelinePublicService_ServiceDesc is the grpc.ServiceDesc for PipelinePublicService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var PipelinePublicService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vdp.pipeline.v1beta.PipelinePublicService",
	HandlerType: (*PipelinePublicServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Liveness",
			Handler:    _PipelinePublicService_Liveness_Handler,
		},
		{
			MethodName: "Readiness",
			Handler:    _PipelinePublicService_Readiness_Handler,
		},
		{
			MethodName: "ListPipelines",
			Handler:    _PipelinePublicService_ListPipelines_Handler,
		},
		{
			MethodName: "LookUpPipeline",
			Handler:    _PipelinePublicService_LookUpPipeline_Handler,
		},
		{
			MethodName: "CreateUserPipeline",
			Handler:    _PipelinePublicService_CreateUserPipeline_Handler,
		},
		{
			MethodName: "ListUserPipelines",
			Handler:    _PipelinePublicService_ListUserPipelines_Handler,
		},
		{
			MethodName: "GetUserPipeline",
			Handler:    _PipelinePublicService_GetUserPipeline_Handler,
		},
		{
			MethodName: "UpdateUserPipeline",
			Handler:    _PipelinePublicService_UpdateUserPipeline_Handler,
		},
		{
			MethodName: "DeleteUserPipeline",
			Handler:    _PipelinePublicService_DeleteUserPipeline_Handler,
		},
		{
			MethodName: "ValidateUserPipeline",
			Handler:    _PipelinePublicService_ValidateUserPipeline_Handler,
		},
		{
			MethodName: "RenameUserPipeline",
			Handler:    _PipelinePublicService_RenameUserPipeline_Handler,
		},
		{
			MethodName: "CloneUserPipeline",
			Handler:    _PipelinePublicService_CloneUserPipeline_Handler,
		},
		{
			MethodName: "TriggerUserPipeline",
			Handler:    _PipelinePublicService_TriggerUserPipeline_Handler,
		},
		{
			MethodName: "TriggerAsyncUserPipeline",
			Handler:    _PipelinePublicService_TriggerAsyncUserPipeline_Handler,
		},
		{
			MethodName: "CreateUserPipelineRelease",
			Handler:    _PipelinePublicService_CreateUserPipelineRelease_Handler,
		},
		{
			MethodName: "ListUserPipelineReleases",
			Handler:    _PipelinePublicService_ListUserPipelineReleases_Handler,
		},
		{
			MethodName: "GetUserPipelineRelease",
			Handler:    _PipelinePublicService_GetUserPipelineRelease_Handler,
		},
		{
			MethodName: "UpdateUserPipelineRelease",
			Handler:    _PipelinePublicService_UpdateUserPipelineRelease_Handler,
		},
		{
			MethodName: "DeleteUserPipelineRelease",
			Handler:    _PipelinePublicService_DeleteUserPipelineRelease_Handler,
		},
		{
			MethodName: "RestoreUserPipelineRelease",
			Handler:    _PipelinePublicService_RestoreUserPipelineRelease_Handler,
		},
		{
			MethodName: "RenameUserPipelineRelease",
			Handler:    _PipelinePublicService_RenameUserPipelineRelease_Handler,
		},
		{
			MethodName: "TriggerUserPipelineRelease",
			Handler:    _PipelinePublicService_TriggerUserPipelineRelease_Handler,
		},
		{
			MethodName: "TriggerAsyncUserPipelineRelease",
			Handler:    _PipelinePublicService_TriggerAsyncUserPipelineRelease_Handler,
		},
		{
			MethodName: "CreateOrganizationPipeline",
			Handler:    _PipelinePublicService_CreateOrganizationPipeline_Handler,
		},
		{
			MethodName: "ListOrganizationPipelines",
			Handler:    _PipelinePublicService_ListOrganizationPipelines_Handler,
		},
		{
			MethodName: "GetOrganizationPipeline",
			Handler:    _PipelinePublicService_GetOrganizationPipeline_Handler,
		},
		{
			MethodName: "UpdateOrganizationPipeline",
			Handler:    _PipelinePublicService_UpdateOrganizationPipeline_Handler,
		},
		{
			MethodName: "DeleteOrganizationPipeline",
			Handler:    _PipelinePublicService_DeleteOrganizationPipeline_Handler,
		},
		{
			MethodName: "ValidateOrganizationPipeline",
			Handler:    _PipelinePublicService_ValidateOrganizationPipeline_Handler,
		},
		{
			MethodName: "RenameOrganizationPipeline",
			Handler:    _PipelinePublicService_RenameOrganizationPipeline_Handler,
		},
		{
			MethodName: "CloneOrganizationPipeline",
			Handler:    _PipelinePublicService_CloneOrganizationPipeline_Handler,
		},
		{
			MethodName: "TriggerOrganizationPipeline",
			Handler:    _PipelinePublicService_TriggerOrganizationPipeline_Handler,
		},
		{
			MethodName: "TriggerAsyncOrganizationPipeline",
			Handler:    _PipelinePublicService_TriggerAsyncOrganizationPipeline_Handler,
		},
		{
			MethodName: "CreateOrganizationPipelineRelease",
			Handler:    _PipelinePublicService_CreateOrganizationPipelineRelease_Handler,
		},
		{
			MethodName: "ListOrganizationPipelineReleases",
			Handler:    _PipelinePublicService_ListOrganizationPipelineReleases_Handler,
		},
		{
			MethodName: "GetOrganizationPipelineRelease",
			Handler:    _PipelinePublicService_GetOrganizationPipelineRelease_Handler,
		},
		{
			MethodName: "UpdateOrganizationPipelineRelease",
			Handler:    _PipelinePublicService_UpdateOrganizationPipelineRelease_Handler,
		},
		{
			MethodName: "DeleteOrganizationPipelineRelease",
			Handler:    _PipelinePublicService_DeleteOrganizationPipelineRelease_Handler,
		},
		{
			MethodName: "RestoreOrganizationPipelineRelease",
			Handler:    _PipelinePublicService_RestoreOrganizationPipelineRelease_Handler,
		},
		{
			MethodName: "RenameOrganizationPipelineRelease",
			Handler:    _PipelinePublicService_RenameOrganizationPipelineRelease_Handler,
		},
		{
			MethodName: "TriggerOrganizationPipelineRelease",
			Handler:    _PipelinePublicService_TriggerOrganizationPipelineRelease_Handler,
		},
		{
			MethodName: "TriggerAsyncOrganizationPipelineRelease",
			Handler:    _PipelinePublicService_TriggerAsyncOrganizationPipelineRelease_Handler,
		},
		{
			MethodName: "GetOperation",
			Handler:    _PipelinePublicService_GetOperation_Handler,
		},
		{
			MethodName: "ListConnectorDefinitions",
			Handler:    _PipelinePublicService_ListConnectorDefinitions_Handler,
		},
		{
			MethodName: "GetConnectorDefinition",
			Handler:    _PipelinePublicService_GetConnectorDefinition_Handler,
		},
		{
			MethodName: "ListOperatorDefinitions",
			Handler:    _PipelinePublicService_ListOperatorDefinitions_Handler,
		},
		{
			MethodName: "ListComponentDefinitions",
			Handler:    _PipelinePublicService_ListComponentDefinitions_Handler,
		},
		{
			MethodName: "GetOperatorDefinition",
			Handler:    _PipelinePublicService_GetOperatorDefinition_Handler,
		},
		{
			MethodName: "CheckName",
			Handler:    _PipelinePublicService_CheckName_Handler,
		},
		{
			MethodName: "CreateUserSecret",
			Handler:    _PipelinePublicService_CreateUserSecret_Handler,
		},
		{
			MethodName: "ListUserSecrets",
			Handler:    _PipelinePublicService_ListUserSecrets_Handler,
		},
		{
			MethodName: "GetUserSecret",
			Handler:    _PipelinePublicService_GetUserSecret_Handler,
		},
		{
			MethodName: "UpdateUserSecret",
			Handler:    _PipelinePublicService_UpdateUserSecret_Handler,
		},
		{
			MethodName: "DeleteUserSecret",
			Handler:    _PipelinePublicService_DeleteUserSecret_Handler,
		},
		{
			MethodName: "CreateOrganizationSecret",
			Handler:    _PipelinePublicService_CreateOrganizationSecret_Handler,
		},
		{
			MethodName: "ListOrganizationSecrets",
			Handler:    _PipelinePublicService_ListOrganizationSecrets_Handler,
		},
		{
			MethodName: "GetOrganizationSecret",
			Handler:    _PipelinePublicService_GetOrganizationSecret_Handler,
		},
		{
			MethodName: "UpdateOrganizationSecret",
			Handler:    _PipelinePublicService_UpdateOrganizationSecret_Handler,
		},
		{
			MethodName: "DeleteOrganizationSecret",
			Handler:    _PipelinePublicService_DeleteOrganizationSecret_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "vdp/pipeline/v1beta/pipeline_public_service.proto",
}