Versions in this module Expand all Collapse all v1 v1.61.0 Apr 30, 2024 Changes in this version + const Batch + const None + const Read + const ReadWrite + type AdminActionHandler struct + Action *executorpb.AdminAction + FlowContext *ExecutionFlowContext + Options []option.ClientOption + OutcomeSender *outputstream.OutcomeSender + func (h *AdminActionHandler) ExecuteAction(ctx context.Context) error + type BatchDmlHandler struct + Action *executorpb.BatchDmlAction + FlowContext *ExecutionFlowContext + OutcomeSender *outputstream.OutcomeSender + func (h *BatchDmlHandler) ExecuteAction(ctx context.Context) error + type CloseBatchTxnHandler struct + Action *executorpb.CloseBatchTransactionAction + FlowContext *ExecutionFlowContext + OutcomeSender *outputstream.OutcomeSender + func (h *CloseBatchTxnHandler) ExecuteAction(ctx context.Context) error + type DmlActionHandler struct + Action *executorpb.DmlAction + FlowContext *ExecutionFlowContext + OutcomeSender *outputstream.OutcomeSender + func (h *DmlActionHandler) ExecuteAction(ctx context.Context) error + type ExecutePartition struct + Action *executorpb.ExecutePartitionAction + FlowContext *ExecutionFlowContext + OutcomeSender *outputstream.OutcomeSender + func (h *ExecutePartition) ExecuteAction(ctx context.Context) error + type ExecutionFlowContext struct + Database string + DbClient *spanner.Client + TxnContext context.Context + func (c *ExecutionFlowContext) CloseOpenTransactions() + func (c *ExecutionFlowContext) IsTransactionActive() bool + type FinishTxnHandler struct + Action *executorpb.FinishTransactionAction + FlowContext *ExecutionFlowContext + OutcomeSender *outputstream.OutcomeSender + func (h *FinishTxnHandler) ExecuteAction(ctx context.Context) error + type MutationActionHandler struct + Action *executorpb.MutationAction + FlowContext *ExecutionFlowContext + OutcomeSender *outputstream.OutcomeSender + func (h *MutationActionHandler) ExecuteAction(ctx context.Context) error + type PartitionQueryActionHandler struct + Action *executorpb.GenerateDbPartitionsForQueryAction + FlowContext *ExecutionFlowContext + OutcomeSender *outputstream.OutcomeSender + func (h *PartitionQueryActionHandler) ExecuteAction(ctx context.Context) error + type PartitionReadActionHandler struct + Action *executorpb.GenerateDbPartitionsForReadAction + FlowContext *ExecutionFlowContext + OutcomeSender *outputstream.OutcomeSender + func (h *PartitionReadActionHandler) ExecuteAction(ctx context.Context) error + type PartitionedUpdate struct + Action *executorpb.PartitionedUpdateAction + FlowContext *ExecutionFlowContext + OutcomeSender *outputstream.OutcomeSender + func (h *PartitionedUpdate) ExecuteAction(ctx context.Context) error + type QueryActionHandler struct + Action *executorpb.QueryAction + FlowContext *ExecutionFlowContext + OutcomeSender *outputstream.OutcomeSender + func (h *QueryActionHandler) ExecuteAction(ctx context.Context) error + type ReadActionHandler struct + Action *executorpb.ReadAction + FlowContext *ExecutionFlowContext + OutcomeSender *outputstream.OutcomeSender + func (h *ReadActionHandler) ExecuteAction(ctx context.Context) error + type StartBatchTxnHandler struct + Action *executorpb.StartBatchTransactionAction + FlowContext *ExecutionFlowContext + Options []option.ClientOption + OutcomeSender *outputstream.OutcomeSender + func (h *StartBatchTxnHandler) ExecuteAction(ctx context.Context) error + type StartTxnHandler struct + Action *executorpb.StartTransactionAction + FlowContext *ExecutionFlowContext + Options []option.ClientOption + OutcomeSender *outputstream.OutcomeSender + func (h *StartTxnHandler) ExecuteAction(ctx context.Context) error + type WriteActionHandler struct + Action *executorpb.MutationAction + FlowContext *ExecutionFlowContext + OutcomeSender *outputstream.OutcomeSender + func (h *WriteActionHandler) ExecuteAction(ctx context.Context) error
Go to main page