1359 lines
51 KiB
Go
1359 lines
51 KiB
Go
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
|
// versions:
|
|
// - protoc-gen-go-grpc v1.2.0
|
|
// - protoc v4.25.1
|
|
// source: pkg/testing/remote/loader.proto
|
|
|
|
package remote
|
|
|
|
import (
|
|
context "context"
|
|
server "github.com/linuxsuren/api-testing/pkg/server"
|
|
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
|
|
|
|
// LoaderClient is the client API for Loader 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 LoaderClient interface {
|
|
ListTestSuite(ctx context.Context, in *server.Empty, opts ...grpc.CallOption) (*TestSuites, error)
|
|
CreateTestSuite(ctx context.Context, in *TestSuite, opts ...grpc.CallOption) (*server.Empty, error)
|
|
GetTestSuite(ctx context.Context, in *TestSuite, opts ...grpc.CallOption) (*TestSuite, error)
|
|
UpdateTestSuite(ctx context.Context, in *TestSuite, opts ...grpc.CallOption) (*TestSuite, error)
|
|
DeleteTestSuite(ctx context.Context, in *TestSuite, opts ...grpc.CallOption) (*server.Empty, error)
|
|
RenameTestSuite(ctx context.Context, in *server.TestSuiteDuplicate, opts ...grpc.CallOption) (*server.HelloReply, error)
|
|
ListTestCases(ctx context.Context, in *TestSuite, opts ...grpc.CallOption) (*server.TestCases, error)
|
|
CreateTestCase(ctx context.Context, in *server.TestCase, opts ...grpc.CallOption) (*server.Empty, error)
|
|
GetTestCase(ctx context.Context, in *server.TestCase, opts ...grpc.CallOption) (*server.TestCase, error)
|
|
UpdateTestCase(ctx context.Context, in *server.TestCase, opts ...grpc.CallOption) (*server.TestCase, error)
|
|
DeleteTestCase(ctx context.Context, in *server.TestCase, opts ...grpc.CallOption) (*server.Empty, error)
|
|
RenameTestCase(ctx context.Context, in *server.TestCaseDuplicate, opts ...grpc.CallOption) (*server.HelloReply, error)
|
|
ListHistoryTestSuite(ctx context.Context, in *server.Empty, opts ...grpc.CallOption) (*HistoryTestSuites, error)
|
|
CreateTestCaseHistory(ctx context.Context, in *server.HistoryTestResult, opts ...grpc.CallOption) (*server.Empty, error)
|
|
GetHistoryTestCaseWithResult(ctx context.Context, in *server.HistoryTestCase, opts ...grpc.CallOption) (*server.HistoryTestResult, error)
|
|
GetHistoryTestCase(ctx context.Context, in *server.HistoryTestCase, opts ...grpc.CallOption) (*server.HistoryTestCase, error)
|
|
DeleteHistoryTestCase(ctx context.Context, in *server.HistoryTestCase, opts ...grpc.CallOption) (*server.Empty, error)
|
|
DeleteAllHistoryTestCase(ctx context.Context, in *server.HistoryTestCase, opts ...grpc.CallOption) (*server.Empty, error)
|
|
GetTestCaseAllHistory(ctx context.Context, in *server.TestCase, opts ...grpc.CallOption) (*server.HistoryTestCases, error)
|
|
GetVersion(ctx context.Context, in *server.Empty, opts ...grpc.CallOption) (*server.Version, error)
|
|
Verify(ctx context.Context, in *server.Empty, opts ...grpc.CallOption) (*server.ExtensionStatus, error)
|
|
PProf(ctx context.Context, in *server.PProfRequest, opts ...grpc.CallOption) (*server.PProfData, error)
|
|
Query(ctx context.Context, in *server.DataQuery, opts ...grpc.CallOption) (*server.DataQueryResult, error)
|
|
}
|
|
|
|
type loaderClient struct {
|
|
cc grpc.ClientConnInterface
|
|
}
|
|
|
|
func NewLoaderClient(cc grpc.ClientConnInterface) LoaderClient {
|
|
return &loaderClient{cc}
|
|
}
|
|
|
|
func (c *loaderClient) ListTestSuite(ctx context.Context, in *server.Empty, opts ...grpc.CallOption) (*TestSuites, error) {
|
|
out := new(TestSuites)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/ListTestSuite", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) CreateTestSuite(ctx context.Context, in *TestSuite, opts ...grpc.CallOption) (*server.Empty, error) {
|
|
out := new(server.Empty)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/CreateTestSuite", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) GetTestSuite(ctx context.Context, in *TestSuite, opts ...grpc.CallOption) (*TestSuite, error) {
|
|
out := new(TestSuite)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/GetTestSuite", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) UpdateTestSuite(ctx context.Context, in *TestSuite, opts ...grpc.CallOption) (*TestSuite, error) {
|
|
out := new(TestSuite)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/UpdateTestSuite", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) DeleteTestSuite(ctx context.Context, in *TestSuite, opts ...grpc.CallOption) (*server.Empty, error) {
|
|
out := new(server.Empty)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/DeleteTestSuite", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) RenameTestSuite(ctx context.Context, in *server.TestSuiteDuplicate, opts ...grpc.CallOption) (*server.HelloReply, error) {
|
|
out := new(server.HelloReply)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/RenameTestSuite", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) ListTestCases(ctx context.Context, in *TestSuite, opts ...grpc.CallOption) (*server.TestCases, error) {
|
|
out := new(server.TestCases)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/ListTestCases", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) CreateTestCase(ctx context.Context, in *server.TestCase, opts ...grpc.CallOption) (*server.Empty, error) {
|
|
out := new(server.Empty)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/CreateTestCase", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) GetTestCase(ctx context.Context, in *server.TestCase, opts ...grpc.CallOption) (*server.TestCase, error) {
|
|
out := new(server.TestCase)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/GetTestCase", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) UpdateTestCase(ctx context.Context, in *server.TestCase, opts ...grpc.CallOption) (*server.TestCase, error) {
|
|
out := new(server.TestCase)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/UpdateTestCase", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) DeleteTestCase(ctx context.Context, in *server.TestCase, opts ...grpc.CallOption) (*server.Empty, error) {
|
|
out := new(server.Empty)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/DeleteTestCase", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) RenameTestCase(ctx context.Context, in *server.TestCaseDuplicate, opts ...grpc.CallOption) (*server.HelloReply, error) {
|
|
out := new(server.HelloReply)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/RenameTestCase", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) ListHistoryTestSuite(ctx context.Context, in *server.Empty, opts ...grpc.CallOption) (*HistoryTestSuites, error) {
|
|
out := new(HistoryTestSuites)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/ListHistoryTestSuite", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) CreateTestCaseHistory(ctx context.Context, in *server.HistoryTestResult, opts ...grpc.CallOption) (*server.Empty, error) {
|
|
out := new(server.Empty)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/CreateTestCaseHistory", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) GetHistoryTestCaseWithResult(ctx context.Context, in *server.HistoryTestCase, opts ...grpc.CallOption) (*server.HistoryTestResult, error) {
|
|
out := new(server.HistoryTestResult)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/GetHistoryTestCaseWithResult", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) GetHistoryTestCase(ctx context.Context, in *server.HistoryTestCase, opts ...grpc.CallOption) (*server.HistoryTestCase, error) {
|
|
out := new(server.HistoryTestCase)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/GetHistoryTestCase", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) DeleteHistoryTestCase(ctx context.Context, in *server.HistoryTestCase, opts ...grpc.CallOption) (*server.Empty, error) {
|
|
out := new(server.Empty)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/DeleteHistoryTestCase", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) DeleteAllHistoryTestCase(ctx context.Context, in *server.HistoryTestCase, opts ...grpc.CallOption) (*server.Empty, error) {
|
|
out := new(server.Empty)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/DeleteAllHistoryTestCase", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) GetTestCaseAllHistory(ctx context.Context, in *server.TestCase, opts ...grpc.CallOption) (*server.HistoryTestCases, error) {
|
|
out := new(server.HistoryTestCases)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/GetTestCaseAllHistory", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) GetVersion(ctx context.Context, in *server.Empty, opts ...grpc.CallOption) (*server.Version, error) {
|
|
out := new(server.Version)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/GetVersion", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) Verify(ctx context.Context, in *server.Empty, opts ...grpc.CallOption) (*server.ExtensionStatus, error) {
|
|
out := new(server.ExtensionStatus)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/Verify", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) PProf(ctx context.Context, in *server.PProfRequest, opts ...grpc.CallOption) (*server.PProfData, error) {
|
|
out := new(server.PProfData)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/PProf", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *loaderClient) Query(ctx context.Context, in *server.DataQuery, opts ...grpc.CallOption) (*server.DataQueryResult, error) {
|
|
out := new(server.DataQueryResult)
|
|
err := c.cc.Invoke(ctx, "/remote.Loader/Query", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
// LoaderServer is the server API for Loader service.
|
|
// All implementations must embed UnimplementedLoaderServer
|
|
// for forward compatibility
|
|
type LoaderServer interface {
|
|
ListTestSuite(context.Context, *server.Empty) (*TestSuites, error)
|
|
CreateTestSuite(context.Context, *TestSuite) (*server.Empty, error)
|
|
GetTestSuite(context.Context, *TestSuite) (*TestSuite, error)
|
|
UpdateTestSuite(context.Context, *TestSuite) (*TestSuite, error)
|
|
DeleteTestSuite(context.Context, *TestSuite) (*server.Empty, error)
|
|
RenameTestSuite(context.Context, *server.TestSuiteDuplicate) (*server.HelloReply, error)
|
|
ListTestCases(context.Context, *TestSuite) (*server.TestCases, error)
|
|
CreateTestCase(context.Context, *server.TestCase) (*server.Empty, error)
|
|
GetTestCase(context.Context, *server.TestCase) (*server.TestCase, error)
|
|
UpdateTestCase(context.Context, *server.TestCase) (*server.TestCase, error)
|
|
DeleteTestCase(context.Context, *server.TestCase) (*server.Empty, error)
|
|
RenameTestCase(context.Context, *server.TestCaseDuplicate) (*server.HelloReply, error)
|
|
ListHistoryTestSuite(context.Context, *server.Empty) (*HistoryTestSuites, error)
|
|
CreateTestCaseHistory(context.Context, *server.HistoryTestResult) (*server.Empty, error)
|
|
GetHistoryTestCaseWithResult(context.Context, *server.HistoryTestCase) (*server.HistoryTestResult, error)
|
|
GetHistoryTestCase(context.Context, *server.HistoryTestCase) (*server.HistoryTestCase, error)
|
|
DeleteHistoryTestCase(context.Context, *server.HistoryTestCase) (*server.Empty, error)
|
|
DeleteAllHistoryTestCase(context.Context, *server.HistoryTestCase) (*server.Empty, error)
|
|
GetTestCaseAllHistory(context.Context, *server.TestCase) (*server.HistoryTestCases, error)
|
|
GetVersion(context.Context, *server.Empty) (*server.Version, error)
|
|
Verify(context.Context, *server.Empty) (*server.ExtensionStatus, error)
|
|
PProf(context.Context, *server.PProfRequest) (*server.PProfData, error)
|
|
Query(context.Context, *server.DataQuery) (*server.DataQueryResult, error)
|
|
mustEmbedUnimplementedLoaderServer()
|
|
}
|
|
|
|
// UnimplementedLoaderServer must be embedded to have forward compatible implementations.
|
|
type UnimplementedLoaderServer struct {
|
|
}
|
|
|
|
func (UnimplementedLoaderServer) ListTestSuite(context.Context, *server.Empty) (*TestSuites, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListTestSuite not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) CreateTestSuite(context.Context, *TestSuite) (*server.Empty, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method CreateTestSuite not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) GetTestSuite(context.Context, *TestSuite) (*TestSuite, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetTestSuite not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) UpdateTestSuite(context.Context, *TestSuite) (*TestSuite, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method UpdateTestSuite not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) DeleteTestSuite(context.Context, *TestSuite) (*server.Empty, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method DeleteTestSuite not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) RenameTestSuite(context.Context, *server.TestSuiteDuplicate) (*server.HelloReply, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method RenameTestSuite not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) ListTestCases(context.Context, *TestSuite) (*server.TestCases, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListTestCases not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) CreateTestCase(context.Context, *server.TestCase) (*server.Empty, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method CreateTestCase not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) GetTestCase(context.Context, *server.TestCase) (*server.TestCase, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetTestCase not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) UpdateTestCase(context.Context, *server.TestCase) (*server.TestCase, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method UpdateTestCase not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) DeleteTestCase(context.Context, *server.TestCase) (*server.Empty, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method DeleteTestCase not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) RenameTestCase(context.Context, *server.TestCaseDuplicate) (*server.HelloReply, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method RenameTestCase not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) ListHistoryTestSuite(context.Context, *server.Empty) (*HistoryTestSuites, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListHistoryTestSuite not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) CreateTestCaseHistory(context.Context, *server.HistoryTestResult) (*server.Empty, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method CreateTestCaseHistory not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) GetHistoryTestCaseWithResult(context.Context, *server.HistoryTestCase) (*server.HistoryTestResult, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetHistoryTestCaseWithResult not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) GetHistoryTestCase(context.Context, *server.HistoryTestCase) (*server.HistoryTestCase, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetHistoryTestCase not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) DeleteHistoryTestCase(context.Context, *server.HistoryTestCase) (*server.Empty, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method DeleteHistoryTestCase not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) DeleteAllHistoryTestCase(context.Context, *server.HistoryTestCase) (*server.Empty, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method DeleteAllHistoryTestCase not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) GetTestCaseAllHistory(context.Context, *server.TestCase) (*server.HistoryTestCases, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetTestCaseAllHistory not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) GetVersion(context.Context, *server.Empty) (*server.Version, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetVersion not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) Verify(context.Context, *server.Empty) (*server.ExtensionStatus, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method Verify not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) PProf(context.Context, *server.PProfRequest) (*server.PProfData, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method PProf not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) Query(context.Context, *server.DataQuery) (*server.DataQueryResult, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method Query not implemented")
|
|
}
|
|
func (UnimplementedLoaderServer) mustEmbedUnimplementedLoaderServer() {}
|
|
|
|
// UnsafeLoaderServer may be embedded to opt out of forward compatibility for this service.
|
|
// Use of this interface is not recommended, as added methods to LoaderServer will
|
|
// result in compilation errors.
|
|
type UnsafeLoaderServer interface {
|
|
mustEmbedUnimplementedLoaderServer()
|
|
}
|
|
|
|
func RegisterLoaderServer(s grpc.ServiceRegistrar, srv LoaderServer) {
|
|
s.RegisterService(&Loader_ServiceDesc, srv)
|
|
}
|
|
|
|
func _Loader_ListTestSuite_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.Empty)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).ListTestSuite(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/ListTestSuite",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).ListTestSuite(ctx, req.(*server.Empty))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_CreateTestSuite_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(TestSuite)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).CreateTestSuite(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/CreateTestSuite",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).CreateTestSuite(ctx, req.(*TestSuite))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_GetTestSuite_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(TestSuite)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).GetTestSuite(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/GetTestSuite",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).GetTestSuite(ctx, req.(*TestSuite))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_UpdateTestSuite_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(TestSuite)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).UpdateTestSuite(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/UpdateTestSuite",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).UpdateTestSuite(ctx, req.(*TestSuite))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_DeleteTestSuite_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(TestSuite)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).DeleteTestSuite(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/DeleteTestSuite",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).DeleteTestSuite(ctx, req.(*TestSuite))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_RenameTestSuite_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.TestSuiteDuplicate)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).RenameTestSuite(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/RenameTestSuite",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).RenameTestSuite(ctx, req.(*server.TestSuiteDuplicate))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_ListTestCases_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(TestSuite)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).ListTestCases(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/ListTestCases",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).ListTestCases(ctx, req.(*TestSuite))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_CreateTestCase_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.TestCase)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).CreateTestCase(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/CreateTestCase",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).CreateTestCase(ctx, req.(*server.TestCase))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_GetTestCase_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.TestCase)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).GetTestCase(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/GetTestCase",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).GetTestCase(ctx, req.(*server.TestCase))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_UpdateTestCase_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.TestCase)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).UpdateTestCase(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/UpdateTestCase",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).UpdateTestCase(ctx, req.(*server.TestCase))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_DeleteTestCase_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.TestCase)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).DeleteTestCase(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/DeleteTestCase",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).DeleteTestCase(ctx, req.(*server.TestCase))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_RenameTestCase_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.TestCaseDuplicate)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).RenameTestCase(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/RenameTestCase",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).RenameTestCase(ctx, req.(*server.TestCaseDuplicate))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_ListHistoryTestSuite_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.Empty)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).ListHistoryTestSuite(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/ListHistoryTestSuite",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).ListHistoryTestSuite(ctx, req.(*server.Empty))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_CreateTestCaseHistory_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.HistoryTestResult)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).CreateTestCaseHistory(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/CreateTestCaseHistory",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).CreateTestCaseHistory(ctx, req.(*server.HistoryTestResult))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_GetHistoryTestCaseWithResult_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.HistoryTestCase)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).GetHistoryTestCaseWithResult(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/GetHistoryTestCaseWithResult",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).GetHistoryTestCaseWithResult(ctx, req.(*server.HistoryTestCase))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_GetHistoryTestCase_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.HistoryTestCase)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).GetHistoryTestCase(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/GetHistoryTestCase",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).GetHistoryTestCase(ctx, req.(*server.HistoryTestCase))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_DeleteHistoryTestCase_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.HistoryTestCase)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).DeleteHistoryTestCase(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/DeleteHistoryTestCase",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).DeleteHistoryTestCase(ctx, req.(*server.HistoryTestCase))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_DeleteAllHistoryTestCase_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.HistoryTestCase)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).DeleteAllHistoryTestCase(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/DeleteAllHistoryTestCase",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).DeleteAllHistoryTestCase(ctx, req.(*server.HistoryTestCase))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_GetTestCaseAllHistory_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.TestCase)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).GetTestCaseAllHistory(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/GetTestCaseAllHistory",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).GetTestCaseAllHistory(ctx, req.(*server.TestCase))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_GetVersion_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.Empty)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).GetVersion(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/GetVersion",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).GetVersion(ctx, req.(*server.Empty))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_Verify_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.Empty)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).Verify(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/Verify",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).Verify(ctx, req.(*server.Empty))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_PProf_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.PProfRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).PProf(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/PProf",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).PProf(ctx, req.(*server.PProfRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Loader_Query_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.DataQuery)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(LoaderServer).Query(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.Loader/Query",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(LoaderServer).Query(ctx, req.(*server.DataQuery))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
// Loader_ServiceDesc is the grpc.ServiceDesc for Loader service.
|
|
// It's only intended for direct use with grpc.RegisterService,
|
|
// and not to be introspected or modified (even as a copy)
|
|
var Loader_ServiceDesc = grpc.ServiceDesc{
|
|
ServiceName: "remote.Loader",
|
|
HandlerType: (*LoaderServer)(nil),
|
|
Methods: []grpc.MethodDesc{
|
|
{
|
|
MethodName: "ListTestSuite",
|
|
Handler: _Loader_ListTestSuite_Handler,
|
|
},
|
|
{
|
|
MethodName: "CreateTestSuite",
|
|
Handler: _Loader_CreateTestSuite_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetTestSuite",
|
|
Handler: _Loader_GetTestSuite_Handler,
|
|
},
|
|
{
|
|
MethodName: "UpdateTestSuite",
|
|
Handler: _Loader_UpdateTestSuite_Handler,
|
|
},
|
|
{
|
|
MethodName: "DeleteTestSuite",
|
|
Handler: _Loader_DeleteTestSuite_Handler,
|
|
},
|
|
{
|
|
MethodName: "RenameTestSuite",
|
|
Handler: _Loader_RenameTestSuite_Handler,
|
|
},
|
|
{
|
|
MethodName: "ListTestCases",
|
|
Handler: _Loader_ListTestCases_Handler,
|
|
},
|
|
{
|
|
MethodName: "CreateTestCase",
|
|
Handler: _Loader_CreateTestCase_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetTestCase",
|
|
Handler: _Loader_GetTestCase_Handler,
|
|
},
|
|
{
|
|
MethodName: "UpdateTestCase",
|
|
Handler: _Loader_UpdateTestCase_Handler,
|
|
},
|
|
{
|
|
MethodName: "DeleteTestCase",
|
|
Handler: _Loader_DeleteTestCase_Handler,
|
|
},
|
|
{
|
|
MethodName: "RenameTestCase",
|
|
Handler: _Loader_RenameTestCase_Handler,
|
|
},
|
|
{
|
|
MethodName: "ListHistoryTestSuite",
|
|
Handler: _Loader_ListHistoryTestSuite_Handler,
|
|
},
|
|
{
|
|
MethodName: "CreateTestCaseHistory",
|
|
Handler: _Loader_CreateTestCaseHistory_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetHistoryTestCaseWithResult",
|
|
Handler: _Loader_GetHistoryTestCaseWithResult_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetHistoryTestCase",
|
|
Handler: _Loader_GetHistoryTestCase_Handler,
|
|
},
|
|
{
|
|
MethodName: "DeleteHistoryTestCase",
|
|
Handler: _Loader_DeleteHistoryTestCase_Handler,
|
|
},
|
|
{
|
|
MethodName: "DeleteAllHistoryTestCase",
|
|
Handler: _Loader_DeleteAllHistoryTestCase_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetTestCaseAllHistory",
|
|
Handler: _Loader_GetTestCaseAllHistory_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetVersion",
|
|
Handler: _Loader_GetVersion_Handler,
|
|
},
|
|
{
|
|
MethodName: "Verify",
|
|
Handler: _Loader_Verify_Handler,
|
|
},
|
|
{
|
|
MethodName: "PProf",
|
|
Handler: _Loader_PProf_Handler,
|
|
},
|
|
{
|
|
MethodName: "Query",
|
|
Handler: _Loader_Query_Handler,
|
|
},
|
|
},
|
|
Streams: []grpc.StreamDesc{},
|
|
Metadata: "pkg/testing/remote/loader.proto",
|
|
}
|
|
|
|
// SecretServiceClient is the client API for SecretService 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 SecretServiceClient interface {
|
|
GetSecret(ctx context.Context, in *server.Secret, opts ...grpc.CallOption) (*server.Secret, error)
|
|
GetSecrets(ctx context.Context, in *server.Empty, opts ...grpc.CallOption) (*server.Secrets, error)
|
|
CreateSecret(ctx context.Context, in *server.Secret, opts ...grpc.CallOption) (*server.CommonResult, error)
|
|
DeleteSecret(ctx context.Context, in *server.Secret, opts ...grpc.CallOption) (*server.CommonResult, error)
|
|
UpdateSecret(ctx context.Context, in *server.Secret, opts ...grpc.CallOption) (*server.CommonResult, error)
|
|
}
|
|
|
|
type secretServiceClient struct {
|
|
cc grpc.ClientConnInterface
|
|
}
|
|
|
|
func NewSecretServiceClient(cc grpc.ClientConnInterface) SecretServiceClient {
|
|
return &secretServiceClient{cc}
|
|
}
|
|
|
|
func (c *secretServiceClient) GetSecret(ctx context.Context, in *server.Secret, opts ...grpc.CallOption) (*server.Secret, error) {
|
|
out := new(server.Secret)
|
|
err := c.cc.Invoke(ctx, "/remote.SecretService/GetSecret", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *secretServiceClient) GetSecrets(ctx context.Context, in *server.Empty, opts ...grpc.CallOption) (*server.Secrets, error) {
|
|
out := new(server.Secrets)
|
|
err := c.cc.Invoke(ctx, "/remote.SecretService/GetSecrets", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *secretServiceClient) CreateSecret(ctx context.Context, in *server.Secret, opts ...grpc.CallOption) (*server.CommonResult, error) {
|
|
out := new(server.CommonResult)
|
|
err := c.cc.Invoke(ctx, "/remote.SecretService/CreateSecret", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *secretServiceClient) DeleteSecret(ctx context.Context, in *server.Secret, opts ...grpc.CallOption) (*server.CommonResult, error) {
|
|
out := new(server.CommonResult)
|
|
err := c.cc.Invoke(ctx, "/remote.SecretService/DeleteSecret", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *secretServiceClient) UpdateSecret(ctx context.Context, in *server.Secret, opts ...grpc.CallOption) (*server.CommonResult, error) {
|
|
out := new(server.CommonResult)
|
|
err := c.cc.Invoke(ctx, "/remote.SecretService/UpdateSecret", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
// SecretServiceServer is the server API for SecretService service.
|
|
// All implementations must embed UnimplementedSecretServiceServer
|
|
// for forward compatibility
|
|
type SecretServiceServer interface {
|
|
GetSecret(context.Context, *server.Secret) (*server.Secret, error)
|
|
GetSecrets(context.Context, *server.Empty) (*server.Secrets, error)
|
|
CreateSecret(context.Context, *server.Secret) (*server.CommonResult, error)
|
|
DeleteSecret(context.Context, *server.Secret) (*server.CommonResult, error)
|
|
UpdateSecret(context.Context, *server.Secret) (*server.CommonResult, error)
|
|
mustEmbedUnimplementedSecretServiceServer()
|
|
}
|
|
|
|
// UnimplementedSecretServiceServer must be embedded to have forward compatible implementations.
|
|
type UnimplementedSecretServiceServer struct {
|
|
}
|
|
|
|
func (UnimplementedSecretServiceServer) GetSecret(context.Context, *server.Secret) (*server.Secret, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetSecret not implemented")
|
|
}
|
|
func (UnimplementedSecretServiceServer) GetSecrets(context.Context, *server.Empty) (*server.Secrets, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetSecrets not implemented")
|
|
}
|
|
func (UnimplementedSecretServiceServer) CreateSecret(context.Context, *server.Secret) (*server.CommonResult, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method CreateSecret not implemented")
|
|
}
|
|
func (UnimplementedSecretServiceServer) DeleteSecret(context.Context, *server.Secret) (*server.CommonResult, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method DeleteSecret not implemented")
|
|
}
|
|
func (UnimplementedSecretServiceServer) UpdateSecret(context.Context, *server.Secret) (*server.CommonResult, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method UpdateSecret not implemented")
|
|
}
|
|
func (UnimplementedSecretServiceServer) mustEmbedUnimplementedSecretServiceServer() {}
|
|
|
|
// UnsafeSecretServiceServer may be embedded to opt out of forward compatibility for this service.
|
|
// Use of this interface is not recommended, as added methods to SecretServiceServer will
|
|
// result in compilation errors.
|
|
type UnsafeSecretServiceServer interface {
|
|
mustEmbedUnimplementedSecretServiceServer()
|
|
}
|
|
|
|
func RegisterSecretServiceServer(s grpc.ServiceRegistrar, srv SecretServiceServer) {
|
|
s.RegisterService(&SecretService_ServiceDesc, srv)
|
|
}
|
|
|
|
func _SecretService_GetSecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.Secret)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SecretServiceServer).GetSecret(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.SecretService/GetSecret",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SecretServiceServer).GetSecret(ctx, req.(*server.Secret))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _SecretService_GetSecrets_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.Empty)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SecretServiceServer).GetSecrets(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.SecretService/GetSecrets",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SecretServiceServer).GetSecrets(ctx, req.(*server.Empty))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _SecretService_CreateSecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.Secret)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SecretServiceServer).CreateSecret(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.SecretService/CreateSecret",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SecretServiceServer).CreateSecret(ctx, req.(*server.Secret))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _SecretService_DeleteSecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.Secret)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SecretServiceServer).DeleteSecret(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.SecretService/DeleteSecret",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SecretServiceServer).DeleteSecret(ctx, req.(*server.Secret))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _SecretService_UpdateSecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.Secret)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SecretServiceServer).UpdateSecret(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.SecretService/UpdateSecret",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SecretServiceServer).UpdateSecret(ctx, req.(*server.Secret))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
// SecretService_ServiceDesc is the grpc.ServiceDesc for SecretService service.
|
|
// It's only intended for direct use with grpc.RegisterService,
|
|
// and not to be introspected or modified (even as a copy)
|
|
var SecretService_ServiceDesc = grpc.ServiceDesc{
|
|
ServiceName: "remote.SecretService",
|
|
HandlerType: (*SecretServiceServer)(nil),
|
|
Methods: []grpc.MethodDesc{
|
|
{
|
|
MethodName: "GetSecret",
|
|
Handler: _SecretService_GetSecret_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetSecrets",
|
|
Handler: _SecretService_GetSecrets_Handler,
|
|
},
|
|
{
|
|
MethodName: "CreateSecret",
|
|
Handler: _SecretService_CreateSecret_Handler,
|
|
},
|
|
{
|
|
MethodName: "DeleteSecret",
|
|
Handler: _SecretService_DeleteSecret_Handler,
|
|
},
|
|
{
|
|
MethodName: "UpdateSecret",
|
|
Handler: _SecretService_UpdateSecret_Handler,
|
|
},
|
|
},
|
|
Streams: []grpc.StreamDesc{},
|
|
Metadata: "pkg/testing/remote/loader.proto",
|
|
}
|
|
|
|
// ConfigServiceClient is the client API for ConfigService 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 ConfigServiceClient interface {
|
|
GetConfigs(ctx context.Context, in *server.Empty, opts ...grpc.CallOption) (*Configs, error)
|
|
GetConfig(ctx context.Context, in *server.SimpleName, opts ...grpc.CallOption) (*Config, error)
|
|
CreateConfig(ctx context.Context, in *Config, opts ...grpc.CallOption) (*server.CommonResult, error)
|
|
UpdateConfig(ctx context.Context, in *Config, opts ...grpc.CallOption) (*server.CommonResult, error)
|
|
DeleteConfig(ctx context.Context, in *server.SimpleName, opts ...grpc.CallOption) (*server.CommonResult, error)
|
|
}
|
|
|
|
type configServiceClient struct {
|
|
cc grpc.ClientConnInterface
|
|
}
|
|
|
|
func NewConfigServiceClient(cc grpc.ClientConnInterface) ConfigServiceClient {
|
|
return &configServiceClient{cc}
|
|
}
|
|
|
|
func (c *configServiceClient) GetConfigs(ctx context.Context, in *server.Empty, opts ...grpc.CallOption) (*Configs, error) {
|
|
out := new(Configs)
|
|
err := c.cc.Invoke(ctx, "/remote.ConfigService/GetConfigs", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *configServiceClient) GetConfig(ctx context.Context, in *server.SimpleName, opts ...grpc.CallOption) (*Config, error) {
|
|
out := new(Config)
|
|
err := c.cc.Invoke(ctx, "/remote.ConfigService/GetConfig", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *configServiceClient) CreateConfig(ctx context.Context, in *Config, opts ...grpc.CallOption) (*server.CommonResult, error) {
|
|
out := new(server.CommonResult)
|
|
err := c.cc.Invoke(ctx, "/remote.ConfigService/CreateConfig", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *configServiceClient) UpdateConfig(ctx context.Context, in *Config, opts ...grpc.CallOption) (*server.CommonResult, error) {
|
|
out := new(server.CommonResult)
|
|
err := c.cc.Invoke(ctx, "/remote.ConfigService/UpdateConfig", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *configServiceClient) DeleteConfig(ctx context.Context, in *server.SimpleName, opts ...grpc.CallOption) (*server.CommonResult, error) {
|
|
out := new(server.CommonResult)
|
|
err := c.cc.Invoke(ctx, "/remote.ConfigService/DeleteConfig", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
// ConfigServiceServer is the server API for ConfigService service.
|
|
// All implementations must embed UnimplementedConfigServiceServer
|
|
// for forward compatibility
|
|
type ConfigServiceServer interface {
|
|
GetConfigs(context.Context, *server.Empty) (*Configs, error)
|
|
GetConfig(context.Context, *server.SimpleName) (*Config, error)
|
|
CreateConfig(context.Context, *Config) (*server.CommonResult, error)
|
|
UpdateConfig(context.Context, *Config) (*server.CommonResult, error)
|
|
DeleteConfig(context.Context, *server.SimpleName) (*server.CommonResult, error)
|
|
mustEmbedUnimplementedConfigServiceServer()
|
|
}
|
|
|
|
// UnimplementedConfigServiceServer must be embedded to have forward compatible implementations.
|
|
type UnimplementedConfigServiceServer struct {
|
|
}
|
|
|
|
func (UnimplementedConfigServiceServer) GetConfigs(context.Context, *server.Empty) (*Configs, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetConfigs not implemented")
|
|
}
|
|
func (UnimplementedConfigServiceServer) GetConfig(context.Context, *server.SimpleName) (*Config, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetConfig not implemented")
|
|
}
|
|
func (UnimplementedConfigServiceServer) CreateConfig(context.Context, *Config) (*server.CommonResult, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method CreateConfig not implemented")
|
|
}
|
|
func (UnimplementedConfigServiceServer) UpdateConfig(context.Context, *Config) (*server.CommonResult, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method UpdateConfig not implemented")
|
|
}
|
|
func (UnimplementedConfigServiceServer) DeleteConfig(context.Context, *server.SimpleName) (*server.CommonResult, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method DeleteConfig not implemented")
|
|
}
|
|
func (UnimplementedConfigServiceServer) mustEmbedUnimplementedConfigServiceServer() {}
|
|
|
|
// UnsafeConfigServiceServer may be embedded to opt out of forward compatibility for this service.
|
|
// Use of this interface is not recommended, as added methods to ConfigServiceServer will
|
|
// result in compilation errors.
|
|
type UnsafeConfigServiceServer interface {
|
|
mustEmbedUnimplementedConfigServiceServer()
|
|
}
|
|
|
|
func RegisterConfigServiceServer(s grpc.ServiceRegistrar, srv ConfigServiceServer) {
|
|
s.RegisterService(&ConfigService_ServiceDesc, srv)
|
|
}
|
|
|
|
func _ConfigService_GetConfigs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.Empty)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ConfigServiceServer).GetConfigs(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.ConfigService/GetConfigs",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ConfigServiceServer).GetConfigs(ctx, req.(*server.Empty))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _ConfigService_GetConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.SimpleName)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ConfigServiceServer).GetConfig(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.ConfigService/GetConfig",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ConfigServiceServer).GetConfig(ctx, req.(*server.SimpleName))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _ConfigService_CreateConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(Config)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ConfigServiceServer).CreateConfig(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.ConfigService/CreateConfig",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ConfigServiceServer).CreateConfig(ctx, req.(*Config))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _ConfigService_UpdateConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(Config)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ConfigServiceServer).UpdateConfig(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.ConfigService/UpdateConfig",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ConfigServiceServer).UpdateConfig(ctx, req.(*Config))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _ConfigService_DeleteConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(server.SimpleName)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ConfigServiceServer).DeleteConfig(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/remote.ConfigService/DeleteConfig",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ConfigServiceServer).DeleteConfig(ctx, req.(*server.SimpleName))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
// ConfigService_ServiceDesc is the grpc.ServiceDesc for ConfigService service.
|
|
// It's only intended for direct use with grpc.RegisterService,
|
|
// and not to be introspected or modified (even as a copy)
|
|
var ConfigService_ServiceDesc = grpc.ServiceDesc{
|
|
ServiceName: "remote.ConfigService",
|
|
HandlerType: (*ConfigServiceServer)(nil),
|
|
Methods: []grpc.MethodDesc{
|
|
{
|
|
MethodName: "GetConfigs",
|
|
Handler: _ConfigService_GetConfigs_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetConfig",
|
|
Handler: _ConfigService_GetConfig_Handler,
|
|
},
|
|
{
|
|
MethodName: "CreateConfig",
|
|
Handler: _ConfigService_CreateConfig_Handler,
|
|
},
|
|
{
|
|
MethodName: "UpdateConfig",
|
|
Handler: _ConfigService_UpdateConfig_Handler,
|
|
},
|
|
{
|
|
MethodName: "DeleteConfig",
|
|
Handler: _ConfigService_DeleteConfig_Handler,
|
|
},
|
|
},
|
|
Streams: []grpc.StreamDesc{},
|
|
Metadata: "pkg/testing/remote/loader.proto",
|
|
}
|