sources

package

v0.5.0 Latest Latest Go to latest Published: May 6, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

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

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

func GetIAMPrincipalEmailFromADC(ctx context.Context) (string, error)

GetIAMPrincipalEmailFromADC finds the email associated with ADC

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.