datasources

package
v0.0.1-test Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 6, 2022 License: AGPL-3.0 Imports: 16 Imported by: 95

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// ErrInvalidConfigToManyDefault indicates that multiple datasource in the provisioning files
	// contains more than one datasource marked as default.
	ErrInvalidConfigToManyDefault = errors.New("datasource.yaml config is invalid. Only one datasource per organization can be marked as default")
)

Functions

func Provision

func Provision(ctx context.Context, configDirectory string, store Store, correlationsStore CorrelationsStore, orgStore utils.OrgStore) error

Provision scans a directory for provisioning config files and provisions the datasource in those files.

Types

type CorrelationsStore

type CorrelationsStore interface {
	DeleteCorrelationsByTargetUID(ctx context.Context, cmd correlations.DeleteCorrelationsByTargetUIDCommand) error
	DeleteCorrelationsBySourceUID(ctx context.Context, cmd correlations.DeleteCorrelationsBySourceUIDCommand) error
	CreateCorrelation(ctx context.Context, cmd correlations.CreateCorrelationCommand) (correlations.Correlation, error)
}

type DatasourceProvisioner

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

DatasourceProvisioner is responsible for provisioning datasources based on configuration read by the `configReader`

type Store

type Store interface {
	GetDataSource(ctx context.Context, query *datasources.GetDataSourceQuery) error
	AddDataSource(ctx context.Context, cmd *datasources.AddDataSourceCommand) error
	UpdateDataSource(ctx context.Context, cmd *datasources.UpdateDataSourceCommand) error
	DeleteDataSource(ctx context.Context, cmd *datasources.DeleteDataSourceCommand) error
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL