Documentation
¶
Index ¶
- Variables
- func MakePublicQueryError(refID, err string) error
- func MakeQueryError(refID, err error) error
- type CommonDataSourceClientSupplier
- type DataSourceClientSupplier
- type QueryAPIBuilder
- func (b *QueryAPIBuilder) GetAPIGroupInfo(scheme *runtime.Scheme, codecs serializer.CodecFactory, ...) (*genericapiserver.APIGroupInfo, error)
- func (b *QueryAPIBuilder) GetAPIRoutes() *builder.APIRoutes
- func (b *QueryAPIBuilder) GetAuthorizer() authorizer.Authorizer
- func (b *QueryAPIBuilder) GetDesiredDualWriterMode(dualWrite bool, modeMap map[string]grafanarest.DualWriterMode) grafanarest.DualWriterMode
- func (b *QueryAPIBuilder) GetGroupVersion() schema.GroupVersion
- func (b *QueryAPIBuilder) GetOpenAPIDefinitions() common.GetOpenAPIDefinitions
- func (b *QueryAPIBuilder) InstallSchema(scheme *runtime.Scheme) error
- func (b *QueryAPIBuilder) PostProcessOpenAPI(oas *spec3.OpenAPI) (*spec3.OpenAPI, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var QueryError = errutil.BadRequest("query.error").MustTemplate( "failed to execute query [{{ .Public.refId }}]: {{ .Error }}", errutil.WithPublic( "failed to execute query [{{ .Public.refId }}]: {{ .Public.error }}", ))
Functions ¶
func MakePublicQueryError ¶
func MakeQueryError ¶
Types ¶
type CommonDataSourceClientSupplier ¶
type CommonDataSourceClientSupplier struct {
Client data.QueryDataClient
}
func (*CommonDataSourceClientSupplier) GetDataSourceClient ¶
func (s *CommonDataSourceClientSupplier) GetDataSourceClient(ctx context.Context, ref data.DataSourceRef) (data.QueryDataClient, error)
type DataSourceClientSupplier ¶
type DataSourceClientSupplier interface { // Get a client for a given datasource // NOTE: authorization headers are not yet added and the client may be shared across multiple users GetDataSourceClient(ctx context.Context, ref data.DataSourceRef) (data.QueryDataClient, error) }
The query runner interface
type QueryAPIBuilder ¶
type QueryAPIBuilder struct {
// contains filtered or unexported fields
}
func NewQueryAPIBuilder ¶
func NewQueryAPIBuilder(features featuremgmt.FeatureToggles, client DataSourceClientSupplier, registry query.DataSourceApiServerRegistry, legacy service.LegacyDataSourceLookup, registerer prometheus.Registerer, tracer tracing.Tracer, ) (*QueryAPIBuilder, error)
func RegisterAPIService ¶
func RegisterAPIService(features featuremgmt.FeatureToggles, apiregistration builder.APIRegistrar, dataSourcesService datasources.DataSourceService, pluginStore pluginstore.Store, accessControl accesscontrol.AccessControl, pluginClient plugins.Client, pCtxProvider *plugincontext.Provider, registerer prometheus.Registerer, tracer tracing.Tracer, legacy service.LegacyDataSourceLookup, ) (*QueryAPIBuilder, error)
func (*QueryAPIBuilder) GetAPIGroupInfo ¶
func (b *QueryAPIBuilder) GetAPIGroupInfo( scheme *runtime.Scheme, codecs serializer.CodecFactory, optsGetter generic.RESTOptionsGetter, _ grafanarest.DualWriterMode, ) (*genericapiserver.APIGroupInfo, error)
func (*QueryAPIBuilder) GetAPIRoutes ¶
func (b *QueryAPIBuilder) GetAPIRoutes() *builder.APIRoutes
Register additional routes with the server
func (*QueryAPIBuilder) GetAuthorizer ¶
func (b *QueryAPIBuilder) GetAuthorizer() authorizer.Authorizer
func (*QueryAPIBuilder) GetDesiredDualWriterMode ¶
func (b *QueryAPIBuilder) GetDesiredDualWriterMode(dualWrite bool, modeMap map[string]grafanarest.DualWriterMode) grafanarest.DualWriterMode
func (*QueryAPIBuilder) GetGroupVersion ¶
func (b *QueryAPIBuilder) GetGroupVersion() schema.GroupVersion
func (*QueryAPIBuilder) GetOpenAPIDefinitions ¶
func (b *QueryAPIBuilder) GetOpenAPIDefinitions() common.GetOpenAPIDefinitions
func (*QueryAPIBuilder) InstallSchema ¶
func (b *QueryAPIBuilder) InstallSchema(scheme *runtime.Scheme) error
func (*QueryAPIBuilder) PostProcessOpenAPI ¶
Source Files
¶
Click to show internal directories.
Click to hide internal directories.