sources

package

v0.3.0 Latest Latest Go to latest Published: Apr 4, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func GetCloudSQLOpts(ipType, userAgent string) ([]cloudsqlconn.Option, error)

GetCloudSQLDialOpts retrieve dial options with the right ip type and user agent for cloud sql databases.

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(ctx context.Context, unmarshal func(interface{}) error) error

type IPType string

func (i *IPType) String() string

func (i *IPType) UnmarshalYAML(ctx context.Context, unmarshal func(interface{}) error) 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.