Versions in this module Expand all Collapse all v0 v0.3.0 Sep 1, 2026 Changes in this version + func GetAvailableSchemaProviderTypes() []string + func GetAvailableSourceTypes() []string + func RegisterSchemaProvider(providerType string, factory SchemaProviderFactory) error + func RegisterSourceType(sourceType string, factory SourceFactory) error + func ResolveSchemaPath(config SchemaSourceConfig, path string) string + func SetGlobalMetrics(metrics SourceMetrics) + type AcknowledgementBarrier struct + func NewAcknowledgementBarrier(count int, commit func(context.Context) error) *AcknowledgementBarrier + func (barrier *AcknowledgementBarrier) Callback(index int) func(context.Context) error + func (barrier *AcknowledgementBarrier) Wait(ctx context.Context) error + type ConfigProperty struct + Default interface{} + Description string + Examples []string + Type string + type ConfigSchema struct + Properties map[string]ConfigProperty + Required []string + type DefaultSchemaProviderRegistry struct + func NewDefaultSchemaProviderRegistry() *DefaultSchemaProviderRegistry + func (r *DefaultSchemaProviderRegistry) CreateProvider(config SchemaSourceConfig) (SchemaProvider, error) + func (r *DefaultSchemaProviderRegistry) GetAvailableTypes() []string + func (r *DefaultSchemaProviderRegistry) GetTypeInfo(providerType string) SchemaProviderTypeInfo + func (r *DefaultSchemaProviderRegistry) RegisterSchemaProvider(providerType string, factory SchemaProviderFactory) error + type DefaultSourceMetrics struct + func (d *DefaultSourceMetrics) RecordError(sourceID, operation string, err error) + func (d *DefaultSourceMetrics) RecordFactProcessed(sourceID, factType string) + func (d *DefaultSourceMetrics) RecordHealthCheck(sourceID string, healthy bool) + func (d *DefaultSourceMetrics) RecordLatency(sourceID string, duration time.Duration) + type DefaultSourceRegistry struct + func NewDefaultSourceRegistry() *DefaultSourceRegistry + func (r *DefaultSourceRegistry) CreateSource(config SourceConfig) (FactSource, error) + func (r *DefaultSourceRegistry) GetAvailableTypes() []string + func (r *DefaultSourceRegistry) GetTypeInfo(sourceType string) SourceTypeInfo + func (r *DefaultSourceRegistry) RegisterSourceType(sourceType string, factory SourceFactory) error + type FactMapping struct + EffectusType string + SchemaVersion string + SourceKey string + type FactSource interface + GetMetadata func() SourceMetadata + GetSourceSchema func() *Schema + HealthCheck func() error + Start func(ctx context.Context) error + Stop func(ctx context.Context) error + Subscribe func(ctx context.Context, factTypes []string) (<-chan *TypedFact, error) + func CreateSource(config SourceConfig) (FactSource, error) + type FormatConverter interface + CanConvert func(sourceFormat, targetFormat string) bool + Convert func(rawData []byte, targetSchema *Schema) (proto.Message, error) + GetSupportedFormats func() []string + type Schema struct + Fields map[string]interface{} + Name string + Version string + type SchemaDefinition struct + Data []byte + Format SchemaFormat + Name string + Source string + Version string + type SchemaFormat string + const SchemaFormatAuto + const SchemaFormatEffectus + const SchemaFormatJSONSchema + const SchemaFormatProto + type SchemaProvider interface + Close func() error + LoadSchemas func(ctx context.Context) ([]SchemaDefinition, error) + func CreateSchemaProvider(config SchemaSourceConfig) (SchemaProvider, error) + type SchemaProviderFactory interface + Create func(config SchemaSourceConfig) (SchemaProvider, error) + GetConfigSchema func() ConfigSchema + ValidateConfig func(config SchemaSourceConfig) error + type SchemaProviderRegistry interface + CreateProvider func(config SchemaSourceConfig) (SchemaProvider, error) + GetAvailableTypes func() []string + GetTypeInfo func(providerType string) SchemaProviderTypeInfo + RegisterSchemaProvider func(providerType string, factory SchemaProviderFactory) error + type SchemaProviderTypeInfo struct + Capabilities []string + ConfigSchema ConfigSchema + Description string + Examples []string + Type string + type SchemaSourceConfig struct + BaseDir string + Config map[string]interface{} + Name string + Namespace string + Type string + Version string + type SourceConfig struct + Config map[string]interface{} + Mappings []FactMapping + SourceID string + Tags []string + Transforms []Transformation + Type string + type SourceError struct + Cause error + Message string + Operation string + SourceID string + func NewSourceError(sourceID, operation, message string, cause error) *SourceError + func (e *SourceError) Error() string + func (e *SourceError) Unwrap() error + type SourceFactory interface + Create func(config SourceConfig) (FactSource, error) + GetConfigSchema func() ConfigSchema + ValidateConfig func(config SourceConfig) error + type SourceMetadata struct + Capabilities []string + Config map[string]string + SchemaFormats []string + SourceID string + SourceType string + Tags []string + Version string + type SourceMetrics interface + RecordError func(sourceID, operation string, err error) + RecordFactProcessed func(sourceID, factType string) + RecordHealthCheck func(sourceID string, healthy bool) + RecordLatency func(sourceID string, duration time.Duration) + func GetGlobalMetrics() SourceMetrics + type SourceRegistry interface + CreateSource func(config SourceConfig) (FactSource, error) + GetAvailableTypes func() []string + GetTypeInfo func(sourceType string) SourceTypeInfo + RegisterSourceType func(sourceType string, factory SourceFactory) error + type SourceTypeInfo struct + Capabilities []string + ConfigSchema ConfigSchema + Description string + Examples []string + Type string + type Transformation struct + Mapping map[string]string + SourcePath string + TargetType string + type TypedFact struct + Acknowledge func(context.Context) error + Data proto.Message + Metadata map[string]string + RawData []byte + SchemaName string + SchemaVersion string + SourceID string + SpanID string + Timestamp time.Time + TraceID string
Go to main page