dashboard

package
v1.0.0-rc7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 20, 2024 License: MIT Imports: 51 Imported by: 0

Documentation

Overview

Copyright © 2023 NAME HERE cosmo-workspace

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ErrResponse added in v0.8.0 

func ErrResponse(log *clog.Logger, err error) error

func Execute added in v0.9.0 

func Execute()

func NewForbidden 

func NewForbidden(err error) error

func NewRootCmd added in v0.9.0 

func NewRootCmd(o *options) *cobra.Command

Types

type HTTPRequestLogger 

type HTTPRequestLogger struct {
	*clog.Logger
}

func NewHTTPRequestLogger 

func NewHTTPRequestLogger(logr *clog.Logger) HTTPRequestLogger

func (HTTPRequestLogger) Middleware 

func (l HTTPRequestLogger) Middleware(next http.Handler) http.Handler

type InClusterServeFiles 

type InClusterServeFiles struct {
	CAFile string
}

type InClusterServer 

type InClusterServer struct {
	Log           *clog.Logger
	StaticFileDir string
	Port          int
	// contains filtered or unexported fields
}

InClusterServer serves certificate for incluster workspace It implements https://pkg.go.dev/sigs.k8s.io/controller-runtime/pkg/manager#Runnable

func NewInClusterServer 

func NewInClusterServer(log *clog.Logger, port int, f InClusterServeFiles) (*InClusterServer, error)

func (*InClusterServer) Start 

func (s *InClusterServer) Start(ctx context.Context) error

Start run server

type Server 

type Server struct {
	Log                 *clog.Logger
	Klient              kosmo.Client
	GracefulShutdownDur time.Duration
	ResponseTimeout     time.Duration
	StaticFileDir       string
	Port                int
	MaxAgeSeconds       int
	TLSPrivateKeyPath   string
	TLSCertPath         string
	Insecure            bool

	CookieDomain      string
	CookieHashKey     string
	CookieBlockKey    string
	CookieSessionName string

	Authorizers map[cosmov1alpha1.UserAuthType]auth.Authorizer
	// contains filtered or unexported fields
}

Server serves dashboard APIs and UI static files It implements https://pkg.go.dev/sigs.k8s.io/controller-runtime/pkg/manager#Runnable

func (*Server) AuthServiceHandler added in v0.8.0 

func (s *Server) AuthServiceHandler(mux *http.ServeMux)

func (*Server) BeginLogin 

func (s *Server) BeginLogin(ctx context.Context, req *connect_go.Request[dashv1alpha1.BeginLoginRequest]) (*connect_go.Response[dashv1alpha1.BeginLoginResponse], error)

BeginLogin is proto interface for webauthn.BeginLogin

func (*Server) BeginRegistration 

func (s *Server) BeginRegistration(ctx context.Context, req *connect_go.Request[dashv1alpha1.BeginRegistrationRequest]) (*connect_go.Response[dashv1alpha1.BeginRegistrationResponse], error)

BeginRegistration is proto interface for webauthn.BeginRegistration

func (*Server) CreateSession 

func (s *Server) CreateSession(w http.ResponseWriter, r *http.Request, sesInfo session.Info) error

func (*Server) CreateUser added in v0.8.0 

func (s *Server) CreateUser(ctx context.Context, req *connect_go.Request[dashv1alpha1.CreateUserRequest]) (*connect_go.Response[dashv1alpha1.CreateUserResponse], error)

func (*Server) CreateWorkspace added in v0.8.0 

func (s *Server) CreateWorkspace(ctx context.Context, req *connect_go.Request[dashv1alpha1.CreateWorkspaceRequest]) (*connect_go.Response[dashv1alpha1.CreateWorkspaceResponse], error)

func (*Server) DeleteCredential 

func (s *Server) DeleteCredential(ctx context.Context, req *connect_go.Request[dashv1alpha1.DeleteCredentialRequest]) (*connect_go.Response[dashv1alpha1.DeleteCredentialResponse], error)

DeleteCredential remove credential of a user by given id

func (*Server) DeleteNetworkRule 

func (s *Server) DeleteNetworkRule(ctx context.Context, req *connect_go.Request[dashv1alpha1.DeleteNetworkRuleRequest]) (*connect_go.Response[dashv1alpha1.DeleteNetworkRuleResponse], error)

func (*Server) DeleteUser 

func (s *Server) DeleteUser(ctx context.Context, req *connect_go.Request[dashv1alpha1.DeleteUserRequest]) (*connect_go.Response[dashv1alpha1.DeleteUserResponse], error)

func (*Server) DeleteWorkspace 

func (s *Server) DeleteWorkspace(ctx context.Context, req *connect_go.Request[dashv1alpha1.DeleteWorkspaceRequest]) (*connect_go.Response[dashv1alpha1.DeleteWorkspaceResponse], error)

func (*Server) FinishLogin 

func (s *Server) FinishLogin(ctx context.Context, req *connect_go.Request[dashv1alpha1.FinishLoginRequest]) (*connect_go.Response[dashv1alpha1.FinishLoginResponse], error)

FinishLogin is proto interface for webauthn.FinishLogin

func (*Server) FinishRegistration 

func (s *Server) FinishRegistration(ctx context.Context, req *connect_go.Request[dashv1alpha1.FinishRegistrationRequest]) (*connect_go.Response[dashv1alpha1.FinishRegistrationResponse], error)

FinishRegistration is proto interface for webauthn.FinishRegistration

func (*Server) GetEvents 

func (s *Server) GetEvents(ctx context.Context, req *connect_go.Request[dashv1alpha1.GetEventsRequest]) (*connect_go.Response[dashv1alpha1.GetEventsResponse], error)

func (*Server) GetUser 

func (s *Server) GetUser(ctx context.Context, req *connect_go.Request[dashv1alpha1.GetUserRequest]) (*connect_go.Response[dashv1alpha1.GetUserResponse], error)

func (*Server) GetUserAddonTemplates added in v0.2.0 

func (s *Server) GetUserAddonTemplates(ctx context.Context, req *connect_go.Request[dashv1alpha1.GetUserAddonTemplatesRequest]) (*connect_go.Response[dashv1alpha1.GetUserAddonTemplatesResponse], error)

func (*Server) GetUsers 

func (s *Server) GetUsers(ctx context.Context, req *connect_go.Request[dashv1alpha1.GetUsersRequest]) (*connect_go.Response[dashv1alpha1.GetUsersResponse], error)

func (*Server) GetWorkspace 

func (s *Server) GetWorkspace(ctx context.Context, req *connect_go.Request[dashv1alpha1.GetWorkspaceRequest]) (*connect_go.Response[dashv1alpha1.GetWorkspaceResponse], error)

func (*Server) GetWorkspaceTemplates 

func (s *Server) GetWorkspaceTemplates(ctx context.Context, req *connect_go.Request[dashv1alpha1.GetWorkspaceTemplatesRequest]) (*connect_go.Response[dashv1alpha1.GetWorkspaceTemplatesResponse], error)

func (*Server) GetWorkspaces 

func (s *Server) GetWorkspaces(ctx context.Context, req *connect_go.Request[dashv1alpha1.GetWorkspacesRequest]) (*connect_go.Response[dashv1alpha1.GetWorkspacesResponse], error)

func (*Server) ListCredentials 

func (s *Server) ListCredentials(ctx context.Context, req *connect_go.Request[dashv1alpha1.ListCredentialsRequest]) (*connect_go.Response[dashv1alpha1.ListCredentialsResponse], error)

ListCredentials returns all the credentials of a user

func (*Server) Login 

func (s *Server) Login(ctx context.Context, req *connect_go.Request[dashv1alpha1.LoginRequest]) (*connect_go.Response[dashv1alpha1.LoginResponse], error)

func (*Server) Logout 

func (s *Server) Logout(ctx context.Context, req *connect_go.Request[emptypb.Empty]) (*connect_go.Response[emptypb.Empty], error)

func (*Server) ServiceAccountLogin 

func (s *Server) ServiceAccountLogin(ctx context.Context, req *connect_go.Request[dashv1alpha1.ServiceAccountLoginRequest]) (*connect_go.Response[dashv1alpha1.LoginResponse], error)

func (*Server) SessionInfo 

func (s *Server) SessionInfo(userName string) (session.Info, time.Time)

func (*Server) Start 

func (s *Server) Start(ctx context.Context) error

Start implements manager.Runnable

func (*Server) StreamServiceHandler 

func (s *Server) StreamServiceHandler(mux *http.ServeMux)

func (*Server) StreamingEvents 

func (s *Server) StreamingEvents(ctx context.Context, req *connect_go.Request[dashv1alpha1.GetEventsRequest], stream *connect_go.ServerStream[dashv1alpha1.GetEventsResponse]) error

StreamingEvents implements dashboardv1alpha1connect.UserServiceHandler.

func (*Server) TemplateServiceHandler added in v0.8.0 

func (s *Server) TemplateServiceHandler(mux *http.ServeMux)

func (*Server) UpdateCredential 

func (s *Server) UpdateCredential(ctx context.Context, req *connect_go.Request[dashv1alpha1.UpdateCredentialRequest]) (*connect_go.Response[dashv1alpha1.UpdateCredentialResponse], error)

UpdateCredential updates credentia

func (*Server) UpdateUserAddons 

func (s *Server) UpdateUserAddons(ctx context.Context, req *connect_go.Request[dashv1alpha1.UpdateUserAddonsRequest]) (*connect_go.Response[dashv1alpha1.UpdateUserAddonsResponse], error)

func (*Server) UpdateUserDisplayName added in v0.8.0 

func (s *Server) UpdateUserDisplayName(ctx context.Context, req *connect_go.Request[dashv1alpha1.UpdateUserDisplayNameRequest]) (*connect_go.Response[dashv1alpha1.UpdateUserDisplayNameResponse], error)

func (*Server) UpdateUserPassword added in v0.8.0 

func (s *Server) UpdateUserPassword(ctx context.Context, req *connect_go.Request[dashv1alpha1.UpdateUserPasswordRequest]) (*connect_go.Response[dashv1alpha1.UpdateUserPasswordResponse], error)

func (*Server) UpdateUserRole added in v0.8.0 

func (s *Server) UpdateUserRole(ctx context.Context, req *connect_go.Request[dashv1alpha1.UpdateUserRoleRequest]) (*connect_go.Response[dashv1alpha1.UpdateUserRoleResponse], error)

func (*Server) UpdateWorkspace added in v0.8.0 

func (s *Server) UpdateWorkspace(ctx context.Context, req *connect_go.Request[dashv1alpha1.UpdateWorkspaceRequest]) (*connect_go.Response[dashv1alpha1.UpdateWorkspaceResponse], error)

func (*Server) UpsertNetworkRule added in v0.8.0 

func (s *Server) UpsertNetworkRule(ctx context.Context, req *connect_go.Request[dashv1alpha1.UpsertNetworkRuleRequest]) (*connect_go.Response[dashv1alpha1.UpsertNetworkRuleResponse], error)

func (*Server) UserServiceHandler added in v0.8.0 

func (s *Server) UserServiceHandler(mux *http.ServeMux)

func (*Server) Verify 

func (s *Server) Verify(ctx context.Context, req *connect_go.Request[emptypb.Empty]) (*connect_go.Response[dashv1alpha1.VerifyResponse], error)

func (*Server) WebAuthnServiceHandler 

func (s *Server) WebAuthnServiceHandler(mux *http.ServeMux)

func (*Server) WorkspaceServiceHandler added in v0.8.0 

func (s *Server) WorkspaceServiceHandler(mux *http.ServeMux)

type StoreStatusResponseWriter 

type StoreStatusResponseWriter struct {
	http.ResponseWriter
	// contains filtered or unexported fields
}

func (*StoreStatusResponseWriter) Flush 

func (w *StoreStatusResponseWriter) Flush()

func (*StoreStatusResponseWriter) StatusCode 

func (w *StoreStatusResponseWriter) StatusCode() int

func (*StoreStatusResponseWriter) StatusString 

func (w *StoreStatusResponseWriter) StatusString() string

func (*StoreStatusResponseWriter) WriteHeader 

func (w *StoreStatusResponseWriter) WriteHeader(statusCode int)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.