Documentation ¶
Index ¶
- Variables
- func RegisterCommandServiceServer(s grpc.ServiceRegistrar, srv CommandServiceServer)
- func RegisterEventQueryServiceServer(s grpc.ServiceRegistrar, srv EventQueryServiceServer)
- func RegisterQueryServiceServer(s grpc.ServiceRegistrar, srv QueryServiceServer)
- type CommandServiceClient
- type CommandServiceServer
- type CommandService_TransactionClient
- type CommandService_TransactionServer
- type EventQueryServiceClient
- type EventQueryServiceServer
- type QueryServiceClient
- type QueryServiceServer
- type UnimplementedCommandServiceServer
- func (UnimplementedCommandServiceServer) AutoMigrate(context.Context, *request.AutoMigrateRequest) (*empty.Empty, error)
- func (UnimplementedCommandServiceServer) Delete(context.Context, *request.DeleteRequest) (*response.CommandStatementResponse, error)
- func (UnimplementedCommandServiceServer) DeleteBatch(context.Context, *request.DeleteBatchRequest) (*response.CommandStatementResponse, error)
- func (UnimplementedCommandServiceServer) Insert(context.Context, *request.InsertRequest) (*response.CommandStatementResponse, error)
- func (UnimplementedCommandServiceServer) InsertBatch(context.Context, *request.InsertBatchRequest) (*response.CommandStatementResponse, error)
- func (UnimplementedCommandServiceServer) Replay(context.Context, *request.ReplayRequest) (*response.CommandStatementResponse, error)
- func (UnimplementedCommandServiceServer) Transaction(CommandService_TransactionServer) error
- func (UnimplementedCommandServiceServer) Update(context.Context, *request.UpdateRequest) (*response.CommandStatementResponse, error)
- type UnimplementedEventQueryServiceServer
- func (UnimplementedEventQueryServiceServer) CommonCountEvent(context.Context, *request.CommonCountEventRequest) (*response.CountEventResponse, error)
- func (UnimplementedEventQueryServiceServer) CommonCountEventHistory(context.Context, *request.CommonCountEventRequest) (*response.CountEventResponse, error)
- func (UnimplementedEventQueryServiceServer) CommonEventHistoryQuery(context.Context, *request.CommonEventQueryRequest) (*response.EventQueryResponse, error)
- func (UnimplementedEventQueryServiceServer) CommonEventHistoryQueryOnly(context.Context, *request.CommonEventQueryRequest) (*response.EventQueryOnlyResponse, error)
- func (UnimplementedEventQueryServiceServer) CommonEventQuery(context.Context, *request.CommonEventQueryRequest) (*response.EventQueryResponse, error)
- func (UnimplementedEventQueryServiceServer) CommonEventQueryOnly(context.Context, *request.CommonEventQueryRequest) (*response.EventQueryOnlyResponse, error)
- func (UnimplementedEventQueryServiceServer) CountEventByKeys(context.Context, *request.CountEventByKeysRequest) (*response.CountEventResponse, error)
- func (UnimplementedEventQueryServiceServer) CountEventHistoryByKeys(context.Context, *request.CountEventByKeysRequest) (*response.CountEventResponse, error)
- func (UnimplementedEventQueryServiceServer) EventHistoryQueryByKeys(context.Context, *request.EventQueryByKeysRequest) (*response.EventQueryResponse, error)
- func (UnimplementedEventQueryServiceServer) EventHistoryQueryOnlyByKeys(context.Context, *request.EventQueryByKeysRequest) (*response.EventQueryOnlyResponse, error)
- func (UnimplementedEventQueryServiceServer) EventQueryByKeys(context.Context, *request.EventQueryByKeysRequest) (*response.EventQueryResponse, error)
- func (UnimplementedEventQueryServiceServer) EventQueryOnlyByKeys(context.Context, *request.EventQueryByKeysRequest) (*response.EventQueryOnlyResponse, error)
- type UnimplementedQueryServiceServer
- func (UnimplementedQueryServiceServer) CommonCount(context.Context, *request.CommonCountRequest) (*response.CountResponse, error)
- func (UnimplementedQueryServiceServer) CommonQuery(context.Context, *request.CommonQueryRequest) (*response.QueryResponse, error)
- func (UnimplementedQueryServiceServer) CommonQueryOnly(context.Context, *request.CommonQueryRequest) (*response.QueryOnlyResponse, error)
- func (UnimplementedQueryServiceServer) CountWhere(context.Context, *request.CountWhereRequest) (*response.CountResponse, error)
- func (UnimplementedQueryServiceServer) QueryByKeys(context.Context, *request.QueryByKeysRequest) (*response.QueryByKeysResponse, error)
- func (UnimplementedQueryServiceServer) QueryByWhereAndOrderBy(context.Context, *request.QueryByWhereAndOrderByRequest) (*response.QueryResponse, error)
- func (UnimplementedQueryServiceServer) QueryOnlyByWhereAndOrderBy(context.Context, *request.QueryByWhereAndOrderByRequest) (*response.QueryOnlyResponse, error)
- type UnsafeCommandServiceServer
- type UnsafeEventQueryServiceServer
- type UnsafeQueryServiceServer
Constants ¶
This section is empty.
Variables ¶
var CommandService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "v1.CommandService", HandlerType: (*CommandServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "AutoMigrate", Handler: _CommandService_AutoMigrate_Handler, }, { MethodName: "Insert", Handler: _CommandService_Insert_Handler, }, { MethodName: "InsertBatch", Handler: _CommandService_InsertBatch_Handler, }, { MethodName: "Delete", Handler: _CommandService_Delete_Handler, }, { MethodName: "DeleteBatch", Handler: _CommandService_DeleteBatch_Handler, }, { MethodName: "Update", Handler: _CommandService_Update_Handler, }, { MethodName: "Replay", Handler: _CommandService_Replay_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Transaction", Handler: _CommandService_Transaction_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "v1/command.proto", }
CommandService_ServiceDesc is the grpc.ServiceDesc for CommandService 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", }
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 File_v1_command_proto protoreflect.FileDescriptor
var File_v1_event_query_proto protoreflect.FileDescriptor
var File_v1_query_proto protoreflect.FileDescriptor
var QueryService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "v1.QueryService", HandlerType: (*QueryServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "QueryByWhereAndOrderBy", Handler: _QueryService_QueryByWhereAndOrderBy_Handler, }, { MethodName: "CommonQuery", Handler: _QueryService_CommonQuery_Handler, }, { MethodName: "QueryOnlyByWhereAndOrderBy", Handler: _QueryService_QueryOnlyByWhereAndOrderBy_Handler, }, { MethodName: "CommonQueryOnly", Handler: _QueryService_CommonQueryOnly_Handler, }, { MethodName: "QueryByKeys", Handler: _QueryService_QueryByKeys_Handler, }, { MethodName: "CountWhere", Handler: _QueryService_CountWhere_Handler, }, { MethodName: "CommonCount", Handler: _QueryService_CommonCount_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "v1/query.proto", }
QueryService_ServiceDesc is the grpc.ServiceDesc for QueryService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterCommandServiceServer ¶
func RegisterCommandServiceServer(s grpc.ServiceRegistrar, srv CommandServiceServer)
func RegisterEventQueryServiceServer ¶
func RegisterEventQueryServiceServer(s grpc.ServiceRegistrar, srv EventQueryServiceServer)
func RegisterQueryServiceServer ¶
func RegisterQueryServiceServer(s grpc.ServiceRegistrar, srv QueryServiceServer)
Types ¶
type CommandServiceClient ¶
type CommandServiceClient interface { AutoMigrate(ctx context.Context, in *request.AutoMigrateRequest, opts ...grpc.CallOption) (*empty.Empty, error) Transaction(ctx context.Context, opts ...grpc.CallOption) (CommandService_TransactionClient, error) Insert(ctx context.Context, in *request.InsertRequest, opts ...grpc.CallOption) (*response.CommandStatementResponse, error) InsertBatch(ctx context.Context, in *request.InsertBatchRequest, opts ...grpc.CallOption) (*response.CommandStatementResponse, error) Delete(ctx context.Context, in *request.DeleteRequest, opts ...grpc.CallOption) (*response.CommandStatementResponse, error) DeleteBatch(ctx context.Context, in *request.DeleteBatchRequest, opts ...grpc.CallOption) (*response.CommandStatementResponse, error) Update(ctx context.Context, in *request.UpdateRequest, opts ...grpc.CallOption) (*response.CommandStatementResponse, error) Replay(ctx context.Context, in *request.ReplayRequest, opts ...grpc.CallOption) (*response.CommandStatementResponse, error) }
CommandServiceClient is the client API for CommandService 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.
func NewCommandServiceClient ¶
func NewCommandServiceClient(cc grpc.ClientConnInterface) CommandServiceClient
type CommandServiceServer ¶
type CommandServiceServer interface { AutoMigrate(context.Context, *request.AutoMigrateRequest) (*empty.Empty, error) Transaction(CommandService_TransactionServer) error Insert(context.Context, *request.InsertRequest) (*response.CommandStatementResponse, error) InsertBatch(context.Context, *request.InsertBatchRequest) (*response.CommandStatementResponse, error) Delete(context.Context, *request.DeleteRequest) (*response.CommandStatementResponse, error) DeleteBatch(context.Context, *request.DeleteBatchRequest) (*response.CommandStatementResponse, error) Update(context.Context, *request.UpdateRequest) (*response.CommandStatementResponse, error) Replay(context.Context, *request.ReplayRequest) (*response.CommandStatementResponse, error) // contains filtered or unexported methods }
CommandServiceServer is the server API for CommandService service. All implementations must embed UnimplementedCommandServiceServer for forward compatibility
type CommandService_TransactionClient ¶
type CommandService_TransactionClient interface { Send(*request.TransactionOperation) error Recv() (*response.CommandStatementResponse, error) grpc.ClientStream }
type CommandService_TransactionServer ¶
type CommandService_TransactionServer interface { Send(*response.CommandStatementResponse) error Recv() (*request.TransactionOperation, error) grpc.ServerStream }
type EventQueryServiceClient ¶
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) }
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.
func NewEventQueryServiceClient ¶
func NewEventQueryServiceClient(cc grpc.ClientConnInterface) EventQueryServiceClient
type EventQueryServiceServer ¶
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) // contains filtered or unexported methods }
EventQueryServiceServer is the server API for EventQueryService service. All implementations must embed UnimplementedEventQueryServiceServer for forward compatibility
type QueryServiceClient ¶
type QueryServiceClient interface { QueryByWhereAndOrderBy(ctx context.Context, in *request.QueryByWhereAndOrderByRequest, opts ...grpc.CallOption) (*response.QueryResponse, error) CommonQuery(ctx context.Context, in *request.CommonQueryRequest, opts ...grpc.CallOption) (*response.QueryResponse, error) QueryOnlyByWhereAndOrderBy(ctx context.Context, in *request.QueryByWhereAndOrderByRequest, opts ...grpc.CallOption) (*response.QueryOnlyResponse, error) CommonQueryOnly(ctx context.Context, in *request.CommonQueryRequest, opts ...grpc.CallOption) (*response.QueryOnlyResponse, error) QueryByKeys(ctx context.Context, in *request.QueryByKeysRequest, opts ...grpc.CallOption) (*response.QueryByKeysResponse, error) CountWhere(ctx context.Context, in *request.CountWhereRequest, opts ...grpc.CallOption) (*response.CountResponse, error) CommonCount(ctx context.Context, in *request.CommonCountRequest, opts ...grpc.CallOption) (*response.CountResponse, error) }
QueryServiceClient is the client API for QueryService 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.
func NewQueryServiceClient ¶
func NewQueryServiceClient(cc grpc.ClientConnInterface) QueryServiceClient
type QueryServiceServer ¶
type QueryServiceServer interface { QueryByWhereAndOrderBy(context.Context, *request.QueryByWhereAndOrderByRequest) (*response.QueryResponse, error) CommonQuery(context.Context, *request.CommonQueryRequest) (*response.QueryResponse, error) QueryOnlyByWhereAndOrderBy(context.Context, *request.QueryByWhereAndOrderByRequest) (*response.QueryOnlyResponse, error) CommonQueryOnly(context.Context, *request.CommonQueryRequest) (*response.QueryOnlyResponse, error) QueryByKeys(context.Context, *request.QueryByKeysRequest) (*response.QueryByKeysResponse, error) CountWhere(context.Context, *request.CountWhereRequest) (*response.CountResponse, error) CommonCount(context.Context, *request.CommonCountRequest) (*response.CountResponse, error) // contains filtered or unexported methods }
QueryServiceServer is the server API for QueryService service. All implementations must embed UnimplementedQueryServiceServer for forward compatibility
type UnimplementedCommandServiceServer ¶
type UnimplementedCommandServiceServer struct { }
UnimplementedCommandServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedCommandServiceServer) AutoMigrate ¶
func (UnimplementedCommandServiceServer) AutoMigrate(context.Context, *request.AutoMigrateRequest) (*empty.Empty, error)
func (UnimplementedCommandServiceServer) Delete ¶
func (UnimplementedCommandServiceServer) Delete(context.Context, *request.DeleteRequest) (*response.CommandStatementResponse, error)
func (UnimplementedCommandServiceServer) DeleteBatch ¶
func (UnimplementedCommandServiceServer) DeleteBatch(context.Context, *request.DeleteBatchRequest) (*response.CommandStatementResponse, error)
func (UnimplementedCommandServiceServer) Insert ¶
func (UnimplementedCommandServiceServer) Insert(context.Context, *request.InsertRequest) (*response.CommandStatementResponse, error)
func (UnimplementedCommandServiceServer) InsertBatch ¶
func (UnimplementedCommandServiceServer) InsertBatch(context.Context, *request.InsertBatchRequest) (*response.CommandStatementResponse, error)
func (UnimplementedCommandServiceServer) Replay ¶
func (UnimplementedCommandServiceServer) Replay(context.Context, *request.ReplayRequest) (*response.CommandStatementResponse, error)
func (UnimplementedCommandServiceServer) Transaction ¶
func (UnimplementedCommandServiceServer) Transaction(CommandService_TransactionServer) error
func (UnimplementedCommandServiceServer) Update ¶
func (UnimplementedCommandServiceServer) Update(context.Context, *request.UpdateRequest) (*response.CommandStatementResponse, error)
type UnimplementedEventQueryServiceServer ¶
type UnimplementedEventQueryServiceServer struct { }
UnimplementedEventQueryServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedEventQueryServiceServer) CommonCountEvent ¶
func (UnimplementedEventQueryServiceServer) CommonCountEvent(context.Context, *request.CommonCountEventRequest) (*response.CountEventResponse, error)
func (UnimplementedEventQueryServiceServer) CommonCountEventHistory ¶
func (UnimplementedEventQueryServiceServer) CommonCountEventHistory(context.Context, *request.CommonCountEventRequest) (*response.CountEventResponse, error)
func (UnimplementedEventQueryServiceServer) CommonEventHistoryQuery ¶
func (UnimplementedEventQueryServiceServer) CommonEventHistoryQuery(context.Context, *request.CommonEventQueryRequest) (*response.EventQueryResponse, error)
func (UnimplementedEventQueryServiceServer) CommonEventHistoryQueryOnly ¶
func (UnimplementedEventQueryServiceServer) CommonEventHistoryQueryOnly(context.Context, *request.CommonEventQueryRequest) (*response.EventQueryOnlyResponse, error)
func (UnimplementedEventQueryServiceServer) CommonEventQuery ¶
func (UnimplementedEventQueryServiceServer) CommonEventQuery(context.Context, *request.CommonEventQueryRequest) (*response.EventQueryResponse, error)
func (UnimplementedEventQueryServiceServer) CommonEventQueryOnly ¶
func (UnimplementedEventQueryServiceServer) CommonEventQueryOnly(context.Context, *request.CommonEventQueryRequest) (*response.EventQueryOnlyResponse, error)
func (UnimplementedEventQueryServiceServer) CountEventByKeys ¶
func (UnimplementedEventQueryServiceServer) CountEventByKeys(context.Context, *request.CountEventByKeysRequest) (*response.CountEventResponse, error)
func (UnimplementedEventQueryServiceServer) CountEventHistoryByKeys ¶
func (UnimplementedEventQueryServiceServer) CountEventHistoryByKeys(context.Context, *request.CountEventByKeysRequest) (*response.CountEventResponse, error)
func (UnimplementedEventQueryServiceServer) EventHistoryQueryByKeys ¶
func (UnimplementedEventQueryServiceServer) EventHistoryQueryByKeys(context.Context, *request.EventQueryByKeysRequest) (*response.EventQueryResponse, error)
func (UnimplementedEventQueryServiceServer) EventHistoryQueryOnlyByKeys ¶
func (UnimplementedEventQueryServiceServer) EventHistoryQueryOnlyByKeys(context.Context, *request.EventQueryByKeysRequest) (*response.EventQueryOnlyResponse, error)
func (UnimplementedEventQueryServiceServer) EventQueryByKeys ¶
func (UnimplementedEventQueryServiceServer) EventQueryByKeys(context.Context, *request.EventQueryByKeysRequest) (*response.EventQueryResponse, error)
func (UnimplementedEventQueryServiceServer) EventQueryOnlyByKeys ¶
func (UnimplementedEventQueryServiceServer) EventQueryOnlyByKeys(context.Context, *request.EventQueryByKeysRequest) (*response.EventQueryOnlyResponse, error)
type UnimplementedQueryServiceServer ¶
type UnimplementedQueryServiceServer struct { }
UnimplementedQueryServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedQueryServiceServer) CommonCount ¶
func (UnimplementedQueryServiceServer) CommonCount(context.Context, *request.CommonCountRequest) (*response.CountResponse, error)
func (UnimplementedQueryServiceServer) CommonQuery ¶
func (UnimplementedQueryServiceServer) CommonQuery(context.Context, *request.CommonQueryRequest) (*response.QueryResponse, error)
func (UnimplementedQueryServiceServer) CommonQueryOnly ¶
func (UnimplementedQueryServiceServer) CommonQueryOnly(context.Context, *request.CommonQueryRequest) (*response.QueryOnlyResponse, error)
func (UnimplementedQueryServiceServer) CountWhere ¶
func (UnimplementedQueryServiceServer) CountWhere(context.Context, *request.CountWhereRequest) (*response.CountResponse, error)
func (UnimplementedQueryServiceServer) QueryByKeys ¶
func (UnimplementedQueryServiceServer) QueryByKeys(context.Context, *request.QueryByKeysRequest) (*response.QueryByKeysResponse, error)
func (UnimplementedQueryServiceServer) QueryByWhereAndOrderBy ¶
func (UnimplementedQueryServiceServer) QueryByWhereAndOrderBy(context.Context, *request.QueryByWhereAndOrderByRequest) (*response.QueryResponse, error)
func (UnimplementedQueryServiceServer) QueryOnlyByWhereAndOrderBy ¶
func (UnimplementedQueryServiceServer) QueryOnlyByWhereAndOrderBy(context.Context, *request.QueryByWhereAndOrderByRequest) (*response.QueryOnlyResponse, error)
type UnsafeCommandServiceServer ¶
type UnsafeCommandServiceServer interface {
// contains filtered or unexported methods
}
UnsafeCommandServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CommandServiceServer will result in compilation errors.
type UnsafeEventQueryServiceServer ¶
type UnsafeEventQueryServiceServer interface {
// contains filtered or unexported methods
}
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 UnsafeQueryServiceServer ¶
type UnsafeQueryServiceServer interface {
// contains filtered or unexported methods
}
UnsafeQueryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueryServiceServer will result in compilation errors.