spanner

package
v1.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 4, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const SourceType string = "spanner"

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	Name           string          `yaml:"name" validate:"required"`
	Type           string          `yaml:"type" validate:"required"`
	Project        string          `yaml:"project" validate:"required"`
	Instance       string          `yaml:"instance" validate:"required"`
	Dialect        sources.Dialect `yaml:"dialect" validate:"required"`
	Database       string          `yaml:"database" validate:"required"`
	UseClientOAuth bool            `yaml:"useClientOAuth"`
}

func (Config) Initialize

func (r Config) Initialize(ctx context.Context, tracer trace.Tracer) (sources.Source, error)

func (Config) SourceConfigType

func (r Config) SourceConfigType() string

type Source

type Source struct {
	Config
	Client *spanner.Client
	// contains filtered or unexported fields
}

func (*Source) DatabaseDialect

func (s *Source) DatabaseDialect() string

func (*Source) GetCatalogClient added in v1.4.0

func (s *Source) GetCatalogClient(ctx context.Context, tokenString string) (*dataplexapi.CatalogClient, error)

func (*Source) InvokeSearchCatalog added in v1.4.0

func (s *Source) InvokeSearchCatalog(ctx context.Context, params map[string]any, tokenStr string) ([]searchcatalog.DataplexSearchResponse, error)

func (*Source) ProjectID added in v1.4.0

func (s *Source) ProjectID() string

func (*Source) RunSQL

func (s *Source) RunSQL(ctx context.Context, readOnly bool, statement string, params map[string]any) (any, error)

func (*Source) SourceType

func (s *Source) SourceType() string

func (*Source) SpannerClient

func (s *Source) SpannerClient() *spanner.Client

func (*Source) ToConfig

func (s *Source) ToConfig() sources.SourceConfig

func (*Source) UseClientAuthorization added in v1.4.0

func (s *Source) UseClientAuthorization() bool

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL