tasks/chasm/lib/nexusoperation/gen/nexusoperationpb/v1/service_grpc.pb.go

// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// plugins:
// - protoc-gen-go-grpc
// - protoc
// source: temporal/server/chasm/lib/nexusoperation/proto/v1/service.proto

package nexusoperationpb

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 (
	NexusOperationService_StartNexusOperation_FullMethodName         = "/temporal.server.chasm.lib.nexusoperation.proto.v1.NexusOperationService/StartNexusOperation"
	NexusOperationService_DescribeNexusOperation_FullMethodName      = "/temporal.server.chasm.lib.nexusoperation.proto.v1.NexusOperationService/DescribeNexusOperation"
	NexusOperationService_RequestCancelNexusOperation_FullMethodName = "/temporal.server.chasm.lib.nexusoperation.proto.v1.NexusOperationService/RequestCancelNexusOperation"
	NexusOperationService_TerminateNexusOperation_FullMethodName     = "/temporal.server.chasm.lib.nexusoperation.proto.v1.NexusOperationService/TerminateNexusOperation"
	NexusOperationService_DeleteNexusOperation_FullMethodName        = "/temporal.server.chasm.lib.nexusoperation.proto.v1.NexusOperationService/DeleteNexusOperation"
	NexusOperationService_PollNexusOperation_FullMethodName          = "/temporal.server.chasm.lib.nexusoperation.proto.v1.NexusOperationService/PollNexusOperation"
)

// NexusOperationServiceClient is the client API for NexusOperationService 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 NexusOperationServiceClient interface {
	StartNexusOperation(ctx context.Context, in *StartNexusOperationRequest, opts ...grpc.CallOption) (*StartNexusOperationResponse, error)
	DescribeNexusOperation(ctx context.Context, in *DescribeNexusOperationRequest, opts ...grpc.CallOption) (*DescribeNexusOperationResponse, error)
	RequestCancelNexusOperation(ctx context.Context, in *RequestCancelNexusOperationRequest, opts ...grpc.CallOption) (*RequestCancelNexusOperationResponse, error)
	TerminateNexusOperation(ctx context.Context, in *TerminateNexusOperationRequest, opts ...grpc.CallOption) (*TerminateNexusOperationResponse, error)
	DeleteNexusOperation(ctx context.Context, in *DeleteNexusOperationRequest, opts ...grpc.CallOption) (*DeleteNexusOperationResponse, error)
	PollNexusOperation(ctx context.Context, in *PollNexusOperationRequest, opts ...grpc.CallOption) (*PollNexusOperationResponse, error)
}

type nexusOperationServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewNexusOperationServiceClient(cc grpc.ClientConnInterface) NexusOperationServiceClient {
	return &nexusOperationServiceClient{cc}
}

func (c *nexusOperationServiceClient) StartNexusOperation(ctx context.Context, in *StartNexusOperationRequest, opts ...grpc.CallOption) (*StartNexusOperationResponse, error) {
	out := new(StartNexusOperationResponse)
	err := c.cc.Invoke(ctx, NexusOperationService_StartNexusOperation_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *nexusOperationServiceClient) DescribeNexusOperation(ctx context.Context, in *DescribeNexusOperationRequest, opts ...grpc.CallOption) (*DescribeNexusOperationResponse, error) {
	out := new(DescribeNexusOperationResponse)
	err := c.cc.Invoke(ctx, NexusOperationService_DescribeNexusOperation_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *nexusOperationServiceClient) RequestCancelNexusOperation(ctx context.Context, in *RequestCancelNexusOperationRequest, opts ...grpc.CallOption) (*RequestCancelNexusOperationResponse, error) {
	out := new(RequestCancelNexusOperationResponse)
	err := c.cc.Invoke(ctx, NexusOperationService_RequestCancelNexusOperation_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *nexusOperationServiceClient) TerminateNexusOperation(ctx context.Context, in *TerminateNexusOperationRequest, opts ...grpc.CallOption) (*TerminateNexusOperationResponse, error) {
	out := new(TerminateNexusOperationResponse)
	err := c.cc.Invoke(ctx, NexusOperationService_TerminateNexusOperation_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *nexusOperationServiceClient) DeleteNexusOperation(ctx context.Context, in *DeleteNexusOperationRequest, opts ...grpc.CallOption) (*DeleteNexusOperationResponse, error) {
	out := new(DeleteNexusOperationResponse)
	err := c.cc.Invoke(ctx, NexusOperationService_DeleteNexusOperation_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *nexusOperationServiceClient) PollNexusOperation(ctx context.Context, in *PollNexusOperationRequest, opts ...grpc.CallOption) (*PollNexusOperationResponse, error) {
	out := new(PollNexusOperationResponse)
	err := c.cc.Invoke(ctx, NexusOperationService_PollNexusOperation_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// NexusOperationServiceServer is the server API for NexusOperationService service.
// All implementations must embed UnimplementedNexusOperationServiceServer
// for forward compatibility
type NexusOperationServiceServer interface {
	StartNexusOperation(context.Context, *StartNexusOperationRequest) (*StartNexusOperationResponse, error)
	DescribeNexusOperation(context.Context, *DescribeNexusOperationRequest) (*DescribeNexusOperationResponse, error)
	RequestCancelNexusOperation(context.Context, *RequestCancelNexusOperationRequest) (*RequestCancelNexusOperationResponse, error)
	TerminateNexusOperation(context.Context, *TerminateNexusOperationRequest) (*TerminateNexusOperationResponse, error)
	DeleteNexusOperation(context.Context, *DeleteNexusOperationRequest) (*DeleteNexusOperationResponse, error)
	PollNexusOperation(context.Context, *PollNexusOperationRequest) (*PollNexusOperationResponse, error)
	mustEmbedUnimplementedNexusOperationServiceServer()
}

// UnimplementedNexusOperationServiceServer must be embedded to have forward compatible implementations.
type UnimplementedNexusOperationServiceServer struct {
}

func (UnimplementedNexusOperationServiceServer) StartNexusOperation(context.Context, *StartNexusOperationRequest) (*StartNexusOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method StartNexusOperation not implemented")
}
func (UnimplementedNexusOperationServiceServer) DescribeNexusOperation(context.Context, *DescribeNexusOperationRequest) (*DescribeNexusOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DescribeNexusOperation not implemented")
}
func (UnimplementedNexusOperationServiceServer) RequestCancelNexusOperation(context.Context, *RequestCancelNexusOperationRequest) (*RequestCancelNexusOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RequestCancelNexusOperation not implemented")
}
func (UnimplementedNexusOperationServiceServer) TerminateNexusOperation(context.Context, *TerminateNexusOperationRequest) (*TerminateNexusOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method TerminateNexusOperation not implemented")
}
func (UnimplementedNexusOperationServiceServer) DeleteNexusOperation(context.Context, *DeleteNexusOperationRequest) (*DeleteNexusOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteNexusOperation not implemented")
}
func (UnimplementedNexusOperationServiceServer) PollNexusOperation(context.Context, *PollNexusOperationRequest) (*PollNexusOperationResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method PollNexusOperation not implemented")
}
func (UnimplementedNexusOperationServiceServer) mustEmbedUnimplementedNexusOperationServiceServer() {}

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

func RegisterNexusOperationServiceServer(s grpc.ServiceRegistrar, srv NexusOperationServiceServer) {
	s.RegisterService(&NexusOperationService_ServiceDesc, srv)
}

func _NexusOperationService_StartNexusOperation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(StartNexusOperationRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(NexusOperationServiceServer).StartNexusOperation(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: NexusOperationService_StartNexusOperation_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(NexusOperationServiceServer).StartNexusOperation(ctx, req.(*StartNexusOperationRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _NexusOperationService_DescribeNexusOperation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DescribeNexusOperationRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(NexusOperationServiceServer).DescribeNexusOperation(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: NexusOperationService_DescribeNexusOperation_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(NexusOperationServiceServer).DescribeNexusOperation(ctx, req.(*DescribeNexusOperationRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _NexusOperationService_RequestCancelNexusOperation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RequestCancelNexusOperationRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(NexusOperationServiceServer).RequestCancelNexusOperation(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: NexusOperationService_RequestCancelNexusOperation_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(NexusOperationServiceServer).RequestCancelNexusOperation(ctx, req.(*RequestCancelNexusOperationRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _NexusOperationService_TerminateNexusOperation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TerminateNexusOperationRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(NexusOperationServiceServer).TerminateNexusOperation(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: NexusOperationService_TerminateNexusOperation_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(NexusOperationServiceServer).TerminateNexusOperation(ctx, req.(*TerminateNexusOperationRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _NexusOperationService_DeleteNexusOperation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteNexusOperationRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(NexusOperationServiceServer).DeleteNexusOperation(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: NexusOperationService_DeleteNexusOperation_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(NexusOperationServiceServer).DeleteNexusOperation(ctx, req.(*DeleteNexusOperationRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _NexusOperationService_PollNexusOperation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PollNexusOperationRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(NexusOperationServiceServer).PollNexusOperation(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: NexusOperationService_PollNexusOperation_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(NexusOperationServiceServer).PollNexusOperation(ctx, req.(*PollNexusOperationRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// NexusOperationService_ServiceDesc is the grpc.ServiceDesc for NexusOperationService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var NexusOperationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "temporal.server.chasm.lib.nexusoperation.proto.v1.NexusOperationService",
	HandlerType: (*NexusOperationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StartNexusOperation",
			Handler:    _NexusOperationService_StartNexusOperation_Handler,
		},
		{
			MethodName: "DescribeNexusOperation",
			Handler:    _NexusOperationService_DescribeNexusOperation_Handler,
		},
		{
			MethodName: "RequestCancelNexusOperation",
			Handler:    _NexusOperationService_RequestCancelNexusOperation_Handler,
		},
		{
			MethodName: "TerminateNexusOperation",
			Handler:    _NexusOperationService_TerminateNexusOperation_Handler,
		},
		{
			MethodName: "DeleteNexusOperation",
			Handler:    _NexusOperationService_DeleteNexusOperation_Handler,
		},
		{
			MethodName: "PollNexusOperation",
			Handler:    _NexusOperationService_PollNexusOperation_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "temporal/server/chasm/lib/nexusoperation/proto/v1/service.proto",
}