connection

Documentation

Index

• Constants
• func EncodeX509KeyPair(cert tls.Certificate) ([]byte, []byte)
• func GetTLS(cert *tls.Certificate) credentials.TransportCredentials
• func SetTokenAuth(token string)
• func SettingsManager(cfg *Config) (*settings.SettingsManager, error)
• type ArgoCDConnectionManager
• type ArgoCDConnectionManagerImpl
  • func NewArgoCDConnectionManagerImpl(Logger *zap.SugaredLogger, settingsManager *settings.SettingsManager, ...) (*ArgoCDConnectionManagerImpl, error)
  • func (impl *ArgoCDConnectionManagerImpl) GetConnection() *grpc.ClientConn
  • func (impl *ArgoCDConnectionManagerImpl) GetLatestDevtronArgoCdUserToken(authConfig *bean.AcdAuthConfig) (string, error)
  • func (impl *ArgoCDConnectionManagerImpl) GetOrUpdateArgoCdUserDetail() string
  • func (impl *ArgoCDConnectionManagerImpl) ValidateGitOpsAndGetOrUpdateArgoCdUserDetail() string
• type Config
  • func GetConfig() (*Config, error)
• type TokenAuth
  • func GetTokenAuth() *TokenAuth
  • func (t TokenAuth) GetRequestMetadata(ctx context.Context, in ...string) (map[string]string, error)
  • func (TokenAuth) RequireTransportSecurity() bool

Constants

const (
	DEVTRON_USER                     = "devtron"
	DEVTRONCD_NAMESPACE              = "devtroncd"
	ARGOCD_CM                        = "argocd-cm"
	ARGOCD_SECRET                    = "argocd-secret"
	ARGO_USER_APIKEY_CAPABILITY      = "apiKey"
	ARGO_USER_LOGIN_CAPABILITY       = "login"
	DEVTRON_ARGOCD_USERNAME_KEY      = "DEVTRON_ACD_USER_NAME"
	DEVTRON_ARGOCD_USER_PASSWORD_KEY = "DEVTRON_ACD_USER_PASSWORD"
	DEVTRON_ARGOCD_TOKEN_KEY         = "DEVTRON_ACD_TOKEN"
)

const (
	ModuleNameArgoCd      string = "argo-cd"
	ModuleStatusInstalled string = "installed"
)

Functions

func EncodeX509KeyPair

func EncodeX509KeyPair(cert tls.Certificate) ([]byte, []byte)

EncodeX509KeyPair encodes a TLS Certificate into its pem encoded format for storage

func GetTLS

func GetTLS(cert *tls.Certificate) credentials.TransportCredentials

func SetTokenAuth

func SetTokenAuth(token string)

func SettingsManager

func SettingsManager(cfg *Config) (*settings.SettingsManager, error)

Types

type ArgoCDConnectionManager

type ArgoCDConnectionManager interface {
	GetConnection() *grpc.ClientConn
	GetOrUpdateArgoCdUserDetail() string
}

type ArgoCDConnectionManagerImpl

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

func NewArgoCDConnectionManagerImpl

func NewArgoCDConnectionManagerImpl(Logger *zap.SugaredLogger, settingsManager *settings.SettingsManager,
	moduleRepository moduleRepo.ModuleRepository,
	environmentVariables *util2.EnvironmentVariables,
	k8sUtil *k8s.K8sServiceImpl,
	k8sCommonService k8s2.K8sCommonService,
	versionService version.VersionService,
	gitOpsConfigReadService config.GitOpsConfigReadService,
	runTimeConfig *k8s.RuntimeConfig) (*ArgoCDConnectionManagerImpl, error)

func (*ArgoCDConnectionManagerImpl) GetConnection

func (impl *ArgoCDConnectionManagerImpl) GetConnection() *grpc.ClientConn

GetConnection - this function will call only for acd connection

func (*ArgoCDConnectionManagerImpl) GetLatestDevtronArgoCdUserToken

func (impl *ArgoCDConnectionManagerImpl) GetLatestDevtronArgoCdUserToken(authConfig *bean.AcdAuthConfig) (string, error)

func (*ArgoCDConnectionManagerImpl) GetOrUpdateArgoCdUserDetail

func (impl *ArgoCDConnectionManagerImpl) GetOrUpdateArgoCdUserDetail() string

func (*ArgoCDConnectionManagerImpl) ValidateGitOpsAndGetOrUpdateArgoCdUserDetail

func (impl *ArgoCDConnectionManagerImpl) ValidateGitOpsAndGetOrUpdateArgoCdUserDetail() string

type Config

type Config struct {
	Host      string `env:"CD_HOST" envDefault:"localhost"`
	Port      string `env:"CD_PORT" envDefault:"8000"`
	Namespace string `env:"CD_NAMESPACE" envDefault:"devtroncd"`
}

func GetConfig

func GetConfig() (*Config, error)

type TokenAuth

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

func GetTokenAuth

func GetTokenAuth() *TokenAuth

func (TokenAuth) GetRequestMetadata

func (t TokenAuth) GetRequestMetadata(ctx context.Context, in ...string) (map[string]string, error)

Return value is mapped to request headers.

func (TokenAuth) RequireTransportSecurity

func (TokenAuth) RequireTransportSecurity() bool