Documentation
¶
Index ¶
- Variables
- func RegisterSQLTraceBenchPluginServer(s grpc.ServiceRegistrar, srv SQLTraceBenchPluginServer)
- type ConvertSchemaRequest
- func (*ConvertSchemaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConvertSchemaRequest) GetSchema() string
- func (*ConvertSchemaRequest) ProtoMessage()
- func (x *ConvertSchemaRequest) ProtoReflect() protoreflect.Message
- func (x *ConvertSchemaRequest) Reset()
- func (x *ConvertSchemaRequest) String() string
- type ConvertSchemaResponse
- func (*ConvertSchemaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConvertSchemaResponse) GetConvertedSchema() string
- func (x *ConvertSchemaResponse) GetError() string
- func (*ConvertSchemaResponse) ProtoMessage()
- func (x *ConvertSchemaResponse) ProtoReflect() protoreflect.Message
- func (x *ConvertSchemaResponse) Reset()
- func (x *ConvertSchemaResponse) String() string
- type Empty
- type ExecuteQueryRequest
- func (*ExecuteQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteQueryRequest) GetArgs() []string
- func (x *ExecuteQueryRequest) GetSql() string
- func (*ExecuteQueryRequest) ProtoMessage()
- func (x *ExecuteQueryRequest) ProtoReflect() protoreflect.Message
- func (x *ExecuteQueryRequest) Reset()
- func (x *ExecuteQueryRequest) String() string
- type ExecuteQueryResponse
- func (*ExecuteQueryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteQueryResponse) GetDurationMicros() int64
- func (x *ExecuteQueryResponse) GetError() string
- func (*ExecuteQueryResponse) ProtoMessage()
- func (x *ExecuteQueryResponse) ProtoReflect() protoreflect.Message
- func (x *ExecuteQueryResponse) Reset()
- func (x *ExecuteQueryResponse) String() string
- type NameResponse
- type SQLTraceBenchPluginClient
- type SQLTraceBenchPluginServer
- type TranslateQueryRequest
- func (*TranslateQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TranslateQueryRequest) GetSql() string
- func (*TranslateQueryRequest) ProtoMessage()
- func (x *TranslateQueryRequest) ProtoReflect() protoreflect.Message
- func (x *TranslateQueryRequest) Reset()
- func (x *TranslateQueryRequest) String() string
- type TranslateQueryResponse
- func (*TranslateQueryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TranslateQueryResponse) GetError() string
- func (x *TranslateQueryResponse) GetTranslatedSql() string
- func (*TranslateQueryResponse) ProtoMessage()
- func (x *TranslateQueryResponse) ProtoReflect() protoreflect.Message
- func (x *TranslateQueryResponse) Reset()
- func (x *TranslateQueryResponse) String() string
- type UnimplementedSQLTraceBenchPluginServer
- func (UnimplementedSQLTraceBenchPluginServer) ConvertSchema(context.Context, *ConvertSchemaRequest) (*ConvertSchemaResponse, error)
- func (UnimplementedSQLTraceBenchPluginServer) ExecuteQuery(context.Context, *ExecuteQueryRequest) (*ExecuteQueryResponse, error)
- func (UnimplementedSQLTraceBenchPluginServer) GetBenchmarkExecutor(context.Context, *Empty) (*Empty, error)
- func (UnimplementedSQLTraceBenchPluginServer) GetName(context.Context, *Empty) (*NameResponse, error)
- func (UnimplementedSQLTraceBenchPluginServer) TranslateQuery(context.Context, *TranslateQueryRequest) (*TranslateQueryResponse, error)
- type UnsafeSQLTraceBenchPluginServer
Constants ¶
This section is empty.
Variables ¶
var File_pkg_proto_plugin_proto protoreflect.FileDescriptor
var SQLTraceBenchPlugin_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.SQLTraceBenchPlugin", HandlerType: (*SQLTraceBenchPluginServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetName", Handler: _SQLTraceBenchPlugin_GetName_Handler, }, { MethodName: "TranslateQuery", Handler: _SQLTraceBenchPlugin_TranslateQuery_Handler, }, { MethodName: "ConvertSchema", Handler: _SQLTraceBenchPlugin_ConvertSchema_Handler, }, { MethodName: "GetBenchmarkExecutor", Handler: _SQLTraceBenchPlugin_GetBenchmarkExecutor_Handler, }, { MethodName: "ExecuteQuery", Handler: _SQLTraceBenchPlugin_ExecuteQuery_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "pkg/proto/plugin.proto", }
SQLTraceBenchPlugin_ServiceDesc is the grpc.ServiceDesc for SQLTraceBenchPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSQLTraceBenchPluginServer ¶
func RegisterSQLTraceBenchPluginServer(s grpc.ServiceRegistrar, srv SQLTraceBenchPluginServer)
Types ¶
type ConvertSchemaRequest ¶
type ConvertSchemaRequest struct {
Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
// contains filtered or unexported fields
}
func (*ConvertSchemaRequest) Descriptor
deprecated
func (*ConvertSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConvertSchemaRequest.ProtoReflect.Descriptor instead.
func (*ConvertSchemaRequest) GetSchema ¶
func (x *ConvertSchemaRequest) GetSchema() string
func (*ConvertSchemaRequest) ProtoMessage ¶
func (*ConvertSchemaRequest) ProtoMessage()
func (*ConvertSchemaRequest) ProtoReflect ¶
func (x *ConvertSchemaRequest) ProtoReflect() protoreflect.Message
func (*ConvertSchemaRequest) Reset ¶
func (x *ConvertSchemaRequest) Reset()
func (*ConvertSchemaRequest) String ¶
func (x *ConvertSchemaRequest) String() string
type ConvertSchemaResponse ¶
type ConvertSchemaResponse struct {
ConvertedSchema string `protobuf:"bytes,1,opt,name=converted_schema,json=convertedSchema,proto3" json:"converted_schema,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*ConvertSchemaResponse) Descriptor
deprecated
func (*ConvertSchemaResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConvertSchemaResponse.ProtoReflect.Descriptor instead.
func (*ConvertSchemaResponse) GetConvertedSchema ¶
func (x *ConvertSchemaResponse) GetConvertedSchema() string
func (*ConvertSchemaResponse) GetError ¶
func (x *ConvertSchemaResponse) GetError() string
func (*ConvertSchemaResponse) ProtoMessage ¶
func (*ConvertSchemaResponse) ProtoMessage()
func (*ConvertSchemaResponse) ProtoReflect ¶
func (x *ConvertSchemaResponse) ProtoReflect() protoreflect.Message
func (*ConvertSchemaResponse) Reset ¶
func (x *ConvertSchemaResponse) Reset()
func (*ConvertSchemaResponse) String ¶
func (x *ConvertSchemaResponse) String() string
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type ExecuteQueryRequest ¶
type ExecuteQueryRequest struct {
Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
Args []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
// contains filtered or unexported fields
}
func (*ExecuteQueryRequest) Descriptor
deprecated
func (*ExecuteQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteQueryRequest.ProtoReflect.Descriptor instead.
func (*ExecuteQueryRequest) GetArgs ¶
func (x *ExecuteQueryRequest) GetArgs() []string
func (*ExecuteQueryRequest) GetSql ¶
func (x *ExecuteQueryRequest) GetSql() string
func (*ExecuteQueryRequest) ProtoMessage ¶
func (*ExecuteQueryRequest) ProtoMessage()
func (*ExecuteQueryRequest) ProtoReflect ¶
func (x *ExecuteQueryRequest) ProtoReflect() protoreflect.Message
func (*ExecuteQueryRequest) Reset ¶
func (x *ExecuteQueryRequest) Reset()
func (*ExecuteQueryRequest) String ¶
func (x *ExecuteQueryRequest) String() string
type ExecuteQueryResponse ¶
type ExecuteQueryResponse struct {
DurationMicros int64 `protobuf:"varint,1,opt,name=duration_micros,json=durationMicros,proto3" json:"duration_micros,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*ExecuteQueryResponse) Descriptor
deprecated
func (*ExecuteQueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteQueryResponse.ProtoReflect.Descriptor instead.
func (*ExecuteQueryResponse) GetDurationMicros ¶
func (x *ExecuteQueryResponse) GetDurationMicros() int64
func (*ExecuteQueryResponse) GetError ¶
func (x *ExecuteQueryResponse) GetError() string
func (*ExecuteQueryResponse) ProtoMessage ¶
func (*ExecuteQueryResponse) ProtoMessage()
func (*ExecuteQueryResponse) ProtoReflect ¶
func (x *ExecuteQueryResponse) ProtoReflect() protoreflect.Message
func (*ExecuteQueryResponse) Reset ¶
func (x *ExecuteQueryResponse) Reset()
func (*ExecuteQueryResponse) String ¶
func (x *ExecuteQueryResponse) String() string
type NameResponse ¶
type NameResponse struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*NameResponse) Descriptor
deprecated
func (*NameResponse) Descriptor() ([]byte, []int)
Deprecated: Use NameResponse.ProtoReflect.Descriptor instead.
func (*NameResponse) GetName ¶
func (x *NameResponse) GetName() string
func (*NameResponse) ProtoMessage ¶
func (*NameResponse) ProtoMessage()
func (*NameResponse) ProtoReflect ¶
func (x *NameResponse) ProtoReflect() protoreflect.Message
func (*NameResponse) Reset ¶
func (x *NameResponse) Reset()
func (*NameResponse) String ¶
func (x *NameResponse) String() string
type SQLTraceBenchPluginClient ¶
type SQLTraceBenchPluginClient interface {
GetName(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*NameResponse, error)
TranslateQuery(ctx context.Context, in *TranslateQueryRequest, opts ...grpc.CallOption) (*TranslateQueryResponse, error)
ConvertSchema(ctx context.Context, in *ConvertSchemaRequest, opts ...grpc.CallOption) (*ConvertSchemaResponse, error)
GetBenchmarkExecutor(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
ExecuteQuery(ctx context.Context, in *ExecuteQueryRequest, opts ...grpc.CallOption) (*ExecuteQueryResponse, error)
}
SQLTraceBenchPluginClient is the client API for SQLTraceBenchPlugin 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 NewSQLTraceBenchPluginClient ¶
func NewSQLTraceBenchPluginClient(cc grpc.ClientConnInterface) SQLTraceBenchPluginClient
type SQLTraceBenchPluginServer ¶
type SQLTraceBenchPluginServer interface {
GetName(context.Context, *Empty) (*NameResponse, error)
TranslateQuery(context.Context, *TranslateQueryRequest) (*TranslateQueryResponse, error)
ConvertSchema(context.Context, *ConvertSchemaRequest) (*ConvertSchemaResponse, error)
GetBenchmarkExecutor(context.Context, *Empty) (*Empty, error)
ExecuteQuery(context.Context, *ExecuteQueryRequest) (*ExecuteQueryResponse, error)
// contains filtered or unexported methods
}
SQLTraceBenchPluginServer is the server API for SQLTraceBenchPlugin service. All implementations must embed UnimplementedSQLTraceBenchPluginServer for forward compatibility
type TranslateQueryRequest ¶
type TranslateQueryRequest struct {
Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
// contains filtered or unexported fields
}
func (*TranslateQueryRequest) Descriptor
deprecated
func (*TranslateQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use TranslateQueryRequest.ProtoReflect.Descriptor instead.
func (*TranslateQueryRequest) GetSql ¶
func (x *TranslateQueryRequest) GetSql() string
func (*TranslateQueryRequest) ProtoMessage ¶
func (*TranslateQueryRequest) ProtoMessage()
func (*TranslateQueryRequest) ProtoReflect ¶
func (x *TranslateQueryRequest) ProtoReflect() protoreflect.Message
func (*TranslateQueryRequest) Reset ¶
func (x *TranslateQueryRequest) Reset()
func (*TranslateQueryRequest) String ¶
func (x *TranslateQueryRequest) String() string
type TranslateQueryResponse ¶
type TranslateQueryResponse struct {
TranslatedSql string `protobuf:"bytes,1,opt,name=translated_sql,json=translatedSql,proto3" json:"translated_sql,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*TranslateQueryResponse) Descriptor
deprecated
func (*TranslateQueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use TranslateQueryResponse.ProtoReflect.Descriptor instead.
func (*TranslateQueryResponse) GetError ¶
func (x *TranslateQueryResponse) GetError() string
func (*TranslateQueryResponse) GetTranslatedSql ¶
func (x *TranslateQueryResponse) GetTranslatedSql() string
func (*TranslateQueryResponse) ProtoMessage ¶
func (*TranslateQueryResponse) ProtoMessage()
func (*TranslateQueryResponse) ProtoReflect ¶
func (x *TranslateQueryResponse) ProtoReflect() protoreflect.Message
func (*TranslateQueryResponse) Reset ¶
func (x *TranslateQueryResponse) Reset()
func (*TranslateQueryResponse) String ¶
func (x *TranslateQueryResponse) String() string
type UnimplementedSQLTraceBenchPluginServer ¶
type UnimplementedSQLTraceBenchPluginServer struct {
}
UnimplementedSQLTraceBenchPluginServer must be embedded to have forward compatible implementations.
func (UnimplementedSQLTraceBenchPluginServer) ConvertSchema ¶
func (UnimplementedSQLTraceBenchPluginServer) ConvertSchema(context.Context, *ConvertSchemaRequest) (*ConvertSchemaResponse, error)
func (UnimplementedSQLTraceBenchPluginServer) ExecuteQuery ¶
func (UnimplementedSQLTraceBenchPluginServer) ExecuteQuery(context.Context, *ExecuteQueryRequest) (*ExecuteQueryResponse, error)
func (UnimplementedSQLTraceBenchPluginServer) GetBenchmarkExecutor ¶
func (UnimplementedSQLTraceBenchPluginServer) GetName ¶
func (UnimplementedSQLTraceBenchPluginServer) GetName(context.Context, *Empty) (*NameResponse, error)
func (UnimplementedSQLTraceBenchPluginServer) TranslateQuery ¶
func (UnimplementedSQLTraceBenchPluginServer) TranslateQuery(context.Context, *TranslateQueryRequest) (*TranslateQueryResponse, error)
type UnsafeSQLTraceBenchPluginServer ¶
type UnsafeSQLTraceBenchPluginServer interface {
// contains filtered or unexported methods
}
UnsafeSQLTraceBenchPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SQLTraceBenchPluginServer will result in compilation errors.