service

package
v0.0.0-cloud Latest Latest
Warning

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

 Go to latest Published: Mar 30, 2023 License: AGPL-3.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultCacheTTL = 5 * time.Second
)

Variables

This section is empty.

Functions

func NewIDScopeResolver 

func NewIDScopeResolver(db DataSourceRetriever) (string, accesscontrol.ScopeAttributeResolver)

NewIDScopeResolver provides an ScopeAttributeResolver able to translate a scope prefixed with "datasources:id:" into an uid based scope.

func NewNameScopeResolver 

func NewNameScopeResolver(db DataSourceRetriever) (string, accesscontrol.ScopeAttributeResolver)

NewNameScopeResolver provides an ScopeAttributeResolver able to translate a scope prefixed with "datasources:name:" into an uid based scope.

Types

type CacheServiceImpl 

type CacheServiceImpl struct {
	CacheService *localcache.CacheService
	SQLStore     db.DB
	// contains filtered or unexported fields
}

func ProvideCacheService 

func ProvideCacheService(cacheService *localcache.CacheService, sqlStore db.DB) *CacheServiceImpl

func (*CacheServiceImpl) GetDatasource 

func (dc *CacheServiceImpl) GetDatasource(
	ctx context.Context,
	datasourceID int64,
	user *user.SignedInUser,
	skipCache bool,
) (*datasources.DataSource, error)

func (*CacheServiceImpl) GetDatasourceByUID 

func (dc *CacheServiceImpl) GetDatasourceByUID(
	ctx context.Context,
	datasourceUID string,
	user *user.SignedInUser,
	skipCache bool,
) (*datasources.DataSource, error)

type DataSourceRetriever 

type DataSourceRetriever interface {
	// GetDataSource gets a datasource.
	GetDataSource(ctx context.Context, query *datasources.GetDataSourceQuery) (*datasources.DataSource, error)
}

DataSourceRetriever interface for retrieving a datasource.

type Service 

type Service struct {
	SQLStore       Store
	SecretsStore   kvstore.SecretsKVStore
	SecretsService secrets.Service
	// contains filtered or unexported fields
}

func ProvideService 

func ProvideService(
	db db.DB, secretsService secrets.Service, secretsStore kvstore.SecretsKVStore, cfg *setting.Cfg,
	features featuremgmt.FeatureToggles, ac accesscontrol.AccessControl, datasourcePermissionsService accesscontrol.DatasourcePermissionsService,
	quotaService quota.Service,
) (*Service, error)

func (*Service) AddDataSource 

func (s *Service) AddDataSource(ctx context.Context, cmd *datasources.AddDataSourceCommand) (*datasources.DataSource, error)

func (*Service) DecryptedBasicAuthPassword 

func (s *Service) DecryptedBasicAuthPassword(ctx context.Context, ds *datasources.DataSource) (string, error)

func (*Service) DecryptedPassword 

func (s *Service) DecryptedPassword(ctx context.Context, ds *datasources.DataSource) (string, error)

func (*Service) DecryptedValue 

func (s *Service) DecryptedValue(ctx context.Context, ds *datasources.DataSource, key string) (string, bool, error)

func (*Service) DecryptedValues 

func (s *Service) DecryptedValues(ctx context.Context, ds *datasources.DataSource) (map[string]string, error)

func (*Service) DeleteDataSource 

func (s *Service) DeleteDataSource(ctx context.Context, cmd *datasources.DeleteDataSourceCommand) error

func (*Service) GetAllDataSources 

func (s *Service) GetAllDataSources(ctx context.Context, query *datasources.GetAllDataSourcesQuery) (res []*datasources.DataSource, err error)

func (*Service) GetDataSource 

func (s *Service) GetDataSource(ctx context.Context, query *datasources.GetDataSourceQuery) (*datasources.DataSource, error)

func (*Service) GetDataSources 

func (s *Service) GetDataSources(ctx context.Context, query *datasources.GetDataSourcesQuery) ([]*datasources.DataSource, error)

func (*Service) GetDataSourcesByType 

func (s *Service) GetDataSourcesByType(ctx context.Context, query *datasources.GetDataSourcesByTypeQuery) ([]*datasources.DataSource, error)

func (*Service) GetDefaultDataSource 

func (s *Service) GetDefaultDataSource(ctx context.Context, query *datasources.GetDefaultDataSourceQuery) (*datasources.DataSource, error)

func (*Service) GetHTTPClient 

func (s *Service) GetHTTPClient(ctx context.Context, ds *datasources.DataSource, provider httpclient.Provider) (*http.Client, error)

func (*Service) GetHTTPTransport 

func (s *Service) GetHTTPTransport(ctx context.Context, ds *datasources.DataSource, provider httpclient.Provider,
	customMiddlewares ...sdkhttpclient.Middleware) (http.RoundTripper, error)

func (*Service) GetTLSConfig 

func (s *Service) GetTLSConfig(ctx context.Context, ds *datasources.DataSource, httpClientProvider httpclient.Provider) (*tls.Config, error)

func (*Service) UpdateDataSource 

func (s *Service) UpdateDataSource(ctx context.Context, cmd *datasources.UpdateDataSourceCommand) (*datasources.DataSource, error)

func (*Service) Usage 

func (s *Service) Usage(ctx context.Context, scopeParams *quota.ScopeParameters) (*quota.Map, error)

type SqlStore 

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

func CreateStore 

func CreateStore(db db.DB, logger log.Logger) *SqlStore

func (*SqlStore) AddDataSource 

func (ss *SqlStore) AddDataSource(ctx context.Context, cmd *datasources.AddDataSourceCommand) (*datasources.DataSource, error)

func (*SqlStore) Count 

func (ss *SqlStore) Count(ctx context.Context, scopeParams *quota.ScopeParameters) (*quota.Map, error)

func (*SqlStore) DeleteDataSource 

func (ss *SqlStore) DeleteDataSource(ctx context.Context, cmd *datasources.DeleteDataSourceCommand) error

DeleteDataSource removes a datasource by org_id as well as either uid (preferred), id, or name and is added to the bus. It also removes permissions related to the datasource.

func (*SqlStore) GetAllDataSources 

func (ss *SqlStore) GetAllDataSources(ctx context.Context, query *datasources.GetAllDataSourcesQuery) (res []*datasources.DataSource, err error)

func (*SqlStore) GetDataSource 

func (ss *SqlStore) GetDataSource(ctx context.Context, query *datasources.GetDataSourceQuery) (*datasources.DataSource, error)

GetDataSource adds a datasource to the query model by querying by org_id as well as either uid (preferred), id, or name and is added to the bus.

func (*SqlStore) GetDataSources 

func (ss *SqlStore) GetDataSources(ctx context.Context, query *datasources.GetDataSourcesQuery) ([]*datasources.DataSource, error)

func (*SqlStore) GetDataSourcesByType 

func (ss *SqlStore) GetDataSourcesByType(ctx context.Context, query *datasources.GetDataSourcesByTypeQuery) ([]*datasources.DataSource, error)

GetDataSourcesByType returns all datasources for a given type or an error if the specified type is an empty string

func (*SqlStore) GetDefaultDataSource 

func (ss *SqlStore) GetDefaultDataSource(ctx context.Context, query *datasources.GetDefaultDataSourceQuery) (*datasources.DataSource, error)

GetDefaultDataSource is used to get the default datasource of organization

func (*SqlStore) UpdateDataSource 

func (ss *SqlStore) UpdateDataSource(ctx context.Context, cmd *datasources.UpdateDataSourceCommand) (*datasources.DataSource, error)

type Store 

type Store interface {
	GetDataSource(context.Context, *datasources.GetDataSourceQuery) (*datasources.DataSource, error)
	GetDataSources(context.Context, *datasources.GetDataSourcesQuery) ([]*datasources.DataSource, error)
	GetDataSourcesByType(context.Context, *datasources.GetDataSourcesByTypeQuery) ([]*datasources.DataSource, error)
	GetDefaultDataSource(context.Context, *datasources.GetDefaultDataSourceQuery) (*datasources.DataSource, error)
	DeleteDataSource(context.Context, *datasources.DeleteDataSourceCommand) error
	AddDataSource(context.Context, *datasources.AddDataSourceCommand) (*datasources.DataSource, error)
	UpdateDataSource(context.Context, *datasources.UpdateDataSourceCommand) (*datasources.DataSource, error)
	GetAllDataSources(ctx context.Context, query *datasources.GetAllDataSourcesQuery) (res []*datasources.DataSource, err error)

	Count(context.Context, *quota.ScopeParameters) (*quota.Map, error)
}

Store is the interface for the datasource Service's storage.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.