kubelatte-ce

1
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
2
// versions:
3
// - protoc-gen-go-grpc v1.3.0
4
// - protoc             v5.26.1
5
// source: Executor.proto
6

7
package proto
8

9
import (
10
	context "context"
11
	grpc "google.golang.org/grpc"
12
	codes "google.golang.org/grpc/codes"
13
	status "google.golang.org/grpc/status"
14
)
15

16
// This is a compile-time assertion to ensure that this generated file
17
// is compatible with the grpc package it is being compiled against.
18
// Requires gRPC-Go v1.32.0 or later.
19
const _ = grpc.SupportPackageIsVersion7
20

21
const (
22
	Executor_DoSideEffect_FullMethodName = "/proto.Executor/DoSideEffect"
23
)
24

25
// ExecutorClient is the client API for Executor service.
26
//
27
// 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.
28
type ExecutorClient interface {
29
	DoSideEffect(ctx context.Context, in *SideEffectInfo, opts ...grpc.CallOption) (*EmptyMes, error)
30
}
31

32
type executorClient struct {
33
	cc grpc.ClientConnInterface
34
}
35

36
func NewExecutorClient(cc grpc.ClientConnInterface) ExecutorClient {
37
	return &executorClient{cc}
38
}
39

40
func (c *executorClient) DoSideEffect(ctx context.Context, in *SideEffectInfo, opts ...grpc.CallOption) (*EmptyMes, error) {
41
	out := new(EmptyMes)
42
	err := c.cc.Invoke(ctx, Executor_DoSideEffect_FullMethodName, in, out, opts...)
43
	if err != nil {
44
		return nil, err
45
	}
46
	return out, nil
47
}
48

49
// ExecutorServer is the server API for Executor service.
50
// All implementations must embed UnimplementedExecutorServer
51
// for forward compatibility
52
type ExecutorServer interface {
53
	DoSideEffect(context.Context, *SideEffectInfo) (*EmptyMes, error)
54
	mustEmbedUnimplementedExecutorServer()
55
}
56

57
// UnimplementedExecutorServer must be embedded to have forward compatible implementations.
58
type UnimplementedExecutorServer struct {
59
}
60

61
func (UnimplementedExecutorServer) DoSideEffect(context.Context, *SideEffectInfo) (*EmptyMes, error) {
62
	return nil, status.Errorf(codes.Unimplemented, "method DoSideEffect not implemented")
63
}
64
func (UnimplementedExecutorServer) mustEmbedUnimplementedExecutorServer() {}
65

66
// UnsafeExecutorServer may be embedded to opt out of forward compatibility for this service.
67
// Use of this interface is not recommended, as added methods to ExecutorServer will
68
// result in compilation errors.
69
type UnsafeExecutorServer interface {
70
	mustEmbedUnimplementedExecutorServer()
71
}
72

73
func RegisterExecutorServer(s grpc.ServiceRegistrar, srv ExecutorServer) {
74
	s.RegisterService(&Executor_ServiceDesc, srv)
75
}
76

77
func _Executor_DoSideEffect_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
78
	in := new(SideEffectInfo)
79
	if err := dec(in); err != nil {
80
		return nil, err
81
	}
82
	if interceptor == nil {
83
		return srv.(ExecutorServer).DoSideEffect(ctx, in)
84
	}
85
	info := &grpc.UnaryServerInfo{
86
		Server:     srv,
87
		FullMethod: Executor_DoSideEffect_FullMethodName,
88
	}
89
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
90
		return srv.(ExecutorServer).DoSideEffect(ctx, req.(*SideEffectInfo))
91
	}
92
	return interceptor(ctx, in, info, handler)
93
}
94

95
// Executor_ServiceDesc is the grpc.ServiceDesc for Executor service.
96
// It's only intended for direct use with grpc.RegisterService,
97
// and not to be introspected or modified (even as a copy)
98
var Executor_ServiceDesc = grpc.ServiceDesc{
99
	ServiceName: "proto.Executor",
100
	HandlerType: (*ExecutorServer)(nil),
101
	Methods: []grpc.MethodDesc{
102
		{
103
			MethodName: "DoSideEffect",
104
			Handler:    _Executor_DoSideEffect_Handler,
105
		},
106
	},
107
	Streams:  []grpc.StreamDesc{},
108
	Metadata: "Executor.proto",
109
}
110