scanner

Documentation

Index

• type StreamResult
  • func NewStream(...) StreamResult
• type UnaryResult
  • func NewUnary(sets []*Ydb.ResultSet, stats *Ydb_TableStats.QueryStats) UnaryResult

Types

type StreamResult

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

func NewStream

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

type UnaryResult

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

func NewUnary

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