connection

Documentation

Index

• type AWSConnection
  • func (in *AWSConnection) DeepCopy() *AWSConnection
  • func (in *AWSConnection) DeepCopyInto(out *AWSConnection)
  • 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
• type Authentication
  • func (in *Authentication) DeepCopy() *Authentication
  • func (in *Authentication) DeepCopyInto(out *Authentication)
  • func (auth Authentication) GetDomain() string
  • func (auth Authentication) GetPassword() string
  • func (auth Authentication) GetUsername() string
  • func (auth Authentication) IsEmpty() bool
• type ConnectionContext
• type GCPConnection
  • func (in *GCPConnection) DeepCopy() *GCPConnection
  • func (in *GCPConnection) DeepCopyInto(out *GCPConnection)
  • func (g *GCPConnection) HydrateConnection(ctx ConnectionContext) error
  • func (g *GCPConnection) Validate() *GCPConnection
• type SFTPConnection
  • func (in *SFTPConnection) DeepCopy() *SFTPConnection
  • func (in *SFTPConnection) DeepCopyInto(out *SFTPConnection)
  • func (c SFTPConnection) GetPort() int
  • func (c *SFTPConnection) HydrateConnection(ctx ConnectionContext) (found bool, err error)
• type SMBConnection
  • func (in *SMBConnection) DeepCopy() *SMBConnection
  • func (in *SMBConnection) DeepCopyInto(out *SMBConnection)
  • func (c SMBConnection) GetPort() int
  • func (c *SMBConnection) HydrateConnection(ctx ConnectionContext) (found bool, err 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" json:"accessKey,omitempty"`
	SecretKey      types.EnvVar `yaml:"secretKey" json:"secretKey,omitempty"`
	SessionToken   types.EnvVar `yaml:"sessionToken,omitempty" json:"sessionToken,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"`
	// 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 (*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) 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.

type Authentication

type Authentication struct {
	Username types.EnvVar `yaml:"username,omitempty" json:"username,omitempty"`
	Password types.EnvVar `yaml:"password,omitempty" json:"password,omitempty"`
}

+kubebuilder:object:generate=true

func (*Authentication) DeepCopy

func (in *Authentication) DeepCopy() *Authentication

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

func (*Authentication) DeepCopyInto

func (in *Authentication) DeepCopyInto(out *Authentication)

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

func (Authentication) GetDomain

func (auth Authentication) GetDomain() string

func (Authentication) GetPassword

func (auth Authentication) GetPassword() string

func (Authentication) GetUsername

func (auth Authentication) GetUsername() string

func (Authentication) IsEmpty

func (auth Authentication) IsEmpty() bool

type ConnectionContext

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

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"`
}

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

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

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

func (*GCPConnection) Validate

func (g *GCPConnection) Validate() *GCPConnection

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" json:"host"`
	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) (found bool, err error)

type SMBConnection

type SMBConnection struct {
	// 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"`
	Authentication `yaml:",inline" json:",inline"`
	//Domain...
	Domain string `yaml:"domain,omitempty" json:"domain,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) HydrateConnection

func (c *SMBConnection) HydrateConnection(ctx ConnectionContext) (found bool, err error)