Versions in this module Expand all Collapse all v0 v0.1.8 May 1, 2026 v0.1.7 Apr 19, 2026 v0.1.6 Mar 30, 2026 v0.1.5 Dec 31, 2025 v0.1.4 Dec 24, 2025 v0.1.3 Dec 15, 2025 v0.1.2 Dec 14, 2025 v0.1.1 Dec 14, 2025 v0.1.0 Oct 27, 2025 Changes in this version + const ServiceGithub + const ServiceGitlab + func CreateHTTPClient(ctx ConnectionContext, conn HTTPConnection) (*http.Client, error) + func Get(ctx context.Context, connectionName string) (*models.Connection, error) + func GetFilesystem(ctx context.Context, conn FilesystemProvider) (fs.FilesystemRW, error) + func GetFilesystemForConnection(ctx context.Context, conn interface{}) (fs.FilesystemRW, error) + type AWSConnection struct + AccessKey types.EnvVar + AssumeRole string + ConnectionName string + Endpoint string + Region string + SecretKey types.EnvVar + SessionToken types.EnvVar + SkipTLSVerify bool + func (in *AWSConnection) DeepCopy() *AWSConnection + func (in *AWSConnection) DeepCopyInto(out *AWSConnection) + func (t *AWSConnection) Client(ctx context.Context) (aws.Config, error) + func (t *AWSConnection) FromModel(connection models.Connection) + func (t *AWSConnection) GetPassword() types.EnvVar + func (t *AWSConnection) GetProperties() map[string]string + func (t *AWSConnection) GetURL() types.EnvVar + func (t *AWSConnection) GetUsername() types.EnvVar + func (t *AWSConnection) Populate(ctx ConnectionContext) error + func (t AWSConnection) ToModel() models.Connection + type AWSKMS struct + KeyID string + func (t *AWSKMS) FromModel(conn models.Connection) + func (t *AWSKMS) Populate(ctx ConnectionContext) error + func (t *AWSKMS) SecretKeeper(ctx context.Context) (*secrets.Keeper, error) + type AzureConnection struct + ClientID *types.EnvVar + ClientSecret *types.EnvVar + ConnectionName string + TenantID string + func (g *AzureConnection) FromModel(connection models.Connection) + func (g *AzureConnection) HydrateConnection(ctx ConnectionContext) error + func (g *AzureConnection) TokenCredential() (azcore.TokenCredential, error) + func (g AzureConnection) ToModel() models.Connection + func (in *AzureConnection) DeepCopy() *AzureConnection + func (in *AzureConnection) DeepCopyInto(out *AzureConnection) + type AzureKeyVault struct + KeyID string + func (t *AzureKeyVault) FromModel(conn models.Connection) + func (t *AzureKeyVault) Populate(ctx ConnectionContext) error + func (t *AzureKeyVault) SecretKeeper(ctx context.Context) (*secrets.Keeper, error) + type CNRMConnection struct + ClusterResource string + ClusterResourceNamespace string + GKE GKEConnection + func (in *CNRMConnection) DeepCopy() *CNRMConnection + func (in *CNRMConnection) DeepCopyInto(out *CNRMConnection) + func (t *CNRMConnection) KubernetesClient(ctx context.Context, freshToken bool) (kubernetes.Interface, *rest.Config, error) + func (t *CNRMConnection) Populate(ctx ConnectionContext) error + type ConnectionContext interface + GetEnvValueFromCache func(env types.EnvVar, namespace string) (string, error) + GetNamespace func() string + HydrateConnectionByURL func(connectionName string) (*models.Connection, error) + type ConnectionSetupResult struct + ApiServer string + Cleanup func() error + EnvVars []string + Sources []string + func SetupConnection(ctx context.Context, connections ExecConnections, cmd *osExec.Cmd) (*ConnectionSetupResult, error) + type EKSConnection struct + Cluster string + func (in *EKSConnection) DeepCopy() *EKSConnection + func (in *EKSConnection) DeepCopyInto(out *EKSConnection) + func (t *EKSConnection) KubernetesClient(ctx context.Context, freshToken bool) (kubernetes.Interface, *rest.Config, error) + func (t *EKSConnection) Populate(ctx ConnectionContext) error + type ExecConnections struct + AWS *AWSConnection + Azure *AzureConnection + EKSPodIdentity bool + FromConfigItem *string + GCP *GCPConnection + Kubernetes *KubernetesConnection + ServiceAccount bool + func (in *ExecConnections) DeepCopy() *ExecConnections + func (in *ExecConnections) DeepCopyInto(out *ExecConnections) + type FilesystemProvider interface + Filesystem func(ctx context.Context) (fs.FilesystemRW, error) + type GCPConnection struct + ConnectionName string + Credentials *types.EnvVar + Endpoint string + Project string + SkipTLSVerify bool + func (g *GCPConnection) HydrateConnection(ctx ConnectionContext) error + func (g *GCPConnection) Token(ctx context.Context, freshToken bool, scopes ...string) (*oauth2.Token, error) + func (g *GCPConnection) TokenSource(ctx context.Context, scopes ...string) (oauth2.TokenSource, error) + func (g *GCPConnection) Validate() *GCPConnection + func (in *GCPConnection) DeepCopy() *GCPConnection + func (in *GCPConnection) DeepCopyInto(out *GCPConnection) + func (t *GCPConnection) FromModel(connection models.Connection) + func (t *GCPConnection) GetCertificate() types.EnvVar + func (t *GCPConnection) GetURL() types.EnvVar + func (t *GCPConnection) ToModel() models.Connection + type GCPKMS struct + KeyID string + func (t *GCPKMS) FromModel(conn models.Connection) + func (t *GCPKMS) Populate(ctx ConnectionContext) error + func (t *GCPKMS) SecretKeeper(ctx context.Context) (*secrets.Keeper, error) + type GCSConnection struct + Bucket string + func (c *GCSConnection) Filesystem(ctx context.Context) (fs.FilesystemRW, error) + func (g *GCSConnection) Client(ctx context.Context) (*gcs.Client, error) + func (g *GCSConnection) HydrateConnection(ctx ConnectionContext) error + func (g *GCSConnection) Validate() *GCSConnection + func (in *GCSConnection) DeepCopy() *GCSConnection + func (in *GCSConnection) DeepCopyInto(out *GCSConnection) + func (t *GCSConnection) GetProperties() map[string]string + type GKEConnection struct + Cluster string + ProjectID string + Zone string + func (in *GKEConnection) DeepCopy() *GKEConnection + func (in *GKEConnection) DeepCopyInto(out *GKEConnection) + func (t *GKEConnection) Client(ctx context.Context) (*container.Service, error) + func (t *GKEConnection) KubernetesClient(ctx context.Context, freshToken bool) (kubernetes.Interface, *rest.Config, error) + func (t *GKEConnection) Populate(ctx ConnectionContext) error + func (t *GKEConnection) Validate() *GKEConnection + type GitClient struct + Auth transport.AuthMethod + AzureDevops bool + Branch string + Depth int + Owner string + Repo string + URL string + func CreateGitConfig(ctx context.Context, conn *GitConnection) (*GitClient, error) + func (gitClient *GitClient) Clone(ctx context.Context, dir string) (map[string]any, error) + func (gitClient GitClient) GetContext() map[string]any + func (gitClient GitClient) GetShortURL() string + func (gitClient GitClient) LoggerName() string + type GitConnection struct + Branch string + Certificate *types.EnvVar + Connection string + Destination *string + Password *types.EnvVar + Type string + URL string + Username *types.EnvVar + func (c *GitConnection) HydrateConnection(ctx context.Context) error + func (git GitConnection) GetCertificate() types.EnvVar + func (git GitConnection) GetPassword() types.EnvVar + func (git GitConnection) GetURL() types.EnvVar + func (git GitConnection) GetUsername() types.EnvVar + func (in *GitConnection) DeepCopy() *GitConnection + func (in *GitConnection) DeepCopyInto(out *GitConnection) + type HTTPConnection struct + Bearer types.EnvVar + ConnectionName string + OAuth types.OAuth + TLS TLSConfig + URL string + func NewHTTPConnection(ctx ConnectionContext, conn models.Connection) (HTTPConnection, error) + func (h *HTTPConnection) Hydrate(ctx ConnectionContext, namespace string) (*HTTPConnection, error) + func (h HTTPConnection) GetEndpoint() string + func (h HTTPConnection) Transport() netHTTP.RoundTripper + func (in *HTTPConnection) DeepCopy() *HTTPConnection + func (in *HTTPConnection) DeepCopyInto(out *HTTPConnection) + func (t *HTTPConnection) FromModel(connection models.Connection) error + type KubeconfigConnection struct + ConnectionName string + Kubeconfig *types.EnvVar + func (in *KubeconfigConnection) DeepCopy() *KubeconfigConnection + func (in *KubeconfigConnection) DeepCopyInto(out *KubeconfigConnection) + func (t KubeconfigConnection) Populate(ctx context.Context) (kubernetes.Interface, *rest.Config, error) + type KubernetesConnection struct + CNRM *CNRMConnection + EKS *EKSConnection + GKE *GKEConnection + func (c KubernetesConnection) CanExpire() bool + func (c KubernetesConnection) Hash() string + func (c KubernetesConnection) String() string + func (in *KubernetesConnection) DeepCopy() *KubernetesConnection + func (in *KubernetesConnection) DeepCopyInto(out *KubernetesConnection) + func (t KubernetesConnection) Populate(ctx context.Context, freshToken bool) (kubernetes.Interface, *rest.Config, error) + func (t KubernetesConnection) ToModel() models.Connection + type Loki struct + ConnectionName string + Password *types.EnvVar + URL string + Username *types.EnvVar + func (c *Loki) Populate(ctx ConnectionContext) error + func (in *Loki) DeepCopy() *Loki + func (in *Loki) DeepCopyInto(out *Loki) + type PrometheusConnection struct + func (in *PrometheusConnection) DeepCopy() *PrometheusConnection + func (in *PrometheusConnection) DeepCopyInto(out *PrometheusConnection) + func (p *PrometheusConnection) NewClient(ctx context.Context) (v1.API, error) + func (p *PrometheusConnection) Populate(ctx ConnectionContext) error + func (t *PrometheusConnection) FromModel(connection models.Connection) error + type S3Connection struct + Bucket string + ObjectPath string + UsePathStyle bool + func (c *S3Connection) Filesystem(ctx context.Context) (fs.FilesystemRW, error) + func (c S3Connection) ToModel() models.Connection + func (in *S3Connection) DeepCopy() *S3Connection + func (in *S3Connection) DeepCopyInto(out *S3Connection) + func (t *S3Connection) GetProperties() map[string]string + func (t *S3Connection) Populate(ctx ConnectionContext) error + type SFTPConnection struct + ConnectionName string + Host string + Port int + func (c *SFTPConnection) Filesystem(ctx context.Context) (fs.FilesystemRW, error) + func (c *SFTPConnection) HydrateConnection(ctx ConnectionContext) (err error) + func (c SFTPConnection) GetPort() int + func (c SFTPConnection) ToModel() models.Connection + func (in *SFTPConnection) DeepCopy() *SFTPConnection + func (in *SFTPConnection) DeepCopyInto(out *SFTPConnection) + type SMBConnection struct + ConnectionName string + Domain string + Port int + Share string + func (c *SMBConnection) Filesystem(ctx context.Context) (fs.FilesystemRW, error) + func (c *SMBConnection) Populate(ctx ConnectionContext) error + func (c SMBConnection) GetPort() int + func (c SMBConnection) ToModel() models.Connection + func (in *SMBConnection) DeepCopy() *SMBConnection + func (in *SMBConnection) DeepCopyInto(out *SMBConnection) + type TLSConfig struct + CA types.EnvVar + Cert types.EnvVar + HandshakeTimeout time.Duration + InsecureSkipVerify bool + Key types.EnvVar + func (in *TLSConfig) DeepCopy() *TLSConfig + func (in *TLSConfig) DeepCopyInto(out *TLSConfig) + func (t TLSConfig) IsEmpty() bool
Go to main page