connection

package
v1.0.1139 Latest Latest
Warning

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

 Go to latest Published: Jan 2, 2026 License: Apache-2.0 Imports: 76 Imported by: 19

Documentation

Index

Constants

View Source 
const (
	ServiceGithub = "github"
	ServiceGitlab = "gitlab"
)

Variables

This section is empty.

Functions

func CreateHTTPClient added in v1.0.538 

func CreateHTTPClient(ctx ConnectionContext, conn HTTPConnection) (*http.Client, error)

CreateHTTPClient requires a hydrated connection

func Get added in v1.0.853 

func Get(ctx context.Context, connectionName string) (*models.Connection, error)

func NewOpenSearchClient added in v1.0.1135 

func NewOpenSearchClient(ctx context.Context, connection models.Connection) (*opensearch.Client, error)

Types

type AWSConnection 

type AWSConnection struct {
	// ConnectionName of the connection. It'll be used to populate the endpoint, accessKey and secretKey.
	ConnectionName string       `yaml:"connection,omitempty" json:"connection,omitempty"`
	AccessKey      types.EnvVar `yaml:"accessKey,omitempty" json:"accessKey,omitempty"`
	SecretKey      types.EnvVar `yaml:"secretKey,omitempty" json:"secretKey,omitempty"`
	SessionToken   types.EnvVar `yaml:"sessionToken,omitempty" json:"sessionToken,omitempty"`
	AssumeRole     string       `yaml:"assumeRole,omitempty" json:"assumeRole,omitempty"`
	Region         string       `yaml:"region,omitempty" json:"region,omitempty"`
	Endpoint       string       `yaml:"endpoint,omitempty" json:"endpoint,omitempty"`
	// Skip TLS verify when connecting to aws
	SkipTLSVerify bool `yaml:"skipTLSVerify,omitempty" json:"skipTLSVerify,omitempty"`
}

+kubebuilder:object:generate=true

func (*AWSConnection) Client added in v1.0.588 

func (t *AWSConnection) Client(ctx context.Context) (aws.Config, error)

Client returns a new aws config. Call this on a hydrated connection.

func (*AWSConnection) DeepCopy 

func (in *AWSConnection) DeepCopy() *AWSConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AWSConnection.

func (*AWSConnection) DeepCopyInto 

func (in *AWSConnection) DeepCopyInto(out *AWSConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AWSConnection) FromModel added in v1.0.819 

func (t *AWSConnection) FromModel(connection models.Connection)

func (*AWSConnection) GetPassword 

func (t *AWSConnection) GetPassword() types.EnvVar

func (*AWSConnection) GetProperties 

func (t *AWSConnection) GetProperties() map[string]string

func (*AWSConnection) GetURL 

func (t *AWSConnection) GetURL() types.EnvVar

func (*AWSConnection) GetUsername 

func (t *AWSConnection) GetUsername() types.EnvVar

func (*AWSConnection) Populate 

func (t *AWSConnection) Populate(ctx ConnectionContext) error

Populate populates an AWSConnection with credentials and other information. If a connection name is specified, it'll be used to populate the endpoint, accessKey and secretKey.

func (AWSConnection) ToModel added in v1.0.605 

func (t AWSConnection) ToModel() models.Connection

type AWSKMS added in v1.0.820 

type AWSKMS struct {
	AWSConnection `json:",inline"`

	// keyID can be an alias (eg: alias/ExampleAlias?region=us-east-1) or the ARN
	KeyID string `json:"keyID,omitempty"`
}

func (*AWSKMS) FromModel added in v1.0.820 

func (t *AWSKMS) FromModel(conn models.Connection)

func (*AWSKMS) Populate added in v1.0.820 

func (t *AWSKMS) Populate(ctx ConnectionContext) error

func (*AWSKMS) SecretKeeper added in v1.0.820 

func (t *AWSKMS) SecretKeeper(ctx context.Context) (*secrets.Keeper, error)

type AzureConnection added in v1.0.614 

type AzureConnection struct {
	ConnectionName string        `yaml:"connection,omitempty" json:"connection,omitempty"`
	ClientID       *types.EnvVar `yaml:"clientID,omitempty" json:"clientID,omitempty"`
	ClientSecret   *types.EnvVar `yaml:"clientSecret,omitempty" json:"clientSecret,omitempty"`
	TenantID       string        `yaml:"tenantID,omitempty" json:"tenantID,omitempty"`
}

+kubebuilder:object:generate=true

func (*AzureConnection) DeepCopy added in v1.0.614 

func (in *AzureConnection) DeepCopy() *AzureConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureConnection.

func (*AzureConnection) DeepCopyInto added in v1.0.614 

func (in *AzureConnection) DeepCopyInto(out *AzureConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureConnection) FromModel added in v1.0.819 

func (g *AzureConnection) FromModel(connection models.Connection)

func (*AzureConnection) HydrateConnection added in v1.0.614 

func (g *AzureConnection) HydrateConnection(ctx ConnectionContext) error

HydrateConnection attempts to find the connection by name and populate the endpoint and credentials.

func (AzureConnection) ToModel added in v1.0.819 

func (g AzureConnection) ToModel() models.Connection

func (*AzureConnection) TokenCredential added in v1.0.819 

func (g *AzureConnection) TokenCredential() (azcore.TokenCredential, error)

type AzureKeyVault added in v1.0.820 

type AzureKeyVault struct {
	AzureConnection `json:",inline"`

	// keyID is a URL to the key in the format
	// 	https://<vault-name>.vault.azure.net/keys/<key-name>
	KeyID string `json:"keyID,omitempty"`
}

func (*AzureKeyVault) FromModel added in v1.0.820 

func (t *AzureKeyVault) FromModel(conn models.Connection)

func (*AzureKeyVault) Populate added in v1.0.820 

func (t *AzureKeyVault) Populate(ctx ConnectionContext) error

func (*AzureKeyVault) SecretKeeper added in v1.0.820 

func (t *AzureKeyVault) SecretKeeper(ctx context.Context) (*secrets.Keeper, error)

type CNRMConnection added in v1.0.845 

type CNRMConnection struct {
	GKE GKEConnection `json:"gke" yaml:"gke"`

	ClusterResource          string `json:"clusterResource"`
	ClusterResourceNamespace string `json:"clusterResourceNamespace"`
}

+kubebuilder:object:generate=true

func (*CNRMConnection) DeepCopy added in v1.0.845 

func (in *CNRMConnection) DeepCopy() *CNRMConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CNRMConnection.

func (*CNRMConnection) DeepCopyInto added in v1.0.845 

func (in *CNRMConnection) DeepCopyInto(out *CNRMConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CNRMConnection) KubernetesClient added in v1.0.845 

func (t *CNRMConnection) KubernetesClient(ctx context.Context, freshToken bool) (kubernetes.Interface, *rest.Config, error)

func (*CNRMConnection) Populate added in v1.0.845 

func (t *CNRMConnection) Populate(ctx ConnectionContext) error

type ConnectionContext 

type ConnectionContext interface {
	gocontext.Context
	HydrateConnectionByURL(connectionName string) (*models.Connection, error)
	GetEnvValueFromCache(env types.EnvVar, namespace string) (string, error)
	GetNamespace() string
}

type ConnectionSetupResult added in v1.0.878 

type ConnectionSetupResult struct {
	Sources   []string `json:"source,omitempty"`
	EnvVars   []string `json:"envVars,omitempty"`
	ApiServer string   `json:"kubeApiServer,omitempty"`

	Cleanup func() error `json:"-"`
}

func SetupConnection added in v1.0.614 

func SetupConnection(ctx context.Context, connections ExecConnections, cmd *osExec.Cmd) (*ConnectionSetupResult, error)

SetupConnections creates the necessary credential files and injects env vars into the cmd

type EKSConnection added in v1.0.845 

type EKSConnection struct {
	AWSConnection `json:",inline" yaml:",inline"`

	Cluster string `json:"cluster"`
}

+kubebuilder:object:generate=true

func (*EKSConnection) DeepCopy added in v1.0.845 

func (in *EKSConnection) DeepCopy() *EKSConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EKSConnection.

func (*EKSConnection) DeepCopyInto added in v1.0.845 

func (in *EKSConnection) DeepCopyInto(out *EKSConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*EKSConnection) KubernetesClient added in v1.0.845 

func (t *EKSConnection) KubernetesClient(ctx context.Context, freshToken bool) (kubernetes.Interface, *rest.Config, error)

func (*EKSConnection) Populate added in v1.0.845 

func (t *EKSConnection) Populate(ctx ConnectionContext) error

type ExecConnections added in v1.0.614 

type ExecConnections struct {
	FromConfigItem *string `yaml:"fromConfigItem,omitempty" json:"fromConfigItem,omitempty" template:"true"`

	// EKSPodIdentity when enabled will allow access to AWS_* env vars
	EKSPodIdentity bool `json:"eksPodIdentity,omitempty"`

	// ServiceAccount when enabled will allow access to KUBERNETES env vars
	ServiceAccount bool `json:"serviceAccount,omitempty"`

	Kubernetes *KubernetesConnection `yaml:"kubernetes,omitempty" json:"kubernetes,omitempty"`
	AWS        *AWSConnection        `yaml:"aws,omitempty" json:"aws,omitempty"`
	GCP        *GCPConnection        `yaml:"gcp,omitempty" json:"gcp,omitempty"`
	Azure      *AzureConnection      `yaml:"azure,omitempty" json:"azure,omitempty"`
}

+kubebuilder:object:generate=true

func (*ExecConnections) DeepCopy added in v1.0.614 

func (in *ExecConnections) DeepCopy() *ExecConnections

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExecConnections.

func (*ExecConnections) DeepCopyInto added in v1.0.614 

func (in *ExecConnections) DeepCopyInto(out *ExecConnections)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type GCPConnection 

type GCPConnection struct {
	// ConnectionName of the connection. It'll be used to populate the endpoint and credentials.
	ConnectionName string        `yaml:"connection,omitempty" json:"connection,omitempty"`
	Endpoint       string        `yaml:"endpoint" json:"endpoint,omitempty"`
	Credentials    *types.EnvVar `yaml:"credentials" json:"credentials,omitempty"`

	// Skip TLS verify
	SkipTLSVerify bool `yaml:"skipTLSVerify,omitempty" json:"skipTLSVerify,omitempty"`

	Project string `yaml:"project" json:"project,omitempty"`
}

+kubebuilder:object:generate=true

func (*GCPConnection) DeepCopy 

func (in *GCPConnection) DeepCopy() *GCPConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GCPConnection.

func (*GCPConnection) DeepCopyInto 

func (in *GCPConnection) DeepCopyInto(out *GCPConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GCPConnection) FromModel added in v1.0.819 

func (t *GCPConnection) FromModel(connection models.Connection)

func (*GCPConnection) GetCertificate added in v1.0.247 

func (t *GCPConnection) GetCertificate() types.EnvVar

func (*GCPConnection) GetURL added in v1.0.247 

func (t *GCPConnection) GetURL() types.EnvVar

func (*GCPConnection) HydrateConnection 

func (g *GCPConnection) HydrateConnection(ctx ConnectionContext) error

HydrateConnection attempts to find the connection by name and populate the endpoint and credentials.

func (*GCPConnection) ToModel added in v1.0.819 

func (t *GCPConnection) ToModel() models.Connection

func (*GCPConnection) Token added in v1.0.845 

func (g *GCPConnection) Token(ctx context.Context, freshToken bool, scopes ...string) (*oauth2.Token, error)

func (*GCPConnection) TokenSource added in v1.0.819 

func (g *GCPConnection) TokenSource(ctx context.Context, scopes ...string) (oauth2.TokenSource, error)

func (*GCPConnection) Validate 

func (g *GCPConnection) Validate() *GCPConnection

type GCPKMS added in v1.0.820 

type GCPKMS struct {
	GCPConnection `json:",inline"`

	// keyID points to the key in the format
	// projects/MYPROJECT/locations/MYLOCATION/keyRings/MYKEYRING/cryptoKeys/MYKEY
	KeyID string `json:"keyID,omitempty"`
}

func (*GCPKMS) FromModel added in v1.0.820 

func (t *GCPKMS) FromModel(conn models.Connection)

func (*GCPKMS) Populate added in v1.0.820 

func (t *GCPKMS) Populate(ctx ConnectionContext) error

func (*GCPKMS) SecretKeeper added in v1.0.820 

func (t *GCPKMS) SecretKeeper(ctx context.Context) (*secrets.Keeper, error)

type GCSConnection added in v1.0.247 

type GCSConnection struct {
	GCPConnection `json:",inline"`
	Bucket        string `yaml:"bucket,omitempty" json:"bucket,omitempty"`
}

+kubebuilder:object:generate=true

func (*GCSConnection) Client added in v1.0.845 

func (g *GCSConnection) Client(ctx context.Context) (*gcs.Client, error)

func (*GCSConnection) DeepCopy added in v1.0.247 

func (in *GCSConnection) DeepCopy() *GCSConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GCSConnection.

func (*GCSConnection) DeepCopyInto added in v1.0.247 

func (in *GCSConnection) DeepCopyInto(out *GCSConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GCSConnection) GetProperties added in v1.0.247 

func (t *GCSConnection) GetProperties() map[string]string

func (*GCSConnection) HydrateConnection added in v1.0.247 

func (g *GCSConnection) HydrateConnection(ctx ConnectionContext) error

HydrateConnection attempts to find the connection by name and populate the endpoint and credentials.

func (*GCSConnection) Validate added in v1.0.247 

func (g *GCSConnection) Validate() *GCSConnection

type GKEConnection added in v1.0.845 

type GKEConnection struct {
	GCPConnection `json:",inline" yaml:",inline"`

	ProjectID string `json:"projectID"`
	Zone      string `json:"zone"`
	Cluster   string `json:"cluster"`
}

+kubebuilder:object:generate=true

func (*GKEConnection) Client added in v1.0.845 

func (t *GKEConnection) Client(ctx context.Context) (*container.Service, error)

func (*GKEConnection) DeepCopy added in v1.0.845 

func (in *GKEConnection) DeepCopy() *GKEConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GKEConnection.

func (*GKEConnection) DeepCopyInto added in v1.0.845 

func (in *GKEConnection) DeepCopyInto(out *GKEConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GKEConnection) KubernetesClient added in v1.0.845 

func (t *GKEConnection) KubernetesClient(ctx context.Context, freshToken bool) (kubernetes.Interface, *rest.Config, error)

func (*GKEConnection) Populate added in v1.0.845 

func (t *GKEConnection) Populate(ctx ConnectionContext) error

func (*GKEConnection) Validate added in v1.0.845 

func (t *GKEConnection) Validate() *GKEConnection

type GitClient added in v1.0.614 

type GitClient struct {
	Auth                transport.AuthMethod
	URL                 string
	Owner, Repo, Branch string
	Depth               int
	AzureDevops         bool
}

func CreateGitConfig added in v1.0.614 

func CreateGitConfig(ctx context.Context, conn *GitConnection) (*GitClient, error)

func (*GitClient) Clone added in v1.0.614 

func (gitClient *GitClient) Clone(ctx context.Context, dir string) (map[string]any, error)

func (GitClient) GetContext added in v1.0.614 

func (gitClient GitClient) GetContext() map[string]any

func (GitClient) GetShortURL added in v1.0.614 

func (gitClient GitClient) GetShortURL() string

func (GitClient) LoggerName added in v1.0.614 

func (gitClient GitClient) LoggerName() string

type GitConnection added in v1.0.614 

type GitConnection struct {
	URL         string        `yaml:"url,omitempty" json:"url,omitempty"`
	Connection  string        `yaml:"connection,omitempty" json:"connection,omitempty"`
	Username    *types.EnvVar `yaml:"username,omitempty" json:"username,omitempty"`
	Password    *types.EnvVar `yaml:"password,omitempty" json:"password,omitempty"`
	Certificate *types.EnvVar `yaml:"certificate,omitempty" json:"certificate,omitempty"`
	// Type of connection e.g. github, gitlab
	Type   string `yaml:"type,omitempty" json:"type,omitempty"`
	Branch string `yaml:"branch,omitempty" json:"branch,omitempty"`

	Depth *int `json:"depth,omitempty"`
	// Destination is the full path to where the contents of the URL should be downloaded to.
	// If left empty, the sha256 hash of the URL will be used as the dir name.
	//
	// Deprecated: no similar functionality available. This depends on the use case
	Destination *string `yaml:"destination,omitempty" json:"destination,omitempty"`
}

+kubebuilder:object:generate=true

func (*GitConnection) DeepCopy added in v1.0.614 

func (in *GitConnection) DeepCopy() *GitConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GitConnection.

func (*GitConnection) DeepCopyInto added in v1.0.614 

func (in *GitConnection) DeepCopyInto(out *GitConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (GitConnection) GetCertificate added in v1.0.817 

func (git GitConnection) GetCertificate() types.EnvVar

func (GitConnection) GetPassword added in v1.0.817 

func (git GitConnection) GetPassword() types.EnvVar

func (GitConnection) GetURL added in v1.0.817 

func (git GitConnection) GetURL() types.EnvVar

func (GitConnection) GetUsername added in v1.0.817 

func (git GitConnection) GetUsername() types.EnvVar

func (*GitConnection) HydrateConnection added in v1.0.614 

func (c *GitConnection) HydrateConnection(ctx context.Context) error

type HTTPConnection added in v1.0.538 

type HTTPConnection struct {
	ConnectionName      string `json:"connection,omitempty" yaml:"connection,omitempty"`
	types.HTTPBasicAuth `json:",inline"`
	URL                 string       `json:"url,omitempty" yaml:"url,omitempty"`
	Bearer              types.EnvVar `json:"bearer,omitempty" yaml:"bearer,omitempty"`
	OAuth               types.OAuth  `json:"oauth,omitempty" yaml:"oauth,omitempty"`
	TLS                 TLSConfig    `json:"tls,omitempty" yaml:"tls,omitempty"`
}

+kubebuilder:object:generate=true

func NewHTTPConnection added in v1.0.538 

func NewHTTPConnection(ctx ConnectionContext, conn models.Connection) (HTTPConnection, error)

func (*HTTPConnection) DeepCopy added in v1.0.539 

func (in *HTTPConnection) DeepCopy() *HTTPConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HTTPConnection.

func (*HTTPConnection) DeepCopyInto added in v1.0.539 

func (in *HTTPConnection) DeepCopyInto(out *HTTPConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*HTTPConnection) FromModel added in v1.0.976 

func (t *HTTPConnection) FromModel(connection models.Connection) error

func (HTTPConnection) GetEndpoint added in v1.0.540 

func (h HTTPConnection) GetEndpoint() string

func (*HTTPConnection) Hydrate added in v1.0.538 

func (h *HTTPConnection) Hydrate(ctx ConnectionContext, namespace string) (*HTTPConnection, error)

func (HTTPConnection) Transport added in v1.0.976 

func (h HTTPConnection) Transport() netHTTP.RoundTripper

type KubeconfigConnection added in v1.0.845 

type KubeconfigConnection struct {
	// Connection name to populate kubeconfig
	ConnectionName string        `json:"connection,omitempty"`
	Kubeconfig     *types.EnvVar `json:"kubeconfig,omitempty"`
}

+kubebuilder:object:generate=true

func (*KubeconfigConnection) DeepCopy added in v1.0.845 

func (in *KubeconfigConnection) DeepCopy() *KubeconfigConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KubeconfigConnection.

func (*KubeconfigConnection) DeepCopyInto added in v1.0.845 

func (in *KubeconfigConnection) DeepCopyInto(out *KubeconfigConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*KubeconfigConnection) Populate added in v1.0.845 

func (t *KubeconfigConnection) Populate(ctx context.Context) (kubernetes.Interface, *rest.Config, error)

type KubernetesConnection added in v1.0.746 

type KubernetesConnection struct {
	KubeconfigConnection `json:",inline"`

	EKS  *EKSConnection  `json:"eks,omitempty"`
	GKE  *GKEConnection  `json:"gke,omitempty"`
	CNRM *CNRMConnection `json:"cnrm,omitempty"`
}

+kubebuilder:object:generate=true

func (KubernetesConnection) CanExpire added in v1.0.854 

func (c KubernetesConnection) CanExpire() bool

func (*KubernetesConnection) DeepCopy added in v1.0.746 

func (in *KubernetesConnection) DeepCopy() *KubernetesConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KubernetesConnection.

func (*KubernetesConnection) DeepCopyInto added in v1.0.746 

func (in *KubernetesConnection) DeepCopyInto(out *KubernetesConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (KubernetesConnection) Hash added in v1.0.854 

func (c KubernetesConnection) Hash() string

Hash returns a unique identifier of a KubernetesConnection, suitable for caching

func (KubernetesConnection) Populate added in v1.0.746 

func (t KubernetesConnection) Populate(ctx context.Context, freshToken bool) (kubernetes.Interface, *rest.Config, error)

func (KubernetesConnection) String added in v1.0.863 

func (c KubernetesConnection) String() string

String returns a human readable string representation of the KubernetesConnection

func (KubernetesConnection) ToModel added in v1.0.746 

func (t KubernetesConnection) ToModel() models.Connection

type Loki added in v1.0.926 

type Loki struct {
	ConnectionName string `json:"connection,omitempty"`

	URL      string        `json:"url,omitempty"`
	Username *types.EnvVar `json:"username,omitempty"`
	Password *types.EnvVar `json:"password,omitempty"`
}

+kubebuilder:object:generate=true

func (*Loki) DeepCopy added in v1.0.926 

func (in *Loki) DeepCopy() *Loki

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Loki.

func (*Loki) DeepCopyInto added in v1.0.926 

func (in *Loki) DeepCopyInto(out *Loki)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Loki) Populate added in v1.0.926 

func (c *Loki) Populate(ctx ConnectionContext) error

type OpensearchConnection added in v1.0.1135 

type OpensearchConnection struct {
	ConnectionName      string `json:"-"`
	types.HTTPBasicAuth `json:",inline"`
	// +kubebuilder:validation:MinItems=1
	URLs               []string `json:"urls,omitempty" yaml:"urls,omitempty"`
	Index              string   `json:"index,omitempty" yaml:"index,omitempty"`
	InsecureSkipVerify bool     `json:"insecureSkipVerify,omitempty" yaml:"insecureSkipVerify,omitempty"`
}

+kubebuilder:object:generate=true

func (*OpensearchConnection) Client added in v1.0.1135 

func (c *OpensearchConnection) Client() (*opensearch.Client, error)

Client creates and returns an OpenSearch client. NOTE: Must be run on a hydrated OpensearchConnection.

func (*OpensearchConnection) DeepCopy added in v1.0.1137 

func (in *OpensearchConnection) DeepCopy() *OpensearchConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpensearchConnection.

func (*OpensearchConnection) DeepCopyInto added in v1.0.1137 

func (in *OpensearchConnection) DeepCopyInto(out *OpensearchConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OpensearchConnection) FromModel added in v1.0.1135 

func (c *OpensearchConnection) FromModel(connection models.Connection) error

func (*OpensearchConnection) Hydrate added in v1.0.1135 

func (c *OpensearchConnection) Hydrate(ctx ConnectionContext) error

func (OpensearchConnection) ToModel added in v1.0.1135 

func (c OpensearchConnection) ToModel() models.Connection

type PrometheusConnection added in v1.0.976 

type PrometheusConnection struct {
	HTTPConnection `json:",inline" yaml:",inline"`
}

+kubebuilder:object:generate=true

func (*PrometheusConnection) DeepCopy added in v1.0.976 

func (in *PrometheusConnection) DeepCopy() *PrometheusConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrometheusConnection.

func (*PrometheusConnection) DeepCopyInto added in v1.0.976 

func (in *PrometheusConnection) DeepCopyInto(out *PrometheusConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PrometheusConnection) FromModel added in v1.0.976 

func (t *PrometheusConnection) FromModel(connection models.Connection) error

func (*PrometheusConnection) NewClient added in v1.0.976 

func (p *PrometheusConnection) NewClient(ctx context.Context) (v1.API, error)

func (*PrometheusConnection) Populate added in v1.0.976 

func (p *PrometheusConnection) Populate(ctx ConnectionContext) error

type S3Connection added in v1.0.247 

type S3Connection struct {
	AWSConnection `json:",inline"`
	Bucket        string `yaml:"bucket,omitempty" json:"bucket,omitempty"`
	// glob path to restrict matches to a subset
	ObjectPath string `yaml:"objectPath,omitempty" json:"objectPath,omitempty"`
	// Use path style path: http://s3.amazonaws.com/BUCKET/KEY instead of http://BUCKET.s3.amazonaws.com/KEY
	UsePathStyle bool `yaml:"usePathStyle,omitempty" json:"usePathStyle,omitempty"`
}

+kubebuilder:object:generate=true

func (*S3Connection) DeepCopy added in v1.0.247 

func (in *S3Connection) DeepCopy() *S3Connection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3Connection.

func (*S3Connection) DeepCopyInto added in v1.0.247 

func (in *S3Connection) DeepCopyInto(out *S3Connection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*S3Connection) GetProperties added in v1.0.247 

func (t *S3Connection) GetProperties() map[string]string

func (*S3Connection) Populate added in v1.0.247 

func (t *S3Connection) Populate(ctx ConnectionContext) error

Populate populates an AWSConnection with credentials and other information. If a connection name is specified, it'll be used to populate the endpoint, accessKey and secretKey.

func (S3Connection) ToModel added in v1.0.605 

func (c S3Connection) ToModel() models.Connection

type SFTPConnection 

type SFTPConnection struct {
	// ConnectionName of the connection. It'll be used to populate the connection fields.
	ConnectionName string `yaml:"connection,omitempty" json:"connection,omitempty"`
	// Port for the SSH server. Defaults to 22
	Port                 int    `yaml:"port,omitempty" json:"port,omitempty"`
	Host                 string `yaml:"host,omitempty" json:"host,omitempty"`
	types.Authentication `yaml:",inline" json:",inline"`
}

+kubebuilder:object:generate=true

func (*SFTPConnection) DeepCopy 

func (in *SFTPConnection) DeepCopy() *SFTPConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SFTPConnection.

func (*SFTPConnection) DeepCopyInto 

func (in *SFTPConnection) DeepCopyInto(out *SFTPConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (SFTPConnection) GetPort 

func (c SFTPConnection) GetPort() int

func (*SFTPConnection) HydrateConnection 

func (c *SFTPConnection) HydrateConnection(ctx ConnectionContext) (err error)

func (SFTPConnection) ToModel added in v1.0.603 

func (c SFTPConnection) ToModel() models.Connection

type SMBConnection 

type SMBConnection struct {
	types.Authentication `yaml:",inline" json:",inline"`
	// ConnectionName of the connection. It'll be used to populate the connection fields.
	ConnectionName string `yaml:"connection,omitempty" json:"connection,omitempty"`
	// Port on which smb server is running. Defaults to 445
	Port   int    `yaml:"port,omitempty" json:"port,omitempty"`
	Domain string `yaml:"domain,omitempty" json:"domain,omitempty"`
	Share  string `yaml:"share,omitempty" json:"share,omitempty"`
}

+kubebuilder:object:generate=true

func (*SMBConnection) DeepCopy 

func (in *SMBConnection) DeepCopy() *SMBConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SMBConnection.

func (*SMBConnection) DeepCopyInto 

func (in *SMBConnection) DeepCopyInto(out *SMBConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (SMBConnection) GetPort 

func (c SMBConnection) GetPort() int

func (*SMBConnection) Populate added in v1.0.603 

func (c *SMBConnection) Populate(ctx ConnectionContext) error

func (SMBConnection) ToModel added in v1.0.603 

func (c SMBConnection) ToModel() models.Connection

type SQLConnection added in v1.0.1111 

type SQLConnection struct {
	ConnectionName string       `yaml:"connection,omitempty" json:"connection,omitempty"`
	Type           string       `yaml:"type,omitempty" json:"type,omitempty"`
	URL            types.EnvVar `yaml:"url,omitempty" json:"url,omitempty"`
	Username       types.EnvVar `yaml:"username,omitempty" json:"username,omitempty"`
	Password       types.EnvVar `yaml:"password,omitempty" json:"password,omitempty"`
}

+kubebuilder:object:generate=true

func (*SQLConnection) Client added in v1.0.1111 

func (s *SQLConnection) Client(ctx context.Context) (*databasesql.DB, error)

Client creates and returns a database/sql DB client

NOTE: Must be run on a hydrated SQLConnection.

func (*SQLConnection) DeepCopy added in v1.0.1112 

func (in *SQLConnection) DeepCopy() *SQLConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SQLConnection.

func (*SQLConnection) DeepCopyInto added in v1.0.1112 

func (in *SQLConnection) DeepCopyInto(out *SQLConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SQLConnection) FromModel added in v1.0.1111 

func (s *SQLConnection) FromModel(connection models.Connection) error

func (*SQLConnection) HydrateConnection added in v1.0.1111 

func (s *SQLConnection) HydrateConnection(ctx context.Context) error

func (SQLConnection) ToModel added in v1.0.1111 

func (s SQLConnection) ToModel() models.Connection

type TLSConfig added in v1.0.538 

type TLSConfig struct {
	// InsecureSkipVerify controls whether a client verifies the server's
	// certificate chain and host name
	InsecureSkipVerify bool `json:"insecureSkipVerify,omitempty" yaml:"insecureSkipVerify,omitempty"`
	// HandshakeTimeout defaults to 10 seconds
	HandshakeTimeout time.Duration `json:"handshakeTimeout,omitempty" yaml:"handshakeTimeout,omitempty"`
	// PEM encoded certificate of the CA to verify the server certificate
	CA types.EnvVar `json:"ca,omitempty" yaml:"ca,omitempty"`
	// PEM encoded client certificate
	Cert types.EnvVar `json:"cert,omitempty" yaml:"cert,omitempty"`
	// PEM encoded client private key
	Key types.EnvVar `json:"key,omitempty" yaml:"key,omitempty"`
}

+kubebuilder:object:generate=true

func (*TLSConfig) DeepCopy added in v1.0.539 

func (in *TLSConfig) DeepCopy() *TLSConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TLSConfig.

func (*TLSConfig) DeepCopyInto added in v1.0.539 

func (in *TLSConfig) DeepCopyInto(out *TLSConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (TLSConfig) IsEmpty added in v1.0.538 

func (t TLSConfig) IsEmpty() bool

Source Files

View all Source files

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.