github/steve
1
0
Fork 0
mirror of https://github.com/niusmallnan/steve.git synced 2025-09-01 05:09:28 +00:00
Code Issues Projects Releases Wiki Activity

Rename to RESTConfig

Browse Source
This commit is contained in:
Darren Shepherd
2020-07-19 13:56:34 -07:00
parent 969e1adfed
commit ece0f7bce5
3 changed files with 12 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/server/cli/clicontext.go
View File

@@ -49,7 +49,7 @@ func (c *Config) ToServer(ctx context.Context) (*server.Server, error) {
} }
return &server.Server{ return &server.Server{
RestConfig: restConfig, RESTConfig: restConfig,
AuthMiddleware: auth, AuthMiddleware: auth,
DashboardURL: func() string { DashboardURL: func() string {
return c.DashboardURL return c.DashboardURL

8
pkg/server/config.go
View File

@@ -9,6 +9,7 @@ import (
"github.com/rancher/steve/pkg/accesscontrol" "github.com/rancher/steve/pkg/accesscontrol"
"github.com/rancher/steve/pkg/auth" "github.com/rancher/steve/pkg/auth"
"github.com/rancher/steve/pkg/client" "github.com/rancher/steve/pkg/client"
"github.com/rancher/steve/pkg/clustercache"
"github.com/rancher/steve/pkg/schema" "github.com/rancher/steve/pkg/schema"
"github.com/rancher/steve/pkg/server/router" "github.com/rancher/steve/pkg/server/router"
"github.com/rancher/wrangler/pkg/generated/controllers/apiextensions.k8s.io" "github.com/rancher/wrangler/pkg/generated/controllers/apiextensions.k8s.io"
@@ -29,7 +30,7 @@ import (
type Server struct { type Server struct {
*Controllers *Controllers
RestConfig *rest.Config RESTConfig *rest.Config
ClientFactory *client.Factory ClientFactory *client.Factory
BaseSchemas *types.APISchemas BaseSchemas *types.APISchemas
@@ -38,13 +39,14 @@ type Server struct {
AuthMiddleware auth.Middleware AuthMiddleware auth.Middleware
Next http.Handler Next http.Handler
Router router.RouterFunc Router router.RouterFunc
ClusterCache clustercache.ClusterCache
PostStartHooks []func() error PostStartHooks []func() error
StartHooks []StartHook StartHooks []StartHook
DashboardURL func() string DashboardURL func() string
} }
type Controllers struct { type Controllers struct {
RestConfig *rest.Config RESTConfig *rest.Config
K8s kubernetes.Interface K8s kubernetes.Interface
Core corev1.Interface Core corev1.Interface
RBAC rbacv1.Interface RBAC rbacv1.Interface
@@ -100,7 +102,7 @@ func NewController(cfg *rest.Config, opts *generic.FactoryOptions) (*Controllers
c.RBAC = rbac.Rbac().V1() c.RBAC = rbac.Rbac().V1()
c.API = api.Apiregistration().V1() c.API = api.Apiregistration().V1()
c.CRD = crd.Apiextensions().V1beta1() c.CRD = crd.Apiextensions().V1beta1()
c.RestConfig = cfg c.RESTConfig = cfg
return c, nil return c, nil
} }

11
pkg/server/server.go
View File

@@ -23,13 +23,13 @@ import (
var ErrConfigRequired = errors.New("rest config is required") var ErrConfigRequired = errors.New("rest config is required")
func setDefaults(server *Server) error { func setDefaults(server *Server) error {
if server.RestConfig == nil { if server.RESTConfig == nil {
return ErrConfigRequired return ErrConfigRequired
} }
if server.Controllers == nil { if server.Controllers == nil {
var err error var err error
server.Controllers, err = NewController(server.RestConfig, nil) server.Controllers, err = NewController(server.RESTConfig, nil)
if err != nil { if err != nil {
return err return err
} }
@@ -54,7 +54,7 @@ func setup(ctx context.Context, server *Server) (http.Handler, *schema.Collectio
cf := server.ClientFactory cf := server.ClientFactory
if cf == nil { if cf == nil {
cf, err = client.NewFactory(server.RestConfig, server.AuthMiddleware != nil) cf, err = client.NewFactory(server.RESTConfig, server.AuthMiddleware != nil)
if err != nil { if err != nil {
return nil, nil, err return nil, nil, err
} }
@@ -67,6 +67,7 @@ func setup(ctx context.Context, server *Server) (http.Handler, *schema.Collectio
} }
ccache := clustercache.NewClusterCache(ctx, cf.DynamicClient()) ccache := clustercache.NewClusterCache(ctx, cf.DynamicClient())
server.ClusterCache = ccache
server.BaseSchemas, err = resources.DefaultSchemas(ctx, server.BaseSchemas, ccache, cf) server.BaseSchemas, err = resources.DefaultSchemas(ctx, server.BaseSchemas, ccache, cf)
if err != nil { if err != nil {
@@ -81,7 +82,7 @@ func setup(ctx context.Context, server *Server) (http.Handler, *schema.Collectio
server.SchemaTemplates = append(server.SchemaTemplates, resources.DefaultSchemaTemplates(cf, summaryCache, asl, server.K8s.Discovery())...) server.SchemaTemplates = append(server.SchemaTemplates, resources.DefaultSchemaTemplates(cf, summaryCache, asl, server.K8s.Discovery())...)
cols, err := common.NewDynamicColumns(server.RestConfig) cols, err := common.NewDynamicColumns(server.RESTConfig)
if err != nil { if err != nil {
return nil, nil, err return nil, nil, err
} }
@@ -97,7 +98,7 @@ func setup(ctx context.Context, server *Server) (http.Handler, *schema.Collectio
ccache, ccache,
sf) sf)
handler, err := handler.New(server.RestConfig, sf, server.AuthMiddleware, server.Next, server.Router) handler, err := handler.New(server.RESTConfig, sf, server.AuthMiddleware, server.Next, server.Router)
if err != nil { if err != nil {
return nil, nil, err return nil, nil, err
} }