// Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.2.0 // - protoc v3.21.12 // source: validator.proto package validator 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 // ValidatorMapfixServiceClient is the client API for ValidatorMapfixService 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 ValidatorMapfixServiceClient interface { Create(ctx context.Context, in *MapfixCreate, opts ...grpc.CallOption) (*MapfixID, error) CreateAuditError(ctx context.Context, in *AuditErrorRequest, opts ...grpc.CallOption) (*NullResponse, error) CreateAuditChecklist(ctx context.Context, in *AuditChecklistRequest, opts ...grpc.CallOption) (*NullResponse, error) SetValidatedModel(ctx context.Context, in *ValidatedModelRequest, opts ...grpc.CallOption) (*NullResponse, error) SetStatusSubmitted(ctx context.Context, in *SubmittedRequest, opts ...grpc.CallOption) (*NullResponse, error) SetStatusRequestChanges(ctx context.Context, in *MapfixID, opts ...grpc.CallOption) (*NullResponse, error) SetStatusValidated(ctx context.Context, in *MapfixID, opts ...grpc.CallOption) (*NullResponse, error) SetStatusNotValidated(ctx context.Context, in *MapfixID, opts ...grpc.CallOption) (*NullResponse, error) SetStatusUploaded(ctx context.Context, in *MapfixID, opts ...grpc.CallOption) (*NullResponse, error) SetStatusNotUploaded(ctx context.Context, in *MapfixID, opts ...grpc.CallOption) (*NullResponse, error) SetStatusReleased(ctx context.Context, in *MapfixReleaseRequest, opts ...grpc.CallOption) (*NullResponse, error) SetStatusNotReleased(ctx context.Context, in *MapfixID, opts ...grpc.CallOption) (*NullResponse, error) } type validatorMapfixServiceClient struct { cc grpc.ClientConnInterface } func NewValidatorMapfixServiceClient(cc grpc.ClientConnInterface) ValidatorMapfixServiceClient { return &validatorMapfixServiceClient{cc} } func (c *validatorMapfixServiceClient) Create(ctx context.Context, in *MapfixCreate, opts ...grpc.CallOption) (*MapfixID, error) { out := new(MapfixID) err := c.cc.Invoke(ctx, "/validator.ValidatorMapfixService/Create", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorMapfixServiceClient) CreateAuditError(ctx context.Context, in *AuditErrorRequest, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorMapfixService/CreateAuditError", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorMapfixServiceClient) CreateAuditChecklist(ctx context.Context, in *AuditChecklistRequest, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorMapfixService/CreateAuditChecklist", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorMapfixServiceClient) SetValidatedModel(ctx context.Context, in *ValidatedModelRequest, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorMapfixService/SetValidatedModel", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorMapfixServiceClient) SetStatusSubmitted(ctx context.Context, in *SubmittedRequest, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorMapfixService/SetStatusSubmitted", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorMapfixServiceClient) SetStatusRequestChanges(ctx context.Context, in *MapfixID, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorMapfixService/SetStatusRequestChanges", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorMapfixServiceClient) SetStatusValidated(ctx context.Context, in *MapfixID, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorMapfixService/SetStatusValidated", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorMapfixServiceClient) SetStatusNotValidated(ctx context.Context, in *MapfixID, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorMapfixService/SetStatusNotValidated", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorMapfixServiceClient) SetStatusUploaded(ctx context.Context, in *MapfixID, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorMapfixService/SetStatusUploaded", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorMapfixServiceClient) SetStatusNotUploaded(ctx context.Context, in *MapfixID, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorMapfixService/SetStatusNotUploaded", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorMapfixServiceClient) SetStatusReleased(ctx context.Context, in *MapfixReleaseRequest, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorMapfixService/SetStatusReleased", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorMapfixServiceClient) SetStatusNotReleased(ctx context.Context, in *MapfixID, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorMapfixService/SetStatusNotReleased", in, out, opts...) if err != nil { return nil, err } return out, nil } // ValidatorMapfixServiceServer is the server API for ValidatorMapfixService service. // All implementations must embed UnimplementedValidatorMapfixServiceServer // for forward compatibility type ValidatorMapfixServiceServer interface { Create(context.Context, *MapfixCreate) (*MapfixID, error) CreateAuditError(context.Context, *AuditErrorRequest) (*NullResponse, error) CreateAuditChecklist(context.Context, *AuditChecklistRequest) (*NullResponse, error) SetValidatedModel(context.Context, *ValidatedModelRequest) (*NullResponse, error) SetStatusSubmitted(context.Context, *SubmittedRequest) (*NullResponse, error) SetStatusRequestChanges(context.Context, *MapfixID) (*NullResponse, error) SetStatusValidated(context.Context, *MapfixID) (*NullResponse, error) SetStatusNotValidated(context.Context, *MapfixID) (*NullResponse, error) SetStatusUploaded(context.Context, *MapfixID) (*NullResponse, error) SetStatusNotUploaded(context.Context, *MapfixID) (*NullResponse, error) SetStatusReleased(context.Context, *MapfixReleaseRequest) (*NullResponse, error) SetStatusNotReleased(context.Context, *MapfixID) (*NullResponse, error) mustEmbedUnimplementedValidatorMapfixServiceServer() } // UnimplementedValidatorMapfixServiceServer must be embedded to have forward compatible implementations. type UnimplementedValidatorMapfixServiceServer struct { } func (UnimplementedValidatorMapfixServiceServer) Create(context.Context, *MapfixCreate) (*MapfixID, error) { return nil, status.Errorf(codes.Unimplemented, "method Create not implemented") } func (UnimplementedValidatorMapfixServiceServer) CreateAuditError(context.Context, *AuditErrorRequest) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateAuditError not implemented") } func (UnimplementedValidatorMapfixServiceServer) CreateAuditChecklist(context.Context, *AuditChecklistRequest) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateAuditChecklist not implemented") } func (UnimplementedValidatorMapfixServiceServer) SetValidatedModel(context.Context, *ValidatedModelRequest) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetValidatedModel not implemented") } func (UnimplementedValidatorMapfixServiceServer) SetStatusSubmitted(context.Context, *SubmittedRequest) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetStatusSubmitted not implemented") } func (UnimplementedValidatorMapfixServiceServer) SetStatusRequestChanges(context.Context, *MapfixID) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetStatusRequestChanges not implemented") } func (UnimplementedValidatorMapfixServiceServer) SetStatusValidated(context.Context, *MapfixID) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetStatusValidated not implemented") } func (UnimplementedValidatorMapfixServiceServer) SetStatusNotValidated(context.Context, *MapfixID) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetStatusNotValidated not implemented") } func (UnimplementedValidatorMapfixServiceServer) SetStatusUploaded(context.Context, *MapfixID) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetStatusUploaded not implemented") } func (UnimplementedValidatorMapfixServiceServer) SetStatusNotUploaded(context.Context, *MapfixID) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetStatusNotUploaded not implemented") } func (UnimplementedValidatorMapfixServiceServer) SetStatusReleased(context.Context, *MapfixReleaseRequest) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetStatusReleased not implemented") } func (UnimplementedValidatorMapfixServiceServer) SetStatusNotReleased(context.Context, *MapfixID) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetStatusNotReleased not implemented") } func (UnimplementedValidatorMapfixServiceServer) mustEmbedUnimplementedValidatorMapfixServiceServer() { } // UnsafeValidatorMapfixServiceServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to ValidatorMapfixServiceServer will // result in compilation errors. type UnsafeValidatorMapfixServiceServer interface { mustEmbedUnimplementedValidatorMapfixServiceServer() } func RegisterValidatorMapfixServiceServer(s grpc.ServiceRegistrar, srv ValidatorMapfixServiceServer) { s.RegisterService(&ValidatorMapfixService_ServiceDesc, srv) } func _ValidatorMapfixService_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(MapfixCreate) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorMapfixServiceServer).Create(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorMapfixService/Create", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorMapfixServiceServer).Create(ctx, req.(*MapfixCreate)) } return interceptor(ctx, in, info, handler) } func _ValidatorMapfixService_CreateAuditError_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(AuditErrorRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorMapfixServiceServer).CreateAuditError(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorMapfixService/CreateAuditError", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorMapfixServiceServer).CreateAuditError(ctx, req.(*AuditErrorRequest)) } return interceptor(ctx, in, info, handler) } func _ValidatorMapfixService_CreateAuditChecklist_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(AuditChecklistRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorMapfixServiceServer).CreateAuditChecklist(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorMapfixService/CreateAuditChecklist", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorMapfixServiceServer).CreateAuditChecklist(ctx, req.(*AuditChecklistRequest)) } return interceptor(ctx, in, info, handler) } func _ValidatorMapfixService_SetValidatedModel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ValidatedModelRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorMapfixServiceServer).SetValidatedModel(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorMapfixService/SetValidatedModel", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorMapfixServiceServer).SetValidatedModel(ctx, req.(*ValidatedModelRequest)) } return interceptor(ctx, in, info, handler) } func _ValidatorMapfixService_SetStatusSubmitted_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SubmittedRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorMapfixServiceServer).SetStatusSubmitted(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorMapfixService/SetStatusSubmitted", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorMapfixServiceServer).SetStatusSubmitted(ctx, req.(*SubmittedRequest)) } return interceptor(ctx, in, info, handler) } func _ValidatorMapfixService_SetStatusRequestChanges_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(MapfixID) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorMapfixServiceServer).SetStatusRequestChanges(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorMapfixService/SetStatusRequestChanges", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorMapfixServiceServer).SetStatusRequestChanges(ctx, req.(*MapfixID)) } return interceptor(ctx, in, info, handler) } func _ValidatorMapfixService_SetStatusValidated_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(MapfixID) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorMapfixServiceServer).SetStatusValidated(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorMapfixService/SetStatusValidated", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorMapfixServiceServer).SetStatusValidated(ctx, req.(*MapfixID)) } return interceptor(ctx, in, info, handler) } func _ValidatorMapfixService_SetStatusNotValidated_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(MapfixID) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorMapfixServiceServer).SetStatusNotValidated(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorMapfixService/SetStatusNotValidated", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorMapfixServiceServer).SetStatusNotValidated(ctx, req.(*MapfixID)) } return interceptor(ctx, in, info, handler) } func _ValidatorMapfixService_SetStatusUploaded_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(MapfixID) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorMapfixServiceServer).SetStatusUploaded(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorMapfixService/SetStatusUploaded", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorMapfixServiceServer).SetStatusUploaded(ctx, req.(*MapfixID)) } return interceptor(ctx, in, info, handler) } func _ValidatorMapfixService_SetStatusNotUploaded_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(MapfixID) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorMapfixServiceServer).SetStatusNotUploaded(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorMapfixService/SetStatusNotUploaded", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorMapfixServiceServer).SetStatusNotUploaded(ctx, req.(*MapfixID)) } return interceptor(ctx, in, info, handler) } func _ValidatorMapfixService_SetStatusReleased_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(MapfixReleaseRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorMapfixServiceServer).SetStatusReleased(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorMapfixService/SetStatusReleased", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorMapfixServiceServer).SetStatusReleased(ctx, req.(*MapfixReleaseRequest)) } return interceptor(ctx, in, info, handler) } func _ValidatorMapfixService_SetStatusNotReleased_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(MapfixID) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorMapfixServiceServer).SetStatusNotReleased(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorMapfixService/SetStatusNotReleased", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorMapfixServiceServer).SetStatusNotReleased(ctx, req.(*MapfixID)) } return interceptor(ctx, in, info, handler) } // ValidatorMapfixService_ServiceDesc is the grpc.ServiceDesc for ValidatorMapfixService service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var ValidatorMapfixService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "validator.ValidatorMapfixService", HandlerType: (*ValidatorMapfixServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _ValidatorMapfixService_Create_Handler, }, { MethodName: "CreateAuditError", Handler: _ValidatorMapfixService_CreateAuditError_Handler, }, { MethodName: "CreateAuditChecklist", Handler: _ValidatorMapfixService_CreateAuditChecklist_Handler, }, { MethodName: "SetValidatedModel", Handler: _ValidatorMapfixService_SetValidatedModel_Handler, }, { MethodName: "SetStatusSubmitted", Handler: _ValidatorMapfixService_SetStatusSubmitted_Handler, }, { MethodName: "SetStatusRequestChanges", Handler: _ValidatorMapfixService_SetStatusRequestChanges_Handler, }, { MethodName: "SetStatusValidated", Handler: _ValidatorMapfixService_SetStatusValidated_Handler, }, { MethodName: "SetStatusNotValidated", Handler: _ValidatorMapfixService_SetStatusNotValidated_Handler, }, { MethodName: "SetStatusUploaded", Handler: _ValidatorMapfixService_SetStatusUploaded_Handler, }, { MethodName: "SetStatusNotUploaded", Handler: _ValidatorMapfixService_SetStatusNotUploaded_Handler, }, { MethodName: "SetStatusReleased", Handler: _ValidatorMapfixService_SetStatusReleased_Handler, }, { MethodName: "SetStatusNotReleased", Handler: _ValidatorMapfixService_SetStatusNotReleased_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "validator.proto", } // ValidatorSubmissionServiceClient is the client API for ValidatorSubmissionService 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 ValidatorSubmissionServiceClient interface { Create(ctx context.Context, in *SubmissionCreate, opts ...grpc.CallOption) (*SubmissionID, error) CreateAuditError(ctx context.Context, in *AuditErrorRequest, opts ...grpc.CallOption) (*NullResponse, error) CreateAuditChecklist(ctx context.Context, in *AuditChecklistRequest, opts ...grpc.CallOption) (*NullResponse, error) SetValidatedModel(ctx context.Context, in *ValidatedModelRequest, opts ...grpc.CallOption) (*NullResponse, error) SetStatusSubmitted(ctx context.Context, in *SubmittedRequest, opts ...grpc.CallOption) (*NullResponse, error) SetStatusRequestChanges(ctx context.Context, in *SubmissionID, opts ...grpc.CallOption) (*NullResponse, error) SetStatusValidated(ctx context.Context, in *SubmissionID, opts ...grpc.CallOption) (*NullResponse, error) SetStatusNotValidated(ctx context.Context, in *SubmissionID, opts ...grpc.CallOption) (*NullResponse, error) SetStatusUploaded(ctx context.Context, in *StatusUploadedRequest, opts ...grpc.CallOption) (*NullResponse, error) SetStatusNotUploaded(ctx context.Context, in *SubmissionID, opts ...grpc.CallOption) (*NullResponse, error) SetStatusReleased(ctx context.Context, in *SubmissionReleaseRequest, opts ...grpc.CallOption) (*NullResponse, error) } type validatorSubmissionServiceClient struct { cc grpc.ClientConnInterface } func NewValidatorSubmissionServiceClient(cc grpc.ClientConnInterface) ValidatorSubmissionServiceClient { return &validatorSubmissionServiceClient{cc} } func (c *validatorSubmissionServiceClient) Create(ctx context.Context, in *SubmissionCreate, opts ...grpc.CallOption) (*SubmissionID, error) { out := new(SubmissionID) err := c.cc.Invoke(ctx, "/validator.ValidatorSubmissionService/Create", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorSubmissionServiceClient) CreateAuditError(ctx context.Context, in *AuditErrorRequest, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorSubmissionService/CreateAuditError", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorSubmissionServiceClient) CreateAuditChecklist(ctx context.Context, in *AuditChecklistRequest, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorSubmissionService/CreateAuditChecklist", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorSubmissionServiceClient) SetValidatedModel(ctx context.Context, in *ValidatedModelRequest, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorSubmissionService/SetValidatedModel", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorSubmissionServiceClient) SetStatusSubmitted(ctx context.Context, in *SubmittedRequest, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorSubmissionService/SetStatusSubmitted", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorSubmissionServiceClient) SetStatusRequestChanges(ctx context.Context, in *SubmissionID, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorSubmissionService/SetStatusRequestChanges", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorSubmissionServiceClient) SetStatusValidated(ctx context.Context, in *SubmissionID, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorSubmissionService/SetStatusValidated", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorSubmissionServiceClient) SetStatusNotValidated(ctx context.Context, in *SubmissionID, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorSubmissionService/SetStatusNotValidated", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorSubmissionServiceClient) SetStatusUploaded(ctx context.Context, in *StatusUploadedRequest, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorSubmissionService/SetStatusUploaded", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorSubmissionServiceClient) SetStatusNotUploaded(ctx context.Context, in *SubmissionID, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorSubmissionService/SetStatusNotUploaded", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorSubmissionServiceClient) SetStatusReleased(ctx context.Context, in *SubmissionReleaseRequest, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorSubmissionService/SetStatusReleased", in, out, opts...) if err != nil { return nil, err } return out, nil } // ValidatorSubmissionServiceServer is the server API for ValidatorSubmissionService service. // All implementations must embed UnimplementedValidatorSubmissionServiceServer // for forward compatibility type ValidatorSubmissionServiceServer interface { Create(context.Context, *SubmissionCreate) (*SubmissionID, error) CreateAuditError(context.Context, *AuditErrorRequest) (*NullResponse, error) CreateAuditChecklist(context.Context, *AuditChecklistRequest) (*NullResponse, error) SetValidatedModel(context.Context, *ValidatedModelRequest) (*NullResponse, error) SetStatusSubmitted(context.Context, *SubmittedRequest) (*NullResponse, error) SetStatusRequestChanges(context.Context, *SubmissionID) (*NullResponse, error) SetStatusValidated(context.Context, *SubmissionID) (*NullResponse, error) SetStatusNotValidated(context.Context, *SubmissionID) (*NullResponse, error) SetStatusUploaded(context.Context, *StatusUploadedRequest) (*NullResponse, error) SetStatusNotUploaded(context.Context, *SubmissionID) (*NullResponse, error) SetStatusReleased(context.Context, *SubmissionReleaseRequest) (*NullResponse, error) mustEmbedUnimplementedValidatorSubmissionServiceServer() } // UnimplementedValidatorSubmissionServiceServer must be embedded to have forward compatible implementations. type UnimplementedValidatorSubmissionServiceServer struct { } func (UnimplementedValidatorSubmissionServiceServer) Create(context.Context, *SubmissionCreate) (*SubmissionID, error) { return nil, status.Errorf(codes.Unimplemented, "method Create not implemented") } func (UnimplementedValidatorSubmissionServiceServer) CreateAuditError(context.Context, *AuditErrorRequest) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateAuditError not implemented") } func (UnimplementedValidatorSubmissionServiceServer) CreateAuditChecklist(context.Context, *AuditChecklistRequest) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateAuditChecklist not implemented") } func (UnimplementedValidatorSubmissionServiceServer) SetValidatedModel(context.Context, *ValidatedModelRequest) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetValidatedModel not implemented") } func (UnimplementedValidatorSubmissionServiceServer) SetStatusSubmitted(context.Context, *SubmittedRequest) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetStatusSubmitted not implemented") } func (UnimplementedValidatorSubmissionServiceServer) SetStatusRequestChanges(context.Context, *SubmissionID) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetStatusRequestChanges not implemented") } func (UnimplementedValidatorSubmissionServiceServer) SetStatusValidated(context.Context, *SubmissionID) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetStatusValidated not implemented") } func (UnimplementedValidatorSubmissionServiceServer) SetStatusNotValidated(context.Context, *SubmissionID) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetStatusNotValidated not implemented") } func (UnimplementedValidatorSubmissionServiceServer) SetStatusUploaded(context.Context, *StatusUploadedRequest) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetStatusUploaded not implemented") } func (UnimplementedValidatorSubmissionServiceServer) SetStatusNotUploaded(context.Context, *SubmissionID) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetStatusNotUploaded not implemented") } func (UnimplementedValidatorSubmissionServiceServer) SetStatusReleased(context.Context, *SubmissionReleaseRequest) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetStatusReleased not implemented") } func (UnimplementedValidatorSubmissionServiceServer) mustEmbedUnimplementedValidatorSubmissionServiceServer() { } // UnsafeValidatorSubmissionServiceServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to ValidatorSubmissionServiceServer will // result in compilation errors. type UnsafeValidatorSubmissionServiceServer interface { mustEmbedUnimplementedValidatorSubmissionServiceServer() } func RegisterValidatorSubmissionServiceServer(s grpc.ServiceRegistrar, srv ValidatorSubmissionServiceServer) { s.RegisterService(&ValidatorSubmissionService_ServiceDesc, srv) } func _ValidatorSubmissionService_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SubmissionCreate) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorSubmissionServiceServer).Create(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorSubmissionService/Create", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorSubmissionServiceServer).Create(ctx, req.(*SubmissionCreate)) } return interceptor(ctx, in, info, handler) } func _ValidatorSubmissionService_CreateAuditError_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(AuditErrorRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorSubmissionServiceServer).CreateAuditError(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorSubmissionService/CreateAuditError", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorSubmissionServiceServer).CreateAuditError(ctx, req.(*AuditErrorRequest)) } return interceptor(ctx, in, info, handler) } func _ValidatorSubmissionService_CreateAuditChecklist_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(AuditChecklistRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorSubmissionServiceServer).CreateAuditChecklist(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorSubmissionService/CreateAuditChecklist", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorSubmissionServiceServer).CreateAuditChecklist(ctx, req.(*AuditChecklistRequest)) } return interceptor(ctx, in, info, handler) } func _ValidatorSubmissionService_SetValidatedModel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ValidatedModelRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorSubmissionServiceServer).SetValidatedModel(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorSubmissionService/SetValidatedModel", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorSubmissionServiceServer).SetValidatedModel(ctx, req.(*ValidatedModelRequest)) } return interceptor(ctx, in, info, handler) } func _ValidatorSubmissionService_SetStatusSubmitted_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SubmittedRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorSubmissionServiceServer).SetStatusSubmitted(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorSubmissionService/SetStatusSubmitted", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorSubmissionServiceServer).SetStatusSubmitted(ctx, req.(*SubmittedRequest)) } return interceptor(ctx, in, info, handler) } func _ValidatorSubmissionService_SetStatusRequestChanges_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SubmissionID) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorSubmissionServiceServer).SetStatusRequestChanges(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorSubmissionService/SetStatusRequestChanges", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorSubmissionServiceServer).SetStatusRequestChanges(ctx, req.(*SubmissionID)) } return interceptor(ctx, in, info, handler) } func _ValidatorSubmissionService_SetStatusValidated_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SubmissionID) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorSubmissionServiceServer).SetStatusValidated(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorSubmissionService/SetStatusValidated", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorSubmissionServiceServer).SetStatusValidated(ctx, req.(*SubmissionID)) } return interceptor(ctx, in, info, handler) } func _ValidatorSubmissionService_SetStatusNotValidated_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SubmissionID) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorSubmissionServiceServer).SetStatusNotValidated(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorSubmissionService/SetStatusNotValidated", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorSubmissionServiceServer).SetStatusNotValidated(ctx, req.(*SubmissionID)) } return interceptor(ctx, in, info, handler) } func _ValidatorSubmissionService_SetStatusUploaded_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(StatusUploadedRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorSubmissionServiceServer).SetStatusUploaded(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorSubmissionService/SetStatusUploaded", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorSubmissionServiceServer).SetStatusUploaded(ctx, req.(*StatusUploadedRequest)) } return interceptor(ctx, in, info, handler) } func _ValidatorSubmissionService_SetStatusNotUploaded_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SubmissionID) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorSubmissionServiceServer).SetStatusNotUploaded(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorSubmissionService/SetStatusNotUploaded", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorSubmissionServiceServer).SetStatusNotUploaded(ctx, req.(*SubmissionID)) } return interceptor(ctx, in, info, handler) } func _ValidatorSubmissionService_SetStatusReleased_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SubmissionReleaseRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorSubmissionServiceServer).SetStatusReleased(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorSubmissionService/SetStatusReleased", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorSubmissionServiceServer).SetStatusReleased(ctx, req.(*SubmissionReleaseRequest)) } return interceptor(ctx, in, info, handler) } // ValidatorSubmissionService_ServiceDesc is the grpc.ServiceDesc for ValidatorSubmissionService service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var ValidatorSubmissionService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "validator.ValidatorSubmissionService", HandlerType: (*ValidatorSubmissionServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _ValidatorSubmissionService_Create_Handler, }, { MethodName: "CreateAuditError", Handler: _ValidatorSubmissionService_CreateAuditError_Handler, }, { MethodName: "CreateAuditChecklist", Handler: _ValidatorSubmissionService_CreateAuditChecklist_Handler, }, { MethodName: "SetValidatedModel", Handler: _ValidatorSubmissionService_SetValidatedModel_Handler, }, { MethodName: "SetStatusSubmitted", Handler: _ValidatorSubmissionService_SetStatusSubmitted_Handler, }, { MethodName: "SetStatusRequestChanges", Handler: _ValidatorSubmissionService_SetStatusRequestChanges_Handler, }, { MethodName: "SetStatusValidated", Handler: _ValidatorSubmissionService_SetStatusValidated_Handler, }, { MethodName: "SetStatusNotValidated", Handler: _ValidatorSubmissionService_SetStatusNotValidated_Handler, }, { MethodName: "SetStatusUploaded", Handler: _ValidatorSubmissionService_SetStatusUploaded_Handler, }, { MethodName: "SetStatusNotUploaded", Handler: _ValidatorSubmissionService_SetStatusNotUploaded_Handler, }, { MethodName: "SetStatusReleased", Handler: _ValidatorSubmissionService_SetStatusReleased_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "validator.proto", } // ValidatorOperationServiceClient is the client API for ValidatorOperationService 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 ValidatorOperationServiceClient interface { Success(ctx context.Context, in *OperationSuccessRequest, opts ...grpc.CallOption) (*NullResponse, error) Fail(ctx context.Context, in *OperationFailRequest, opts ...grpc.CallOption) (*NullResponse, error) } type validatorOperationServiceClient struct { cc grpc.ClientConnInterface } func NewValidatorOperationServiceClient(cc grpc.ClientConnInterface) ValidatorOperationServiceClient { return &validatorOperationServiceClient{cc} } func (c *validatorOperationServiceClient) Success(ctx context.Context, in *OperationSuccessRequest, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorOperationService/Success", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorOperationServiceClient) Fail(ctx context.Context, in *OperationFailRequest, opts ...grpc.CallOption) (*NullResponse, error) { out := new(NullResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorOperationService/Fail", in, out, opts...) if err != nil { return nil, err } return out, nil } // ValidatorOperationServiceServer is the server API for ValidatorOperationService service. // All implementations must embed UnimplementedValidatorOperationServiceServer // for forward compatibility type ValidatorOperationServiceServer interface { Success(context.Context, *OperationSuccessRequest) (*NullResponse, error) Fail(context.Context, *OperationFailRequest) (*NullResponse, error) mustEmbedUnimplementedValidatorOperationServiceServer() } // UnimplementedValidatorOperationServiceServer must be embedded to have forward compatible implementations. type UnimplementedValidatorOperationServiceServer struct { } func (UnimplementedValidatorOperationServiceServer) Success(context.Context, *OperationSuccessRequest) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method Success not implemented") } func (UnimplementedValidatorOperationServiceServer) Fail(context.Context, *OperationFailRequest) (*NullResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method Fail not implemented") } func (UnimplementedValidatorOperationServiceServer) mustEmbedUnimplementedValidatorOperationServiceServer() { } // UnsafeValidatorOperationServiceServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to ValidatorOperationServiceServer will // result in compilation errors. type UnsafeValidatorOperationServiceServer interface { mustEmbedUnimplementedValidatorOperationServiceServer() } func RegisterValidatorOperationServiceServer(s grpc.ServiceRegistrar, srv ValidatorOperationServiceServer) { s.RegisterService(&ValidatorOperationService_ServiceDesc, srv) } func _ValidatorOperationService_Success_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(OperationSuccessRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorOperationServiceServer).Success(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorOperationService/Success", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorOperationServiceServer).Success(ctx, req.(*OperationSuccessRequest)) } return interceptor(ctx, in, info, handler) } func _ValidatorOperationService_Fail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(OperationFailRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorOperationServiceServer).Fail(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorOperationService/Fail", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorOperationServiceServer).Fail(ctx, req.(*OperationFailRequest)) } return interceptor(ctx, in, info, handler) } // ValidatorOperationService_ServiceDesc is the grpc.ServiceDesc for ValidatorOperationService service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var ValidatorOperationService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "validator.ValidatorOperationService", HandlerType: (*ValidatorOperationServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Success", Handler: _ValidatorOperationService_Success_Handler, }, { MethodName: "Fail", Handler: _ValidatorOperationService_Fail_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "validator.proto", } // ValidatorScriptServiceClient is the client API for ValidatorScriptService 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 ValidatorScriptServiceClient interface { Create(ctx context.Context, in *ScriptCreate, opts ...grpc.CallOption) (*ScriptID, error) Get(ctx context.Context, in *ScriptID, opts ...grpc.CallOption) (*Script, error) List(ctx context.Context, in *ScriptListRequest, opts ...grpc.CallOption) (*ScriptListResponse, error) } type validatorScriptServiceClient struct { cc grpc.ClientConnInterface } func NewValidatorScriptServiceClient(cc grpc.ClientConnInterface) ValidatorScriptServiceClient { return &validatorScriptServiceClient{cc} } func (c *validatorScriptServiceClient) Create(ctx context.Context, in *ScriptCreate, opts ...grpc.CallOption) (*ScriptID, error) { out := new(ScriptID) err := c.cc.Invoke(ctx, "/validator.ValidatorScriptService/Create", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorScriptServiceClient) Get(ctx context.Context, in *ScriptID, opts ...grpc.CallOption) (*Script, error) { out := new(Script) err := c.cc.Invoke(ctx, "/validator.ValidatorScriptService/Get", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorScriptServiceClient) List(ctx context.Context, in *ScriptListRequest, opts ...grpc.CallOption) (*ScriptListResponse, error) { out := new(ScriptListResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorScriptService/List", in, out, opts...) if err != nil { return nil, err } return out, nil } // ValidatorScriptServiceServer is the server API for ValidatorScriptService service. // All implementations must embed UnimplementedValidatorScriptServiceServer // for forward compatibility type ValidatorScriptServiceServer interface { Create(context.Context, *ScriptCreate) (*ScriptID, error) Get(context.Context, *ScriptID) (*Script, error) List(context.Context, *ScriptListRequest) (*ScriptListResponse, error) mustEmbedUnimplementedValidatorScriptServiceServer() } // UnimplementedValidatorScriptServiceServer must be embedded to have forward compatible implementations. type UnimplementedValidatorScriptServiceServer struct { } func (UnimplementedValidatorScriptServiceServer) Create(context.Context, *ScriptCreate) (*ScriptID, error) { return nil, status.Errorf(codes.Unimplemented, "method Create not implemented") } func (UnimplementedValidatorScriptServiceServer) Get(context.Context, *ScriptID) (*Script, error) { return nil, status.Errorf(codes.Unimplemented, "method Get not implemented") } func (UnimplementedValidatorScriptServiceServer) List(context.Context, *ScriptListRequest) (*ScriptListResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method List not implemented") } func (UnimplementedValidatorScriptServiceServer) mustEmbedUnimplementedValidatorScriptServiceServer() { } // UnsafeValidatorScriptServiceServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to ValidatorScriptServiceServer will // result in compilation errors. type UnsafeValidatorScriptServiceServer interface { mustEmbedUnimplementedValidatorScriptServiceServer() } func RegisterValidatorScriptServiceServer(s grpc.ServiceRegistrar, srv ValidatorScriptServiceServer) { s.RegisterService(&ValidatorScriptService_ServiceDesc, srv) } func _ValidatorScriptService_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ScriptCreate) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorScriptServiceServer).Create(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorScriptService/Create", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorScriptServiceServer).Create(ctx, req.(*ScriptCreate)) } return interceptor(ctx, in, info, handler) } func _ValidatorScriptService_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ScriptID) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorScriptServiceServer).Get(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorScriptService/Get", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorScriptServiceServer).Get(ctx, req.(*ScriptID)) } return interceptor(ctx, in, info, handler) } func _ValidatorScriptService_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ScriptListRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorScriptServiceServer).List(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorScriptService/List", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorScriptServiceServer).List(ctx, req.(*ScriptListRequest)) } return interceptor(ctx, in, info, handler) } // ValidatorScriptService_ServiceDesc is the grpc.ServiceDesc for ValidatorScriptService service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var ValidatorScriptService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "validator.ValidatorScriptService", HandlerType: (*ValidatorScriptServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _ValidatorScriptService_Create_Handler, }, { MethodName: "Get", Handler: _ValidatorScriptService_Get_Handler, }, { MethodName: "List", Handler: _ValidatorScriptService_List_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "validator.proto", } // ValidatorScriptPolicyServiceClient is the client API for ValidatorScriptPolicyService 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 ValidatorScriptPolicyServiceClient interface { Create(ctx context.Context, in *ScriptPolicyCreate, opts ...grpc.CallOption) (*ScriptPolicyID, error) List(ctx context.Context, in *ScriptPolicyListRequest, opts ...grpc.CallOption) (*ScriptPolicyListResponse, error) } type validatorScriptPolicyServiceClient struct { cc grpc.ClientConnInterface } func NewValidatorScriptPolicyServiceClient(cc grpc.ClientConnInterface) ValidatorScriptPolicyServiceClient { return &validatorScriptPolicyServiceClient{cc} } func (c *validatorScriptPolicyServiceClient) Create(ctx context.Context, in *ScriptPolicyCreate, opts ...grpc.CallOption) (*ScriptPolicyID, error) { out := new(ScriptPolicyID) err := c.cc.Invoke(ctx, "/validator.ValidatorScriptPolicyService/Create", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *validatorScriptPolicyServiceClient) List(ctx context.Context, in *ScriptPolicyListRequest, opts ...grpc.CallOption) (*ScriptPolicyListResponse, error) { out := new(ScriptPolicyListResponse) err := c.cc.Invoke(ctx, "/validator.ValidatorScriptPolicyService/List", in, out, opts...) if err != nil { return nil, err } return out, nil } // ValidatorScriptPolicyServiceServer is the server API for ValidatorScriptPolicyService service. // All implementations must embed UnimplementedValidatorScriptPolicyServiceServer // for forward compatibility type ValidatorScriptPolicyServiceServer interface { Create(context.Context, *ScriptPolicyCreate) (*ScriptPolicyID, error) List(context.Context, *ScriptPolicyListRequest) (*ScriptPolicyListResponse, error) mustEmbedUnimplementedValidatorScriptPolicyServiceServer() } // UnimplementedValidatorScriptPolicyServiceServer must be embedded to have forward compatible implementations. type UnimplementedValidatorScriptPolicyServiceServer struct { } func (UnimplementedValidatorScriptPolicyServiceServer) Create(context.Context, *ScriptPolicyCreate) (*ScriptPolicyID, error) { return nil, status.Errorf(codes.Unimplemented, "method Create not implemented") } func (UnimplementedValidatorScriptPolicyServiceServer) List(context.Context, *ScriptPolicyListRequest) (*ScriptPolicyListResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method List not implemented") } func (UnimplementedValidatorScriptPolicyServiceServer) mustEmbedUnimplementedValidatorScriptPolicyServiceServer() { } // UnsafeValidatorScriptPolicyServiceServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to ValidatorScriptPolicyServiceServer will // result in compilation errors. type UnsafeValidatorScriptPolicyServiceServer interface { mustEmbedUnimplementedValidatorScriptPolicyServiceServer() } func RegisterValidatorScriptPolicyServiceServer(s grpc.ServiceRegistrar, srv ValidatorScriptPolicyServiceServer) { s.RegisterService(&ValidatorScriptPolicyService_ServiceDesc, srv) } func _ValidatorScriptPolicyService_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ScriptPolicyCreate) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorScriptPolicyServiceServer).Create(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorScriptPolicyService/Create", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorScriptPolicyServiceServer).Create(ctx, req.(*ScriptPolicyCreate)) } return interceptor(ctx, in, info, handler) } func _ValidatorScriptPolicyService_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ScriptPolicyListRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ValidatorScriptPolicyServiceServer).List(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/validator.ValidatorScriptPolicyService/List", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ValidatorScriptPolicyServiceServer).List(ctx, req.(*ScriptPolicyListRequest)) } return interceptor(ctx, in, info, handler) } // ValidatorScriptPolicyService_ServiceDesc is the grpc.ServiceDesc for ValidatorScriptPolicyService service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var ValidatorScriptPolicyService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "validator.ValidatorScriptPolicyService", HandlerType: (*ValidatorScriptPolicyServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _ValidatorScriptPolicyService_Create_Handler, }, { MethodName: "List", Handler: _ValidatorScriptPolicyService_List_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "validator.proto", }