82 lines
2.0 KiB
Go
82 lines
2.0 KiB
Go
package snapshot
|
|
|
|
import (
|
|
"context"
|
|
"net/http"
|
|
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
"k8s.io/apimachinery/pkg/runtime"
|
|
"k8s.io/apiserver/pkg/registry/rest"
|
|
|
|
dashv0 "github.com/grafana/grafana/apps/dashboard/pkg/apis/dashboard/v0alpha1"
|
|
"github.com/grafana/grafana/pkg/apimachinery/apis/common/v0alpha1"
|
|
"github.com/grafana/grafana/pkg/apimachinery/utils"
|
|
"github.com/grafana/grafana/pkg/services/apiserver/endpoints/request"
|
|
"github.com/grafana/grafana/pkg/services/dashboardsnapshots"
|
|
)
|
|
|
|
// Currently only works with v0alpha1
|
|
type dashboardREST struct {
|
|
Service dashboardsnapshots.Service
|
|
}
|
|
|
|
func NewDashboardREST(
|
|
resourceInfo utils.ResourceInfo,
|
|
service dashboardsnapshots.Service,
|
|
) (rest.Storage, error) {
|
|
return &dashboardREST{
|
|
Service: service,
|
|
}, nil
|
|
}
|
|
|
|
var (
|
|
_ rest.Connecter = (*dashboardREST)(nil)
|
|
_ rest.StorageMetadata = (*dashboardREST)(nil)
|
|
)
|
|
|
|
func (r *dashboardREST) New() runtime.Object {
|
|
return &dashv0.Dashboard{}
|
|
}
|
|
|
|
func (r *dashboardREST) Destroy() {
|
|
}
|
|
|
|
func (r *dashboardREST) ConnectMethods() []string {
|
|
return []string{"GET"}
|
|
}
|
|
|
|
func (r *dashboardREST) NewConnectOptions() (runtime.Object, bool, string) {
|
|
return nil, false, ""
|
|
}
|
|
|
|
func (r *dashboardREST) ProducesMIMETypes(verb string) []string {
|
|
return nil
|
|
}
|
|
|
|
func (r *dashboardREST) ProducesObject(verb string) interface{} {
|
|
return r.New()
|
|
}
|
|
|
|
func (r *dashboardREST) Connect(ctx context.Context, name string, opts runtime.Object, responder rest.Responder) (http.Handler, error) {
|
|
_, err := request.NamespaceInfoFrom(ctx, true)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
snap, err := r.Service.GetDashboardSnapshot(ctx, &dashboardsnapshots.GetDashboardSnapshotQuery{Key: name})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
|
|
// TODO... support conversions (not required in v0)
|
|
dash := &dashv0.Dashboard{
|
|
ObjectMeta: metav1.ObjectMeta{
|
|
Namespace: name,
|
|
},
|
|
Spec: v0alpha1.Unstructured{
|
|
Object: snap.Dashboard.MustMap(),
|
|
},
|
|
}
|
|
responder.Object(200, dash)
|
|
}), nil
|
|
}
|