plugin

Oct 30, 2025

Changes in this version

+ func GetConfigType(raw RawPluginConfig, source Source) interface

type DiscoveryResult

+ Statistics []Statistic

+ type Statistic struct

+ AssetMRN string

+ MetricName string

+ Value float64

Sep 25, 2025

Changes in this version

+ const SensitiveMask

type Config

+ Name string

type MetadataField

+ Sensitive bool

type RawPluginConfig

+ func (r RawPluginConfig) MaskSensitiveFields(configStruct interface{}) RawPluginConfig

+ type Run struct

+ CompletedAt *time.Time

+ Config RawPluginConfig

+ CreatedBy string

+ ErrorMessage string

+ ID string

+ PipelineName string

+ RunID string

+ SourceName string

+ StartedAt time.Time

+ Status RunStatus

+ Summary *RunSummary

+ type RunCheckpoint struct

+ CreatedAt time.Time

+ EntityMRN string

+ EntityType string

+ ID string

+ Operation string

+ RunID string

+ SourceFields []string

+ type RunStatus string

+ const StatusCancelled

+ const StatusCompleted

+ const StatusFailed

+ const StatusRunning

+ type RunSummary struct

+ AssetsCreated int

+ AssetsDeleted int

+ AssetsUpdated int

+ DocumentationAdded int

+ DurationSeconds int

+ ErrorsCount int

+ LineageCreated int

+ LineageUpdated int

+ TotalEntities int

+ type StatefulRunContext struct

+ CurrentRunID string

+ LastRunCheckpoints map[string]*RunCheckpoint

+ PipelineName string

+ SourceName string

+ type StatefulSource interface

+ SupportsStatefulIngestion func() bool

Jun 9, 2025

Changes in this version

+ var ErrEndpointNotFound = fmt.Errorf("endpoint not found")

type AWSConfig

+ func ExtractAWSConfig(rawConfig map[string]interface{}) (*AWSConfig, error)

+ func (a *AWSConfig) NewAWSConfig(ctx context.Context) (aws.Config, error)

type RawPluginConfig

+ func (c RawPluginConfig) MaskSensitiveInfo(sensitiveValues ...string) RawPluginConfig

Apr 4, 2025

Changes in this version

+ func InterpolateTags(tags TagsConfig, metadata map[string]interface{}) []string

+ func MapToMetadata(source interface{}) map[string]interface

+ func NewAWSConfig(ctx context.Context, rawConfig map[string]interface{}) (aws.Config, error)

+ func ProcessAWSTags(tagsToMetadata bool, includeTags []string, tags map[string]string) map[string]interface

+ func ShouldIncludeResource(name string, filter Filter) bool

+ func UnmarshalPluginConfig[T any](raw RawPluginConfig) (*T, error)

+ type AWSConfig struct

+ Credentials AWSCredentials

+ Filter Filter

+ IncludeTags []string

+ TagsToMetadata bool

+ func (a *AWSConfig) Validate() error

+ type AWSCredentials struct

+ Endpoint string

+ ID string

+ Profile string

+ Region string

+ Role string

+ RoleExternalID string

+ Secret string

+ Token string

+ type AWSPlugin struct

+ type BaseConfig struct

+ AWSConfig *AWSConfig

+ ExternalLinks []ExternalLink

+ GlobalDocumentation []string

+ GlobalDocumentationPosition string

+ Merge MergeConfig

+ Metadata MetadataConfig

+ Tags TagsConfig

+ type Config struct

+ Runs []SourceRun

+ type DiscoveryResult struct

+ Assets []asset.Asset

+ Documentation []assetdocs.Documentation

+ Lineage []lineage.LineageEdge

+ type ExternalLink struct

+ Icon string

+ Name string

+ URL string

+ type FieldMergeConfig struct

+ Filter MetadataFilter

+ Priority int

+ Strategy MergeStrategy

+ type Filter struct

+ Exclude []string

+ Include []string

+ type MergeConfig struct

+ Description string

+ Metadata string

+ Name string

+ Tags string

+ type MergePolicy struct

+ Fields map[string]FieldMergeConfig

+ MetadataMapping []MetadataMapping

+ MetadataRules MetadataRules

+ Strategy MergeStrategy

+ type MergeStrategy string

+ const MergeStrategyAppend

+ const MergeStrategyKeepFirst

+ const MergeStrategyMerge

+ const MergeStrategyOverwrite

+ type MetadataConfig struct

+ Allow []string

+ type MetadataField struct

+ Description string

+ Path string

+ Required bool

+ Type string

+ func GetMetadataFields(v interface{}) []MetadataField

+ type MetadataFilter struct

+ Mode string

+ Prefixes []string

+ Props []string

+ type MetadataMapping struct

+ DefaultValue any

+ Source string

+ Target string

+ Type string

+ type MetadataRules struct

+ Environment MetadataFilter

+ Merge MetadataFilter

+ type PluginConfig struct

+ Source string

+ type RawPluginConfig map[string]interface

+ type Source interface

+ Discover func(ctx context.Context, config RawPluginConfig) (*DiscoveryResult, error)

+ Validate func(config RawPluginConfig) error

+ type SourceRun map[string]RawPluginConfig

+ type TagsConfig []string