// Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.2.0 // - protoc v3.12.4 // source: v1/event_query.proto package v1 import ( context "context" request "git.sxidc.com/service-supports/dps-sdk/pb/v1/request" response "git.sxidc.com/service-supports/dps-sdk/pb/v1/response" 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 // EventQueryServiceClient is the client API for EventQueryService 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 EventQueryServiceClient interface { EventQueryByKeys(ctx context.Context, in *request.EventQueryByKeysRequest, opts ...grpc.CallOption) (*response.EventQueryResponse, error) CommonEventQuery(ctx context.Context, in *request.CommonEventQueryRequest, opts ...grpc.CallOption) (*response.EventQueryResponse, error) EventQueryOnlyByKeys(ctx context.Context, in *request.EventQueryByKeysRequest, opts ...grpc.CallOption) (*response.EventQueryOnlyResponse, error) CommonEventQueryOnly(ctx context.Context, in *request.CommonEventQueryRequest, opts ...grpc.CallOption) (*response.EventQueryOnlyResponse, error) CountEventByKeys(ctx context.Context, in *request.CountEventByKeysRequest, opts ...grpc.CallOption) (*response.CountEventResponse, error) CommonCountEvent(ctx context.Context, in *request.CommonCountEventRequest, opts ...grpc.CallOption) (*response.CountEventResponse, error) EventHistoryQueryByKeys(ctx context.Context, in *request.EventQueryByKeysRequest, opts ...grpc.CallOption) (*response.EventQueryResponse, error) CommonEventHistoryQuery(ctx context.Context, in *request.CommonEventQueryRequest, opts ...grpc.CallOption) (*response.EventQueryResponse, error) EventHistoryQueryOnlyByKeys(ctx context.Context, in *request.EventQueryByKeysRequest, opts ...grpc.CallOption) (*response.EventQueryOnlyResponse, error) CommonEventHistoryQueryOnly(ctx context.Context, in *request.CommonEventQueryRequest, opts ...grpc.CallOption) (*response.EventQueryOnlyResponse, error) CountEventHistoryByKeys(ctx context.Context, in *request.CountEventByKeysRequest, opts ...grpc.CallOption) (*response.CountEventResponse, error) CommonCountEventHistory(ctx context.Context, in *request.CommonCountEventRequest, opts ...grpc.CallOption) (*response.CountEventResponse, error) } type eventQueryServiceClient struct { cc grpc.ClientConnInterface } func NewEventQueryServiceClient(cc grpc.ClientConnInterface) EventQueryServiceClient { return &eventQueryServiceClient{cc} } func (c *eventQueryServiceClient) EventQueryByKeys(ctx context.Context, in *request.EventQueryByKeysRequest, opts ...grpc.CallOption) (*response.EventQueryResponse, error) { out := new(response.EventQueryResponse) err := c.cc.Invoke(ctx, "/v1.EventQueryService/EventQueryByKeys", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *eventQueryServiceClient) CommonEventQuery(ctx context.Context, in *request.CommonEventQueryRequest, opts ...grpc.CallOption) (*response.EventQueryResponse, error) { out := new(response.EventQueryResponse) err := c.cc.Invoke(ctx, "/v1.EventQueryService/CommonEventQuery", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *eventQueryServiceClient) EventQueryOnlyByKeys(ctx context.Context, in *request.EventQueryByKeysRequest, opts ...grpc.CallOption) (*response.EventQueryOnlyResponse, error) { out := new(response.EventQueryOnlyResponse) err := c.cc.Invoke(ctx, "/v1.EventQueryService/EventQueryOnlyByKeys", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *eventQueryServiceClient) CommonEventQueryOnly(ctx context.Context, in *request.CommonEventQueryRequest, opts ...grpc.CallOption) (*response.EventQueryOnlyResponse, error) { out := new(response.EventQueryOnlyResponse) err := c.cc.Invoke(ctx, "/v1.EventQueryService/CommonEventQueryOnly", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *eventQueryServiceClient) CountEventByKeys(ctx context.Context, in *request.CountEventByKeysRequest, opts ...grpc.CallOption) (*response.CountEventResponse, error) { out := new(response.CountEventResponse) err := c.cc.Invoke(ctx, "/v1.EventQueryService/CountEventByKeys", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *eventQueryServiceClient) CommonCountEvent(ctx context.Context, in *request.CommonCountEventRequest, opts ...grpc.CallOption) (*response.CountEventResponse, error) { out := new(response.CountEventResponse) err := c.cc.Invoke(ctx, "/v1.EventQueryService/CommonCountEvent", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *eventQueryServiceClient) EventHistoryQueryByKeys(ctx context.Context, in *request.EventQueryByKeysRequest, opts ...grpc.CallOption) (*response.EventQueryResponse, error) { out := new(response.EventQueryResponse) err := c.cc.Invoke(ctx, "/v1.EventQueryService/EventHistoryQueryByKeys", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *eventQueryServiceClient) CommonEventHistoryQuery(ctx context.Context, in *request.CommonEventQueryRequest, opts ...grpc.CallOption) (*response.EventQueryResponse, error) { out := new(response.EventQueryResponse) err := c.cc.Invoke(ctx, "/v1.EventQueryService/CommonEventHistoryQuery", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *eventQueryServiceClient) EventHistoryQueryOnlyByKeys(ctx context.Context, in *request.EventQueryByKeysRequest, opts ...grpc.CallOption) (*response.EventQueryOnlyResponse, error) { out := new(response.EventQueryOnlyResponse) err := c.cc.Invoke(ctx, "/v1.EventQueryService/EventHistoryQueryOnlyByKeys", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *eventQueryServiceClient) CommonEventHistoryQueryOnly(ctx context.Context, in *request.CommonEventQueryRequest, opts ...grpc.CallOption) (*response.EventQueryOnlyResponse, error) { out := new(response.EventQueryOnlyResponse) err := c.cc.Invoke(ctx, "/v1.EventQueryService/CommonEventHistoryQueryOnly", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *eventQueryServiceClient) CountEventHistoryByKeys(ctx context.Context, in *request.CountEventByKeysRequest, opts ...grpc.CallOption) (*response.CountEventResponse, error) { out := new(response.CountEventResponse) err := c.cc.Invoke(ctx, "/v1.EventQueryService/CountEventHistoryByKeys", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *eventQueryServiceClient) CommonCountEventHistory(ctx context.Context, in *request.CommonCountEventRequest, opts ...grpc.CallOption) (*response.CountEventResponse, error) { out := new(response.CountEventResponse) err := c.cc.Invoke(ctx, "/v1.EventQueryService/CommonCountEventHistory", in, out, opts...) if err != nil { return nil, err } return out, nil } // EventQueryServiceServer is the server API for EventQueryService service. // All implementations must embed UnimplementedEventQueryServiceServer // for forward compatibility type EventQueryServiceServer interface { EventQueryByKeys(context.Context, *request.EventQueryByKeysRequest) (*response.EventQueryResponse, error) CommonEventQuery(context.Context, *request.CommonEventQueryRequest) (*response.EventQueryResponse, error) EventQueryOnlyByKeys(context.Context, *request.EventQueryByKeysRequest) (*response.EventQueryOnlyResponse, error) CommonEventQueryOnly(context.Context, *request.CommonEventQueryRequest) (*response.EventQueryOnlyResponse, error) CountEventByKeys(context.Context, *request.CountEventByKeysRequest) (*response.CountEventResponse, error) CommonCountEvent(context.Context, *request.CommonCountEventRequest) (*response.CountEventResponse, error) EventHistoryQueryByKeys(context.Context, *request.EventQueryByKeysRequest) (*response.EventQueryResponse, error) CommonEventHistoryQuery(context.Context, *request.CommonEventQueryRequest) (*response.EventQueryResponse, error) EventHistoryQueryOnlyByKeys(context.Context, *request.EventQueryByKeysRequest) (*response.EventQueryOnlyResponse, error) CommonEventHistoryQueryOnly(context.Context, *request.CommonEventQueryRequest) (*response.EventQueryOnlyResponse, error) CountEventHistoryByKeys(context.Context, *request.CountEventByKeysRequest) (*response.CountEventResponse, error) CommonCountEventHistory(context.Context, *request.CommonCountEventRequest) (*response.CountEventResponse, error) mustEmbedUnimplementedEventQueryServiceServer() } // UnimplementedEventQueryServiceServer must be embedded to have forward compatible implementations. type UnimplementedEventQueryServiceServer struct { } func (UnimplementedEventQueryServiceServer) EventQueryByKeys(context.Context, *request.EventQueryByKeysRequest) (*response.EventQueryResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method EventQueryByKeys not implemented") } func (UnimplementedEventQueryServiceServer) CommonEventQuery(context.Context, *request.CommonEventQueryRequest) (*response.EventQueryResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CommonEventQuery not implemented") } func (UnimplementedEventQueryServiceServer) EventQueryOnlyByKeys(context.Context, *request.EventQueryByKeysRequest) (*response.EventQueryOnlyResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method EventQueryOnlyByKeys not implemented") } func (UnimplementedEventQueryServiceServer) CommonEventQueryOnly(context.Context, *request.CommonEventQueryRequest) (*response.EventQueryOnlyResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CommonEventQueryOnly not implemented") } func (UnimplementedEventQueryServiceServer) CountEventByKeys(context.Context, *request.CountEventByKeysRequest) (*response.CountEventResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CountEventByKeys not implemented") } func (UnimplementedEventQueryServiceServer) CommonCountEvent(context.Context, *request.CommonCountEventRequest) (*response.CountEventResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CommonCountEvent not implemented") } func (UnimplementedEventQueryServiceServer) EventHistoryQueryByKeys(context.Context, *request.EventQueryByKeysRequest) (*response.EventQueryResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method EventHistoryQueryByKeys not implemented") } func (UnimplementedEventQueryServiceServer) CommonEventHistoryQuery(context.Context, *request.CommonEventQueryRequest) (*response.EventQueryResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CommonEventHistoryQuery not implemented") } func (UnimplementedEventQueryServiceServer) EventHistoryQueryOnlyByKeys(context.Context, *request.EventQueryByKeysRequest) (*response.EventQueryOnlyResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method EventHistoryQueryOnlyByKeys not implemented") } func (UnimplementedEventQueryServiceServer) CommonEventHistoryQueryOnly(context.Context, *request.CommonEventQueryRequest) (*response.EventQueryOnlyResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CommonEventHistoryQueryOnly not implemented") } func (UnimplementedEventQueryServiceServer) CountEventHistoryByKeys(context.Context, *request.CountEventByKeysRequest) (*response.CountEventResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CountEventHistoryByKeys not implemented") } func (UnimplementedEventQueryServiceServer) CommonCountEventHistory(context.Context, *request.CommonCountEventRequest) (*response.CountEventResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CommonCountEventHistory not implemented") } func (UnimplementedEventQueryServiceServer) mustEmbedUnimplementedEventQueryServiceServer() {} // UnsafeEventQueryServiceServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to EventQueryServiceServer will // result in compilation errors. type UnsafeEventQueryServiceServer interface { mustEmbedUnimplementedEventQueryServiceServer() } func RegisterEventQueryServiceServer(s grpc.ServiceRegistrar, srv EventQueryServiceServer) { s.RegisterService(&EventQueryService_ServiceDesc, srv) } func _EventQueryService_EventQueryByKeys_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(request.EventQueryByKeysRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(EventQueryServiceServer).EventQueryByKeys(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/v1.EventQueryService/EventQueryByKeys", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(EventQueryServiceServer).EventQueryByKeys(ctx, req.(*request.EventQueryByKeysRequest)) } return interceptor(ctx, in, info, handler) } func _EventQueryService_CommonEventQuery_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(request.CommonEventQueryRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(EventQueryServiceServer).CommonEventQuery(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/v1.EventQueryService/CommonEventQuery", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(EventQueryServiceServer).CommonEventQuery(ctx, req.(*request.CommonEventQueryRequest)) } return interceptor(ctx, in, info, handler) } func _EventQueryService_EventQueryOnlyByKeys_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(request.EventQueryByKeysRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(EventQueryServiceServer).EventQueryOnlyByKeys(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/v1.EventQueryService/EventQueryOnlyByKeys", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(EventQueryServiceServer).EventQueryOnlyByKeys(ctx, req.(*request.EventQueryByKeysRequest)) } return interceptor(ctx, in, info, handler) } func _EventQueryService_CommonEventQueryOnly_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(request.CommonEventQueryRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(EventQueryServiceServer).CommonEventQueryOnly(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/v1.EventQueryService/CommonEventQueryOnly", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(EventQueryServiceServer).CommonEventQueryOnly(ctx, req.(*request.CommonEventQueryRequest)) } return interceptor(ctx, in, info, handler) } func _EventQueryService_CountEventByKeys_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(request.CountEventByKeysRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(EventQueryServiceServer).CountEventByKeys(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/v1.EventQueryService/CountEventByKeys", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(EventQueryServiceServer).CountEventByKeys(ctx, req.(*request.CountEventByKeysRequest)) } return interceptor(ctx, in, info, handler) } func _EventQueryService_CommonCountEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(request.CommonCountEventRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(EventQueryServiceServer).CommonCountEvent(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/v1.EventQueryService/CommonCountEvent", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(EventQueryServiceServer).CommonCountEvent(ctx, req.(*request.CommonCountEventRequest)) } return interceptor(ctx, in, info, handler) } func _EventQueryService_EventHistoryQueryByKeys_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(request.EventQueryByKeysRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(EventQueryServiceServer).EventHistoryQueryByKeys(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/v1.EventQueryService/EventHistoryQueryByKeys", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(EventQueryServiceServer).EventHistoryQueryByKeys(ctx, req.(*request.EventQueryByKeysRequest)) } return interceptor(ctx, in, info, handler) } func _EventQueryService_CommonEventHistoryQuery_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(request.CommonEventQueryRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(EventQueryServiceServer).CommonEventHistoryQuery(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/v1.EventQueryService/CommonEventHistoryQuery", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(EventQueryServiceServer).CommonEventHistoryQuery(ctx, req.(*request.CommonEventQueryRequest)) } return interceptor(ctx, in, info, handler) } func _EventQueryService_EventHistoryQueryOnlyByKeys_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(request.EventQueryByKeysRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(EventQueryServiceServer).EventHistoryQueryOnlyByKeys(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/v1.EventQueryService/EventHistoryQueryOnlyByKeys", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(EventQueryServiceServer).EventHistoryQueryOnlyByKeys(ctx, req.(*request.EventQueryByKeysRequest)) } return interceptor(ctx, in, info, handler) } func _EventQueryService_CommonEventHistoryQueryOnly_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(request.CommonEventQueryRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(EventQueryServiceServer).CommonEventHistoryQueryOnly(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/v1.EventQueryService/CommonEventHistoryQueryOnly", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(EventQueryServiceServer).CommonEventHistoryQueryOnly(ctx, req.(*request.CommonEventQueryRequest)) } return interceptor(ctx, in, info, handler) } func _EventQueryService_CountEventHistoryByKeys_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(request.CountEventByKeysRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(EventQueryServiceServer).CountEventHistoryByKeys(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/v1.EventQueryService/CountEventHistoryByKeys", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(EventQueryServiceServer).CountEventHistoryByKeys(ctx, req.(*request.CountEventByKeysRequest)) } return interceptor(ctx, in, info, handler) } func _EventQueryService_CommonCountEventHistory_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(request.CommonCountEventRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(EventQueryServiceServer).CommonCountEventHistory(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/v1.EventQueryService/CommonCountEventHistory", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(EventQueryServiceServer).CommonCountEventHistory(ctx, req.(*request.CommonCountEventRequest)) } return interceptor(ctx, in, info, handler) } // EventQueryService_ServiceDesc is the grpc.ServiceDesc for EventQueryService service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var EventQueryService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "v1.EventQueryService", HandlerType: (*EventQueryServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "EventQueryByKeys", Handler: _EventQueryService_EventQueryByKeys_Handler, }, { MethodName: "CommonEventQuery", Handler: _EventQueryService_CommonEventQuery_Handler, }, { MethodName: "EventQueryOnlyByKeys", Handler: _EventQueryService_EventQueryOnlyByKeys_Handler, }, { MethodName: "CommonEventQueryOnly", Handler: _EventQueryService_CommonEventQueryOnly_Handler, }, { MethodName: "CountEventByKeys", Handler: _EventQueryService_CountEventByKeys_Handler, }, { MethodName: "CommonCountEvent", Handler: _EventQueryService_CommonCountEvent_Handler, }, { MethodName: "EventHistoryQueryByKeys", Handler: _EventQueryService_EventHistoryQueryByKeys_Handler, }, { MethodName: "CommonEventHistoryQuery", Handler: _EventQueryService_CommonEventHistoryQuery_Handler, }, { MethodName: "EventHistoryQueryOnlyByKeys", Handler: _EventQueryService_EventHistoryQueryOnlyByKeys_Handler, }, { MethodName: "CommonEventHistoryQueryOnly", Handler: _EventQueryService_CommonEventHistoryQueryOnly_Handler, }, { MethodName: "CountEventHistoryByKeys", Handler: _EventQueryService_CountEventHistoryByKeys_Handler, }, { MethodName: "CommonCountEventHistory", Handler: _EventQueryService_CommonCountEventHistory_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "v1/event_query.proto", }