util

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Mar 5, 2021 License: Apache-2.0 Imports: 48 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CompareUnOrdered 

func CompareUnOrdered(a, b []int) bool

func CreateEcrRepo 

func CreateEcrRepo(repoName string, RegistryURL string, reg string, accessKey string, secretKey string) error

FIXME: this code is temp

func GetLogger deprecated 

func GetLogger() *zap.SugaredLogger

Deprecated: instead calling this method inject logger from wire

func IntValidator 

func IntValidator() (*validator.Validate, error)

func IsErrNoRows 

func IsErrNoRows(err error) bool

func NewHttpClient 

func NewHttpClient() *http.Client

func NewSugardLogger 

func NewSugardLogger() *zap.SugaredLogger

func TopoSort 

func TopoSort(graph map[int][]int) []int

func Tprintf 

func Tprintf(tmpl string, data interface{}) (string, error)

Tprintf passed template string is formatted usign its operands and returns the resulting string. Spaces are added between operands when neither is a string.

func ValidateCheckoutPath 

func ValidateCheckoutPath(fl validator.FieldLevel) bool

func ValidateName 

func ValidateName(fl validator.FieldLevel) bool

Types

type ApiError 

type ApiError struct {
	HttpStatusCode    int         `json:"-"`
	Code              string      `json:"code,omitempty"`
	InternalMessage   string      `json:"internalMessage,omitempty"`
	UserMessage       interface{} `json:"userMessage,omitempty"`
	UserDetailMessage string      `json:"userDetailMessage,omitempty"`
}

func (*ApiError) Error 

func (e *ApiError) Error() string

func (*ApiError) ErrorfInternal 

func (e *ApiError) ErrorfInternal(format string, a ...interface{}) error

default internal will be set

func (ApiError) ErrorfUser 

func (e ApiError) ErrorfUser(format string, a ...interface{}) error

default user message will be set

type ChartConfig 

type ChartConfig struct {
	ChartName      string
	ChartLocation  string
	FileName       string //filename
	FileContent    string
	ReleaseMessage string
}

type ChartGitAttribute 

type ChartGitAttribute struct {
	RepoUrl, ChartLocation string
}

type ChartTemplateService 

type ChartTemplateService interface {
	CreateChart(chartMetaData *chart.Metadata, refChartLocation string, templateName string) (*ChartValues, *ChartGitAttribute, error)
	GetChartVersion(location string) (string, error)
	CreateChartProxy(chartMetaData *chart.Metadata, refChartLocation string, templateName string, version string, envName string, appName string) (string, *ChartGitAttribute, error)
	GitPull(clonedDir string, repoUrl string, appStoreName string) error
}

type ChartTemplateServiceImpl 

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

func NewChartTemplateServiceImpl 

func NewChartTemplateServiceImpl(logger *zap.SugaredLogger,
	chartWorkingDir ChartWorkingDir,
	client *http.Client,
	gitFactory *GitFactory) *ChartTemplateServiceImpl

func (ChartTemplateServiceImpl) CleanDir 

func (impl ChartTemplateServiceImpl) CleanDir(dir string)

func (ChartTemplateServiceImpl) CreateChart 

func (impl ChartTemplateServiceImpl) CreateChart(chartMetaData *chart.Metadata, refChartLocation string, templateName string) (*ChartValues, *ChartGitAttribute, error)

func (ChartTemplateServiceImpl) CreateChartProxy 

func (impl ChartTemplateServiceImpl) CreateChartProxy(chartMetaData *chart.Metadata, refChartLocation string, templateName string, version string, envName string, appName string) (string, *ChartGitAttribute, error)

func (ChartTemplateServiceImpl) GetChartVersion 

func (ChartTemplateServiceImpl) GetChartVersion(location string) (string, error)

func (ChartTemplateServiceImpl) GitPull 

func (impl ChartTemplateServiceImpl) GitPull(clonedDir string, repoUrl string, appStoreName string) error

type ChartValues 

type ChartValues struct {
	Values                  string `json:"values"`            //yaml
	AppOverrides            string `json:"appOverrides"`      //json
	EnvOverrides            string `json:"envOverrides"`      //json
	ReleaseOverrides        string `json:"releaseOverrides"`  //json
	PipelineOverrides       string `json:"pipelineOverrides"` //json
	ImageDescriptorTemplate string `json:"-"`
}

type ChartWorkingDir 

type ChartWorkingDir string

type ClusterConfig 

type ClusterConfig struct {
	Host        string
	BearerToken string
}

type GitClient 

type GitClient interface {
	CreateRepository(name, description string) (url string, isNew bool, err error)
	CommitValues(config *ChartConfig) (commitHash string, err error)
	GetRepoUrl(projectName string) (repoUrl string, err error)
}

func NewGitLabClient 

func NewGitLabClient(config *GitConfig, logger *zap.SugaredLogger, gitService GitService) (GitClient, error)

type GitConfig 

type GitConfig struct {
	GitlabGroupId      string //local
	GitlabGroupPath    string //local
	GitToken           string `env:"GIT_TOKEN" `                                      //not null  // public
	GitUserName        string `env:"GIT_USERNAME" `                                   //not null  // public
	GitWorkingDir      string `env:"GIT_WORKING_DIRECTORY" envDefault:"/tmp/gitops/"` //working directory for git. might use pvc
	GithubOrganization string
	GitProvider        string `env:"GIT_PROVIDER" envDefault:"GITHUB"` // SUPPORTED VALUES  GITHUB, GITLAB
	GitHost            string `env:"GIT_HOST" envDefault:""`
}

func GetGitConfig 

func GetGitConfig(gitOpsRepository repository.GitOpsConfigRepository) (*GitConfig, error)

type GitFactory 

type GitFactory struct {
	Client GitClient

	GitWorkingDir string
	// contains filtered or unexported fields
}

func NewGitFactory 

func NewGitFactory(logger *zap.SugaredLogger, gitOpsRepository repository.GitOpsConfigRepository) (*GitFactory, error)

func (*GitFactory) Reload 

func (factory *GitFactory) Reload() error

type GitHubClient 

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

func NewGithubClient 

func NewGithubClient(token string, org string, logger *zap.SugaredLogger, gitService GitService) GitHubClient

func (GitHubClient) CommitValues 

func (impl GitHubClient) CommitValues(config *ChartConfig) (commitHash string, err error)

func (GitHubClient) CreateRepository 

func (impl GitHubClient) CreateRepository(name, description string) (url string, isNew bool, err error)

func (GitHubClient) GetRepoUrl 

func (impl GitHubClient) GetRepoUrl(projectName string) (repoUrl string, err error)

type GitLabClient 

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

func (GitLabClient) CommitValues 

func (impl GitLabClient) CommitValues(config *ChartConfig) (commitHash string, err error)

func (GitLabClient) CreateRepository 

func (impl GitLabClient) CreateRepository(name, description string) (url string, isNew bool, err error)

func (GitLabClient) DeleteProject 

func (impl GitLabClient) DeleteProject(projectName string) (err error)

func (GitLabClient) GetRepoUrl 

func (impl GitLabClient) GetRepoUrl(projectName string) (repoUrl string, err error)

type GitService 

type GitService interface {
	Clone(url, targetDir string) (clonedDir string, err error)
	CommitAndPushAllChanges(repoRoot, commitMsg string) (commitHash string, err error)
	ForceResetHead(repoRoot string) (err error)
	CommitValues(config *ChartConfig) (commitHash string, err error)

	GetCloneDirectory(targetDir string) (clonedDir string)
	Pull(repoRoot string) (err error)
}

-------------------- go-git integration -------------------

type GitServiceImpl 

type GitServiceImpl struct {
	Auth transport.AuthMethod
	// contains filtered or unexported fields
}

func NewGitServiceImpl 

func NewGitServiceImpl(config *GitConfig, logger *zap.SugaredLogger) *GitServiceImpl

func (GitServiceImpl) Clone 

func (impl GitServiceImpl) Clone(url, targetDir string) (clonedDir string, err error)

func (GitServiceImpl) CommitAndPushAllChanges 

func (impl GitServiceImpl) CommitAndPushAllChanges(repoRoot, commitMsg string) (commitHash string, err error)

func (GitServiceImpl) CommitValues 

func (impl GitServiceImpl) CommitValues(config *ChartConfig) (commitHash string, err error)

func (GitServiceImpl) ForceResetHead 

func (impl GitServiceImpl) ForceResetHead(repoRoot string) (err error)

func (GitServiceImpl) GetCloneDirectory 

func (impl GitServiceImpl) GetCloneDirectory(targetDir string) (clonedDir string)

func (GitServiceImpl) Pull 

func (impl GitServiceImpl) Pull(repoRoot string) (err error)

type JsonPatchType 

type JsonPatchType struct {
	Op    string      `json:"op"`
	Path  string      `json:"path"`
	Value interface{} `json:"value"`
}

type K8sUtil 

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

func NewK8sUtil 

func NewK8sUtil(logger *zap.SugaredLogger) *K8sUtil

func (K8sUtil) CreateNsIfNotExists 

func (impl K8sUtil) CreateNsIfNotExists(namespace string, clusterConfig *ClusterConfig) (err error)

func (K8sUtil) CreateSecretFast 

func (impl K8sUtil) CreateSecretFast(namespace string, data map[string][]byte, secretName string, client *v12.CoreV1Client) (*v1.Secret, error)

func (K8sUtil) GetClient 

func (impl K8sUtil) GetClient(clusterConfig *ClusterConfig) (*v12.CoreV1Client, error)

func (K8sUtil) GetConfigMap 

func (impl K8sUtil) GetConfigMap(namespace string, name string, clusterConfig *ClusterConfig) (*v1.ConfigMap, error)

func (K8sUtil) GetConfigMapFast 

func (impl K8sUtil) GetConfigMapFast(namespace string, name string, client *v12.CoreV1Client) (*v1.ConfigMap, error)

func (K8sUtil) GetSecretFast 

func (impl K8sUtil) GetSecretFast(namespace string, name string, client *v12.CoreV1Client) (*v1.Secret, error)

func (K8sUtil) PatchConfigMap 

func (impl K8sUtil) PatchConfigMap(namespace string, clusterConfig *ClusterConfig, name string, data map[string]interface{}) (*v1.ConfigMap, error)

func (K8sUtil) PatchConfigMapJsonType 

func (impl K8sUtil) PatchConfigMapJsonType(namespace string, clusterConfig *ClusterConfig, name string, data interface{}, path string) (*v1.ConfigMap, error)

func (K8sUtil) UpdateConfigMap 

func (impl K8sUtil) UpdateConfigMap(namespace string, cm *v1.ConfigMap, clusterConfig *ClusterConfig) (*v1.ConfigMap, error)

func (K8sUtil) UpdateConfigMapFast 

func (impl K8sUtil) UpdateConfigMapFast(namespace string, cm *v1.ConfigMap, client *v12.CoreV1Client) (*v1.ConfigMap, error)

func (K8sUtil) UpdateSecretFast 

func (impl K8sUtil) UpdateSecretFast(namespace string, secret *v1.Secret, client *v12.CoreV1Client) (*v1.Secret, error)

type LogConfig 

type LogConfig struct {
	Level int `env:"LOG_LEVEL" envDefault:"0"`
}

type MergeUtil 

type MergeUtil struct {
	Logger *zap.SugaredLogger
}

func (MergeUtil) ConfigMapMerge 

func (m MergeUtil) ConfigMapMerge(appLevelConfigMapJson string, envLevelConfigMapJson string) (data string, err error)

func (MergeUtil) ConfigSecretMerge 

func (m MergeUtil) ConfigSecretMerge(appLevelSecretJson string, envLevelSecretJson string, chartMajorVersion int, chartMinorVersion int) (data string, err error)

func (MergeUtil) JsonPatch 

func (m MergeUtil) JsonPatch(target, patch []byte) (data []byte, err error)

//returns json representation of merged values 

func (m MergeUtil) MergeOverride(helmValues string, override []byte) ([]byte, error) {
	cf, err := conflate.FromData([]byte(helmValues), override)
	if err != nil {
		m.Logger.Errorw("error in merging config",
			"original", helmValues,
			"override", override,
			"error", err)
		return nil, err
	}
	jsonBytes, err := cf.MarshalJSON()
	if err != nil {
		m.Logger.Errorw("error in marshaling yaml ",
			"cf", cf,
			"error", err)
		return nil, err
	}
	dst := new(bytes.Buffer)
	err = json.Compact(dst, jsonBytes)
	if err != nil {
		return nil, err
	}
	jsonBytes = dst.Bytes()
	m.Logger.Infow("merged config ",
		"original", helmValues,
		"override", override,
		"yaml", jsonBytes,
	)
	return jsonBytes, nil
}

func (m MergeUtil) MergeOverrideVal(data ...[]byte) ([]byte, error) {
	cf, err := conflate.FromData(data...)
	if err != nil {
		m.Logger.Errorw("error in merging config",
			"val", data,
			"error", err)
		return nil, err
	}
	jsonBytes, err := cf.MarshalJSON()
	if err != nil {
		m.Logger.Errorw("error in marshaling yaml ",
			"cf", cf,
			"error", err)
		return nil, err
	}
	dst := new(bytes.Buffer)
	err = json.Compact(dst, jsonBytes)
	if err != nil {
		return nil, err
	}
	jsonBytes = dst.Bytes()
	return jsonBytes, nil
}

merges two json objects

Source Files

View all Source files

Directories

Path Synopsis

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.