s4wave_sql_table_view

package
v0.54.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const SRPCSqlTableViewResourceServiceServiceID = "s4wave.sql.table_view.SqlTableViewResourceService"
View Source 
const SqlTableViewTypeID = "sql/table-view"

SqlTableViewTypeID is the world ObjectType id for SQL table views.

Variables

This section is empty.

Functions

func NewSRPCSqlTableViewResourceServiceHandler 

func NewSRPCSqlTableViewResourceServiceHandler(impl SRPCSqlTableViewResourceServiceServer, serviceID string) srpc.Handler

NewSRPCSqlTableViewResourceServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: s4wave.sql.table_view.SqlTableViewResourceService

func NewTableViewBlock 

func NewTableViewBlock() block.Block

NewTableViewBlock constructs a SQL table view block.

func SRPCRegisterSqlTableViewResourceService 

func SRPCRegisterSqlTableViewResourceService(mux srpc.Mux, impl SRPCSqlTableViewResourceServiceServer) error

SRPCRegisterSqlTableViewResourceService registers the implementation with the mux. Uses the default serviceID: s4wave.sql.table_view.SqlTableViewResourceService

func SyncTableViewGraphQuads 

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

SyncTableViewGraphQuads replaces the table view's target schema graph link.

func WriteTableViewRootRef 

func WriteTableViewRootRef(ctx context.Context, ws world.WorldState, tableView *TableView) (*bucket.ObjectRef, error)

WriteTableViewRootRef writes a SQL table view root block and returns its ref.

Types

type DriverCapability added in v0.54.0 

type DriverCapability struct {

	// UpdateRow is true when typed row updates can be attempted.
	UpdateRow bool `protobuf:"varint,1,opt,name=update_row,json=updateRow,proto3" json:"updateRow,omitempty"`
	// UpdateRowUnsupportedReason explains why UpdateRow is unavailable.
	UpdateRowUnsupportedReason string `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

DriverCapability describes SQL driver operations exposed by this table view.

func (*DriverCapability) CloneMessageVT added in v0.54.0 

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

func (*DriverCapability) CloneVT added in v0.54.0 

func (m *DriverCapability) CloneVT() *DriverCapability

func (*DriverCapability) EqualMessageVT added in v0.54.0 

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

func (*DriverCapability) EqualVT added in v0.54.0 

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

func (*DriverCapability) GetUpdateRow added in v0.54.0 

func (x *DriverCapability) GetUpdateRow() bool

func (*DriverCapability) GetUpdateRowUnsupportedReason added in v0.54.0 

func (x *DriverCapability) GetUpdateRowUnsupportedReason() string

func (*DriverCapability) MarshalJSON added in v0.54.0 

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

MarshalJSON marshals the DriverCapability to JSON.

func (*DriverCapability) MarshalProtoJSON added in v0.54.0 

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

MarshalProtoJSON marshals the DriverCapability message to JSON.

func (*DriverCapability) MarshalProtoText added in v0.54.0 

func (x *DriverCapability) MarshalProtoText() string

func (*DriverCapability) MarshalToSizedBufferVT added in v0.54.0 

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

func (*DriverCapability) MarshalToVT added in v0.54.0 

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

func (*DriverCapability) MarshalVT added in v0.54.0 

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

func (*DriverCapability) ProtoMessage added in v0.54.0 

func (*DriverCapability) ProtoMessage()

func (*DriverCapability) Reset added in v0.54.0 

func (x *DriverCapability) Reset()

func (*DriverCapability) SizeVT added in v0.54.0 

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

func (*DriverCapability) String added in v0.54.0 

func (x *DriverCapability) String() string

func (*DriverCapability) UnmarshalJSON added in v0.54.0 

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

UnmarshalJSON unmarshals the DriverCapability from JSON.

func (*DriverCapability) UnmarshalProtoJSON added in v0.54.0 

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

UnmarshalProtoJSON unmarshals the DriverCapability message from JSON.

func (*DriverCapability) UnmarshalVT added in v0.54.0 

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

type FetchRowsRequest 

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

FetchRowsRequest executes the saved table view.

func (*FetchRowsRequest) CloneMessageVT 

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

func (*FetchRowsRequest) CloneVT 

func (m *FetchRowsRequest) CloneVT() *FetchRowsRequest

func (*FetchRowsRequest) EqualMessageVT 

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

func (*FetchRowsRequest) EqualVT 

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

func (*FetchRowsRequest) MarshalJSON 

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

MarshalJSON marshals the FetchRowsRequest to JSON.

func (*FetchRowsRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the FetchRowsRequest message to JSON.

func (*FetchRowsRequest) MarshalProtoText 

func (x *FetchRowsRequest) MarshalProtoText() string

func (*FetchRowsRequest) MarshalToSizedBufferVT 

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

func (*FetchRowsRequest) MarshalToVT 

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

func (*FetchRowsRequest) MarshalVT 

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

func (*FetchRowsRequest) ProtoMessage 

func (*FetchRowsRequest) ProtoMessage()

func (*FetchRowsRequest) Reset 

func (x *FetchRowsRequest) Reset()

func (*FetchRowsRequest) SizeVT 

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

func (*FetchRowsRequest) String 

func (x *FetchRowsRequest) String() string

func (*FetchRowsRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the FetchRowsRequest from JSON.

func (*FetchRowsRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the FetchRowsRequest message from JSON.

func (*FetchRowsRequest) UnmarshalVT 

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

type FetchRowsResponse 

type FetchRowsResponse struct {

	// Columns describes the returned columns.
	Columns []*sql.ColumnSchema `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	// RowBatches stores returned rows in column order.
	RowBatches []*sql.RowBatch `protobuf:"bytes,2,rep,name=row_batches,json=rowBatches,proto3" json:"rowBatches,omitempty"`
	// RowCount is the number of returned rows.
	RowCount uint64 `protobuf:"varint,3,opt,name=row_count,json=rowCount,proto3" json:"rowCount,omitempty"`
	// Truncated indicates rows were omitted by the view row limit.
	Truncated bool `protobuf:"varint,4,opt,name=truncated,proto3" json:"truncated,omitempty"`
	// contains filtered or unexported fields
}

FetchRowsResponse contains rows returned by the table view.

func (*FetchRowsResponse) CloneMessageVT 

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

func (*FetchRowsResponse) CloneVT 

func (m *FetchRowsResponse) CloneVT() *FetchRowsResponse

func (*FetchRowsResponse) EqualMessageVT 

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

func (*FetchRowsResponse) EqualVT 

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

func (*FetchRowsResponse) GetColumns 

func (x *FetchRowsResponse) GetColumns() []*sql.ColumnSchema

func (*FetchRowsResponse) GetRowBatches 

func (x *FetchRowsResponse) GetRowBatches() []*sql.RowBatch

func (*FetchRowsResponse) GetRowCount 

func (x *FetchRowsResponse) GetRowCount() uint64

func (*FetchRowsResponse) GetTruncated 

func (x *FetchRowsResponse) GetTruncated() bool

func (*FetchRowsResponse) MarshalJSON 

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

MarshalJSON marshals the FetchRowsResponse to JSON.

func (*FetchRowsResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the FetchRowsResponse message to JSON.

func (*FetchRowsResponse) MarshalProtoText 

func (x *FetchRowsResponse) MarshalProtoText() string

func (*FetchRowsResponse) MarshalToSizedBufferVT 

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

func (*FetchRowsResponse) MarshalToVT 

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

func (*FetchRowsResponse) MarshalVT 

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

func (*FetchRowsResponse) ProtoMessage 

func (*FetchRowsResponse) ProtoMessage()

func (*FetchRowsResponse) Reset 

func (x *FetchRowsResponse) Reset()

func (*FetchRowsResponse) SizeVT 

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

func (*FetchRowsResponse) String 

func (x *FetchRowsResponse) String() string

func (*FetchRowsResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the FetchRowsResponse from JSON.

func (*FetchRowsResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the FetchRowsResponse message from JSON.

func (*FetchRowsResponse) UnmarshalVT 

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

type GetDriverCapabilityRequest added in v0.54.0 

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

GetDriverCapabilityRequest is a request for driver operation support.

func (*GetDriverCapabilityRequest) CloneMessageVT added in v0.54.0 

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

func (*GetDriverCapabilityRequest) CloneVT added in v0.54.0 

func (m *GetDriverCapabilityRequest) CloneVT() *GetDriverCapabilityRequest

func (*GetDriverCapabilityRequest) EqualMessageVT added in v0.54.0 

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

func (*GetDriverCapabilityRequest) EqualVT added in v0.54.0 

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

func (*GetDriverCapabilityRequest) MarshalJSON added in v0.54.0 

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

MarshalJSON marshals the GetDriverCapabilityRequest to JSON.

func (*GetDriverCapabilityRequest) MarshalProtoJSON added in v0.54.0 

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

MarshalProtoJSON marshals the GetDriverCapabilityRequest message to JSON.

func (*GetDriverCapabilityRequest) MarshalProtoText added in v0.54.0 

func (x *GetDriverCapabilityRequest) MarshalProtoText() string

func (*GetDriverCapabilityRequest) MarshalToSizedBufferVT added in v0.54.0 

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

func (*GetDriverCapabilityRequest) MarshalToVT added in v0.54.0 

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

func (*GetDriverCapabilityRequest) MarshalVT added in v0.54.0 

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

func (*GetDriverCapabilityRequest) ProtoMessage added in v0.54.0 

func (*GetDriverCapabilityRequest) ProtoMessage()

func (*GetDriverCapabilityRequest) Reset added in v0.54.0 

func (x *GetDriverCapabilityRequest) Reset()

func (*GetDriverCapabilityRequest) SizeVT added in v0.54.0 

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

func (*GetDriverCapabilityRequest) String added in v0.54.0 

func (x *GetDriverCapabilityRequest) String() string

func (*GetDriverCapabilityRequest) UnmarshalJSON added in v0.54.0 

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

UnmarshalJSON unmarshals the GetDriverCapabilityRequest from JSON.

func (*GetDriverCapabilityRequest) UnmarshalProtoJSON added in v0.54.0 

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

UnmarshalProtoJSON unmarshals the GetDriverCapabilityRequest message from JSON.

func (*GetDriverCapabilityRequest) UnmarshalVT added in v0.54.0 

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

type GetDriverCapabilityResponse added in v0.54.0 

type GetDriverCapabilityResponse struct {

	// Capability describes SQL operations available through the target driver.
	Capability *DriverCapability `protobuf:"bytes,1,opt,name=capability,proto3" json:"capability,omitempty"`
	// contains filtered or unexported fields
}

GetDriverCapabilityResponse contains update support reported by the target driver.

func (*GetDriverCapabilityResponse) CloneMessageVT added in v0.54.0 

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

func (*GetDriverCapabilityResponse) CloneVT added in v0.54.0 

func (m *GetDriverCapabilityResponse) CloneVT() *GetDriverCapabilityResponse

func (*GetDriverCapabilityResponse) EqualMessageVT added in v0.54.0 

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

func (*GetDriverCapabilityResponse) EqualVT added in v0.54.0 

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

func (*GetDriverCapabilityResponse) GetCapability added in v0.54.0 

func (x *GetDriverCapabilityResponse) GetCapability() *DriverCapability

func (*GetDriverCapabilityResponse) MarshalJSON added in v0.54.0 

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

MarshalJSON marshals the GetDriverCapabilityResponse to JSON.

func (*GetDriverCapabilityResponse) MarshalProtoJSON added in v0.54.0 

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

MarshalProtoJSON marshals the GetDriverCapabilityResponse message to JSON.

func (*GetDriverCapabilityResponse) MarshalProtoText added in v0.54.0 

func (x *GetDriverCapabilityResponse) MarshalProtoText() string

func (*GetDriverCapabilityResponse) MarshalToSizedBufferVT added in v0.54.0 

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

func (*GetDriverCapabilityResponse) MarshalToVT added in v0.54.0 

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

func (*GetDriverCapabilityResponse) MarshalVT added in v0.54.0 

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

func (*GetDriverCapabilityResponse) ProtoMessage added in v0.54.0 

func (*GetDriverCapabilityResponse) ProtoMessage()

func (*GetDriverCapabilityResponse) Reset added in v0.54.0 

func (x *GetDriverCapabilityResponse) Reset()

func (*GetDriverCapabilityResponse) SizeVT added in v0.54.0 

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

func (*GetDriverCapabilityResponse) String added in v0.54.0 

func (x *GetDriverCapabilityResponse) String() string

func (*GetDriverCapabilityResponse) UnmarshalJSON added in v0.54.0 

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

UnmarshalJSON unmarshals the GetDriverCapabilityResponse from JSON.

func (*GetDriverCapabilityResponse) UnmarshalProtoJSON added in v0.54.0 

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

UnmarshalProtoJSON unmarshals the GetDriverCapabilityResponse message from JSON.

func (*GetDriverCapabilityResponse) UnmarshalVT added in v0.54.0 

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

type GetTableViewRequest 

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

GetTableViewRequest is a request for table view metadata.

func (*GetTableViewRequest) CloneMessageVT 

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

func (*GetTableViewRequest) CloneVT 

func (m *GetTableViewRequest) CloneVT() *GetTableViewRequest

func (*GetTableViewRequest) EqualMessageVT 

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

func (*GetTableViewRequest) EqualVT 

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

func (*GetTableViewRequest) MarshalJSON 

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

MarshalJSON marshals the GetTableViewRequest to JSON.

func (*GetTableViewRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetTableViewRequest message to JSON.

func (*GetTableViewRequest) MarshalProtoText 

func (x *GetTableViewRequest) MarshalProtoText() string

func (*GetTableViewRequest) MarshalToSizedBufferVT 

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

func (*GetTableViewRequest) MarshalToVT 

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

func (*GetTableViewRequest) MarshalVT 

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

func (*GetTableViewRequest) ProtoMessage 

func (*GetTableViewRequest) ProtoMessage()

func (*GetTableViewRequest) Reset 

func (x *GetTableViewRequest) Reset()

func (*GetTableViewRequest) SizeVT 

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

func (*GetTableViewRequest) String 

func (x *GetTableViewRequest) String() string

func (*GetTableViewRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetTableViewRequest from JSON.

func (*GetTableViewRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetTableViewRequest message from JSON.

func (*GetTableViewRequest) UnmarshalVT 

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

type GetTableViewResponse 

type GetTableViewResponse struct {

	// TableView is the persisted table view block.
	TableView *TableView `protobuf:"bytes,1,opt,name=table_view,json=tableView,proto3" json:"tableView,omitempty"`
	// contains filtered or unexported fields
}

GetTableViewResponse contains table view metadata.

func (*GetTableViewResponse) CloneMessageVT 

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

func (*GetTableViewResponse) CloneVT 

func (m *GetTableViewResponse) CloneVT() *GetTableViewResponse

func (*GetTableViewResponse) EqualMessageVT 

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

func (*GetTableViewResponse) EqualVT 

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

func (*GetTableViewResponse) GetTableView 

func (x *GetTableViewResponse) GetTableView() *TableView

func (*GetTableViewResponse) MarshalJSON 

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

MarshalJSON marshals the GetTableViewResponse to JSON.

func (*GetTableViewResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetTableViewResponse message to JSON.

func (*GetTableViewResponse) MarshalProtoText 

func (x *GetTableViewResponse) MarshalProtoText() string

func (*GetTableViewResponse) MarshalToSizedBufferVT 

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

func (*GetTableViewResponse) MarshalToVT 

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

func (*GetTableViewResponse) MarshalVT 

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

func (*GetTableViewResponse) ProtoMessage 

func (*GetTableViewResponse) ProtoMessage()

func (*GetTableViewResponse) Reset 

func (x *GetTableViewResponse) Reset()

func (*GetTableViewResponse) SizeVT 

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

func (*GetTableViewResponse) String 

func (x *GetTableViewResponse) String() string

func (*GetTableViewResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetTableViewResponse from JSON.

func (*GetTableViewResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetTableViewResponse message from JSON.

func (*GetTableViewResponse) UnmarshalVT 

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

type SRPCSqlTableViewResourceServiceClient 

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

	// GetTableView returns the table view metadata.
	GetTableView(ctx context.Context, in *GetTableViewRequest) (*GetTableViewResponse, error)
	// GetDriverCapability returns SQL driver operations available to this view.
	GetDriverCapability(ctx context.Context, in *GetDriverCapabilityRequest) (*GetDriverCapabilityResponse, error)
	// FetchRows executes the table view SELECT.
	FetchRows(ctx context.Context, in *FetchRowsRequest) (*FetchRowsResponse, error)
	// UpdateRow applies a typed UPDATE against rows matching the supplied row values.
	UpdateRow(ctx context.Context, in *UpdateRowRequest) (*UpdateRowResponse, error)
}

func NewSRPCSqlTableViewResourceServiceClient 

func NewSRPCSqlTableViewResourceServiceClient(cc srpc.Client) SRPCSqlTableViewResourceServiceClient

func NewSRPCSqlTableViewResourceServiceClientWithServiceID 

func NewSRPCSqlTableViewResourceServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCSqlTableViewResourceServiceClient

type SRPCSqlTableViewResourceServiceHandler 

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

func (SRPCSqlTableViewResourceServiceHandler) GetMethodIDs 

func (SRPCSqlTableViewResourceServiceHandler) GetMethodIDs() []string

func (*SRPCSqlTableViewResourceServiceHandler) GetServiceID 

func (d *SRPCSqlTableViewResourceServiceHandler) GetServiceID() string

func (*SRPCSqlTableViewResourceServiceHandler) InvokeMethod 

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

func (SRPCSqlTableViewResourceServiceHandler) InvokeMethod_FetchRows 

func (SRPCSqlTableViewResourceServiceHandler) InvokeMethod_FetchRows(impl SRPCSqlTableViewResourceServiceServer, strm srpc.Stream) error

func (SRPCSqlTableViewResourceServiceHandler) InvokeMethod_GetDriverCapability added in v0.54.0 

func (SRPCSqlTableViewResourceServiceHandler) InvokeMethod_GetDriverCapability(impl SRPCSqlTableViewResourceServiceServer, strm srpc.Stream) error

func (SRPCSqlTableViewResourceServiceHandler) InvokeMethod_GetTableView 

func (SRPCSqlTableViewResourceServiceHandler) InvokeMethod_GetTableView(impl SRPCSqlTableViewResourceServiceServer, strm srpc.Stream) error

func (SRPCSqlTableViewResourceServiceHandler) InvokeMethod_UpdateRow added in v0.54.0 

func (SRPCSqlTableViewResourceServiceHandler) InvokeMethod_UpdateRow(impl SRPCSqlTableViewResourceServiceServer, strm srpc.Stream) error

type SRPCSqlTableViewResourceServiceServer 

type SRPCSqlTableViewResourceServiceServer interface {
	// GetTableView returns the table view metadata.
	GetTableView(context.Context, *GetTableViewRequest) (*GetTableViewResponse, error)
	// GetDriverCapability returns SQL driver operations available to this view.
	GetDriverCapability(context.Context, *GetDriverCapabilityRequest) (*GetDriverCapabilityResponse, error)
	// FetchRows executes the table view SELECT.
	FetchRows(context.Context, *FetchRowsRequest) (*FetchRowsResponse, error)
	// UpdateRow applies a typed UPDATE against rows matching the supplied row values.
	UpdateRow(context.Context, *UpdateRowRequest) (*UpdateRowResponse, error)
}

type SRPCSqlTableViewResourceService_FetchRowsStream 

type SRPCSqlTableViewResourceService_FetchRowsStream interface {
	srpc.Stream
}

type SRPCSqlTableViewResourceService_GetDriverCapabilityStream added in v0.54.0 

type SRPCSqlTableViewResourceService_GetDriverCapabilityStream interface {
	srpc.Stream
}

type SRPCSqlTableViewResourceService_GetTableViewStream 

type SRPCSqlTableViewResourceService_GetTableViewStream interface {
	srpc.Stream
}

type SRPCSqlTableViewResourceService_UpdateRowStream added in v0.54.0 

type SRPCSqlTableViewResourceService_UpdateRowStream interface {
	srpc.Stream
}

type SortOrder 

type SortOrder struct {

	// ColumnName is the column to sort.
	ColumnName string `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"columnName,omitempty"`
	// Descending sorts the column descending when true.
	Descending bool `protobuf:"varint,2,opt,name=descending,proto3" json:"descending,omitempty"`
	// contains filtered or unexported fields
}

SortOrder describes one ORDER BY term.

func (*SortOrder) CloneMessageVT 

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

func (*SortOrder) CloneVT 

func (m *SortOrder) CloneVT() *SortOrder

func (*SortOrder) EqualMessageVT 

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

func (*SortOrder) EqualVT 

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

func (*SortOrder) GetColumnName 

func (x *SortOrder) GetColumnName() string

func (*SortOrder) GetDescending 

func (x *SortOrder) GetDescending() bool

func (*SortOrder) MarshalJSON 

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

MarshalJSON marshals the SortOrder to JSON.

func (*SortOrder) MarshalProtoJSON 

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

MarshalProtoJSON marshals the SortOrder message to JSON.

func (*SortOrder) MarshalProtoText 

func (x *SortOrder) MarshalProtoText() string

func (*SortOrder) MarshalToSizedBufferVT 

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

func (*SortOrder) MarshalToVT 

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

func (*SortOrder) MarshalVT 

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

func (*SortOrder) ProtoMessage 

func (*SortOrder) ProtoMessage()

func (*SortOrder) Reset 

func (x *SortOrder) Reset()

func (*SortOrder) SizeVT 

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

func (*SortOrder) String 

func (x *SortOrder) String() string

func (*SortOrder) UnmarshalJSON 

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

UnmarshalJSON unmarshals the SortOrder from JSON.

func (*SortOrder) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the SortOrder message from JSON.

func (*SortOrder) UnmarshalVT 

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

type TableView 

type TableView struct {

	// TargetSchemaObjectKey is the sql/schema object this view reads from.
	TargetSchemaObjectKey string `protobuf:"bytes,1,opt,name=target_schema_object_key,json=targetSchemaObjectKey,proto3" json:"targetSchemaObjectKey,omitempty"`
	// TargetTableName is the table name inside the target schema.
	TargetTableName string `protobuf:"bytes,2,opt,name=target_table_name,json=targetTableName,proto3" json:"targetTableName,omitempty"`
	// WhereExpression is an optional SQL WHERE expression.
	WhereExpression string `protobuf:"bytes,3,opt,name=where_expression,json=whereExpression,proto3" json:"whereExpression,omitempty"`
	// ProjectedColumns limits returned columns. Empty selects all columns.
	ProjectedColumns []string `protobuf:"bytes,4,rep,name=projected_columns,json=projectedColumns,proto3" json:"projectedColumns,omitempty"`
	// SortOrder orders returned rows.
	SortOrder []*SortOrder `protobuf:"bytes,5,rep,name=sort_order,json=sortOrder,proto3" json:"sortOrder,omitempty"`
	// RowLimit limits returned rows. Zero uses the default limit.
	RowLimit uint32 `protobuf:"varint,6,opt,name=row_limit,json=rowLimit,proto3" json:"rowLimit,omitempty"`
	// WhereParameters are positional bind arguments used by WhereExpression.
	WhereParameters []*sql.SqlValue `protobuf:"bytes,7,rep,name=where_parameters,json=whereParameters,proto3" json:"whereParameters,omitempty"`
	// DisplayName is an optional user-facing label.
	DisplayName string `protobuf:"bytes,8,opt,name=display_name,json=displayName,proto3" json:"displayName,omitempty"`
	// Description is optional user-facing metadata.
	Description string `protobuf:"bytes,9,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

TableView is a standalone saved table projection and filter.

func ReadTableViewObjectRoot 

func ReadTableViewObjectRoot(ctx context.Context, obj world.ObjectState) (*TableView, error)

ReadTableViewObjectRoot reads a SQL table view root from an object state.

func ReadTableViewRoot 

func ReadTableViewRoot(ctx context.Context, ws world.WorldState, objectKey string) (*TableView, error)

ReadTableViewRoot reads a SQL table view object's root.

func (*TableView) CloneMessageVT 

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

func (*TableView) CloneVT 

func (m *TableView) CloneVT() *TableView

func (*TableView) EqualMessageVT 

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

func (*TableView) EqualVT 

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

func (*TableView) GetDescription 

func (x *TableView) GetDescription() string

func (*TableView) GetDisplayName 

func (x *TableView) GetDisplayName() string

func (*TableView) GetProjectedColumns 

func (x *TableView) GetProjectedColumns() []string

func (*TableView) GetRowLimit 

func (x *TableView) GetRowLimit() uint32

func (*TableView) GetSortOrder 

func (x *TableView) GetSortOrder() []*SortOrder

func (*TableView) GetTargetSchemaObjectKey 

func (x *TableView) GetTargetSchemaObjectKey() string

func (*TableView) GetTargetTableName 

func (x *TableView) GetTargetTableName() string

func (*TableView) GetWhereExpression 

func (x *TableView) GetWhereExpression() string

func (*TableView) GetWhereParameters 

func (x *TableView) GetWhereParameters() []*sql.SqlValue

func (*TableView) MarshalBlock 

func (v *TableView) MarshalBlock() ([]byte, error)

MarshalBlock marshals the SQL table view root.

func (*TableView) MarshalJSON 

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

MarshalJSON marshals the TableView to JSON.

func (*TableView) MarshalProtoJSON 

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

MarshalProtoJSON marshals the TableView message to JSON.

func (*TableView) MarshalProtoText 

func (x *TableView) MarshalProtoText() string

func (*TableView) MarshalToSizedBufferVT 

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

func (*TableView) MarshalToVT 

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

func (*TableView) MarshalVT 

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

func (*TableView) ProtoMessage 

func (*TableView) ProtoMessage()

func (*TableView) Reset 

func (x *TableView) Reset()

func (*TableView) SizeVT 

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

func (*TableView) String 

func (x *TableView) String() string

func (*TableView) UnmarshalBlock 

func (v *TableView) UnmarshalBlock(data []byte) error

UnmarshalBlock unmarshals the SQL table view root.

func (*TableView) UnmarshalJSON 

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

UnmarshalJSON unmarshals the TableView from JSON.

func (*TableView) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the TableView message from JSON.

func (*TableView) UnmarshalVT 

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

func (*TableView) Validate 

func (v *TableView) Validate() error

Validate performs cursory checks on the SQL table view root.

type UpdateRowRequest added in v0.54.0 

type UpdateRowRequest struct {

	// MatchColumns names columns used in the WHERE clause.
	MatchColumns []string `protobuf:"bytes,1,rep,name=match_columns,json=matchColumns,proto3" json:"matchColumns,omitempty"`
	// MatchValues are compared with MatchColumns in order.
	MatchValues []*sql.SqlValue `protobuf:"bytes,2,rep,name=match_values,json=matchValues,proto3" json:"matchValues,omitempty"`
	// SetColumns names columns updated by the SET clause.
	SetColumns []string `protobuf:"bytes,3,rep,name=set_columns,json=setColumns,proto3" json:"setColumns,omitempty"`
	// SetValues are assigned to SetColumns in order.
	SetValues []*sql.SqlValue `protobuf:"bytes,4,rep,name=set_values,json=setValues,proto3" json:"setValues,omitempty"`
	// contains filtered or unexported fields
}

UpdateRowRequest updates table rows selected by typed match values.

func (*UpdateRowRequest) CloneMessageVT added in v0.54.0 

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

func (*UpdateRowRequest) CloneVT added in v0.54.0 

func (m *UpdateRowRequest) CloneVT() *UpdateRowRequest

func (*UpdateRowRequest) EqualMessageVT added in v0.54.0 

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

func (*UpdateRowRequest) EqualVT added in v0.54.0 

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

func (*UpdateRowRequest) GetMatchColumns added in v0.54.0 

func (x *UpdateRowRequest) GetMatchColumns() []string

func (*UpdateRowRequest) GetMatchValues added in v0.54.0 

func (x *UpdateRowRequest) GetMatchValues() []*sql.SqlValue

func (*UpdateRowRequest) GetSetColumns added in v0.54.0 

func (x *UpdateRowRequest) GetSetColumns() []string

func (*UpdateRowRequest) GetSetValues added in v0.54.0 

func (x *UpdateRowRequest) GetSetValues() []*sql.SqlValue

func (*UpdateRowRequest) MarshalJSON added in v0.54.0 

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

MarshalJSON marshals the UpdateRowRequest to JSON.

func (*UpdateRowRequest) MarshalProtoJSON added in v0.54.0 

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

MarshalProtoJSON marshals the UpdateRowRequest message to JSON.

func (*UpdateRowRequest) MarshalProtoText added in v0.54.0 

func (x *UpdateRowRequest) MarshalProtoText() string

func (*UpdateRowRequest) MarshalToSizedBufferVT added in v0.54.0 

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

func (*UpdateRowRequest) MarshalToVT added in v0.54.0 

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

func (*UpdateRowRequest) MarshalVT added in v0.54.0 

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

func (*UpdateRowRequest) ProtoMessage added in v0.54.0 

func (*UpdateRowRequest) ProtoMessage()

func (*UpdateRowRequest) Reset added in v0.54.0 

func (x *UpdateRowRequest) Reset()

func (*UpdateRowRequest) SizeVT added in v0.54.0 

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

func (*UpdateRowRequest) String added in v0.54.0 

func (x *UpdateRowRequest) String() string

func (*UpdateRowRequest) UnmarshalJSON added in v0.54.0 

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

UnmarshalJSON unmarshals the UpdateRowRequest from JSON.

func (*UpdateRowRequest) UnmarshalProtoJSON added in v0.54.0 

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

UnmarshalProtoJSON unmarshals the UpdateRowRequest message from JSON.

func (*UpdateRowRequest) UnmarshalVT added in v0.54.0 

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

type UpdateRowResponse added in v0.54.0 

type UpdateRowResponse struct {

	// RowsAffected is the number of rows updated by the driver.
	RowsAffected uint64 `protobuf:"varint,1,opt,name=rows_affected,json=rowsAffected,proto3" json:"rowsAffected,omitempty"`
	// contains filtered or unexported fields
}

UpdateRowResponse is returned after a typed row update.

func (*UpdateRowResponse) CloneMessageVT added in v0.54.0 

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

func (*UpdateRowResponse) CloneVT added in v0.54.0 

func (m *UpdateRowResponse) CloneVT() *UpdateRowResponse

func (*UpdateRowResponse) EqualMessageVT added in v0.54.0 

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

func (*UpdateRowResponse) EqualVT added in v0.54.0 

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

func (*UpdateRowResponse) GetRowsAffected added in v0.54.0 

func (x *UpdateRowResponse) GetRowsAffected() uint64

func (*UpdateRowResponse) MarshalJSON added in v0.54.0 

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

MarshalJSON marshals the UpdateRowResponse to JSON.

func (*UpdateRowResponse) MarshalProtoJSON added in v0.54.0 

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

MarshalProtoJSON marshals the UpdateRowResponse message to JSON.

func (*UpdateRowResponse) MarshalProtoText added in v0.54.0 

func (x *UpdateRowResponse) MarshalProtoText() string

func (*UpdateRowResponse) MarshalToSizedBufferVT added in v0.54.0 

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

func (*UpdateRowResponse) MarshalToVT added in v0.54.0 

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

func (*UpdateRowResponse) MarshalVT added in v0.54.0 

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

func (*UpdateRowResponse) ProtoMessage added in v0.54.0 

func (*UpdateRowResponse) ProtoMessage()

func (*UpdateRowResponse) Reset added in v0.54.0 

func (x *UpdateRowResponse) Reset()

func (*UpdateRowResponse) SizeVT added in v0.54.0 

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

func (*UpdateRowResponse) String added in v0.54.0 

func (x *UpdateRowResponse) String() string

func (*UpdateRowResponse) UnmarshalJSON added in v0.54.0 

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

UnmarshalJSON unmarshals the UpdateRowResponse from JSON.

func (*UpdateRowResponse) UnmarshalProtoJSON added in v0.54.0 

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

UnmarshalProtoJSON unmarshals the UpdateRowResponse message from JSON.

func (*UpdateRowResponse) UnmarshalVT added in v0.54.0 

func (m *UpdateRowResponse) 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.