service

type DataSourceMetadata struct {
	Type         string `json:"type"`
	ProviderAuth bool   `json:"providerAuth"`
}

type DataSourcesService interface {
	// GetByName returns a data source by name.
	GetByName(ctx context.Context, name string, project uuid.UUID, opts *ReadOptions) (*minderv1.DataSource, error)

	// GetByID returns a data source by ID.
	GetByID(ctx context.Context, id uuid.UUID, project uuid.UUID, opts *ReadOptions) (*minderv1.DataSource, error)

	// List lists all data sources in the given project.
	List(ctx context.Context, project uuid.UUID, opts *ReadOptions) ([]*minderv1.DataSource, error)

	// Create creates a new data source.
	Create(
		ctx context.Context,
		projectID uuid.UUID,
		subscriptionID uuid.UUID,
		ds *minderv1.DataSource,
		opts *Options,
	) (*minderv1.DataSource, error)

	// Update updates an existing data source.
	Update(
		ctx context.Context,
		projectID uuid.UUID,
		subscriptionID uuid.UUID,
		ds *minderv1.DataSource,
		opts *Options,
	) (*minderv1.DataSource, error)

	// Upsert creates a new data source if it does not exist or updates it if it already exists.
	// This is used in the subscription logic.
	Upsert(ctx context.Context, projectID uuid.UUID, subscriptionID uuid.UUID, ds *minderv1.DataSource, opts *Options) error

	// Delete deletes a data source in the given project.
	//
	// Note that one cannot delete a data source that is in use by a rule type.
	Delete(ctx context.Context, id uuid.UUID, project uuid.UUID, opts *Options) error

	// BuildDataSourceRegistry bundles up all data sources referenced in the rule type
	// into a registry.
	BuildDataSourceRegistry(ctx context.Context, rt *minderv1.RuleType, opts *Options) (*v1datasources.DataSourceRegistry, error)
}

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

type ReadOptions struct {
	Options
	// contains filtered or unexported fields
}