query

package

v0.510.3 Latest Latest Go to latest Published: Jun 4, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/block/ftl

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func BeginTransaction(ctx context.Context, dbName string) (string, error)
func CommitCurrentTransaction(ctx context.Context, dbName string) error
func Exec[Req any](ctx context.Context, dbName string, rawSQL string, params []any, ...) error
func GetTransactionMetadata(txnID string) *ftlv1.Metadata_Pair
func Many[Req, Resp any](ctx context.Context, dbName string, rawSQL string, params []any, ...) ([]Resp, error)
func One[Req, Resp any](ctx context.Context, dbName string, rawSQL string, params []any, ...) (resp Resp, err error)
func RollbackCurrentTransaction(ctx context.Context, dbName string) error
type InlineQueryClient
- func NewInlineQueryClient(service *iquery.Service) *InlineQueryClient

Constants ¶

View Source

const (
	TransactionMetadataKey = internal.MetadataKey(transactionMetadataString)
)

Variables ¶

This section is empty.

Functions ¶

func BeginTransaction ¶

func BeginTransaction(ctx context.Context, dbName string) (string, error)

func CommitCurrentTransaction ¶

func CommitCurrentTransaction(ctx context.Context, dbName string) error

func Exec ¶

func Exec[Req any](ctx context.Context, dbName string, rawSQL string, params []any, colFieldNames []tuple.Pair[string, string]) error

func GetTransactionMetadata ¶

func GetTransactionMetadata(txnID string) *ftlv1.Metadata_Pair

func Many ¶

func Many[Req, Resp any](ctx context.Context, dbName string, rawSQL string, params []any, colFieldNames []tuple.Pair[string, string]) ([]Resp, error)

func One ¶

func One[Req, Resp any](ctx context.Context, dbName string, rawSQL string, params []any, colFieldNames []tuple.Pair[string, string]) (resp Resp, err error)

func RollbackCurrentTransaction ¶

func RollbackCurrentTransaction(ctx context.Context, dbName string) error

Types ¶

type InlineQueryClient ¶

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

InlineQueryClient is used to perform queries by the unit test harness. It executes the query server logic in-process and does not require network communication.

func NewInlineQueryClient ¶

func NewInlineQueryClient(service *iquery.Service) *InlineQueryClient

func (*InlineQueryClient) BeginTransaction ¶

func (c *InlineQueryClient) BeginTransaction(
	ctx context.Context,
	req *connect.Request[querypb.BeginTransactionRequest],
) (*connect.Response[querypb.BeginTransactionResponse], error)

func (*InlineQueryClient) CommitTransaction ¶

func (c *InlineQueryClient) CommitTransaction(
	ctx context.Context,
	req *connect.Request[querypb.CommitTransactionRequest],
) (*connect.Response[querypb.CommitTransactionResponse], error)

func (*InlineQueryClient) ExecuteQuery ¶

func (c *InlineQueryClient) ExecuteQuery(
	ctx context.Context,
	req *connect.Request[querypb.ExecuteQueryRequest],
) (*connect.ServerStreamForClient[querypb.ExecuteQueryResponse], error)

func (*InlineQueryClient) Ping ¶

func (c *InlineQueryClient) Ping(ctx context.Context, req *connect.Request[ftlv1.PingRequest]) (*connect.Response[ftlv1.PingResponse], error)

func (*InlineQueryClient) RollbackTransaction ¶

func (c *InlineQueryClient) RollbackTransaction(
	ctx context.Context,
	req *connect.Request[querypb.RollbackTransactionRequest],
) (*connect.Response[querypb.RollbackTransactionResponse], error)

Source Files ¶

View all Source files

client.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL