writer

Documentation

Index

• func RegisterMetrics(r metrics.Registerer)
• type QueryOption
  • func WithLogger(l *zap.Logger) QueryOption
  • func WithMetrics(r metrics.Registerer) QueryOption
• type Writer
  • func NewWriter(ctx context.Context, project, dataset, table string, ...) (Writer, error)

Functions

func RegisterMetrics

func RegisterMetrics(r metrics.Registerer)

Types

type QueryOption

type QueryOption func(*options)

func WithLogger

func WithLogger(l *zap.Logger) QueryOption

func WithMetrics

func WithMetrics(r metrics.Registerer) QueryOption

type Writer

type Writer interface {
	AppendRows(ctx context.Context, batches [][][]byte) ([]int, error)
	Close() error
}

func NewWriter

func NewWriter(
	ctx context.Context,
	project, dataset, table string,
	desc protoreflect.MessageDescriptor,
	opts ...QueryOption,
) (Writer, error)