fluxService

Documentation

Index

• Constants
• Variables
• func GetFluxAppDetailDto(appDetail *FluxApplicationDto) *client.FluxApplication
• type EnvironmentDetail
• type FluxAppDetailRequest
• type FluxAppStatusDetail
• type FluxAppType
• type FluxApplicationDto
• type FluxApplicationService
• type FluxApplicationServiceImpl
  • func NewFluxApplicationServiceImpl(logger *zap.SugaredLogger, ...) *FluxApplicationServiceImpl
  • func (impl *FluxApplicationServiceImpl) BuildFluxAppDetail(request *client.FluxAppDetailRequest) (*FluxKsAppDetail, error)
  • func (impl *FluxApplicationServiceImpl) GetApplicationListDtos(resources unstructured.UnstructuredList, clusterName string, clusterId int, ...) ([]*FluxApplicationDto, error)
  • func (impl *FluxApplicationServiceImpl) GetFluxApplicationListForCluster(config *client.ClusterConfig) *client.FluxApplicationList
• type FluxHr
• type FluxKsAppDetail
• type FluxKsResourceDetail
• type ObjMetadata
• type ObjectMetadataCompact

Constants

const (
	FluxKustomizationGroup     = "kustomize.toolkit.fluxcd.io"
	FluxAppKustomizationKind   = "Kustomization"
	FluxKustomizationVersionV1 = "v1"
	AllNamespaces              = ""
	FluxHelmReleaseGroup       = "helm.toolkit.fluxcd.io"
	FluxAppHelmreleaseKind     = "HelmRelease"
	FluxHelmReleaseVersionV2   = "v2"
	FluxLabel                  = "labels"
	KustomizeNameLabel         = "kustomize.toolkit.fluxcd.io/name"
	KustomizeNamespaceLabel    = "kustomize.toolkit.fluxcd.io/namespace"
)

const (
	StatusMissing              = "Missing"
	Reason                     = "StatusNotReady"
	ErrMessageForHelmRelease   = "Status is missing for this helmRelease"
	ErrMessageForKustomization = "Status is missing for this kustomization"
)

const (
	HelmReleaseFluxAppType FluxAppType = "HelmRelease"
	AppNameKey                         = "Name"
	StatusKey                          = "Status"
	ReadyKey                           = "Ready"
	ColumnNameKey                      = "name"
	NamespaceKey                       = "namespace"
	MetaDataField                      = "metadata"
	ObjectField                        = "object"
	SpecField                          = "spec"

	StorageNamespaceKey = "storageNamespace"
	ReleaseNameKey      = "releaseName"
	TargetNamespaceKey  = "targetNamespace"
)

const (
	STATUS    = "status"
	INVENTORY = "inventory"
	ENTRIES   = "entries"
	ID        = "id"
	VERSION   = "v"
)

const (
	FieldSeparator  = "_"
	ColonTranscoded = "__"
)

Variables

var GvkForHelmreleaseFluxApp = schema.GroupVersionKind{
	Group:   FluxHelmReleaseGroup,
	Kind:    FluxAppHelmreleaseKind,
	Version: FluxHelmReleaseVersionV2,
}

var GvkForKustomizationFluxApp = schema.GroupVersionKind{
	Group:   FluxKustomizationGroup,
	Kind:    FluxAppKustomizationKind,
	Version: FluxKustomizationVersionV1,
}

Functions

func GetFluxAppDetailDto

func GetFluxAppDetailDto(appDetail *FluxApplicationDto) *client.FluxApplication

GetFluxAppDetailDto converting the AppDetail in Grpc format

Types

type EnvironmentDetail

type EnvironmentDetail struct {
	ClusterId   int    `json:"clusterId"`
	ClusterName string `json:"clusterName"`
	Namespace   string `json:"namespace"`
}

type FluxAppDetailRequest

type FluxAppDetailRequest struct {
	Config      *client.ClusterConfig
	Name        string `json:"name"`
	Namespace   string `json:"namespace"`
	IsKustomize bool   `json:"isKustomize"`
}

type FluxAppStatusDetail

type FluxAppStatusDetail struct {
	Status  string
	Reason  string
	Message string
}

type FluxAppType

type FluxAppType string

type FluxApplicationDto

type FluxApplicationDto struct {
	Name                  string             `json:"appName"`
	HealthStatus          string             `json:"appStatus"`
	SyncStatus            string             `json:"syncStatus"`
	EnvironmentDetails    *EnvironmentDetail `json:"environmentDetail"`
	FluxAppDeploymentType FluxAppType        `json:"fluxAppDeploymentType"`
}

type FluxApplicationService

type FluxApplicationService interface {
	GetFluxApplicationListForCluster(config *client.ClusterConfig) *client.FluxApplicationList
	BuildFluxAppDetail(request *client.FluxAppDetailRequest) (*FluxKsAppDetail, error)
}

type FluxApplicationServiceImpl

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

func NewFluxApplicationServiceImpl

func NewFluxApplicationServiceImpl(logger *zap.SugaredLogger,
	clusterRepository clusterRepository.ClusterRepository,
	k8sUtil k8sUtils.K8sService,
	converter converter.ClusterBeanConverter, common commonHelmService.CommonHelmService) *FluxApplicationServiceImpl

func (*FluxApplicationServiceImpl) BuildFluxAppDetail

func (impl *FluxApplicationServiceImpl) BuildFluxAppDetail(request *client.FluxAppDetailRequest) (*FluxKsAppDetail, error)

BuildFluxAppDetail Build Flux App Detail

func (*FluxApplicationServiceImpl) GetApplicationListDtos

func (impl *FluxApplicationServiceImpl) GetApplicationListDtos(resources unstructured.UnstructuredList, clusterName string, clusterId int, FluxAppType FluxAppType) ([]*FluxApplicationDto, error)

GetApplicationListDtos fetching the list of filtered apps from resources for flux Apps i.e. combined the both Kustomization and flux type

func (*FluxApplicationServiceImpl) GetFluxApplicationListForCluster

func (impl *FluxApplicationServiceImpl) GetFluxApplicationListForCluster(config *client.ClusterConfig) *client.FluxApplicationList

GetFluxApplicationListForCluster Getting App list for the cluster

type FluxHr

type FluxHr struct {
	Name      string
	Namespace string
}

type FluxKsAppDetail

type FluxKsAppDetail struct {
	*FluxApplicationDto
	AppStatusDto *FluxAppStatusDetail
	TreeResponse []*bean.ResourceTreeResponse
}

type FluxKsResourceDetail

type FluxKsResourceDetail struct {
	Name      string
	Namespace string
	Group     string
	Version   string
	Kind      string
}

type ObjMetadata

type ObjMetadata struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace"`
	Group     string `json:"group"`
	Kind      string `json:"kind"`
}

type ObjectMetadataCompact

type ObjectMetadataCompact struct {
	Id      string `json:"id"`
	Version string `json:"version"`
}