s4wave_sql_query

package
v0.56.0 Latest Latest
Warning

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

 Go to latest Published: Jul 11, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCSqlQueryResourceServiceServiceID = "s4wave.sql.query.SqlQueryResourceService"
View Source 
const SqlQueryBlockTypeID = "github.com/s4wave/spacewave/sdk/sql/query.Query"

SqlQueryBlockTypeID is the block type id for SQL query roots.

View Source 
const SqlQueryTypeID = "sql/query"

SqlQueryTypeID is the world ObjectType id for SQL queries.

Variables

View Source 
var SqlQueryBlockType = blocktype.NewBlockType(
	SqlQueryBlockTypeID,
	func() *Query { return &Query{} },
)

SqlQueryBlockType constructs SQL query root blocks for typed cursor writes.

Functions

func NewQueryBlock 

func NewQueryBlock() block.Block

NewQueryBlock constructs a SQL query block.

func NewSRPCSqlQueryResourceServiceHandler 

func NewSRPCSqlQueryResourceServiceHandler(impl SRPCSqlQueryResourceServiceServer, serviceID string) srpc.Handler

NewSRPCSqlQueryResourceServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: s4wave.sql.query.SqlQueryResourceService

func SRPCRegisterSqlQueryResourceService 

func SRPCRegisterSqlQueryResourceService(mux srpc.Mux, impl SRPCSqlQueryResourceServiceServer) error

SRPCRegisterSqlQueryResourceService registers the implementation with the mux. Uses the default serviceID: s4wave.sql.query.SqlQueryResourceService

func SyncTargetDbQuad 

func SyncTargetDbQuad(ctx context.Context, ws world.WorldState, objectKey string) error

SyncTargetDbQuad replaces the query's target database graph link.

func WriteQueryRootRef 

func WriteQueryRootRef(ctx context.Context, ws world.WorldState, query *Query) (*bucket.ObjectRef, error)

WriteQueryRootRef writes a SQL query root block and returns its ref.

Types

type GetQueryTextRequest 

type GetQueryTextRequest struct {
	// contains filtered or unexported fields
}

GetQueryTextRequest is a request for query text.

func (*GetQueryTextRequest) CloneMessageVT 

func (m *GetQueryTextRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetQueryTextRequest) CloneVT 

func (m *GetQueryTextRequest) CloneVT() *GetQueryTextRequest

func (*GetQueryTextRequest) EqualMessageVT 

func (this *GetQueryTextRequest) EqualMessageVT(thatMsg any) bool

func (*GetQueryTextRequest) EqualVT 

func (this *GetQueryTextRequest) EqualVT(that *GetQueryTextRequest) bool

func (*GetQueryTextRequest) MarshalJSON 

func (x *GetQueryTextRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetQueryTextRequest to JSON.

func (*GetQueryTextRequest) MarshalProtoJSON 

func (x *GetQueryTextRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetQueryTextRequest message to JSON.

func (*GetQueryTextRequest) MarshalProtoText 

func (x *GetQueryTextRequest) MarshalProtoText() string

func (*GetQueryTextRequest) MarshalToSizedBufferVT 

func (m *GetQueryTextRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetQueryTextRequest) MarshalToVT 

func (m *GetQueryTextRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetQueryTextRequest) MarshalVT 

func (m *GetQueryTextRequest) MarshalVT() (dAtA []byte, err error)

func (*GetQueryTextRequest) ProtoMessage 

func (*GetQueryTextRequest) ProtoMessage()

func (*GetQueryTextRequest) Reset 

func (x *GetQueryTextRequest) Reset()

func (*GetQueryTextRequest) SizeVT 

func (m *GetQueryTextRequest) SizeVT() (n int)

func (*GetQueryTextRequest) String 

func (x *GetQueryTextRequest) String() string

func (*GetQueryTextRequest) UnmarshalJSON 

func (x *GetQueryTextRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetQueryTextRequest from JSON.

func (*GetQueryTextRequest) UnmarshalProtoJSON 

func (x *GetQueryTextRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetQueryTextRequest message from JSON.

func (*GetQueryTextRequest) UnmarshalVT 

func (m *GetQueryTextRequest) UnmarshalVT(dAtA []byte) error

type GetQueryTextResponse 

type GetQueryTextResponse struct {

	// SqlText is the SQL text executed by Run.
	SqlText string `protobuf:"bytes,1,opt,name=sql_text,json=sqlText,proto3" json:"sqlText,omitempty"`
	// DialectHint records the SQL dialect expected by the author.
	DialectHint string `protobuf:"bytes,2,opt,name=dialect_hint,json=dialectHint,proto3" json:"dialectHint,omitempty"`
	// TargetDbObjectKey is the sql/db object this query runs against.
	TargetDbObjectKey string `protobuf:"bytes,3,opt,name=target_db_object_key,json=targetDbObjectKey,proto3" json:"targetDbObjectKey,omitempty"`
	// Parameters are positional SQL bind arguments.
	Parameters []*sql.SqlValue `protobuf:"bytes,4,rep,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

GetQueryTextResponse contains query text, target metadata, and bind arguments.

func (*GetQueryTextResponse) CloneMessageVT 

func (m *GetQueryTextResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetQueryTextResponse) CloneVT 

func (m *GetQueryTextResponse) CloneVT() *GetQueryTextResponse

func (*GetQueryTextResponse) EqualMessageVT 

func (this *GetQueryTextResponse) EqualMessageVT(thatMsg any) bool

func (*GetQueryTextResponse) EqualVT 

func (this *GetQueryTextResponse) EqualVT(that *GetQueryTextResponse) bool

func (*GetQueryTextResponse) GetDialectHint 

func (x *GetQueryTextResponse) GetDialectHint() string

func (*GetQueryTextResponse) GetParameters added in v0.54.0 

func (x *GetQueryTextResponse) GetParameters() []*sql.SqlValue

func (*GetQueryTextResponse) GetSqlText 

func (x *GetQueryTextResponse) GetSqlText() string

func (*GetQueryTextResponse) GetTargetDbObjectKey 

func (x *GetQueryTextResponse) GetTargetDbObjectKey() string

func (*GetQueryTextResponse) MarshalJSON 

func (x *GetQueryTextResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetQueryTextResponse to JSON.

func (*GetQueryTextResponse) MarshalProtoJSON 

func (x *GetQueryTextResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetQueryTextResponse message to JSON.

func (*GetQueryTextResponse) MarshalProtoText 

func (x *GetQueryTextResponse) MarshalProtoText() string

func (*GetQueryTextResponse) MarshalToSizedBufferVT 

func (m *GetQueryTextResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetQueryTextResponse) MarshalToVT 

func (m *GetQueryTextResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetQueryTextResponse) MarshalVT 

func (m *GetQueryTextResponse) MarshalVT() (dAtA []byte, err error)

func (*GetQueryTextResponse) ProtoMessage 

func (*GetQueryTextResponse) ProtoMessage()

func (*GetQueryTextResponse) Reset 

func (x *GetQueryTextResponse) Reset()

func (*GetQueryTextResponse) SizeVT 

func (m *GetQueryTextResponse) SizeVT() (n int)

func (*GetQueryTextResponse) String 

func (x *GetQueryTextResponse) String() string

func (*GetQueryTextResponse) UnmarshalJSON 

func (x *GetQueryTextResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetQueryTextResponse from JSON.

func (*GetQueryTextResponse) UnmarshalProtoJSON 

func (x *GetQueryTextResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetQueryTextResponse message from JSON.

func (*GetQueryTextResponse) UnmarshalVT 

func (m *GetQueryTextResponse) UnmarshalVT(dAtA []byte) error

type Query 

type Query struct {

	// SqlText is the SQL text executed by Run.
	SqlText string `protobuf:"bytes,1,opt,name=sql_text,json=sqlText,proto3" json:"sqlText,omitempty"`
	// Parameters are positional SQL bind arguments.
	Parameters []*sql.SqlValue `protobuf:"bytes,2,rep,name=parameters,proto3" json:"parameters,omitempty"`
	// DialectHint records the SQL dialect expected by the author.
	DialectHint string `protobuf:"bytes,3,opt,name=dialect_hint,json=dialectHint,proto3" json:"dialectHint,omitempty"`
	// TargetDbObjectKey is the sql/db object this query runs against.
	TargetDbObjectKey string `protobuf:"bytes,4,opt,name=target_db_object_key,json=targetDbObjectKey,proto3" json:"targetDbObjectKey,omitempty"`
	// contains filtered or unexported fields
}

Query is a standalone SQL query world object.

func ReadQueryObjectRoot 

func ReadQueryObjectRoot(ctx context.Context, obj world.ObjectState) (*Query, error)

ReadQueryObjectRoot reads a SQL query root from an object state.

func ReadQueryRoot 

func ReadQueryRoot(ctx context.Context, ws world.WorldState, objectKey string) (*Query, error)

ReadQueryRoot reads a SQL query object's root.

func (*Query) CloneMessageVT 

func (m *Query) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*Query) CloneVT 

func (m *Query) CloneVT() *Query

func (*Query) EqualMessageVT 

func (this *Query) EqualMessageVT(thatMsg any) bool

func (*Query) EqualVT 

func (this *Query) EqualVT(that *Query) bool

func (*Query) GetDialectHint 

func (x *Query) GetDialectHint() string

func (*Query) GetParameters 

func (x *Query) GetParameters() []*sql.SqlValue

func (*Query) GetSqlText 

func (x *Query) GetSqlText() string

func (*Query) GetTargetDbObjectKey 

func (x *Query) GetTargetDbObjectKey() string

func (*Query) MarshalBlock 

func (q *Query) MarshalBlock() ([]byte, error)

MarshalBlock marshals the SQL query root.

func (*Query) MarshalJSON 

func (x *Query) MarshalJSON() ([]byte, error)

MarshalJSON marshals the Query to JSON.

func (*Query) MarshalProtoJSON 

func (x *Query) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the Query message to JSON.

func (*Query) MarshalProtoText 

func (x *Query) MarshalProtoText() string

func (*Query) MarshalToSizedBufferVT 

func (m *Query) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Query) MarshalToVT 

func (m *Query) MarshalToVT(dAtA []byte) (int, error)

func (*Query) MarshalVT 

func (m *Query) MarshalVT() (dAtA []byte, err error)

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (x *Query) Reset()

func (*Query) SizeVT 

func (m *Query) SizeVT() (n int)

func (*Query) String 

func (x *Query) String() string

func (*Query) UnmarshalBlock 

func (q *Query) UnmarshalBlock(data []byte) error

UnmarshalBlock unmarshals the SQL query root.

func (*Query) UnmarshalJSON 

func (x *Query) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the Query from JSON.

func (*Query) UnmarshalProtoJSON 

func (x *Query) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the Query message from JSON.

func (*Query) UnmarshalVT 

func (m *Query) UnmarshalVT(dAtA []byte) error

func (*Query) Validate 

func (q *Query) Validate() error

Validate performs cursory checks on the SQL query root.

type RunQueryRequest 

type RunQueryRequest struct {

	// MaxRows limits rows persisted in the result. Zero uses the default.
	MaxRows uint32 `protobuf:"varint,1,opt,name=max_rows,json=maxRows,proto3" json:"maxRows,omitempty"`
	// contains filtered or unexported fields
}

RunQueryRequest executes the query.

func (*RunQueryRequest) CloneMessageVT 

func (m *RunQueryRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*RunQueryRequest) CloneVT 

func (m *RunQueryRequest) CloneVT() *RunQueryRequest

func (*RunQueryRequest) EqualMessageVT 

func (this *RunQueryRequest) EqualMessageVT(thatMsg any) bool

func (*RunQueryRequest) EqualVT 

func (this *RunQueryRequest) EqualVT(that *RunQueryRequest) bool

func (*RunQueryRequest) GetMaxRows 

func (x *RunQueryRequest) GetMaxRows() uint32

func (*RunQueryRequest) MarshalJSON 

func (x *RunQueryRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the RunQueryRequest to JSON.

func (*RunQueryRequest) MarshalProtoJSON 

func (x *RunQueryRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the RunQueryRequest message to JSON.

func (*RunQueryRequest) MarshalProtoText 

func (x *RunQueryRequest) MarshalProtoText() string

func (*RunQueryRequest) MarshalToSizedBufferVT 

func (m *RunQueryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RunQueryRequest) MarshalToVT 

func (m *RunQueryRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RunQueryRequest) MarshalVT 

func (m *RunQueryRequest) MarshalVT() (dAtA []byte, err error)

func (*RunQueryRequest) ProtoMessage 

func (*RunQueryRequest) ProtoMessage()

func (*RunQueryRequest) Reset 

func (x *RunQueryRequest) Reset()

func (*RunQueryRequest) SizeVT 

func (m *RunQueryRequest) SizeVT() (n int)

func (*RunQueryRequest) String 

func (x *RunQueryRequest) String() string

func (*RunQueryRequest) UnmarshalJSON 

func (x *RunQueryRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the RunQueryRequest from JSON.

func (*RunQueryRequest) UnmarshalProtoJSON 

func (x *RunQueryRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the RunQueryRequest message from JSON.

func (*RunQueryRequest) UnmarshalVT 

func (m *RunQueryRequest) UnmarshalVT(dAtA []byte) error

type RunQueryResponse 

type RunQueryResponse struct {

	// ResultObjectKey is the new sql/query-result world object key.
	ResultObjectKey string `protobuf:"bytes,1,opt,name=result_object_key,json=resultObjectKey,proto3" json:"resultObjectKey,omitempty"`
	// Error is set when SQL execution failed but a result object was created.
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

RunQueryResponse identifies the created result object.

func (*RunQueryResponse) CloneMessageVT 

func (m *RunQueryResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*RunQueryResponse) CloneVT 

func (m *RunQueryResponse) CloneVT() *RunQueryResponse

func (*RunQueryResponse) EqualMessageVT 

func (this *RunQueryResponse) EqualMessageVT(thatMsg any) bool

func (*RunQueryResponse) EqualVT 

func (this *RunQueryResponse) EqualVT(that *RunQueryResponse) bool

func (*RunQueryResponse) GetError 

func (x *RunQueryResponse) GetError() string

func (*RunQueryResponse) GetResultObjectKey 

func (x *RunQueryResponse) GetResultObjectKey() string

func (*RunQueryResponse) MarshalJSON 

func (x *RunQueryResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the RunQueryResponse to JSON.

func (*RunQueryResponse) MarshalProtoJSON 

func (x *RunQueryResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the RunQueryResponse message to JSON.

func (*RunQueryResponse) MarshalProtoText 

func (x *RunQueryResponse) MarshalProtoText() string

func (*RunQueryResponse) MarshalToSizedBufferVT 

func (m *RunQueryResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RunQueryResponse) MarshalToVT 

func (m *RunQueryResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RunQueryResponse) MarshalVT 

func (m *RunQueryResponse) MarshalVT() (dAtA []byte, err error)

func (*RunQueryResponse) ProtoMessage 

func (*RunQueryResponse) ProtoMessage()

func (*RunQueryResponse) Reset 

func (x *RunQueryResponse) Reset()

func (*RunQueryResponse) SizeVT 

func (m *RunQueryResponse) SizeVT() (n int)

func (*RunQueryResponse) String 

func (x *RunQueryResponse) String() string

func (*RunQueryResponse) UnmarshalJSON 

func (x *RunQueryResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the RunQueryResponse from JSON.

func (*RunQueryResponse) UnmarshalProtoJSON 

func (x *RunQueryResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the RunQueryResponse message from JSON.

func (*RunQueryResponse) UnmarshalVT 

func (m *RunQueryResponse) UnmarshalVT(dAtA []byte) error

type SRPCSqlQueryResourceServiceClient 

type SRPCSqlQueryResourceServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	// GetQueryText returns the query text and target metadata.
	GetQueryText(ctx context.Context, in *GetQueryTextRequest) (*GetQueryTextResponse, error)
	// SetQueryText updates the query text and target metadata.
	SetQueryText(ctx context.Context, in *SetQueryTextRequest) (*SetQueryTextResponse, error)
	// SetParameters updates the positional bind arguments.
	SetParameters(ctx context.Context, in *SetParametersRequest) (*SetParametersResponse, error)
	// Run executes the query and creates a query result object.
	Run(ctx context.Context, in *RunQueryRequest) (*RunQueryResponse, error)
}

func NewSRPCSqlQueryResourceServiceClient 

func NewSRPCSqlQueryResourceServiceClient(cc srpc.Client) SRPCSqlQueryResourceServiceClient

func NewSRPCSqlQueryResourceServiceClientWithServiceID 

func NewSRPCSqlQueryResourceServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCSqlQueryResourceServiceClient

type SRPCSqlQueryResourceServiceHandler 

type SRPCSqlQueryResourceServiceHandler struct {
	// contains filtered or unexported fields
}

func (SRPCSqlQueryResourceServiceHandler) GetMethodIDs 

func (SRPCSqlQueryResourceServiceHandler) GetMethodIDs() []string

func (*SRPCSqlQueryResourceServiceHandler) GetServiceID 

func (d *SRPCSqlQueryResourceServiceHandler) GetServiceID() string

func (*SRPCSqlQueryResourceServiceHandler) InvokeMethod 

func (d *SRPCSqlQueryResourceServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCSqlQueryResourceServiceHandler) InvokeMethod_GetQueryText 

func (SRPCSqlQueryResourceServiceHandler) InvokeMethod_GetQueryText(impl SRPCSqlQueryResourceServiceServer, strm srpc.Stream) error

func (SRPCSqlQueryResourceServiceHandler) InvokeMethod_Run 

func (SRPCSqlQueryResourceServiceHandler) InvokeMethod_Run(impl SRPCSqlQueryResourceServiceServer, strm srpc.Stream) error

func (SRPCSqlQueryResourceServiceHandler) InvokeMethod_SetParameters 

func (SRPCSqlQueryResourceServiceHandler) InvokeMethod_SetParameters(impl SRPCSqlQueryResourceServiceServer, strm srpc.Stream) error

func (SRPCSqlQueryResourceServiceHandler) InvokeMethod_SetQueryText 

func (SRPCSqlQueryResourceServiceHandler) InvokeMethod_SetQueryText(impl SRPCSqlQueryResourceServiceServer, strm srpc.Stream) error

type SRPCSqlQueryResourceServiceServer 

type SRPCSqlQueryResourceServiceServer interface {
	// GetQueryText returns the query text and target metadata.
	GetQueryText(context.Context, *GetQueryTextRequest) (*GetQueryTextResponse, error)
	// SetQueryText updates the query text and target metadata.
	SetQueryText(context.Context, *SetQueryTextRequest) (*SetQueryTextResponse, error)
	// SetParameters updates the positional bind arguments.
	SetParameters(context.Context, *SetParametersRequest) (*SetParametersResponse, error)
	// Run executes the query and creates a query result object.
	Run(context.Context, *RunQueryRequest) (*RunQueryResponse, error)
}

type SRPCSqlQueryResourceService_GetQueryTextStream 

type SRPCSqlQueryResourceService_GetQueryTextStream interface {
	srpc.Stream
}

type SRPCSqlQueryResourceService_RunStream 

type SRPCSqlQueryResourceService_RunStream interface {
	srpc.Stream
}

type SRPCSqlQueryResourceService_SetParametersStream 

type SRPCSqlQueryResourceService_SetParametersStream interface {
	srpc.Stream
}

type SRPCSqlQueryResourceService_SetQueryTextStream 

type SRPCSqlQueryResourceService_SetQueryTextStream interface {
	srpc.Stream
}

type SetParametersRequest 

type SetParametersRequest struct {

	// Parameters are positional SQL bind arguments.
	Parameters []*sql.SqlValue `protobuf:"bytes,1,rep,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

SetParametersRequest updates positional bind arguments.

func (*SetParametersRequest) CloneMessageVT 

func (m *SetParametersRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SetParametersRequest) CloneVT 

func (m *SetParametersRequest) CloneVT() *SetParametersRequest

func (*SetParametersRequest) EqualMessageVT 

func (this *SetParametersRequest) EqualMessageVT(thatMsg any) bool

func (*SetParametersRequest) EqualVT 

func (this *SetParametersRequest) EqualVT(that *SetParametersRequest) bool

func (*SetParametersRequest) GetParameters 

func (x *SetParametersRequest) GetParameters() []*sql.SqlValue

func (*SetParametersRequest) MarshalJSON 

func (x *SetParametersRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SetParametersRequest to JSON.

func (*SetParametersRequest) MarshalProtoJSON 

func (x *SetParametersRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SetParametersRequest message to JSON.

func (*SetParametersRequest) MarshalProtoText 

func (x *SetParametersRequest) MarshalProtoText() string

func (*SetParametersRequest) MarshalToSizedBufferVT 

func (m *SetParametersRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetParametersRequest) MarshalToVT 

func (m *SetParametersRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SetParametersRequest) MarshalVT 

func (m *SetParametersRequest) MarshalVT() (dAtA []byte, err error)

func (*SetParametersRequest) ProtoMessage 

func (*SetParametersRequest) ProtoMessage()

func (*SetParametersRequest) Reset 

func (x *SetParametersRequest) Reset()

func (*SetParametersRequest) SizeVT 

func (m *SetParametersRequest) SizeVT() (n int)

func (*SetParametersRequest) String 

func (x *SetParametersRequest) String() string

func (*SetParametersRequest) UnmarshalJSON 

func (x *SetParametersRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SetParametersRequest from JSON.

func (*SetParametersRequest) UnmarshalProtoJSON 

func (x *SetParametersRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SetParametersRequest message from JSON.

func (*SetParametersRequest) UnmarshalVT 

func (m *SetParametersRequest) UnmarshalVT(dAtA []byte) error

type SetParametersResponse 

type SetParametersResponse struct {
	// contains filtered or unexported fields
}

SetParametersResponse is returned after updating parameters.

func (*SetParametersResponse) CloneMessageVT 

func (m *SetParametersResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SetParametersResponse) CloneVT 

func (m *SetParametersResponse) CloneVT() *SetParametersResponse

func (*SetParametersResponse) EqualMessageVT 

func (this *SetParametersResponse) EqualMessageVT(thatMsg any) bool

func (*SetParametersResponse) EqualVT 

func (this *SetParametersResponse) EqualVT(that *SetParametersResponse) bool

func (*SetParametersResponse) MarshalJSON 

func (x *SetParametersResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SetParametersResponse to JSON.

func (*SetParametersResponse) MarshalProtoJSON 

func (x *SetParametersResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SetParametersResponse message to JSON.

func (*SetParametersResponse) MarshalProtoText 

func (x *SetParametersResponse) MarshalProtoText() string

func (*SetParametersResponse) MarshalToSizedBufferVT 

func (m *SetParametersResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetParametersResponse) MarshalToVT 

func (m *SetParametersResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SetParametersResponse) MarshalVT 

func (m *SetParametersResponse) MarshalVT() (dAtA []byte, err error)

func (*SetParametersResponse) ProtoMessage 

func (*SetParametersResponse) ProtoMessage()

func (*SetParametersResponse) Reset 

func (x *SetParametersResponse) Reset()

func (*SetParametersResponse) SizeVT 

func (m *SetParametersResponse) SizeVT() (n int)

func (*SetParametersResponse) String 

func (x *SetParametersResponse) String() string

func (*SetParametersResponse) UnmarshalJSON 

func (x *SetParametersResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SetParametersResponse from JSON.

func (*SetParametersResponse) UnmarshalProtoJSON 

func (x *SetParametersResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SetParametersResponse message from JSON.

func (*SetParametersResponse) UnmarshalVT 

func (m *SetParametersResponse) UnmarshalVT(dAtA []byte) error

type SetQueryTextRequest 

type SetQueryTextRequest struct {

	// SqlText is the SQL text executed by Run.
	SqlText string `protobuf:"bytes,1,opt,name=sql_text,json=sqlText,proto3" json:"sqlText,omitempty"`
	// DialectHint records the SQL dialect expected by the author.
	DialectHint string `protobuf:"bytes,2,opt,name=dialect_hint,json=dialectHint,proto3" json:"dialectHint,omitempty"`
	// TargetDbObjectKey is the sql/db object this query runs against.
	TargetDbObjectKey string `protobuf:"bytes,3,opt,name=target_db_object_key,json=targetDbObjectKey,proto3" json:"targetDbObjectKey,omitempty"`
	// contains filtered or unexported fields
}

SetQueryTextRequest updates query text and target metadata.

func (*SetQueryTextRequest) CloneMessageVT 

func (m *SetQueryTextRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SetQueryTextRequest) CloneVT 

func (m *SetQueryTextRequest) CloneVT() *SetQueryTextRequest

func (*SetQueryTextRequest) EqualMessageVT 

func (this *SetQueryTextRequest) EqualMessageVT(thatMsg any) bool

func (*SetQueryTextRequest) EqualVT 

func (this *SetQueryTextRequest) EqualVT(that *SetQueryTextRequest) bool

func (*SetQueryTextRequest) GetDialectHint 

func (x *SetQueryTextRequest) GetDialectHint() string

func (*SetQueryTextRequest) GetSqlText 

func (x *SetQueryTextRequest) GetSqlText() string

func (*SetQueryTextRequest) GetTargetDbObjectKey 

func (x *SetQueryTextRequest) GetTargetDbObjectKey() string

func (*SetQueryTextRequest) MarshalJSON 

func (x *SetQueryTextRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SetQueryTextRequest to JSON.

func (*SetQueryTextRequest) MarshalProtoJSON 

func (x *SetQueryTextRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SetQueryTextRequest message to JSON.

func (*SetQueryTextRequest) MarshalProtoText 

func (x *SetQueryTextRequest) MarshalProtoText() string

func (*SetQueryTextRequest) MarshalToSizedBufferVT 

func (m *SetQueryTextRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetQueryTextRequest) MarshalToVT 

func (m *SetQueryTextRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SetQueryTextRequest) MarshalVT 

func (m *SetQueryTextRequest) MarshalVT() (dAtA []byte, err error)

func (*SetQueryTextRequest) ProtoMessage 

func (*SetQueryTextRequest) ProtoMessage()

func (*SetQueryTextRequest) Reset 

func (x *SetQueryTextRequest) Reset()

func (*SetQueryTextRequest) SizeVT 

func (m *SetQueryTextRequest) SizeVT() (n int)

func (*SetQueryTextRequest) String 

func (x *SetQueryTextRequest) String() string

func (*SetQueryTextRequest) UnmarshalJSON 

func (x *SetQueryTextRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SetQueryTextRequest from JSON.

func (*SetQueryTextRequest) UnmarshalProtoJSON 

func (x *SetQueryTextRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SetQueryTextRequest message from JSON.

func (*SetQueryTextRequest) UnmarshalVT 

func (m *SetQueryTextRequest) UnmarshalVT(dAtA []byte) error

type SetQueryTextResponse 

type SetQueryTextResponse struct {
	// contains filtered or unexported fields
}

SetQueryTextResponse is returned after updating the query text.

func (*SetQueryTextResponse) CloneMessageVT 

func (m *SetQueryTextResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SetQueryTextResponse) CloneVT 

func (m *SetQueryTextResponse) CloneVT() *SetQueryTextResponse

func (*SetQueryTextResponse) EqualMessageVT 

func (this *SetQueryTextResponse) EqualMessageVT(thatMsg any) bool

func (*SetQueryTextResponse) EqualVT 

func (this *SetQueryTextResponse) EqualVT(that *SetQueryTextResponse) bool

func (*SetQueryTextResponse) MarshalJSON 

func (x *SetQueryTextResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SetQueryTextResponse to JSON.

func (*SetQueryTextResponse) MarshalProtoJSON 

func (x *SetQueryTextResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SetQueryTextResponse message to JSON.

func (*SetQueryTextResponse) MarshalProtoText 

func (x *SetQueryTextResponse) MarshalProtoText() string

func (*SetQueryTextResponse) MarshalToSizedBufferVT 

func (m *SetQueryTextResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetQueryTextResponse) MarshalToVT 

func (m *SetQueryTextResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SetQueryTextResponse) MarshalVT 

func (m *SetQueryTextResponse) MarshalVT() (dAtA []byte, err error)

func (*SetQueryTextResponse) ProtoMessage 

func (*SetQueryTextResponse) ProtoMessage()

func (*SetQueryTextResponse) Reset 

func (x *SetQueryTextResponse) Reset()

func (*SetQueryTextResponse) SizeVT 

func (m *SetQueryTextResponse) SizeVT() (n int)

func (*SetQueryTextResponse) String 

func (x *SetQueryTextResponse) String() string

func (*SetQueryTextResponse) UnmarshalJSON 

func (x *SetQueryTextResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SetQueryTextResponse from JSON.

func (*SetQueryTextResponse) UnmarshalProtoJSON 

func (x *SetQueryTextResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SetQueryTextResponse message from JSON.

func (*SetQueryTextResponse) UnmarshalVT 

func (m *SetQueryTextResponse) UnmarshalVT(dAtA []byte) error

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.