mirror of
https://github.com/grafana/grafana.git
synced 2025-02-25 18:55:37 -06:00
88 lines
2.5 KiB
Go
88 lines
2.5 KiB
Go
|
// SPDX-License-Identifier: AGPL-3.0-only
|
||
|
|
|
||
|
|
package apistore
|
||
|
|
|
||
|
|
import (
|
||
|
|
"path"
|
||
|
|
"time"
|
||
|
|
|
||
|
|
"k8s.io/apimachinery/pkg/runtime"
|
||
|
|
"k8s.io/apimachinery/pkg/runtime/schema"
|
||
|
|
"k8s.io/apiserver/pkg/registry/generic"
|
||
|
|
"k8s.io/apiserver/pkg/storage"
|
||
|
|
"k8s.io/apiserver/pkg/storage/storagebackend"
|
||
|
|
"k8s.io/apiserver/pkg/storage/storagebackend/factory"
|
||
|
|
flowcontrolrequest "k8s.io/apiserver/pkg/util/flowcontrol/request"
|
||
|
|
"k8s.io/client-go/tools/cache"
|
||
|
|
|
||
|
|
"github.com/grafana/grafana/pkg/storage/unified/resource"
|
||
|
|
)
|
||
|
|
|
||
|
|
var _ generic.RESTOptionsGetter = (*RESTOptionsGetter)(nil)
|
||
|
|
|
||
|
|
type RESTOptionsGetter struct {
|
||
|
|
client resource.ResourceStoreClient
|
||
|
|
Codec runtime.Codec
|
||
|
|
}
|
||
|
|
|
||
|
|
func NewRESTOptionsGetterForServer(server resource.ResourceServer, codec runtime.Codec) *RESTOptionsGetter {
|
||
|
|
return &RESTOptionsGetter{
|
||
|
|
client: resource.NewLocalResourceStoreClient(server),
|
||
|
|
Codec: codec,
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func NewRESTOptionsGetter(client resource.ResourceStoreClient, codec runtime.Codec) *RESTOptionsGetter {
|
||
|
|
return &RESTOptionsGetter{
|
||
|
|
client: client,
|
||
|
|
Codec: codec,
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func (f *RESTOptionsGetter) GetRESTOptions(resource schema.GroupResource) (generic.RESTOptions, error) {
|
||
|
|
storageConfig := &storagebackend.ConfigForResource{
|
||
|
|
Config: storagebackend.Config{
|
||
|
|
Type: "custom",
|
||
|
|
Prefix: "",
|
||
|
|
Transport: storagebackend.TransportConfig{
|
||
|
|
ServerList: []string{
|
||
|
|
// ??? string(connectionInfo),
|
||
|
|
},
|
||
|
|
},
|
||
|
|
Codec: f.Codec,
|
||
|
|
EncodeVersioner: nil,
|
||
|
|
Transformer: nil,
|
||
|
|
CompactionInterval: 0,
|
||
|
|
CountMetricPollPeriod: 0,
|
||
|
|
DBMetricPollInterval: 0,
|
||
|
|
HealthcheckTimeout: 0,
|
||
|
|
ReadycheckTimeout: 0,
|
||
|
|
StorageObjectCountTracker: nil,
|
||
|
|
},
|
||
|
|
GroupResource: resource,
|
||
|
|
}
|
||
|
|
|
||
|
|
ret := generic.RESTOptions{
|
||
|
|
StorageConfig: storageConfig,
|
||
|
|
Decorator: func(
|
||
|
|
config *storagebackend.ConfigForResource,
|
||
|
|
resourcePrefix string,
|
||
|
|
keyFunc func(obj runtime.Object) (string, error),
|
||
|
|
newFunc func() runtime.Object,
|
||
|
|
newListFunc func() runtime.Object,
|
||
|
|
getAttrsFunc storage.AttrFunc,
|
||
|
|
trigger storage.IndexerFuncs,
|
||
|
|
indexers *cache.Indexers,
|
||
|
|
) (storage.Interface, factory.DestroyFunc, error) {
|
||
|
|
return NewStorage(config, resource, f.client, f.Codec, keyFunc, newFunc, newListFunc, getAttrsFunc)
|
||
|
|
},
|
||
|
|
DeleteCollectionWorkers: 0,
|
||
|
|
EnableGarbageCollection: false,
|
||
|
|
ResourcePrefix: path.Join(storageConfig.Prefix, resource.Group, resource.Resource),
|
||
|
|
CountMetricPollPeriod: 1 * time.Second,
|
||
|
|
StorageObjectCountTracker: flowcontrolrequest.NewStorageObjectCountTracker(),
|
||
|
|
}
|
||
|
|
|
||
|
|
return ret, nil
|
||
|
|
}
|