kubelatte-ce
Форк от sbertech/kubelatte-ce
109 строк · 3.6 Кб
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
7package proto8
9import (10context "context"11grpc "google.golang.org/grpc"12codes "google.golang.org/grpc/codes"13status "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.
19const _ = grpc.SupportPackageIsVersion720
21const (22Executor_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.
28type ExecutorClient interface {29DoSideEffect(ctx context.Context, in *SideEffectInfo, opts ...grpc.CallOption) (*EmptyMes, error)30}
31
32type executorClient struct {33cc grpc.ClientConnInterface34}
35
36func NewExecutorClient(cc grpc.ClientConnInterface) ExecutorClient {37return &executorClient{cc}38}
39
40func (c *executorClient) DoSideEffect(ctx context.Context, in *SideEffectInfo, opts ...grpc.CallOption) (*EmptyMes, error) {41out := new(EmptyMes)42err := c.cc.Invoke(ctx, Executor_DoSideEffect_FullMethodName, in, out, opts...)43if err != nil {44return nil, err45}46return out, nil47}
48
49// ExecutorServer is the server API for Executor service.
50// All implementations must embed UnimplementedExecutorServer
51// for forward compatibility
52type ExecutorServer interface {53DoSideEffect(context.Context, *SideEffectInfo) (*EmptyMes, error)54mustEmbedUnimplementedExecutorServer()55}
56
57// UnimplementedExecutorServer must be embedded to have forward compatible implementations.
58type UnimplementedExecutorServer struct {59}
60
61func (UnimplementedExecutorServer) DoSideEffect(context.Context, *SideEffectInfo) (*EmptyMes, error) {62return nil, status.Errorf(codes.Unimplemented, "method DoSideEffect not implemented")63}
64func (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.
69type UnsafeExecutorServer interface {70mustEmbedUnimplementedExecutorServer()71}
72
73func RegisterExecutorServer(s grpc.ServiceRegistrar, srv ExecutorServer) {74s.RegisterService(&Executor_ServiceDesc, srv)75}
76
77func _Executor_DoSideEffect_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {78in := new(SideEffectInfo)79if err := dec(in); err != nil {80return nil, err81}82if interceptor == nil {83return srv.(ExecutorServer).DoSideEffect(ctx, in)84}85info := &grpc.UnaryServerInfo{86Server: srv,87FullMethod: Executor_DoSideEffect_FullMethodName,88}89handler := func(ctx context.Context, req interface{}) (interface{}, error) {90return srv.(ExecutorServer).DoSideEffect(ctx, req.(*SideEffectInfo))91}92return 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)
98var Executor_ServiceDesc = grpc.ServiceDesc{99ServiceName: "proto.Executor",100HandlerType: (*ExecutorServer)(nil),101Methods: []grpc.MethodDesc{102{103MethodName: "DoSideEffect",104Handler: _Executor_DoSideEffect_Handler,105},106},107Streams: []grpc.StreamDesc{},108Metadata: "Executor.proto",109}
110