Documentation
¶
Index ¶
- func DecodeFluxExternalAppId(appId string) (*bean.FluxAppIdentifier, error)
- type FluxApplicationService
- type FluxApplicationServiceImpl
- func (impl *FluxApplicationServiceImpl) GetFluxAppDetail(ctx context.Context, app *bean.FluxAppIdentifier) (*bean.FluxApplicationDetailDto, error)
- func (impl *FluxApplicationServiceImpl) HibernateFluxApplication(ctx context.Context, app *bean.FluxAppIdentifier, ...) ([]*openapi.HibernateStatus, error)
- func (impl *FluxApplicationServiceImpl) ListFluxApplications(ctx context.Context, clusterIds []int, noStream bool, w http.ResponseWriter)
- func (impl *FluxApplicationServiceImpl) UnHibernateFluxApplication(ctx context.Context, app *bean.FluxAppIdentifier, ...) ([]*openapi.HibernateStatus, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DecodeFluxExternalAppId ¶
func DecodeFluxExternalAppId(appId string) (*bean.FluxAppIdentifier, error)
Types ¶
type FluxApplicationService ¶
type FluxApplicationService interface {
ListFluxApplications(ctx context.Context, clusterIds []int, noStream bool, w http.ResponseWriter)
GetFluxAppDetail(ctx context.Context, app *bean.FluxAppIdentifier) (*bean.FluxApplicationDetailDto, error)
HibernateFluxApplication(ctx context.Context, app *bean.FluxAppIdentifier, hibernateRequest *openapi.HibernateRequest) ([]*openapi.HibernateStatus, error)
UnHibernateFluxApplication(ctx context.Context, app *bean.FluxAppIdentifier, hibernateRequest *openapi.HibernateRequest) ([]*openapi.HibernateStatus, error)
}
type FluxApplicationServiceImpl ¶
type FluxApplicationServiceImpl struct {
// contains filtered or unexported fields
}
func NewFluxApplicationServiceImpl ¶
func NewFluxApplicationServiceImpl(logger *zap.SugaredLogger, helmAppReadService read.HelmAppReadService, clusterService cluster.ClusterService, helmAppClient gRPC.HelmAppClient, pump connector.Pump, pipelineRepository pipelineConfig.PipelineRepository, installedAppRepository repository.InstalledAppRepository) *FluxApplicationServiceImpl
func (*FluxApplicationServiceImpl) GetFluxAppDetail ¶
func (impl *FluxApplicationServiceImpl) GetFluxAppDetail(ctx context.Context, app *bean.FluxAppIdentifier) (*bean.FluxApplicationDetailDto, error)
func (*FluxApplicationServiceImpl) HibernateFluxApplication ¶
func (impl *FluxApplicationServiceImpl) HibernateFluxApplication(ctx context.Context, app *bean.FluxAppIdentifier, hibernateRequest *openapi.HibernateRequest) ([]*openapi.HibernateStatus, error)
func (*FluxApplicationServiceImpl) ListFluxApplications ¶
func (impl *FluxApplicationServiceImpl) ListFluxApplications(ctx context.Context, clusterIds []int, noStream bool, w http.ResponseWriter)
func (*FluxApplicationServiceImpl) UnHibernateFluxApplication ¶
func (impl *FluxApplicationServiceImpl) UnHibernateFluxApplication(ctx context.Context, app *bean.FluxAppIdentifier, hibernateRequest *openapi.HibernateRequest) ([]*openapi.HibernateStatus, error)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.