Files
go-grpc/validator/validator_grpc.pb.go

1355 lines
56 KiB
Go

// 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",
}