query

Documentation

Index

• Variables
• 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 ...options.DoOption) error
  • func (c Client) DoTx(ctx context.Context, op query.TxOperation, opts ...options.DoTxOption) error
• type Session
  • func (s *Session) Begin(ctx context.Context, txSettings query.TransactionSettings) (query.Transaction, error)
  • func (s *Session) Close(ctx context.Context) error
  • func (s *Session) Execute(ctx context.Context, q string, opts ...options.ExecuteOption) (query.Transaction, query.Result, error)
  • func (s *Session) ID() string
  • func (s *Session) NodeID() int64
  • func (s *Session) Status() query.SessionStatus

Variables

var (
	ErrNotImplemented = errors.New("not implemented yet")
)

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 ...options.DoOption) error

func (Client) DoTx

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

type Session

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

func (*Session) Begin

func (s *Session) Begin(ctx context.Context, txSettings query.TransactionSettings) (query.Transaction, error)

func (*Session) Close

func (s *Session) Close(ctx context.Context) error

func (*Session) Execute

func (s *Session) Execute(
	ctx context.Context, q string, opts ...options.ExecuteOption,
) (query.Transaction, query.Result, error)

func (*Session) ID

func (s *Session) ID() string

func (*Session) NodeID

func (s *Session) NodeID() int64

func (*Session) Status

func (s *Session) Status() query.SessionStatus