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) 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 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 (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) 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.