Versions in this module Expand all Collapse all v1 v1.117.0 Jul 29, 2026 Changes in this version + type DataHubGetEntityFunc func(ctx context.Context, urn string) (any, error) + type DataHubGetGlossaryTermFunc func(ctx context.Context, urn string) (any, error) + type DataHubSource struct + func NewDataHubSource(getEntity DataHubGetEntityFunc, getGlossaryTerm DataHubGetGlossaryTermFunc) *DataHubSource + func (*DataHubSource) Name() string + func (*DataHubSource) Operations() []string + func (s *DataHubSource) Execute(ctx context.Context, op string, params map[string]any) (any, error) + type TrinoQueryFunc func(ctx context.Context, connection, sql string) ([]map[string]any, error) + type TrinoSource struct + func NewTrinoSource(exec TrinoQueryFunc) *TrinoSource + func (*TrinoSource) Name() string + func (*TrinoSource) Operations() []string + func (s *TrinoSource) Execute(ctx context.Context, op string, params map[string]any) (any, error)
Go to main page