sqlite_og

package
v0.0.0-...-f25badd Latest Latest
Warning

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

 Go to latest Published: Dec 9, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_sqliteog_proto protoreflect.FileDescriptor
View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Invoke.ProtoReflect.Descriptor instead.

func (*Invoke) GetArgs 

func (x *Invoke) GetArgs() []string

func (*Invoke) GetFunctionName 

func (x *Invoke) GetFunctionName() string

func (*Invoke) ProtoMessage 

func (*Invoke) ProtoMessage()

func (*Invoke) ProtoReflect 

func (x *Invoke) ProtoReflect() protoreflect.Message

func (*Invoke) Reset 

func (x *Invoke) Reset()

func (*Invoke) String 

func (x *Invoke) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Row.ProtoReflect.Descriptor instead.

func (*Row) GetFields 

func (x *Row) GetFields() []string

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) ProtoReflect 

func (x *Row) ProtoReflect() protoreflect.Message

func (*Row) Reset 

func (x *Row) Reset()

func (*Row) String 

func (x *Row) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Statement.ProtoReflect.Descriptor instead.

func (*Statement) GetCnxId 

func (x *Statement) GetCnxId() string

func (*Statement) GetParams 

func (x *Statement) GetParams() []string

func (*Statement) GetSql 

func (x *Statement) GetSql() string

func (*Statement) ProtoMessage 

func (*Statement) ProtoMessage()

func (*Statement) ProtoReflect 

func (x *Statement) ProtoReflect() protoreflect.Message

func (*Statement) Reset 

func (x *Statement) Reset()

func (*Statement) String 

func (x *Statement) String() string

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) Ping 

func (UnimplementedSqliteOGServer) Ping(context.Context, *Empty) (*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.

Source Files

View all Source files

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.