cluster

Documentation

Index

• Constants
• Variables
• type ClusterRestHandler
• type ClusterRestHandlerImpl
  • func NewClusterRestHandlerImpl(clusterService cluster.ClusterService, logger *zap.SugaredLogger, ...) *ClusterRestHandlerImpl
  • func (impl ClusterRestHandlerImpl) DeleteCluster(w http.ResponseWriter, r *http.Request)
  • func (impl ClusterRestHandlerImpl) FindAll(w http.ResponseWriter, r *http.Request)
  • func (impl ClusterRestHandlerImpl) FindAllForAutoComplete(w http.ResponseWriter, r *http.Request)
  • func (impl ClusterRestHandlerImpl) FindById(w http.ResponseWriter, r *http.Request)
  • func (impl ClusterRestHandlerImpl) FindOne(w http.ResponseWriter, r *http.Request)
  • func (impl ClusterRestHandlerImpl) Save(w http.ResponseWriter, r *http.Request)
  • func (impl ClusterRestHandlerImpl) Update(w http.ResponseWriter, r *http.Request)
• type ClusterRouter
• type ClusterRouterImpl
  • func NewClusterRouterImpl(handler ClusterRestHandler) *ClusterRouterImpl
  • func (impl ClusterRouterImpl) InitClusterRouter(clusterRouter *mux.Router)
• type EnvironmentRestHandler
• type EnvironmentRestHandlerImpl
  • func NewEnvironmentRestHandlerImpl(svc request.EnvironmentService, logger *zap.SugaredLogger, ...) *EnvironmentRestHandlerImpl
  • func (handler EnvironmentRestHandlerImpl) CheckAuthorizationForGlobalEnvironment(token string, object string) bool
  • func (impl EnvironmentRestHandlerImpl) Create(w http.ResponseWriter, r *http.Request)
  • func (impl EnvironmentRestHandlerImpl) DeleteEnvironment(w http.ResponseWriter, r *http.Request)
  • func (impl EnvironmentRestHandlerImpl) FindById(w http.ResponseWriter, r *http.Request)
  • func (impl EnvironmentRestHandlerImpl) Get(w http.ResponseWriter, r *http.Request)
  • func (impl EnvironmentRestHandlerImpl) GetAll(w http.ResponseWriter, r *http.Request)
  • func (impl EnvironmentRestHandlerImpl) GetAllActive(w http.ResponseWriter, r *http.Request)
  • func (impl EnvironmentRestHandlerImpl) GetCombinedEnvironmentListForDropDown(w http.ResponseWriter, r *http.Request)
  • func (impl EnvironmentRestHandlerImpl) GetCombinedEnvironmentListForDropDownByClusterIds(w http.ResponseWriter, r *http.Request)
  • func (impl EnvironmentRestHandlerImpl) GetEnvironmentListForAutocomplete(w http.ResponseWriter, r *http.Request)
  • func (impl EnvironmentRestHandlerImpl) Update(w http.ResponseWriter, r *http.Request)
• type EnvironmentRouter
• type EnvironmentRouterImpl
  • func NewEnvironmentRouterImpl(environmentClusterMappingsRestHandler EnvironmentRestHandler) *EnvironmentRouterImpl
  • func (impl EnvironmentRouterImpl) InitEnvironmentClusterMappingsRouter(environmentClusterMappingsRouter *mux.Router)

Constants

const CLUSTER_DELETE_SUCCESS_RESP = "Cluster deleted successfully."

const ENV_DELETE_SUCCESS_RESP = "Environment deleted successfully."

Variables

var ClusterWireSet = wire.NewSet(
	repository.NewClusterRepositoryImpl,
	wire.Bind(new(repository.ClusterRepository), new(*repository.ClusterRepositoryImpl)),
	cluster.NewClusterServiceImplExtended,
	wire.Bind(new(cluster.ClusterService), new(*cluster.ClusterServiceImplExtended)),
	NewClusterRestHandlerImpl,
	wire.Bind(new(ClusterRestHandler), new(*ClusterRestHandlerImpl)),
	NewClusterRouterImpl,
	wire.Bind(new(ClusterRouter), new(*ClusterRouterImpl)),

	repository.NewEnvironmentRepositoryImpl,
	wire.Bind(new(repository.EnvironmentRepository), new(*repository.EnvironmentRepositoryImpl)),
	cluster.NewEnvironmentServiceImpl,
	wire.Bind(new(cluster.EnvironmentService), new(*cluster.EnvironmentServiceImpl)),
	NewEnvironmentRestHandlerImpl,
	wire.Bind(new(EnvironmentRestHandler), new(*EnvironmentRestHandlerImpl)),
	NewEnvironmentRouterImpl,
	wire.Bind(new(EnvironmentRouter), new(*EnvironmentRouterImpl)),
)

var ClusterWireSetEa = wire.NewSet(
	repository.NewClusterRepositoryImpl,
	wire.Bind(new(repository.ClusterRepository), new(*repository.ClusterRepositoryImpl)),
	cluster.NewClusterServiceImpl,
	wire.Bind(new(cluster.ClusterService), new(*cluster.ClusterServiceImpl)),
	NewClusterRestHandlerImpl,
	wire.Bind(new(ClusterRestHandler), new(*ClusterRestHandlerImpl)),
	NewClusterRouterImpl,
	wire.Bind(new(ClusterRouter), new(*ClusterRouterImpl)),
	repository.NewEnvironmentRepositoryImpl,
	wire.Bind(new(repository.EnvironmentRepository), new(*repository.EnvironmentRepositoryImpl)),
	cluster.NewEnvironmentServiceImpl,
	wire.Bind(new(cluster.EnvironmentService), new(*cluster.EnvironmentServiceImpl)),
	NewEnvironmentRestHandlerImpl,
	wire.Bind(new(EnvironmentRestHandler), new(*EnvironmentRestHandlerImpl)),
	NewEnvironmentRouterImpl,
	wire.Bind(new(EnvironmentRouter), new(*EnvironmentRouterImpl)),
)

minimal wire to be used with EA

Types

type ClusterRestHandler

type ClusterRestHandler interface {
	Save(w http.ResponseWriter, r *http.Request)
	FindOne(w http.ResponseWriter, r *http.Request)
	FindAll(w http.ResponseWriter, r *http.Request)

	FindById(w http.ResponseWriter, r *http.Request)
	Update(w http.ResponseWriter, r *http.Request)

	FindAllForAutoComplete(w http.ResponseWriter, r *http.Request)
	DeleteCluster(w http.ResponseWriter, r *http.Request)
}

type ClusterRestHandlerImpl

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

func NewClusterRestHandlerImpl

func NewClusterRestHandlerImpl(clusterService cluster.ClusterService,
	logger *zap.SugaredLogger,
	userService user.UserService,
	validator *validator.Validate,
	enforcer casbin.Enforcer,
	deleteService delete2.DeleteService,
	argoUserService argo.ArgoUserService) *ClusterRestHandlerImpl

func (ClusterRestHandlerImpl) DeleteCluster

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) FindById

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

func (ClusterRestHandlerImpl) FindOne

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

func (ClusterRestHandlerImpl) Save

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

func (ClusterRestHandlerImpl) Update

func (impl ClusterRestHandlerImpl) Update(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)
	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, logger *zap.SugaredLogger, userService user.UserService,
	validator *validator.Validate, enforcer casbin.Enforcer,
	deleteService delete2.DeleteService,
) *EnvironmentRestHandlerImpl

func (EnvironmentRestHandlerImpl) CheckAuthorizationForGlobalEnvironment

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

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

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

func (EnvironmentRestHandlerImpl) GetCombinedEnvironmentListForDropDownByClusterIds

func (impl EnvironmentRestHandlerImpl) GetCombinedEnvironmentListForDropDownByClusterIds(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)