sources

package

v0.0.5 Latest Latest Go to latest Published: Jan 14, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func InitConnectionSpan(ctx context.Context, tracer trace.Tracer, sourceKind, sourceName string) (context.Context, trace.Span)

InitConnectionSpan adds a span for database pool connection initialization

type Dialect string

Dialect represents the dialect type of a database.

func (i *Dialect) String() string

func (i *Dialect) UnmarshalYAML(node *yaml.Node) error

type IPType string

func (i *IPType) String() string

func (i *IPType) UnmarshalYAML(node *yaml.Node) error

type Source interface {
	SourceKind() string
}

Source is the interface for the source itself.

type SourceConfig interface {
	SourceConfigKind() string
	Initialize(ctx context.Context, tracer trace.Tracer) (Source, error)
}

SourceConfig is the interface for configuring a source.