connection

Documentation

Index

• Constants
• func EncodeX509KeyPair(cert tls.Certificate) ([]byte, []byte)
• 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)
• 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(token string) *grpc.ClientConn
• 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 (
	ModuleNameArgoCd      string = "argo-cd"
	ModuleStatusInstalled string = "installed"
)

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

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 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)

func SettingsManager

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

Types

type ArgoCDConnectionManager

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

type ArgoCDConnectionManagerImpl

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

func NewArgoCDConnectionManagerImpl

func NewArgoCDConnectionManagerImpl(Logger *zap.SugaredLogger, settingsManager *settings.SettingsManager,
	moduleRepository moduleRepo.ModuleRepository) (*ArgoCDConnectionManagerImpl, error)

func (*ArgoCDConnectionManagerImpl) GetConnection

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

GetConnection - this function will call only for acd connection

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