pipeline_private_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_private_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 (
	PipelinePrivateService_ListPipelinesAdmin_FullMethodName        = "/vdp.pipeline.v1beta.PipelinePrivateService/ListPipelinesAdmin"
	PipelinePrivateService_LookUpPipelineAdmin_FullMethodName       = "/vdp.pipeline.v1beta.PipelinePrivateService/LookUpPipelineAdmin"
	PipelinePrivateService_ListPipelineReleasesAdmin_FullMethodName = "/vdp.pipeline.v1beta.PipelinePrivateService/ListPipelineReleasesAdmin"
)

// PipelinePrivateServiceClient is the client API for PipelinePrivateService 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 PipelinePrivateServiceClient interface {
	// List pipelines (admin only)
	//
	// This is a *private* method that allows admin users and internal clients to
	// list *all* pipeline resources.
	ListPipelinesAdmin(ctx context.Context, in *ListPipelinesAdminRequest, opts ...grpc.CallOption) (*ListPipelinesAdminResponse, error)
	// Get a pipeline by UID (admin only)
	//
	// This is a *private* method that allows admin users to access any pipeline
	// resource by its UID.
	LookUpPipelineAdmin(ctx context.Context, in *LookUpPipelineAdminRequest, opts ...grpc.CallOption) (*LookUpPipelineAdminResponse, error)
	// List pipeline releases (admin only)
	//
	// This is a *private* method that allows admin users to list *all* pipeline
	// releases.
	ListPipelineReleasesAdmin(ctx context.Context, in *ListPipelineReleasesAdminRequest, opts ...grpc.CallOption) (*ListPipelineReleasesAdminResponse, error)
}

type pipelinePrivateServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewPipelinePrivateServiceClient(cc grpc.ClientConnInterface) PipelinePrivateServiceClient {
	return &pipelinePrivateServiceClient{cc}
}

func (c *pipelinePrivateServiceClient) ListPipelinesAdmin(ctx context.Context, in *ListPipelinesAdminRequest, opts ...grpc.CallOption) (*ListPipelinesAdminResponse, error) {
	out := new(ListPipelinesAdminResponse)
	err := c.cc.Invoke(ctx, PipelinePrivateService_ListPipelinesAdmin_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePrivateServiceClient) LookUpPipelineAdmin(ctx context.Context, in *LookUpPipelineAdminRequest, opts ...grpc.CallOption) (*LookUpPipelineAdminResponse, error) {
	out := new(LookUpPipelineAdminResponse)
	err := c.cc.Invoke(ctx, PipelinePrivateService_LookUpPipelineAdmin_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pipelinePrivateServiceClient) ListPipelineReleasesAdmin(ctx context.Context, in *ListPipelineReleasesAdminRequest, opts ...grpc.CallOption) (*ListPipelineReleasesAdminResponse, error) {
	out := new(ListPipelineReleasesAdminResponse)
	err := c.cc.Invoke(ctx, PipelinePrivateService_ListPipelineReleasesAdmin_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// PipelinePrivateServiceServer is the server API for PipelinePrivateService service.
// All implementations should embed UnimplementedPipelinePrivateServiceServer
// for forward compatibility
type PipelinePrivateServiceServer interface {
	// List pipelines (admin only)
	//
	// This is a *private* method that allows admin users and internal clients to
	// list *all* pipeline resources.
	ListPipelinesAdmin(context.Context, *ListPipelinesAdminRequest) (*ListPipelinesAdminResponse, error)
	// Get a pipeline by UID (admin only)
	//
	// This is a *private* method that allows admin users to access any pipeline
	// resource by its UID.
	LookUpPipelineAdmin(context.Context, *LookUpPipelineAdminRequest) (*LookUpPipelineAdminResponse, error)
	// List pipeline releases (admin only)
	//
	// This is a *private* method that allows admin users to list *all* pipeline
	// releases.
	ListPipelineReleasesAdmin(context.Context, *ListPipelineReleasesAdminRequest) (*ListPipelineReleasesAdminResponse, error)
}

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

func (UnimplementedPipelinePrivateServiceServer) ListPipelinesAdmin(context.Context, *ListPipelinesAdminRequest) (*ListPipelinesAdminResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListPipelinesAdmin not implemented")
}
func (UnimplementedPipelinePrivateServiceServer) LookUpPipelineAdmin(context.Context, *LookUpPipelineAdminRequest) (*LookUpPipelineAdminResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method LookUpPipelineAdmin not implemented")
}
func (UnimplementedPipelinePrivateServiceServer) ListPipelineReleasesAdmin(context.Context, *ListPipelineReleasesAdminRequest) (*ListPipelineReleasesAdminResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListPipelineReleasesAdmin not implemented")
}

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

func RegisterPipelinePrivateServiceServer(s grpc.ServiceRegistrar, srv PipelinePrivateServiceServer) {
	s.RegisterService(&PipelinePrivateService_ServiceDesc, srv)
}

func _PipelinePrivateService_ListPipelinesAdmin_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListPipelinesAdminRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePrivateServiceServer).ListPipelinesAdmin(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePrivateService_ListPipelinesAdmin_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePrivateServiceServer).ListPipelinesAdmin(ctx, req.(*ListPipelinesAdminRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePrivateService_LookUpPipelineAdmin_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(LookUpPipelineAdminRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePrivateServiceServer).LookUpPipelineAdmin(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePrivateService_LookUpPipelineAdmin_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePrivateServiceServer).LookUpPipelineAdmin(ctx, req.(*LookUpPipelineAdminRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _PipelinePrivateService_ListPipelineReleasesAdmin_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListPipelineReleasesAdminRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PipelinePrivateServiceServer).ListPipelineReleasesAdmin(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: PipelinePrivateService_ListPipelineReleasesAdmin_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PipelinePrivateServiceServer).ListPipelineReleasesAdmin(ctx, req.(*ListPipelineReleasesAdminRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// PipelinePrivateService_ServiceDesc is the grpc.ServiceDesc for PipelinePrivateService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var PipelinePrivateService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vdp.pipeline.v1beta.PipelinePrivateService",
	HandlerType: (*PipelinePrivateServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListPipelinesAdmin",
			Handler:    _PipelinePrivateService_ListPipelinesAdmin_Handler,
		},
		{
			MethodName: "LookUpPipelineAdmin",
			Handler:    _PipelinePrivateService_LookUpPipelineAdmin_Handler,
		},
		{
			MethodName: "ListPipelineReleasesAdmin",
			Handler:    _PipelinePrivateService_ListPipelineReleasesAdmin_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "vdp/pipeline/v1beta/pipeline_private_service.proto",
}