datasource

Documentation

Index

• func GetDatasourceID(ctx context.Context) int64
• func GetDatasourceLastUpdatedTime(ctx context.Context) string
• type AWSClient
  • func New(loader Loader) AWSClient
• type Loader

Functions

func GetDatasourceID

func GetDatasourceID(ctx context.Context) int64

func GetDatasourceLastUpdatedTime

func GetDatasourceLastUpdatedTime(ctx context.Context) string

Types

type AWSClient

type AWSClient interface {
	Init(config backend.DataSourceInstanceSettings)
	GetDB(ctx context.Context, id int64, options sqlds.Options) (*sql.DB, error)
	GetAsyncDB(ctx context.Context, id int64, options sqlds.Options) (awsds.AsyncDB, error)
	GetAPI(ctx context.Context, id int64, options sqlds.Options) (api.AWSAPI, error)
}

AWSClient provides creation and caching of sessions, database connections, and API clients

func New

func New(loader Loader) AWSClient

type Loader

type Loader interface {
	LoadSettings(context.Context) models.Settings
	LoadAPI(context.Context, *awsds.SessionCache, models.Settings) (api.AWSAPI, error)
	LoadDriver(context.Context, api.AWSAPI) (driver.Driver, error)
	LoadAsyncDriver(context.Context, api.AWSAPI) (asyncDriver.Driver, error)
}