connection

Documentation

Index

• type Conn
  • func (c *Conn) Begin(ctx context.Context) (*Tx, error)
• type Manager
  • func NewManager(db *sql.DB) *Manager
  • func (m *Manager) Connection(ctx context.Context, projectID, datasetID string) (*Conn, error)
• type Tx
  • func (t *Tx) Commit() error
  • func (t *Tx) ContentRepoMode() error
  • func (t *Tx) MetadataRepoMode() error
  • func (t *Tx) RollbackIfNotCommitted() error
  • func (t *Tx) SetProjectAndDataset(projectID, datasetID string)
  • func (t *Tx) Tx() *sql.Tx

Types

type Conn

type Conn struct {
	ProjectID string
	DatasetID string
	Conn      *sql.Conn
}

func (*Conn) Begin

func (c *Conn) Begin(ctx context.Context) (*Tx, error)

type Manager

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

func NewManager

func NewManager(db *sql.DB) *Manager

func (*Manager) Connection

func (m *Manager) Connection(ctx context.Context, projectID, datasetID string) (*Conn, error)

type Tx

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

func (*Tx) Commit

func (t *Tx) Commit() error

func (*Tx) ContentRepoMode

func (t *Tx) ContentRepoMode() error

func (*Tx) MetadataRepoMode

func (t *Tx) MetadataRepoMode() error

func (*Tx) RollbackIfNotCommitted

func (t *Tx) RollbackIfNotCommitted() error

func (*Tx) SetProjectAndDataset

func (t *Tx) SetProjectAndDataset(projectID, datasetID string)

func (*Tx) Tx

func (t *Tx) Tx() *sql.Tx