Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrAborted = errors.New("aborted")
Functions ¶
Types ¶
type RWConnector ¶
type RWConnector struct { QueryIn chan *RWQueryMessage QueryOut chan *RWQueryMessage ExecIn chan *RWExecMessage ExecOut chan *RWExecMessage RollbackIn chan struct{} CommitIn chan struct{} Errors chan error // only for starting, commit and rollback Ready chan struct{} }
RWConnector starts a Cloud Spanner read-write transaction and provides blocking APIs to query, exec, rollback and commit.
func NewRWConnector ¶
func NewRWConnector(ctx context.Context, c *spanner.Client) *RWConnector
type RWExecMessage ¶
type RWQueryMessage ¶
Click to show internal directories.
Click to hide internal directories.