// Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.3.0 // - protoc v5.29.3 // source: application.proto package protobufs 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 const ( HypergraphComparisonService_HyperStream_FullMethodName = "/quilibrium.node.application.pb.HypergraphComparisonService/HyperStream" HypergraphComparisonService_GetChildrenForPath_FullMethodName = "/quilibrium.node.application.pb.HypergraphComparisonService/GetChildrenForPath" HypergraphComparisonService_PerformSync_FullMethodName = "/quilibrium.node.application.pb.HypergraphComparisonService/PerformSync" ) // HypergraphComparisonServiceClient is the client API for HypergraphComparisonService 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 HypergraphComparisonServiceClient interface { HyperStream(ctx context.Context, opts ...grpc.CallOption) (HypergraphComparisonService_HyperStreamClient, error) GetChildrenForPath(ctx context.Context, in *GetChildrenForPathRequest, opts ...grpc.CallOption) (*GetChildrenForPathResponse, error) // PerformSync provides a client-driven sync interface. Unlike HyperStream // which requires both sides to walk in lockstep, PerformSync uses a simple // request/response pattern where the client navigates the server's tree // and fetches data as needed. PerformSync(ctx context.Context, opts ...grpc.CallOption) (HypergraphComparisonService_PerformSyncClient, error) } type hypergraphComparisonServiceClient struct { cc grpc.ClientConnInterface } func NewHypergraphComparisonServiceClient(cc grpc.ClientConnInterface) HypergraphComparisonServiceClient { return &hypergraphComparisonServiceClient{cc} } func (c *hypergraphComparisonServiceClient) HyperStream(ctx context.Context, opts ...grpc.CallOption) (HypergraphComparisonService_HyperStreamClient, error) { stream, err := c.cc.NewStream(ctx, &HypergraphComparisonService_ServiceDesc.Streams[0], HypergraphComparisonService_HyperStream_FullMethodName, opts...) if err != nil { return nil, err } x := &hypergraphComparisonServiceHyperStreamClient{stream} return x, nil } type HypergraphComparisonService_HyperStreamClient interface { Send(*HypergraphComparison) error Recv() (*HypergraphComparison, error) grpc.ClientStream } type hypergraphComparisonServiceHyperStreamClient struct { grpc.ClientStream } func (x *hypergraphComparisonServiceHyperStreamClient) Send(m *HypergraphComparison) error { return x.ClientStream.SendMsg(m) } func (x *hypergraphComparisonServiceHyperStreamClient) Recv() (*HypergraphComparison, error) { m := new(HypergraphComparison) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func (c *hypergraphComparisonServiceClient) GetChildrenForPath(ctx context.Context, in *GetChildrenForPathRequest, opts ...grpc.CallOption) (*GetChildrenForPathResponse, error) { out := new(GetChildrenForPathResponse) err := c.cc.Invoke(ctx, HypergraphComparisonService_GetChildrenForPath_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *hypergraphComparisonServiceClient) PerformSync(ctx context.Context, opts ...grpc.CallOption) (HypergraphComparisonService_PerformSyncClient, error) { stream, err := c.cc.NewStream(ctx, &HypergraphComparisonService_ServiceDesc.Streams[1], HypergraphComparisonService_PerformSync_FullMethodName, opts...) if err != nil { return nil, err } x := &hypergraphComparisonServicePerformSyncClient{stream} return x, nil } type HypergraphComparisonService_PerformSyncClient interface { Send(*HypergraphSyncQuery) error Recv() (*HypergraphSyncResponse, error) grpc.ClientStream } type hypergraphComparisonServicePerformSyncClient struct { grpc.ClientStream } func (x *hypergraphComparisonServicePerformSyncClient) Send(m *HypergraphSyncQuery) error { return x.ClientStream.SendMsg(m) } func (x *hypergraphComparisonServicePerformSyncClient) Recv() (*HypergraphSyncResponse, error) { m := new(HypergraphSyncResponse) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } return m, nil } // HypergraphComparisonServiceServer is the server API for HypergraphComparisonService service. // All implementations must embed UnimplementedHypergraphComparisonServiceServer // for forward compatibility type HypergraphComparisonServiceServer interface { HyperStream(HypergraphComparisonService_HyperStreamServer) error GetChildrenForPath(context.Context, *GetChildrenForPathRequest) (*GetChildrenForPathResponse, error) // PerformSync provides a client-driven sync interface. Unlike HyperStream // which requires both sides to walk in lockstep, PerformSync uses a simple // request/response pattern where the client navigates the server's tree // and fetches data as needed. PerformSync(HypergraphComparisonService_PerformSyncServer) error mustEmbedUnimplementedHypergraphComparisonServiceServer() } // UnimplementedHypergraphComparisonServiceServer must be embedded to have forward compatible implementations. type UnimplementedHypergraphComparisonServiceServer struct { } func (UnimplementedHypergraphComparisonServiceServer) HyperStream(HypergraphComparisonService_HyperStreamServer) error { return status.Errorf(codes.Unimplemented, "method HyperStream not implemented") } func (UnimplementedHypergraphComparisonServiceServer) GetChildrenForPath(context.Context, *GetChildrenForPathRequest) (*GetChildrenForPathResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetChildrenForPath not implemented") } func (UnimplementedHypergraphComparisonServiceServer) PerformSync(HypergraphComparisonService_PerformSyncServer) error { return status.Errorf(codes.Unimplemented, "method PerformSync not implemented") } func (UnimplementedHypergraphComparisonServiceServer) mustEmbedUnimplementedHypergraphComparisonServiceServer() { } // UnsafeHypergraphComparisonServiceServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to HypergraphComparisonServiceServer will // result in compilation errors. type UnsafeHypergraphComparisonServiceServer interface { mustEmbedUnimplementedHypergraphComparisonServiceServer() } func RegisterHypergraphComparisonServiceServer(s grpc.ServiceRegistrar, srv HypergraphComparisonServiceServer) { s.RegisterService(&HypergraphComparisonService_ServiceDesc, srv) } func _HypergraphComparisonService_HyperStream_Handler(srv interface{}, stream grpc.ServerStream) error { return srv.(HypergraphComparisonServiceServer).HyperStream(&hypergraphComparisonServiceHyperStreamServer{stream}) } type HypergraphComparisonService_HyperStreamServer interface { Send(*HypergraphComparison) error Recv() (*HypergraphComparison, error) grpc.ServerStream } type hypergraphComparisonServiceHyperStreamServer struct { grpc.ServerStream } func (x *hypergraphComparisonServiceHyperStreamServer) Send(m *HypergraphComparison) error { return x.ServerStream.SendMsg(m) } func (x *hypergraphComparisonServiceHyperStreamServer) Recv() (*HypergraphComparison, error) { m := new(HypergraphComparison) if err := x.ServerStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func _HypergraphComparisonService_GetChildrenForPath_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetChildrenForPathRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(HypergraphComparisonServiceServer).GetChildrenForPath(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: HypergraphComparisonService_GetChildrenForPath_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(HypergraphComparisonServiceServer).GetChildrenForPath(ctx, req.(*GetChildrenForPathRequest)) } return interceptor(ctx, in, info, handler) } func _HypergraphComparisonService_PerformSync_Handler(srv interface{}, stream grpc.ServerStream) error { return srv.(HypergraphComparisonServiceServer).PerformSync(&hypergraphComparisonServicePerformSyncServer{stream}) } type HypergraphComparisonService_PerformSyncServer interface { Send(*HypergraphSyncResponse) error Recv() (*HypergraphSyncQuery, error) grpc.ServerStream } type hypergraphComparisonServicePerformSyncServer struct { grpc.ServerStream } func (x *hypergraphComparisonServicePerformSyncServer) Send(m *HypergraphSyncResponse) error { return x.ServerStream.SendMsg(m) } func (x *hypergraphComparisonServicePerformSyncServer) Recv() (*HypergraphSyncQuery, error) { m := new(HypergraphSyncQuery) if err := x.ServerStream.RecvMsg(m); err != nil { return nil, err } return m, nil } // HypergraphComparisonService_ServiceDesc is the grpc.ServiceDesc for HypergraphComparisonService service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var HypergraphComparisonService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "quilibrium.node.application.pb.HypergraphComparisonService", HandlerType: (*HypergraphComparisonServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetChildrenForPath", Handler: _HypergraphComparisonService_GetChildrenForPath_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "HyperStream", Handler: _HypergraphComparisonService_HyperStream_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "PerformSync", Handler: _HypergraphComparisonService_PerformSync_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "application.proto", }