merge main
This commit is contained in:
@@ -21,7 +21,7 @@ func (b *DataSourceAPIBuilder) Validate(ctx context.Context, a admission.Attribu
|
||||
func (b *DataSourceAPIBuilder) Mutate(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) (err error) {
|
||||
obj := a.GetObject()
|
||||
|
||||
if b.specProvider == nil || obj == nil || a.GetOperation() == admission.Connect {
|
||||
if b.schemaProvider == nil || obj == nil || a.GetOperation() == admission.Connect {
|
||||
return nil // This is normal for sub-resource
|
||||
}
|
||||
|
||||
@@ -30,7 +30,7 @@ func (b *DataSourceAPIBuilder) Mutate(ctx context.Context, a admission.Attribute
|
||||
return fmt.Errorf("expected datasource object")
|
||||
}
|
||||
|
||||
info, err := b.specProvider()
|
||||
info, err := b.schemaProvider()
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
@@ -54,11 +54,11 @@ func (b *DataSourceAPIBuilder) PostProcessOpenAPI(oas *spec3.OpenAPI) (*spec3.Op
|
||||
ds.Properties["apiVersion"] = *spec.StringProperty().WithEnum(b.GetGroupVersion().String())
|
||||
ds.Properties["kind"] = *spec.StringProperty().WithEnum("DataSource")
|
||||
|
||||
if b.specProvider == nil {
|
||||
if b.schemaProvider == nil {
|
||||
return oas, nil
|
||||
}
|
||||
|
||||
custom, err := b.specProvider()
|
||||
custom, err := b.schemaProvider()
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
@@ -46,7 +46,7 @@ type DataSourceAPIBuilder struct {
|
||||
datasources PluginDatasourceProvider
|
||||
contextProvider PluginContextWrapper
|
||||
accessControl accesscontrol.AccessControl
|
||||
specProvider func() (*datasourceV0.DataSourceOpenAPIExtension, error) // TODO? include query types
|
||||
schemaProvider func() (*datasourceV0.DataSourceOpenAPIExtension, error) // TODO? include query types
|
||||
queryTypes *queryV0.QueryTypeDefinitionList
|
||||
log log.Logger
|
||||
}
|
||||
@@ -98,9 +98,9 @@ func RegisterAPIService(
|
||||
return nil, err
|
||||
}
|
||||
|
||||
// HARDCODE spec access
|
||||
// HARDCODE schema access
|
||||
if ds.ID == "grafana-testdata-datasource" {
|
||||
builder.specProvider = hardcoded.TestdataOpenAPIExtension
|
||||
builder.schemaProvider = hardcoded.TestdataOpenAPIExtension
|
||||
}
|
||||
|
||||
apiRegistrar.RegisterAPI(builder)
|
||||
|
||||
@@ -152,10 +152,10 @@ func (q *connectionsProvider) asConnection(ds *datasources.DataSource, ns string
|
||||
},
|
||||
Title: ds.Name,
|
||||
Datasource: queryV0.DataSourceConnectionRef{
|
||||
Group: gv.Group,
|
||||
Version: gv.Version,
|
||||
Name: ds.UID,
|
||||
PluginID: ds.Type,
|
||||
Group: gv.Group,
|
||||
Version: gv.Version,
|
||||
Name: ds.UID,
|
||||
Plugin: ds.Type,
|
||||
},
|
||||
}
|
||||
v.UID = gapiutil.CalculateClusterWideUID(v) // indicates if the value changed on the server
|
||||
|
||||
Reference in New Issue
Block a user