argocdServer

Documentation

Index

• Constants
• func EncodeX509KeyPair(cert tls.Certificate) ([]byte, []byte)
• func GetConnection(token string, settings *settings.ArgoCDSettings) *grpc.ClientConn
• func GetTLS(cert *tls.Certificate) credentials.TransportCredentials
• func NewCDHTTPReverseProxy(serverAddr string, transport http.RoundTripper, ...) func(writer http.ResponseWriter, request *http.Request)
• func NewDexHTTPReverseProxy(serverAddr string, transport http.RoundTripper) func(writer http.ResponseWriter, request *http.Request)
• func SetTokenAuth(token string)
• type AppTemplate
• type ArgoK8sClient
• type ArgoK8sClientImpl
  • func NewArgoK8sClientImpl(logger *zap.SugaredLogger) *ArgoK8sClientImpl
  • func (impl ArgoK8sClientImpl) CreateAcdApp(appRequest *AppTemplate, cluster *cluster.Cluster) (string, error)
  • func (impl ArgoK8sClientImpl) CreateArgoApplication(namespace string, application string, config *rest.Config) error
  • func (impl ArgoK8sClientImpl) GetArgoApplication(namespace string, appName string, cluster *cluster.Cluster) (map[string]interface{}, error)
• 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
• type VersionService
• type VersionServiceImpl
  • func NewVersionServiceImpl(settings *settings.ArgoCDSettings, logger *zap.SugaredLogger) *VersionServiceImpl
  • func (service VersionServiceImpl) CheckVersion() (err error)
  • func (service VersionServiceImpl) GetVersion() (apiVersion string, err error)

Constants

const (
	AuthEndPoint  = "/auth/callback"
	LoginEndPoint = "/auth/login"
	Orchestrator  = "/orchestrator"
	RedirectURI   = "redirect_uri"
	Dashboard     = "dashboard"
	Location      = "Location"
)

const DevtronInstalationNs = "devtroncd"

const TimeoutSlow = 30 * time.Second

Functions

func EncodeX509KeyPair

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

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

func GetConnection

func GetConnection(token string, settings *settings.ArgoCDSettings) *grpc.ClientConn

func GetTLS

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

func NewCDHTTPReverseProxy

func NewCDHTTPReverseProxy(serverAddr string, transport http.RoundTripper, userVerifier func(token string) (int32, error)) func(writer http.ResponseWriter, request *http.Request)

func NewDexHTTPReverseProxy

func NewDexHTTPReverseProxy(serverAddr string, transport http.RoundTripper) func(writer http.ResponseWriter, request *http.Request)

NewDexHTTPReverseProxy returns a reverse proxy to the Dex server. Dex is assumed to be configured with the external issuer URL muxed to the same path configured in server.go. In other words, if Argo CD API server wants to proxy requests at /api/dex, then the dex config yaml issuer URL should also be /api/dex (e.g. issuer: https://argocd.example.com/api/dex)

func SetTokenAuth

func SetTokenAuth(token string)

Types

type AppTemplate

type AppTemplate struct {
	ApplicationName string
	Namespace       string
	TargetNamespace string
	TargetServer    string
	Project         string
	ValuesFile      string
	RepoPath        string
	RepoUrl         string
}

type ArgoK8sClient

type ArgoK8sClient interface {
	CreateAcdApp(appRequest *AppTemplate, cluster *cluster.Cluster) (string, error)
	GetArgoApplication(namespace string, appName string, cluster *cluster.Cluster) (map[string]interface{}, error)
}

type ArgoK8sClientImpl

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

func NewArgoK8sClientImpl

func NewArgoK8sClientImpl(logger *zap.SugaredLogger,
) *ArgoK8sClientImpl

func (ArgoK8sClientImpl) CreateAcdApp

func (impl ArgoK8sClientImpl) CreateAcdApp(appRequest *AppTemplate, cluster *cluster.Cluster) (string, error)

func (ArgoK8sClientImpl) CreateArgoApplication

func (impl ArgoK8sClientImpl) CreateArgoApplication(namespace string, application string, config *rest.Config) error

func (ArgoK8sClientImpl) GetArgoApplication

func (impl ArgoK8sClientImpl) GetArgoApplication(namespace string, appName string, cluster *cluster.Cluster) (map[string]interface{}, error)

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

type VersionService

type VersionService interface {
	CheckVersion() (err error)
	GetVersion() (apiVersion string, err error)
}

type VersionServiceImpl

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

func NewVersionServiceImpl

func NewVersionServiceImpl(settings *settings.ArgoCDSettings, logger *zap.SugaredLogger) *VersionServiceImpl

func (VersionServiceImpl) CheckVersion

func (service VersionServiceImpl) CheckVersion() (err error)

func (VersionServiceImpl) GetVersion

func (service VersionServiceImpl) GetVersion() (apiVersion string, err error)