Documentation
¶
Index ¶
- Constants
- type Config
- type Source
- func (s *Source) DatabaseDialect() string
- func (s *Source) GetCatalogClient(ctx context.Context, tokenString string) (*dataplexapi.CatalogClient, error)
- func (s *Source) InvokeSearchCatalog(ctx context.Context, params map[string]any, tokenStr string) ([]searchcatalog.DataplexSearchResponse, error)
- func (s *Source) IsReadOnly() bool
- func (s *Source) ProjectID() string
- func (s *Source) RunSQL(ctx context.Context, readOnly bool, statement string, params map[string]any) (any, error)
- func (s *Source) SourceType() string
- func (s *Source) SpannerClient() *spanner.Client
- func (s *Source) ToConfig() sources.SourceConfig
- func (s *Source) UseClientAuthorization() bool
Constants ¶
View Source
const InstanceTypeOmni = "omni"
InstanceTypeOmni selects a Spanner Omni deployment instead of Cloud Spanner.
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 and Instance are required for Cloud Spanner and optional for
// Spanner Omni.
Project string `yaml:"project"`
Instance string `yaml:"instance"`
Dialect sources.Dialect `yaml:"dialect" validate:"required"`
Database string `yaml:"database" validate:"required"`
UseClientOAuth bool `yaml:"useClientOAuth"`
// InstanceType is "cloud" (default) or "omni". The omni-prefixed fields
// apply only to Spanner Omni.
InstanceType string `yaml:"instanceType" validate:"omitempty,oneof=cloud omni"`
OmniEndpoint string `yaml:"omniEndpoint"`
OmniUsePlainText bool `yaml:"omniUsePlainText"`
OmniCaCertificateFile string `yaml:"omniCaCertificateFile"`
OmniClientCertificateFile string `yaml:"omniClientCertificateFile"`
OmniClientKeyFile string `yaml:"omniClientKeyFile"`
OmniUsername string `yaml:"omniUsername"`
OmniPassword string `yaml:"omniPassword"`
}
func (Config) Initialize ¶
func (Config) SourceConfigType ¶
type Source ¶
func (*Source) DatabaseDialect ¶
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) IsReadOnly ¶ added in v1.10.0
func (*Source) SourceType ¶
func (*Source) SpannerClient ¶
func (*Source) ToConfig ¶
func (s *Source) ToConfig() sources.SourceConfig
func (*Source) UseClientAuthorization ¶ added in v1.4.0
Click to show internal directories.
Click to hide internal directories.