query

Documentation

Index

• type Client
  • func New(ctx context.Context, balancer balancer, config *config.Config) (*Client, error)
  • func (c Client) Close(ctx context.Context) error
  • func (c Client) Do(ctx context.Context, op query.Operation, opts ...query.DoOption) error
  • func (c Client) DoTx(ctx context.Context, op query.TxOperation, opts ...query.DoTxOption) error
• type SessionPool

Types

type Client

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

func New

func New(ctx context.Context, balancer balancer, config *config.Config) (*Client, error)

func (Client) Close

func (c Client) Close(ctx context.Context) error

func (Client) Do

func (c Client) Do(ctx context.Context, op query.Operation, opts ...query.DoOption) error

func (Client) DoTx

func (c Client) DoTx(ctx context.Context, op query.TxOperation, opts ...query.DoTxOption) error

type SessionPool

type SessionPool interface {
	With(ctx context.Context, f func(ctx context.Context, s *session) error) error
	Close(ctx context.Context) error
}