config

Documentation

Index

• type InfraConfigClient
• type InfraConfigClientImpl
  • func NewInfraConfigClient(logger *zap.SugaredLogger, ...) *InfraConfigClientImpl
  • func (impl *InfraConfigClientImpl) ConvertToProfilePlatformMap(...) (map[int]map[string][]*v1.ConfigurationBean, error)
  • func (impl *InfraConfigClientImpl) GetConfigurationBeansForProfile(...) (map[string][]*v1.ConfigurationBean, error)
  • func (impl *InfraConfigClientImpl) GetConfigurationUnits() (map[v1.ConfigKeyStr]map[string]v1.Unit, error)
  • func (impl *InfraConfigClientImpl) GetDefaultConfigurationForPlatform(platformName string, ...) []*v1.ConfigurationBean
  • func (impl *InfraConfigClientImpl) GetInfraConfigEntities(profileId int, infraConfig *v1.InfraConfig) ([]*repository.InfraProfileConfigurationEntity, error)
  • func (impl *InfraConfigClientImpl) GetInfraProfileConfigurationEntities(profileBean *v1.ProfileBeanDto, userId int32) ([]*repository.InfraProfileConfigurationEntity, error)
  • func (impl *InfraConfigClientImpl) HandleInfraConfigTriggerAudit(workflowId int, triggeredBy int32, infraConfigs map[string]*v1.InfraConfig) error
  • func (impl *InfraConfigClientImpl) HandlePostCreateOperations(tx *pg.Tx, createdInfraConfigs []*repository.InfraProfileConfigurationEntity) error
  • func (impl *InfraConfigClientImpl) HandlePostUpdateOperations(tx *pg.Tx, updatedInfraConfigs []*repository.InfraProfileConfigurationEntity) error
  • func (impl *InfraConfigClientImpl) MergeInfraConfigurations(supportedConfigKey v1.ConfigKeyStr, profileConfiguration *v1.ConfigurationBean, ...) (*v1.ConfigurationBean, error)
  • func (impl *InfraConfigClientImpl) OverrideInfraConfig(infraConfiguration *v1.InfraConfig, configurationBean *v1.ConfigurationBean) (*v1.InfraConfig, error)
  • func (impl *InfraConfigClientImpl) Validate(profileBean, defaultProfile *v1.ProfileBeanDto) (map[string]v1.InfraConfigKeys, error)
• type InfraConfigEntClient

Types

type InfraConfigClient

type InfraConfigClient interface {
	GetDefaultConfigurationForPlatform(platformName string, defaultConfigurationsMap map[string][]*v1.ConfigurationBean) []*v1.ConfigurationBean
	GetConfigurationBeansForProfile(infraProfileConfigurationEntities []*repository.InfraProfileConfigurationEntity, profileName string) (map[string][]*v1.ConfigurationBean, error)
	Validate(profileBean, defaultProfile *v1.ProfileBeanDto) (map[string]v1.InfraConfigKeys, error)
	GetConfigurationUnits() (map[v1.ConfigKeyStr]map[string]v1.Unit, error)
	GetInfraProfileConfigurationEntities(profileBean *v1.ProfileBeanDto, userId int32) ([]*repository.InfraProfileConfigurationEntity, error)
	HandlePostUpdateOperations(tx *pg.Tx, updatedInfraConfigs []*repository.InfraProfileConfigurationEntity) error
	HandlePostCreateOperations(tx *pg.Tx, createdInfraConfigs []*repository.InfraProfileConfigurationEntity) error
	GetInfraConfigEntities(profileId int, infraConfig *v1.InfraConfig) ([]*repository.InfraProfileConfigurationEntity, error)
	OverrideInfraConfig(infraConfiguration *v1.InfraConfig, configurationBean *v1.ConfigurationBean) (*v1.InfraConfig, error)
	ConvertToProfilePlatformMap(infraProfileConfigurationEntities []*repository.InfraProfileConfigurationEntity, profilesMap map[int]*v1.ProfileBeanDto, profilePlatforms []*repository.ProfilePlatformMapping) (map[int]map[string][]*v1.ConfigurationBean, error)
	MergeInfraConfigurations(supportedConfigKey v1.ConfigKeyStr, profileConfiguration *v1.ConfigurationBean, defaultConfigurations []*v1.ConfigurationBean) (*v1.ConfigurationBean, error)
	HandleInfraConfigTriggerAudit(workflowId int, triggeredBy int32, infraConfigs map[string]*v1.InfraConfig) error
	InfraConfigEntClient
}

type InfraConfigClientImpl

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

func NewInfraConfigClient

func NewInfraConfigClient(logger *zap.SugaredLogger,
	scopedVariableManager variables.ScopedVariableManager,
	configReadService read.ConfigReadService) *InfraConfigClientImpl

func (*InfraConfigClientImpl) ConvertToProfilePlatformMap

func (impl *InfraConfigClientImpl) ConvertToProfilePlatformMap(infraProfileConfigurationEntities []*repository.InfraProfileConfigurationEntity,
	profilesMap map[int]*v1.ProfileBeanDto, profilePlatforms []*repository.ProfilePlatformMapping) (map[int]map[string][]*v1.ConfigurationBean, error)

func (*InfraConfigClientImpl) GetConfigurationBeansForProfile

func (impl *InfraConfigClientImpl) GetConfigurationBeansForProfile(infraProfileConfigurationEntities []*repository.InfraProfileConfigurationEntity, profileName string) (map[string][]*v1.ConfigurationBean, error)

func (*InfraConfigClientImpl) GetConfigurationUnits

func (impl *InfraConfigClientImpl) GetConfigurationUnits() (map[v1.ConfigKeyStr]map[string]v1.Unit, error)

func (*InfraConfigClientImpl) GetDefaultConfigurationForPlatform

func (impl *InfraConfigClientImpl) GetDefaultConfigurationForPlatform(platformName string, defaultConfigurationsMap map[string][]*v1.ConfigurationBean) []*v1.ConfigurationBean

func (*InfraConfigClientImpl) GetInfraConfigEntities

func (impl *InfraConfigClientImpl) GetInfraConfigEntities(profileId int, infraConfig *v1.InfraConfig) ([]*repository.InfraProfileConfigurationEntity, error)

func (*InfraConfigClientImpl) GetInfraProfileConfigurationEntities

func (impl *InfraConfigClientImpl) GetInfraProfileConfigurationEntities(profileBean *v1.ProfileBeanDto, userId int32) ([]*repository.InfraProfileConfigurationEntity, error)

GetInfraProfileConfigurationEntities converts bean.ProfileBeanDto back to []repository.InfraProfileConfigurationEntity

func (*InfraConfigClientImpl) HandleInfraConfigTriggerAudit

func (impl *InfraConfigClientImpl) HandleInfraConfigTriggerAudit(workflowId int, triggeredBy int32, infraConfigs map[string]*v1.InfraConfig) error

func (*InfraConfigClientImpl) HandlePostCreateOperations

func (impl *InfraConfigClientImpl) HandlePostCreateOperations(tx *pg.Tx, createdInfraConfigs []*repository.InfraProfileConfigurationEntity) error

func (*InfraConfigClientImpl) HandlePostUpdateOperations

func (impl *InfraConfigClientImpl) HandlePostUpdateOperations(tx *pg.Tx, updatedInfraConfigs []*repository.InfraProfileConfigurationEntity) error

func (*InfraConfigClientImpl) MergeInfraConfigurations

func (impl *InfraConfigClientImpl) MergeInfraConfigurations(supportedConfigKey v1.ConfigKeyStr, profileConfiguration *v1.ConfigurationBean, defaultConfigurations []*v1.ConfigurationBean) (*v1.ConfigurationBean, error)

func (*InfraConfigClientImpl) OverrideInfraConfig

func (impl *InfraConfigClientImpl) OverrideInfraConfig(infraConfiguration *v1.InfraConfig, configurationBean *v1.ConfigurationBean) (*v1.InfraConfig, error)

func (*InfraConfigClientImpl) Validate

func (impl *InfraConfigClientImpl) Validate(profileBean, defaultProfile *v1.ProfileBeanDto) (map[string]v1.InfraConfigKeys, error)

type InfraConfigEntClient

type InfraConfigEntClient interface{}