plugin

Jan 4, 2026

Changes in this version

+ func DecryptConfig(config map[string]interface{}, configSpec []ConfigField, ...) error

+ func DecryptConfigForPlugin(pluginID string, config map[string]interface{}, encryptor *crypto.Encryptor) error

+ func EncryptConfig(config map[string]interface{}, configSpec []ConfigField, ...) error

+ func EncryptConfigForPlugin(pluginID string, config map[string]interface{}, encryptor *crypto.Encryptor) error

+ func GetSensitiveFields(configSpec []ConfigField) map[string]bool

+ func GetValidator() *validator.Validate

+ func ValidateStruct(s interface{}) error

+ type AWSCredentialStatus struct

+ Available bool

+ Error string

+ Sources []string

+ func DetectAWSCredentials(ctx context.Context) *AWSCredentialStatus

type AWSCredentials

+ UseDefault bool

+ type AssetRunHistory struct

+ AssetMRN string

+ Runs []RunHistoryEvent

+ type ConfigField struct

+ Default interface{}

+ Description string

+ Fields []ConfigField

+ IsArray bool

+ Label string

+ Name string

+ Options []FieldOption

+ Placeholder string

+ Required bool

+ Sensitive bool

+ Type FieldType

+ Validation *Validation

+ func GenerateConfigSpec(configType interface{}) []ConfigField

type DiscoveryResult

+ RunHistory []AssetRunHistory

+ type FieldOption struct

+ Label string

+ Value string

+ type FieldType string

+ const FieldTypeBool

+ const FieldTypeInt

+ const FieldTypeMultiselect

+ const FieldTypeObject

+ const FieldTypePassword

+ const FieldTypeSelect

+ const FieldTypeString

+ type PluginMeta struct

+ Category string

+ ConfigSpec []ConfigField

+ Description string

+ ID string

+ Icon string

+ Name string

type RawPluginConfig

+ func MaskSensitiveFieldsFromSpec(config RawPluginConfig, configSpec []ConfigField) RawPluginConfig

+ type Registry struct

+ func GetRegistry() *Registry

+ func (r *Registry) Get(id string) (*RegistryEntry, error)

+ func (r *Registry) GetSource(id string) (Source, error)

+ func (r *Registry) List() []PluginMeta

+ func (r *Registry) Register(meta PluginMeta, source Source) error

+ type RegistryEntry struct

+ Meta PluginMeta

+ Source Source

+ type RunHistoryEvent struct

+ EventTime time.Time

+ EventType string

+ JobFacets map[string]interface{}

+ JobName string

+ JobNamespace string

+ RunFacets map[string]interface{}

+ RunID string

+ type Validation struct

+ Max *int

+ MaxLen *int

+ Min *int

+ MinLen *int

+ Pattern string

+ type ValidationError struct

+ Field string

+ Message string

+ type ValidationErrors struct

+ Errors []ValidationError

+ func (v ValidationErrors) Error() string

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