setup

Documentation

Index

• func TestPool() *pgxpool.Pool
• func TruncateTablesWith(pool *pgxpool.Pool)
• type DummyJobBuilder
  • func NewDummyJobBuilder() *DummyJobBuilder
  • func (d *DummyJobBuilder) Build(tnnt tenant.Tenant) *job.Job
  • func (d *DummyJobBuilder) OverrideAlertChannelNames(alertChannelNames []string) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideAlertConfig(alertConfig job.Config) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideAlertName(alertName string) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideAsset(asset map[string]string) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideDescription(description string) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideDestinationURN(destinationURN job.ResourceURN) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideHookConfig(hookConfig job.Config) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideHookName(hookName string) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideLabels(labels map[string]string) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideName(name job.Name) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideOwner(owner string) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideResourceLimitConfig(config *job.MetadataResourceConfig) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideResourceRequestConfig(config *job.MetadataResourceConfig) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideRetry(retry *job.Retry) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideScheduler(scheduler map[string]string) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideSourceURNs(sourceURNs []job.ResourceURN) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideSpecHTTPUpstreams(specHTTPUpstreams []*job.SpecHTTPUpstream) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideSpecUpstreamNames(specUpstreamNames []job.SpecUpstreamName) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideStartDate(startDate job.ScheduleDate) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideTaskConfig(taskConfig job.Config) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideTaskName(taskName job.TaskName) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideVersion(version int) *DummyJobBuilder
  • func (d *DummyJobBuilder) OverrideWindow(window models.Window) *DummyJobBuilder
• type MockPluginBQ
  • func (MockPluginBQ) CompileAssets(_ context.Context, _ plugin.CompileAssetsRequest) (*plugin.CompileAssetsResponse, error)
  • func (MockPluginBQ) GenerateDependencies(_ context.Context, req plugin.GenerateDependenciesRequest) (*plugin.GenerateDependenciesResponse, error)
  • func (MockPluginBQ) GenerateDestination(_ context.Context, request plugin.GenerateDestinationRequest) (*plugin.GenerateDestinationResponse, error)
  • func (MockPluginBQ) GetName(_ context.Context) (string, error)

Functions

func TestPool

func TestPool() *pgxpool.Pool

func TruncateTablesWith

func TruncateTablesWith(pool *pgxpool.Pool)

Types

type DummyJobBuilder

type DummyJobBuilder struct {
	// contains filtered or unexported fields
}

func NewDummyJobBuilder

func NewDummyJobBuilder() *DummyJobBuilder

func (*DummyJobBuilder) Build

func (d *DummyJobBuilder) Build(tnnt tenant.Tenant) *job.Job

func (*DummyJobBuilder) OverrideAlertChannelNames

func (d *DummyJobBuilder) OverrideAlertChannelNames(alertChannelNames []string) *DummyJobBuilder

func (*DummyJobBuilder) OverrideAlertConfig

func (d *DummyJobBuilder) OverrideAlertConfig(alertConfig job.Config) *DummyJobBuilder

func (*DummyJobBuilder) OverrideAlertName

func (d *DummyJobBuilder) OverrideAlertName(alertName string) *DummyJobBuilder

func (*DummyJobBuilder) OverrideAsset

func (d *DummyJobBuilder) OverrideAsset(asset map[string]string) *DummyJobBuilder

func (*DummyJobBuilder) OverrideDescription

func (d *DummyJobBuilder) OverrideDescription(description string) *DummyJobBuilder

func (*DummyJobBuilder) OverrideDestinationURN

func (d *DummyJobBuilder) OverrideDestinationURN(destinationURN job.ResourceURN) *DummyJobBuilder

func (*DummyJobBuilder) OverrideHookConfig

func (d *DummyJobBuilder) OverrideHookConfig(hookConfig job.Config) *DummyJobBuilder

func (*DummyJobBuilder) OverrideHookName

func (d *DummyJobBuilder) OverrideHookName(hookName string) *DummyJobBuilder

func (*DummyJobBuilder) OverrideLabels

func (d *DummyJobBuilder) OverrideLabels(labels map[string]string) *DummyJobBuilder

func (*DummyJobBuilder) OverrideName

func (d *DummyJobBuilder) OverrideName(name job.Name) *DummyJobBuilder

func (*DummyJobBuilder) OverrideOwner

func (d *DummyJobBuilder) OverrideOwner(owner string) *DummyJobBuilder

func (*DummyJobBuilder) OverrideResourceLimitConfig

func (d *DummyJobBuilder) OverrideResourceLimitConfig(config *job.MetadataResourceConfig) *DummyJobBuilder

func (*DummyJobBuilder) OverrideResourceRequestConfig

func (d *DummyJobBuilder) OverrideResourceRequestConfig(config *job.MetadataResourceConfig) *DummyJobBuilder

func (*DummyJobBuilder) OverrideRetry

func (d *DummyJobBuilder) OverrideRetry(retry *job.Retry) *DummyJobBuilder

func (*DummyJobBuilder) OverrideScheduler

func (d *DummyJobBuilder) OverrideScheduler(scheduler map[string]string) *DummyJobBuilder

func (*DummyJobBuilder) OverrideSourceURNs

func (d *DummyJobBuilder) OverrideSourceURNs(sourceURNs []job.ResourceURN) *DummyJobBuilder

func (*DummyJobBuilder) OverrideSpecHTTPUpstreams

func (d *DummyJobBuilder) OverrideSpecHTTPUpstreams(specHTTPUpstreams []*job.SpecHTTPUpstream) *DummyJobBuilder

func (*DummyJobBuilder) OverrideSpecUpstreamNames

func (d *DummyJobBuilder) OverrideSpecUpstreamNames(specUpstreamNames []job.SpecUpstreamName) *DummyJobBuilder

func (*DummyJobBuilder) OverrideStartDate

func (d *DummyJobBuilder) OverrideStartDate(startDate job.ScheduleDate) *DummyJobBuilder

func (*DummyJobBuilder) OverrideTaskConfig

func (d *DummyJobBuilder) OverrideTaskConfig(taskConfig job.Config) *DummyJobBuilder

func (*DummyJobBuilder) OverrideTaskName

func (d *DummyJobBuilder) OverrideTaskName(taskName job.TaskName) *DummyJobBuilder

func (*DummyJobBuilder) OverrideVersion

func (d *DummyJobBuilder) OverrideVersion(version int) *DummyJobBuilder

func (*DummyJobBuilder) OverrideWindow

func (d *DummyJobBuilder) OverrideWindow(window models.Window) *DummyJobBuilder

type MockPluginBQ

type MockPluginBQ struct{}

func (MockPluginBQ) CompileAssets

func (MockPluginBQ) CompileAssets(_ context.Context, _ plugin.CompileAssetsRequest) (*plugin.CompileAssetsResponse, error)

func (MockPluginBQ) GenerateDependencies

func (MockPluginBQ) GenerateDependencies(_ context.Context, req plugin.GenerateDependenciesRequest) (*plugin.GenerateDependenciesResponse, error)

func (MockPluginBQ) GenerateDestination

func (MockPluginBQ) GenerateDestination(_ context.Context, request plugin.GenerateDestinationRequest) (*plugin.GenerateDestinationResponse, error)

func (MockPluginBQ) GetName

func (MockPluginBQ) GetName(_ context.Context) (string, error)