initialisation

Documentation

Index

• func GetDbClient(ctx context.Context, invoker constants.Invoker, ...) (client db_common.Client, err error)
• type InitData
  • func NewErrorInitData(err error) *InitData
  • func NewInitData(w *workspace.Workspace) *InitData
  • func (i *InitData) Cleanup(ctx context.Context)
  • func (i *InitData) Init(ctx context.Context, invoker constants.Invoker) (res *InitData)
  • func (i *InitData) RegisterExporters(exporters ...*export.SnapshotExporter) *InitData

Functions

func GetDbClient

func GetDbClient(ctx context.Context, invoker constants.Invoker, onConnectionCallback db_client.DbConnectionCallback) (client db_common.Client, err error)

GetDbClient either creates a DB client using the configured connection string (if present) or creates a LocalDbClient

Types

type InitData

type InitData struct {
	Workspace *workspace.Workspace
	Client    db_common.Client
	Result    *db_common.InitResult

	// used for query only
	PreparedStatementSource *modconfig.ResourceMaps

	ShutdownTelemetry func()
	ExportResolver    *export.Resolver
}

func NewErrorInitData

func NewErrorInitData(err error) *InitData

func NewInitData

func NewInitData(w *workspace.Workspace) *InitData

func (*InitData) Cleanup

func (i *InitData) Cleanup(ctx context.Context)

func (*InitData) Init

func (i *InitData) Init(ctx context.Context, invoker constants.Invoker) (res *InitData)

func (*InitData) RegisterExporters

func (i *InitData) RegisterExporters(exporters ...*export.SnapshotExporter) *InitData