cluster

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2024 License: Apache-2.0 Imports: 35 Imported by: 2

Documentation

Index

Constants

View Source 
const CLUSTER_DELETE_SUCCESS_RESP = "Cluster deleted successfully."
View Source 
const ENV_DELETE_SUCCESS_RESP = "Environment deleted successfully."

Variables

View Source 
var ClusterWireSet = wire.NewSet(
	repository.NewClusterRepositoryImpl,
	wire.Bind(new(repository.ClusterRepository), new(*repository.ClusterRepositoryImpl)),
	cluster.NewClusterServiceImpl,
	cluster.NewClusterServiceImplExtended,
	wire.Bind(new(cluster.ClusterService), new(*cluster.ClusterServiceImplExtended)),
	read.NewClusterReadServiceImpl,
	wire.Bind(new(read.ClusterReadService), new(*read.ClusterReadServiceImpl)),

	rbac.NewClusterRbacServiceImpl,
	wire.Bind(new(rbac.ClusterRbacService), new(*rbac.ClusterRbacServiceImpl)),

	repository.NewClusterDescriptionRepositoryImpl,
	wire.Bind(new(repository.ClusterDescriptionRepository), new(*repository.ClusterDescriptionRepositoryImpl)),
	repository2.NewGenericNoteHistoryRepositoryImpl,
	wire.Bind(new(repository2.GenericNoteHistoryRepository), new(*repository2.GenericNoteHistoryRepositoryImpl)),
	repository2.NewGenericNoteRepositoryImpl,
	wire.Bind(new(repository2.GenericNoteRepository), new(*repository2.GenericNoteRepositoryImpl)),
	genericNotes.NewGenericNoteHistoryServiceImpl,
	wire.Bind(new(genericNotes.GenericNoteHistoryService), new(*genericNotes.GenericNoteHistoryServiceImpl)),
	genericNotes.NewGenericNoteServiceImpl,
	wire.Bind(new(genericNotes.GenericNoteService), new(*genericNotes.GenericNoteServiceImpl)),
	cluster.NewClusterDescriptionServiceImpl,
	wire.Bind(new(cluster.ClusterDescriptionService), new(*cluster.ClusterDescriptionServiceImpl)),

	NewClusterRestHandlerImpl,
	wire.Bind(new(ClusterRestHandler), new(*ClusterRestHandlerImpl)),
	NewClusterRouterImpl,
	wire.Bind(new(ClusterRouter), new(*ClusterRouterImpl)),

	repository3.NewEnvironmentRepositoryImpl,
	wire.Bind(new(repository3.EnvironmentRepository), new(*repository3.EnvironmentRepositoryImpl)),
	environment.NewEnvironmentServiceImpl,
	wire.Bind(new(environment.EnvironmentService), new(*environment.EnvironmentServiceImpl)),
	read2.NewEnvironmentReadServiceImpl,
	wire.Bind(new(read2.EnvironmentReadService), new(*read2.EnvironmentReadServiceImpl)),
	NewEnvironmentRestHandlerImpl,
	wire.Bind(new(EnvironmentRestHandler), new(*EnvironmentRestHandlerImpl)),
	NewEnvironmentRouterImpl,
	wire.Bind(new(EnvironmentRouter), new(*EnvironmentRouterImpl)),
)
View Source 
var ClusterWireSetEa = wire.NewSet(
	repository.NewClusterRepositoryImpl,
	wire.Bind(new(repository.ClusterRepository), new(*repository.ClusterRepositoryImpl)),
	rbac.NewClusterRbacServiceImpl,
	wire.Bind(new(rbac.ClusterRbacService), new(*rbac.ClusterRbacServiceImpl)),
	cluster.NewClusterServiceImpl,
	wire.Bind(new(cluster.ClusterService), new(*cluster.ClusterServiceImpl)),
	read.NewClusterReadServiceImpl,
	wire.Bind(new(read.ClusterReadService), new(*read.ClusterReadServiceImpl)),

	repository.NewClusterDescriptionRepositoryImpl,
	wire.Bind(new(repository.ClusterDescriptionRepository), new(*repository.ClusterDescriptionRepositoryImpl)),
	repository2.NewGenericNoteHistoryRepositoryImpl,
	wire.Bind(new(repository2.GenericNoteHistoryRepository), new(*repository2.GenericNoteHistoryRepositoryImpl)),
	repository2.NewGenericNoteRepositoryImpl,
	wire.Bind(new(repository2.GenericNoteRepository), new(*repository2.GenericNoteRepositoryImpl)),
	genericNotes.NewGenericNoteHistoryServiceImpl,
	wire.Bind(new(genericNotes.GenericNoteHistoryService), new(*genericNotes.GenericNoteHistoryServiceImpl)),
	genericNotes.NewGenericNoteServiceImpl,
	wire.Bind(new(genericNotes.GenericNoteService), new(*genericNotes.GenericNoteServiceImpl)),
	cluster.NewClusterDescriptionServiceImpl,
	wire.Bind(new(cluster.ClusterDescriptionService), new(*cluster.ClusterDescriptionServiceImpl)),

	NewClusterRestHandlerImpl,
	wire.Bind(new(ClusterRestHandler), new(*ClusterRestHandlerImpl)),
	NewClusterRouterImpl,
	wire.Bind(new(ClusterRouter), new(*ClusterRouterImpl)),
	repository3.NewEnvironmentRepositoryImpl,
	wire.Bind(new(repository3.EnvironmentRepository), new(*repository3.EnvironmentRepositoryImpl)),
	environment.NewEnvironmentServiceImpl,
	wire.Bind(new(environment.EnvironmentService), new(*environment.EnvironmentServiceImpl)),
	read2.NewEnvironmentReadServiceImpl,
	wire.Bind(new(read2.EnvironmentReadService), new(*read2.EnvironmentReadServiceImpl)),
	NewEnvironmentRestHandlerImpl,
	wire.Bind(new(EnvironmentRestHandler), new(*EnvironmentRestHandlerImpl)),
	NewEnvironmentRouterImpl,
	wire.Bind(new(EnvironmentRouter), new(*EnvironmentRouterImpl)),
)

minimal wire to be used with EA

Functions

This section is empty.

Types

type ClusterReachableResponse added in v0.6.18 

type ClusterReachableResponse struct {
	ClusterReachable bool   `json:"clusterReachable"`
	ClusterName      string `json:"clusterName"`
}

type ClusterRestHandler 

type ClusterRestHandler interface {
	Save(w http.ResponseWriter, r *http.Request)
	SaveClusters(w http.ResponseWriter, r *http.Request)
	ValidateKubeconfig(w http.ResponseWriter, r *http.Request)
	FindAll(w http.ResponseWriter, r *http.Request)
	FindById(w http.ResponseWriter, r *http.Request)
	FindNoteByClusterId(w http.ResponseWriter, r *http.Request)
	Update(w http.ResponseWriter, r *http.Request)
	UpdateClusterDescription(w http.ResponseWriter, r *http.Request)
	UpdateClusterNote(w http.ResponseWriter, r *http.Request)
	FindAllForAutoComplete(w http.ResponseWriter, r *http.Request)
	DeleteCluster(w http.ResponseWriter, r *http.Request)
	GetClusterNamespaces(w http.ResponseWriter, r *http.Request)
	GetAllClusterNamespaces(w http.ResponseWriter, r *http.Request)
	FindAllForClusterPermission(w http.ResponseWriter, r *http.Request)
}

type ClusterRestHandlerImpl 

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

func NewClusterRestHandlerImpl 

func NewClusterRestHandlerImpl(clusterService cluster.ClusterService,
	clusterNoteService genericNotes.GenericNoteService,
	clusterDescriptionService cluster.ClusterDescriptionService,
	logger *zap.SugaredLogger,
	userService user.UserService,
	validator *validator.Validate,
	enforcer casbin.Enforcer,
	deleteService delete2.DeleteService,
	argoUserService argo.ArgoUserService,
	environmentService environment.EnvironmentService,
	clusterRbacService rbac.ClusterRbacService) *ClusterRestHandlerImpl

func (ClusterRestHandlerImpl) DeleteCluster added in v0.3.15 

func (impl ClusterRestHandlerImpl) DeleteCluster(w http.ResponseWriter, r *http.Request)

func (ClusterRestHandlerImpl) FindAll 

func (impl ClusterRestHandlerImpl) FindAll(w http.ResponseWriter, r *http.Request)

func (ClusterRestHandlerImpl) FindAllForAutoComplete 

func (impl ClusterRestHandlerImpl) FindAllForAutoComplete(w http.ResponseWriter, r *http.Request)

func (ClusterRestHandlerImpl) FindAllForClusterPermission added in v0.6.11 

func (impl ClusterRestHandlerImpl) FindAllForClusterPermission(w http.ResponseWriter, r *http.Request)

func (ClusterRestHandlerImpl) FindById 

func (impl ClusterRestHandlerImpl) FindById(w http.ResponseWriter, r *http.Request)

func (ClusterRestHandlerImpl) FindNoteByClusterId added in v0.6.17 

func (impl ClusterRestHandlerImpl) FindNoteByClusterId(w http.ResponseWriter, r *http.Request)

func (ClusterRestHandlerImpl) GetAllClusterNamespaces added in v0.6.10 

func (impl ClusterRestHandlerImpl) GetAllClusterNamespaces(w http.ResponseWriter, r *http.Request)

func (ClusterRestHandlerImpl) GetClusterNamespaces added in v0.6.11 

func (impl ClusterRestHandlerImpl) GetClusterNamespaces(w http.ResponseWriter, r *http.Request)

func (ClusterRestHandlerImpl) HandleRbacForClusterNamespace added in v1.1.0 

func (impl ClusterRestHandlerImpl) HandleRbacForClusterNamespace(userId int32, token string, clusterNamespaces map[string][]string) (map[string][]string, error)

func (ClusterRestHandlerImpl) Save 

func (impl ClusterRestHandlerImpl) Save(w http.ResponseWriter, r *http.Request)

func (ClusterRestHandlerImpl) SaveClusters added in v0.6.18 

func (impl ClusterRestHandlerImpl) SaveClusters(w http.ResponseWriter, r *http.Request)

func (ClusterRestHandlerImpl) Update 

func (impl ClusterRestHandlerImpl) Update(w http.ResponseWriter, r *http.Request)

func (ClusterRestHandlerImpl) UpdateClusterDescription added in v0.6.26 

func (impl ClusterRestHandlerImpl) UpdateClusterDescription(w http.ResponseWriter, r *http.Request)

func (ClusterRestHandlerImpl) UpdateClusterNote added in v0.6.17 

func (impl ClusterRestHandlerImpl) UpdateClusterNote(w http.ResponseWriter, r *http.Request)

func (ClusterRestHandlerImpl) ValidateKubeconfig added in v0.6.18 

func (impl ClusterRestHandlerImpl) ValidateKubeconfig(w http.ResponseWriter, r *http.Request)

type ClusterRouter 

type ClusterRouter interface {
	InitClusterRouter(clusterRouter *mux.Router)
}

type ClusterRouterImpl 

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

func NewClusterRouterImpl 

func NewClusterRouterImpl(handler ClusterRestHandler) *ClusterRouterImpl

func (ClusterRouterImpl) InitClusterRouter 

func (impl ClusterRouterImpl) InitClusterRouter(clusterRouter *mux.Router)

type EnvironmentRestHandler 

type EnvironmentRestHandler interface {
	Create(w http.ResponseWriter, r *http.Request)
	Get(w http.ResponseWriter, r *http.Request)
	GetAll(w http.ResponseWriter, r *http.Request)
	GetAllActive(w http.ResponseWriter, r *http.Request)
	Update(w http.ResponseWriter, r *http.Request)
	FindById(w http.ResponseWriter, r *http.Request)
	GetEnvironmentListForAutocomplete(w http.ResponseWriter, r *http.Request)
	GetCombinedEnvironmentListForDropDown(w http.ResponseWriter, r *http.Request)
	GetEnvironmentConnection(w http.ResponseWriter, r *http.Request)
	DeleteEnvironment(w http.ResponseWriter, r *http.Request)
	GetCombinedEnvironmentListForDropDownByClusterIds(w http.ResponseWriter, r *http.Request)
}

type EnvironmentRestHandlerImpl 

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

func NewEnvironmentRestHandlerImpl 

func NewEnvironmentRestHandlerImpl(svc request.EnvironmentService, environmentReadService read.EnvironmentReadService, logger *zap.SugaredLogger, userService user.UserService, validator *validator.Validate, enforcer casbin.Enforcer, deleteService delete2.DeleteService, k8sUtil *k8s2.K8sServiceImpl, k8sCommonService k8s.K8sCommonService) *EnvironmentRestHandlerImpl

func (EnvironmentRestHandlerImpl) CheckAuthorizationByEmailInBatchForGlobalEnvironment added in v0.6.17 

func (handler EnvironmentRestHandlerImpl) CheckAuthorizationByEmailInBatchForGlobalEnvironment(token string, object []string) map[string]bool

func (EnvironmentRestHandlerImpl) CheckAuthorizationForGlobalEnvironment added in v0.3.14 

func (handler EnvironmentRestHandlerImpl) CheckAuthorizationForGlobalEnvironment(token string, object string) bool

func (EnvironmentRestHandlerImpl) Create 

func (impl EnvironmentRestHandlerImpl) Create(w http.ResponseWriter, r *http.Request)

func (EnvironmentRestHandlerImpl) DeleteEnvironment added in v0.3.15 

func (impl EnvironmentRestHandlerImpl) DeleteEnvironment(w http.ResponseWriter, r *http.Request)

func (EnvironmentRestHandlerImpl) FindById 

func (impl EnvironmentRestHandlerImpl) FindById(w http.ResponseWriter, r *http.Request)

func (EnvironmentRestHandlerImpl) Get 

func (impl EnvironmentRestHandlerImpl) Get(w http.ResponseWriter, r *http.Request)

func (EnvironmentRestHandlerImpl) GetAll 

func (impl EnvironmentRestHandlerImpl) GetAll(w http.ResponseWriter, r *http.Request)

func (EnvironmentRestHandlerImpl) GetAllActive 

func (impl EnvironmentRestHandlerImpl) GetAllActive(w http.ResponseWriter, r *http.Request)

func (EnvironmentRestHandlerImpl) GetCombinedEnvironmentListForDropDown added in v0.3.14 

func (impl EnvironmentRestHandlerImpl) GetCombinedEnvironmentListForDropDown(w http.ResponseWriter, r *http.Request)

func (EnvironmentRestHandlerImpl) GetCombinedEnvironmentListForDropDownByClusterIds added in v0.3.14 

func (impl EnvironmentRestHandlerImpl) GetCombinedEnvironmentListForDropDownByClusterIds(w http.ResponseWriter, r *http.Request)

func (EnvironmentRestHandlerImpl) GetEnvironmentConnection added in v0.6.18 

func (impl EnvironmentRestHandlerImpl) GetEnvironmentConnection(w http.ResponseWriter, r *http.Request)

func (EnvironmentRestHandlerImpl) GetEnvironmentListForAutocomplete 

func (impl EnvironmentRestHandlerImpl) GetEnvironmentListForAutocomplete(w http.ResponseWriter, r *http.Request)

func (EnvironmentRestHandlerImpl) Update 

func (impl EnvironmentRestHandlerImpl) Update(w http.ResponseWriter, r *http.Request)

type EnvironmentRouter 

type EnvironmentRouter interface {
	InitEnvironmentClusterMappingsRouter(clusterAccountsRouter *mux.Router)
}

type EnvironmentRouterImpl 

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

func NewEnvironmentRouterImpl 

func NewEnvironmentRouterImpl(environmentClusterMappingsRestHandler EnvironmentRestHandler) *EnvironmentRouterImpl

func (EnvironmentRouterImpl) InitEnvironmentClusterMappingsRouter 

func (impl EnvironmentRouterImpl) InitEnvironmentClusterMappingsRouter(environmentClusterMappingsRouter *mux.Router)

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.