endpoints

Documentation

Index

• func Serve(clientSet *kubernetes.Clientset, namespace string, kubeConfig *rest.Config, ...)
• type CORS
  • func NewCORSMiddleware(allowedOrigins string) CORS
  • func (c *CORS) Middleware(next http.Handler) http.Handler
• type ClusterGet
  • func (s *ClusterGet) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type ClusterUpdate
  • func (s *ClusterUpdate) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type ComponentsDelete
  • func (s *ComponentsDelete) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type ComponentsInstallUninstall
  • func (s *ComponentsInstallUninstall) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type ComponentsList
  • func (s *ComponentsList) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type ComponentsUpdate
  • func (s *ComponentsUpdate) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type EnableAuthMiddleware
  • func MustNewAuthMiddleware(pattern string) EnableAuthMiddleware
  • func (a EnableAuthMiddleware) Middleware(next http.Handler) http.Handler
• type JwtMiddleware
  • func NewJwtMiddleware(jwtSecret string) JwtMiddleware
  • func (j JwtMiddleware) Middleware(next http.Handler) http.Handler
• type KafkaSubjects
  • func (s *KafkaSubjects) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type KafkaTopics
  • func (s *KafkaTopics) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Service
• type Services
  • func (s *Services) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type ServicesResponse
• type SystemTokenMiddleware
  • func NewSystemTokenMiddleware(systemToken string) SystemTokenMiddleware
  • func (s SystemTokenMiddleware) Middleware(next http.Handler) http.Handler

Functions

func Serve

func Serve(clientSet *kubernetes.Clientset, namespace string, kubeConfig *rest.Config, repoFilePath string)

Types

type CORS

type CORS struct {
	// contains filtered or unexported fields
}

func NewCORSMiddleware

func NewCORSMiddleware(allowedOrigins string) CORS

func (*CORS) Middleware

func (c *CORS) Middleware(next http.Handler) http.Handler

type ClusterGet

type ClusterGet struct {
	// contains filtered or unexported fields
}

func (*ClusterGet) ServeHTTP

func (s *ClusterGet) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ClusterUpdate

type ClusterUpdate struct {
	// contains filtered or unexported fields
}

func (*ClusterUpdate) ServeHTTP

func (s *ClusterUpdate) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ComponentsDelete

type ComponentsDelete struct {
	// contains filtered or unexported fields
}

func (*ComponentsDelete) ServeHTTP

func (s *ComponentsDelete) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ComponentsInstallUninstall

type ComponentsInstallUninstall struct {
	Cli       helmCli.Client
	ClientSet *kubernetes.Clientset
	Namespace string
}

func (*ComponentsInstallUninstall) ServeHTTP

func (s *ComponentsInstallUninstall) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ComponentsList

type ComponentsList struct {
	ClientSet *kubernetes.Clientset
	Namespace string
	Index     *search.Index
}

func (*ComponentsList) ServeHTTP

func (s *ComponentsList) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ComponentsUpdate

type ComponentsUpdate struct {
	// contains filtered or unexported fields
}

func (*ComponentsUpdate) ServeHTTP

func (s *ComponentsUpdate) ServeHTTP(w http.ResponseWriter, r *http.Request)

type EnableAuthMiddleware

type EnableAuthMiddleware struct {
	// contains filtered or unexported fields
}

func MustNewAuthMiddleware

func MustNewAuthMiddleware(pattern string) EnableAuthMiddleware

MustNewAuthMiddleware Only paths that match the regexp pattern will be authenticated

func (EnableAuthMiddleware) Middleware

func (a EnableAuthMiddleware) Middleware(next http.Handler) http.Handler

type JwtMiddleware

type JwtMiddleware struct {
	// contains filtered or unexported fields
}

func NewJwtMiddleware

func NewJwtMiddleware(jwtSecret string) JwtMiddleware

func (JwtMiddleware) Middleware

func (j JwtMiddleware) Middleware(next http.Handler) http.Handler

type KafkaSubjects

type KafkaSubjects struct {
	ClientSet *kubernetes.Clientset
	Namespace string
	Index     *search.Index
}

func (*KafkaSubjects) ServeHTTP

func (s *KafkaSubjects) ServeHTTP(w http.ResponseWriter, r *http.Request)

type KafkaTopics

type KafkaTopics struct {
	ClientSet *kubernetes.Clientset
	Namespace string
	Index     *search.Index
}

func (*KafkaTopics) ServeHTTP

func (s *KafkaTopics) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Service

type Service struct {
	Enabled   bool   `json:"enabled"`
	Component string `json:"component"`
}

type Services

type Services struct {
	// contains filtered or unexported fields
}

func (*Services) ServeHTTP

func (s *Services) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ServicesResponse

type ServicesResponse struct {
	Services map[string]Service `json:"services"`
}

type SystemTokenMiddleware

type SystemTokenMiddleware struct {
	// contains filtered or unexported fields
}

func NewSystemTokenMiddleware

func NewSystemTokenMiddleware(systemToken string) SystemTokenMiddleware

func (SystemTokenMiddleware) Middleware

func (s SystemTokenMiddleware) Middleware(next http.Handler) http.Handler