scanner

Documentation

Index

• func WithIgnoreTruncated(ignoreTruncated bool) option
• func WithMarkTruncatedAsRetryable() option
• type StreamResult
  • func NewStream(ctx context.Context, ...) (StreamResult, error)
• type UnaryResult
  • func NewUnary(sets []*Ydb.ResultSet, stats *Ydb_TableStats.QueryStats, opts ...option) UnaryResult

Functions

func WithIgnoreTruncated

func WithIgnoreTruncated(ignoreTruncated bool) option

func WithMarkTruncatedAsRetryable

func WithMarkTruncatedAsRetryable() option

Types

type StreamResult

type StreamResult interface {
	result.StreamResult
	// contains filtered or unexported methods
}

func NewStream

func NewStream(
	ctx context.Context,
	recv func(ctx context.Context) (*Ydb.ResultSet, *Ydb_TableStats.QueryStats, error),
	onClose func(error) error,
	opts ...option,
) (StreamResult, error)

type UnaryResult

type UnaryResult interface {
	result.Result
	// contains filtered or unexported methods
}

func NewUnary

func NewUnary(sets []*Ydb.ResultSet, stats *Ydb_TableStats.QueryStats, opts ...option) UnaryResult