Documentation ¶
Index ¶
- Variables
- func RegisterSqliteOGServer(s grpc.ServiceRegistrar, srv SqliteOGServer)
- type ConnectionId
- type ConnectionRequest
- func (*ConnectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectionRequest) GetAggregators() []string
- func (x *ConnectionRequest) GetDbName() string
- func (x *ConnectionRequest) GetFunctions() []string
- func (*ConnectionRequest) ProtoMessage()
- func (x *ConnectionRequest) ProtoReflect() protoreflect.Message
- func (x *ConnectionRequest) Reset()
- func (x *ConnectionRequest) String() string
- type Empty
- type ExecuteOrQueryResult
- func (*ExecuteOrQueryResult) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteOrQueryResult) GetExecuteResult() *ExecuteResult
- func (x *ExecuteOrQueryResult) GetQueryResult() *QueryResult
- func (*ExecuteOrQueryResult) ProtoMessage()
- func (x *ExecuteOrQueryResult) ProtoReflect() protoreflect.Message
- func (x *ExecuteOrQueryResult) Reset()
- func (x *ExecuteOrQueryResult) String() string
- type ExecuteResult
- func (*ExecuteResult) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteResult) GetAffectedRows() int64
- func (x *ExecuteResult) GetLastInsertId() int64
- func (*ExecuteResult) ProtoMessage()
- func (x *ExecuteResult) ProtoReflect() protoreflect.Message
- func (x *ExecuteResult) Reset()
- func (x *ExecuteResult) String() string
- type InvocationResult
- func (*InvocationResult) Descriptor() ([]byte, []int)deprecated
- func (x *InvocationResult) GetInitial() bool
- func (x *InvocationResult) GetResult() []string
- func (*InvocationResult) ProtoMessage()
- func (x *InvocationResult) ProtoReflect() protoreflect.Message
- func (x *InvocationResult) Reset()
- func (x *InvocationResult) String() string
- type Invoke
- type QueryResult
- func (*QueryResult) Descriptor() ([]byte, []int)deprecated
- func (x *QueryResult) GetColumnTypes() []string
- func (x *QueryResult) GetColumns() []string
- func (x *QueryResult) GetRows() []*Row
- func (*QueryResult) ProtoMessage()
- func (x *QueryResult) ProtoReflect() protoreflect.Message
- func (x *QueryResult) Reset()
- func (x *QueryResult) String() string
- type Row
- type SqliteOGClient
- type SqliteOGServer
- type SqliteOG_CallbackClient
- type SqliteOG_CallbackServer
- type Statement
- func (*Statement) Descriptor() ([]byte, []int)deprecated
- func (x *Statement) GetCnxId() string
- func (x *Statement) GetParams() []string
- func (x *Statement) GetSql() string
- func (*Statement) ProtoMessage()
- func (x *Statement) ProtoReflect() protoreflect.Message
- func (x *Statement) Reset()
- func (x *Statement) String() string
- type UnimplementedSqliteOGServer
- func (UnimplementedSqliteOGServer) Callback(SqliteOG_CallbackServer) error
- func (UnimplementedSqliteOGServer) Close(context.Context, *ConnectionId) (*Empty, error)
- func (UnimplementedSqliteOGServer) Connection(context.Context, *ConnectionRequest) (*ConnectionId, error)
- func (UnimplementedSqliteOGServer) Execute(context.Context, *Statement) (*ExecuteResult, error)
- func (UnimplementedSqliteOGServer) ExecuteOrQuery(context.Context, *Statement) (*ExecuteOrQueryResult, error)
- func (UnimplementedSqliteOGServer) IsValid(context.Context, *ConnectionId) (*Empty, error)
- func (UnimplementedSqliteOGServer) Ping(context.Context, *Empty) (*Empty, error)
- func (UnimplementedSqliteOGServer) Query(context.Context, *Statement) (*QueryResult, error)
- func (UnimplementedSqliteOGServer) ResetSession(context.Context, *ConnectionId) (*ConnectionId, error)
- type UnsafeSqliteOGServer
Constants ¶
This section is empty.
Variables ¶
var File_proto_sqliteog_proto protoreflect.FileDescriptor
var SqliteOG_ServiceDesc = grpc.ServiceDesc{ ServiceName: "SqliteOG", HandlerType: (*SqliteOGServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Query", Handler: _SqliteOG_Query_Handler, }, { MethodName: "Execute", Handler: _SqliteOG_Execute_Handler, }, { MethodName: "ExecuteOrQuery", Handler: _SqliteOG_ExecuteOrQuery_Handler, }, { MethodName: "Connection", Handler: _SqliteOG_Connection_Handler, }, { MethodName: "Close", Handler: _SqliteOG_Close_Handler, }, { MethodName: "IsValid", Handler: _SqliteOG_IsValid_Handler, }, { MethodName: "Ping", Handler: _SqliteOG_Ping_Handler, }, { MethodName: "ResetSession", Handler: _SqliteOG_ResetSession_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Callback", Handler: _SqliteOG_Callback_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "proto/sqliteog.proto", }
SqliteOG_ServiceDesc is the grpc.ServiceDesc for SqliteOG service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSqliteOGServer ¶
func RegisterSqliteOGServer(s grpc.ServiceRegistrar, srv SqliteOGServer)
Types ¶
type ConnectionId ¶
type ConnectionId struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*ConnectionId) Descriptor
deprecated
func (*ConnectionId) Descriptor() ([]byte, []int)
Deprecated: Use ConnectionId.ProtoReflect.Descriptor instead.
func (*ConnectionId) GetId ¶
func (x *ConnectionId) GetId() string
func (*ConnectionId) ProtoMessage ¶
func (*ConnectionId) ProtoMessage()
func (*ConnectionId) ProtoReflect ¶
func (x *ConnectionId) ProtoReflect() protoreflect.Message
func (*ConnectionId) Reset ¶
func (x *ConnectionId) Reset()
func (*ConnectionId) String ¶
func (x *ConnectionId) String() string
type ConnectionRequest ¶
type ConnectionRequest struct { DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"` Functions []string `protobuf:"bytes,2,rep,name=functions,proto3" json:"functions,omitempty"` Aggregators []string `protobuf:"bytes,3,rep,name=aggregators,proto3" json:"aggregators,omitempty"` // contains filtered or unexported fields }
func (*ConnectionRequest) Descriptor
deprecated
func (*ConnectionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConnectionRequest.ProtoReflect.Descriptor instead.
func (*ConnectionRequest) GetAggregators ¶
func (x *ConnectionRequest) GetAggregators() []string
func (*ConnectionRequest) GetDbName ¶
func (x *ConnectionRequest) GetDbName() string
func (*ConnectionRequest) GetFunctions ¶
func (x *ConnectionRequest) GetFunctions() []string
func (*ConnectionRequest) ProtoMessage ¶
func (*ConnectionRequest) ProtoMessage()
func (*ConnectionRequest) ProtoReflect ¶
func (x *ConnectionRequest) ProtoReflect() protoreflect.Message
func (*ConnectionRequest) Reset ¶
func (x *ConnectionRequest) Reset()
func (*ConnectionRequest) String ¶
func (x *ConnectionRequest) 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 ExecuteOrQueryResult ¶
type ExecuteOrQueryResult struct { QueryResult *QueryResult `protobuf:"bytes,1,opt,name=query_result,json=queryResult,proto3" json:"query_result,omitempty"` ExecuteResult *ExecuteResult `protobuf:"bytes,2,opt,name=execute_result,json=executeResult,proto3" json:"execute_result,omitempty"` // contains filtered or unexported fields }
func (*ExecuteOrQueryResult) Descriptor
deprecated
func (*ExecuteOrQueryResult) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteOrQueryResult.ProtoReflect.Descriptor instead.
func (*ExecuteOrQueryResult) GetExecuteResult ¶
func (x *ExecuteOrQueryResult) GetExecuteResult() *ExecuteResult
func (*ExecuteOrQueryResult) GetQueryResult ¶
func (x *ExecuteOrQueryResult) GetQueryResult() *QueryResult
func (*ExecuteOrQueryResult) ProtoMessage ¶
func (*ExecuteOrQueryResult) ProtoMessage()
func (*ExecuteOrQueryResult) ProtoReflect ¶
func (x *ExecuteOrQueryResult) ProtoReflect() protoreflect.Message
func (*ExecuteOrQueryResult) Reset ¶
func (x *ExecuteOrQueryResult) Reset()
func (*ExecuteOrQueryResult) String ¶
func (x *ExecuteOrQueryResult) String() string
type ExecuteResult ¶
type ExecuteResult struct { LastInsertId int64 `protobuf:"varint,1,opt,name=lastInsertId,proto3" json:"lastInsertId,omitempty"` AffectedRows int64 `protobuf:"varint,2,opt,name=affectedRows,proto3" json:"affectedRows,omitempty"` // contains filtered or unexported fields }
func (*ExecuteResult) Descriptor
deprecated
func (*ExecuteResult) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteResult.ProtoReflect.Descriptor instead.
func (*ExecuteResult) GetAffectedRows ¶
func (x *ExecuteResult) GetAffectedRows() int64
func (*ExecuteResult) GetLastInsertId ¶
func (x *ExecuteResult) GetLastInsertId() int64
func (*ExecuteResult) ProtoMessage ¶
func (*ExecuteResult) ProtoMessage()
func (*ExecuteResult) ProtoReflect ¶
func (x *ExecuteResult) ProtoReflect() protoreflect.Message
func (*ExecuteResult) Reset ¶
func (x *ExecuteResult) Reset()
func (*ExecuteResult) String ¶
func (x *ExecuteResult) String() string
type InvocationResult ¶
type InvocationResult struct { Initial bool `protobuf:"varint,1,opt,name=initial,proto3" json:"initial,omitempty"` Result []string `protobuf:"bytes,2,rep,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*InvocationResult) Descriptor
deprecated
func (*InvocationResult) Descriptor() ([]byte, []int)
Deprecated: Use InvocationResult.ProtoReflect.Descriptor instead.
func (*InvocationResult) GetInitial ¶
func (x *InvocationResult) GetInitial() bool
func (*InvocationResult) GetResult ¶
func (x *InvocationResult) GetResult() []string
func (*InvocationResult) ProtoMessage ¶
func (*InvocationResult) ProtoMessage()
func (*InvocationResult) ProtoReflect ¶
func (x *InvocationResult) ProtoReflect() protoreflect.Message
func (*InvocationResult) Reset ¶
func (x *InvocationResult) Reset()
func (*InvocationResult) String ¶
func (x *InvocationResult) String() string
type Invoke ¶
type Invoke struct { FunctionName string `protobuf:"bytes,1,opt,name=functionName,proto3" json:"functionName,omitempty"` Args []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"` // contains filtered or unexported fields }
func (*Invoke) Descriptor
deprecated
func (*Invoke) GetFunctionName ¶
func (*Invoke) ProtoMessage ¶
func (*Invoke) ProtoMessage()
func (*Invoke) ProtoReflect ¶
func (x *Invoke) ProtoReflect() protoreflect.Message
type QueryResult ¶
type QueryResult struct { Columns []string `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"` ColumnTypes []string `protobuf:"bytes,2,rep,name=columnTypes,proto3" json:"columnTypes,omitempty"` Rows []*Row `protobuf:"bytes,3,rep,name=rows,proto3" json:"rows,omitempty"` // contains filtered or unexported fields }
func (*QueryResult) Descriptor
deprecated
func (*QueryResult) Descriptor() ([]byte, []int)
Deprecated: Use QueryResult.ProtoReflect.Descriptor instead.
func (*QueryResult) GetColumnTypes ¶
func (x *QueryResult) GetColumnTypes() []string
func (*QueryResult) GetColumns ¶
func (x *QueryResult) GetColumns() []string
func (*QueryResult) GetRows ¶
func (x *QueryResult) GetRows() []*Row
func (*QueryResult) ProtoMessage ¶
func (*QueryResult) ProtoMessage()
func (*QueryResult) ProtoReflect ¶
func (x *QueryResult) ProtoReflect() protoreflect.Message
func (*QueryResult) Reset ¶
func (x *QueryResult) Reset()
func (*QueryResult) String ¶
func (x *QueryResult) String() string
type Row ¶
type Row struct { Fields []string `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"` // contains filtered or unexported fields }
func (*Row) Descriptor
deprecated
func (*Row) ProtoMessage ¶
func (*Row) ProtoMessage()
func (*Row) ProtoReflect ¶
func (x *Row) ProtoReflect() protoreflect.Message
type SqliteOGClient ¶
type SqliteOGClient interface { Query(ctx context.Context, in *Statement, opts ...grpc.CallOption) (*QueryResult, error) Execute(ctx context.Context, in *Statement, opts ...grpc.CallOption) (*ExecuteResult, error) ExecuteOrQuery(ctx context.Context, in *Statement, opts ...grpc.CallOption) (*ExecuteOrQueryResult, error) Callback(ctx context.Context, opts ...grpc.CallOption) (SqliteOG_CallbackClient, error) Connection(ctx context.Context, in *ConnectionRequest, opts ...grpc.CallOption) (*ConnectionId, error) Close(ctx context.Context, in *ConnectionId, opts ...grpc.CallOption) (*Empty, error) IsValid(ctx context.Context, in *ConnectionId, opts ...grpc.CallOption) (*Empty, error) Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) ResetSession(ctx context.Context, in *ConnectionId, opts ...grpc.CallOption) (*ConnectionId, error) }
SqliteOGClient is the client API for SqliteOG 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 NewSqliteOGClient ¶
func NewSqliteOGClient(cc grpc.ClientConnInterface) SqliteOGClient
type SqliteOGServer ¶
type SqliteOGServer interface { Query(context.Context, *Statement) (*QueryResult, error) Execute(context.Context, *Statement) (*ExecuteResult, error) ExecuteOrQuery(context.Context, *Statement) (*ExecuteOrQueryResult, error) Callback(SqliteOG_CallbackServer) error Connection(context.Context, *ConnectionRequest) (*ConnectionId, error) Close(context.Context, *ConnectionId) (*Empty, error) IsValid(context.Context, *ConnectionId) (*Empty, error) Ping(context.Context, *Empty) (*Empty, error) ResetSession(context.Context, *ConnectionId) (*ConnectionId, error) // contains filtered or unexported methods }
SqliteOGServer is the server API for SqliteOG service. All implementations must embed UnimplementedSqliteOGServer for forward compatibility
type SqliteOG_CallbackClient ¶
type SqliteOG_CallbackClient interface { Send(*InvocationResult) error Recv() (*Invoke, error) grpc.ClientStream }
type SqliteOG_CallbackServer ¶
type SqliteOG_CallbackServer interface { Send(*Invoke) error Recv() (*InvocationResult, error) grpc.ServerStream }
type Statement ¶
type Statement struct { Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"` Params []string `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty"` CnxId string `protobuf:"bytes,3,opt,name=cnx_id,json=cnxId,proto3" json:"cnx_id,omitempty"` // contains filtered or unexported fields }
func (*Statement) Descriptor
deprecated
func (*Statement) ProtoMessage ¶
func (*Statement) ProtoMessage()
func (*Statement) ProtoReflect ¶
func (x *Statement) ProtoReflect() protoreflect.Message
type UnimplementedSqliteOGServer ¶
type UnimplementedSqliteOGServer struct { }
UnimplementedSqliteOGServer must be embedded to have forward compatible implementations.
func (UnimplementedSqliteOGServer) Callback ¶
func (UnimplementedSqliteOGServer) Callback(SqliteOG_CallbackServer) error
func (UnimplementedSqliteOGServer) Close ¶
func (UnimplementedSqliteOGServer) Close(context.Context, *ConnectionId) (*Empty, error)
func (UnimplementedSqliteOGServer) Connection ¶
func (UnimplementedSqliteOGServer) Connection(context.Context, *ConnectionRequest) (*ConnectionId, error)
func (UnimplementedSqliteOGServer) Execute ¶
func (UnimplementedSqliteOGServer) Execute(context.Context, *Statement) (*ExecuteResult, error)
func (UnimplementedSqliteOGServer) ExecuteOrQuery ¶
func (UnimplementedSqliteOGServer) ExecuteOrQuery(context.Context, *Statement) (*ExecuteOrQueryResult, error)
func (UnimplementedSqliteOGServer) IsValid ¶
func (UnimplementedSqliteOGServer) IsValid(context.Context, *ConnectionId) (*Empty, error)
func (UnimplementedSqliteOGServer) Query ¶
func (UnimplementedSqliteOGServer) Query(context.Context, *Statement) (*QueryResult, error)
func (UnimplementedSqliteOGServer) ResetSession ¶
func (UnimplementedSqliteOGServer) ResetSession(context.Context, *ConnectionId) (*ConnectionId, error)
type UnsafeSqliteOGServer ¶
type UnsafeSqliteOGServer interface {
// contains filtered or unexported methods
}
UnsafeSqliteOGServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SqliteOGServer will result in compilation errors.