Documentation
¶
Index ¶
- Constants
- type Config
- type Source
- func (s *Source) CatalogClient() *dataplexapi.CatalogClient
- func (s *Source) GetDataScanClient() *dataplexapi.DataScanClient
- func (s *Source) LookupContext(ctx context.Context, name string, resources []string) (*dataplexpb.LookupContextResponse, error)
- func (s *Source) LookupEntry(ctx context.Context, name string, view int, aspectTypes []string, entry string) (*dataplexpb.Entry, error)
- func (s *Source) ProjectID() string
- func (s *Source) SearchAspectTypes(ctx context.Context, query string, pageSize int, orderBy string) ([]*dataplexpb.AspectType, error)
- func (s *Source) SearchDataQualityScans(ctx context.Context, filter string, pageSize int, orderBy string) ([]*dataplexpb.DataScan, error)
- func (s *Source) SearchEntries(ctx context.Context, query string, pageSize int, orderBy string, scope string) ([]*dataplexpb.SearchEntriesResult, error)
- func (s *Source) SourceType() string
- func (s *Source) ToConfig() sources.SourceConfig
Constants ¶
View Source
const SourceType string = "dataplex"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
// Dataplex configs
Name string `yaml:"name" validate:"required"`
Type string `yaml:"type" validate:"required"`
Project string `yaml:"project" validate:"required"`
}
func (Config) Initialize ¶
func (Config) SourceConfigType ¶
type Source ¶
type Source struct {
Config
Client *dataplexapi.CatalogClient
DataScanClient *dataplexapi.DataScanClient
}
func (*Source) CatalogClient ¶
func (s *Source) CatalogClient() *dataplexapi.CatalogClient
func (*Source) GetDataScanClient ¶ added in v1.2.0
func (s *Source) GetDataScanClient() *dataplexapi.DataScanClient
func (*Source) LookupContext ¶
func (s *Source) LookupContext(ctx context.Context, name string, resources []string) (*dataplexpb.LookupContextResponse, error)
func (*Source) LookupEntry ¶
func (*Source) SearchAspectTypes ¶
func (s *Source) SearchAspectTypes(ctx context.Context, query string, pageSize int, orderBy string) ([]*dataplexpb.AspectType, error)
func (*Source) SearchDataQualityScans ¶ added in v1.2.0
func (*Source) SearchEntries ¶
func (s *Source) SearchEntries(ctx context.Context, query string, pageSize int, orderBy string, scope string) ([]*dataplexpb.SearchEntriesResult, error)
func (*Source) SourceType ¶
func (*Source) ToConfig ¶
func (s *Source) ToConfig() sources.SourceConfig
Source Files
Click to show internal directories.
Click to hide internal directories.