table

Documentation

Index

• Variables
• func ErrNoProgress(attempts int) error
• type Client
  • func New(ctx context.Context, cluster cluster.Cluster, opts ...config.Option) Client
• type Session
• type SessionBuilder
• type SessionProvider
  • func SingleSession(s Session, b retry.Backoff) SessionProvider
• type SessionProviderFunc
  • func (f SessionProviderFunc) Close(ctx context.Context) error
  • func (f SessionProviderFunc) CloseSession(ctx context.Context, s Session) error
  • func (f SessionProviderFunc) Do(ctx context.Context, op table.Operation, opts ...table.Option) (err error)
  • func (f SessionProviderFunc) Get(ctx context.Context) (Session, error)
  • func (f SessionProviderFunc) Put(ctx context.Context, s Session) error
• type Statement
  • func (s *Statement) Execute(ctx context.Context, tx *table.TransactionControl, ...) (txr table.Transaction, r result.Result, err error)
  • func (s *Statement) NumInput() int
  • func (s *Statement) Text() string
• type Transaction
  • func (tx *Transaction) CommitTx(ctx context.Context, opts ...options.CommitTransactionOption) (r result.Result, err error)
  • func (tx *Transaction) Execute(ctx context.Context, query string, params *table.QueryParameters, ...) (r result.Result, err error)
  • func (tx *Transaction) ExecuteStatement(ctx context.Context, stmt table.Statement, params *table.QueryParameters, ...) (r result.Result, err error)
  • func (tx *Transaction) ID() string
  • func (tx *Transaction) IsNil() bool
  • func (tx *Transaction) Rollback(ctx context.Context) (err error)

Variables

var (
	// ErrSessionPoolClosed is returned by a client instance to indicate
	// that client is closed and not able to complete requested operation.
	ErrSessionPoolClosed = errors.New("ydb: table: session pool is closed")

	// ErrSessionPoolOverflow is returned by a client instance to indicate
	// that the client is full and requested operation is not able to complete.
	ErrSessionPoolOverflow = errors.New("ydb: table: session pool overflow")

	// ErrSessionUnknown is returned by a client instance to indicate that
	// requested session does not exist within the client.
	ErrSessionUnknown = errors.New("ydb: table: unknown session")
)

Functions

func ErrNoProgress

func ErrNoProgress(attempts int) error

ErrNoProgress is returned by a client instance to indicate that operation could not be completed.

Types

type Client

type Client interface {
	table.Client

	Get(ctx context.Context) (s Session, err error)
	Put(ctx context.Context, s Session) (err error)
	CloseSession(ctx context.Context, s Session) (err error)
}

func New

func New(ctx context.Context, cluster cluster.Cluster, opts ...config.Option) Client

type Session

type Session interface {
	table.ClosableSession

	IsClosed() bool
	Status() string
	OnClose(f func(ctx context.Context))
}

type SessionBuilder

type SessionBuilder func(context.Context) (Session, error)

SessionBuilder is the interface that holds logic of creating sessions.

type SessionProvider

type SessionProvider interface {
	// Get returns alive idle session or creates new one.
	Get(context.Context) (Session, error)

	// Put takes no longer needed session for reuse or deletion depending
	// on implementation.
	// Put must be fast, if necessary must be async
	Put(context.Context, Session) (err error)

	// CloseSession provides the most effective way of session closing
	// instead of plain session.Close().
	// CloseSession must be fast. If necessary, can be async.
	CloseSession(ctx context.Context, s Session) error

	// Close provide cleanup sessions
	Close(ctx context.Context) error

	// Do provide the best effort for execute operation
	// Do implements internal busy loop until one of the following conditions is met:
	// - deadline was canceled or deadlined
	// - retry operation returned nil as error
	// Warning: if deadline without deadline or cancellation func Retry will be worked infinite
	Do(ctx context.Context, op table.Operation, opts ...table.Option) (err error)
}

SessionProvider is the interface that holds session lifecycle logic.

func SingleSession

func SingleSession(s Session, b retry.Backoff) SessionProvider

SingleSession returns SessionProvider that uses only given session during retries.

type SessionProviderFunc

type SessionProviderFunc struct {
	OnGet   func(context.Context) (Session, error)
	OnPut   func(context.Context, Session) error
	OnDo    func(context.Context, table.Operation, ...table.Option) error
	OnClose func(context.Context) error
}

func (SessionProviderFunc) Close

func (f SessionProviderFunc) Close(ctx context.Context) error

func (SessionProviderFunc) CloseSession

func (f SessionProviderFunc) CloseSession(ctx context.Context, s Session) error

func (SessionProviderFunc) Do

func (f SessionProviderFunc) Do(ctx context.Context, op table.Operation, opts ...table.Option) (err error)

func (SessionProviderFunc) Get

func (f SessionProviderFunc) Get(ctx context.Context) (Session, error)

func (SessionProviderFunc) Put

func (f SessionProviderFunc) Put(ctx context.Context, s Session) error

type Statement

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

Statement is a prepared statement. Like a single session, it is not safe for concurrent use by multiple goroutines.

func (*Statement) Execute

func (s *Statement) Execute(
	ctx context.Context, tx *table.TransactionControl,
	params *table.QueryParameters,
	opts ...options.ExecuteDataQueryOption,
) (
	txr table.Transaction, r result.Result, err error,
)

Execute executes prepared data query.

func (*Statement) NumInput

func (s *Statement) NumInput() int

func (*Statement) Text

func (s *Statement) Text() string

type Transaction

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

Transaction is a database transaction. Hence session methods are not goroutine safe, Transaction is not goroutine safe either.

func (*Transaction) CommitTx

func (tx *Transaction) CommitTx(
	ctx context.Context,
	opts ...options.CommitTransactionOption,
) (r result.Result, err error)

CommitTx commits specified active transaction.

func (*Transaction) Execute

func (tx *Transaction) Execute(
	ctx context.Context,
	query string, params *table.QueryParameters,
	opts ...options.ExecuteDataQueryOption,
) (r result.Result, err error)

Execute executes query represented by text within transaction tx.

func (*Transaction) ExecuteStatement

func (tx *Transaction) ExecuteStatement(
	ctx context.Context,
	stmt table.Statement, params *table.QueryParameters,
	opts ...options.ExecuteDataQueryOption,
) (r result.Result, err error)

ExecuteStatement executes prepared statement stmt within transaction tx.

func (*Transaction) ID

func (tx *Transaction) ID() string

func (*Transaction) IsNil

func (tx *Transaction) IsNil() bool

func (*Transaction) Rollback

func (tx *Transaction) Rollback(ctx context.Context) (err error)

Rollback performs a rollback of the specified active transaction.