v1

package
v1.10.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 6, 2024 License: GPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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: "DeleteWhere",
			Handler:    _CommandService_DeleteWhere_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _CommandService_Update_Handler,
		},
		{
			MethodName: "UpdateWhere",
			Handler:    _CommandService_UpdateWhere_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)

View Source 
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)

View Source 
var File_v1_command_proto protoreflect.FileDescriptor
View Source 
var File_v1_event_query_proto protoreflect.FileDescriptor
View Source 
var File_v1_query_proto protoreflect.FileDescriptor
View Source 
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)
	DeleteWhere(ctx context.Context, in *request.DeleteWhereRequest, opts ...grpc.CallOption) (*response.CommandStatementResponse, error)
	Update(ctx context.Context, in *request.UpdateRequest, opts ...grpc.CallOption) (*response.CommandStatementResponse, error)
	UpdateWhere(ctx context.Context, in *request.UpdateWhereRequest, 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)
	DeleteWhere(context.Context, *request.DeleteWhereRequest) (*response.CommandStatementResponse, error)
	Update(context.Context, *request.UpdateRequest) (*response.CommandStatementResponse, error)
	UpdateWhere(context.Context, *request.UpdateWhereRequest) (*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) DeleteWhere added in v1.6.6 

func (UnimplementedCommandServiceServer) DeleteWhere(context.Context, *request.DeleteWhereRequest) (*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)

func (UnimplementedCommandServiceServer) UpdateWhere added in v1.7.0 

func (UnimplementedCommandServiceServer) UpdateWhere(context.Context, *request.UpdateWhereRequest) (*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.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.