spark

package
v5.20.0 Latest Latest
Warning

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

Go to latest
Published: Jun 7, 2022 License: Apache-2.0 Imports: 38 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Name = "spark"
)
View Source
const (
	ProviderAzure = "azure"
)

Variables

This section is empty.

Functions

func IsCredentialsNotFoundError

func IsCredentialsNotFoundError(err error) bool

IsCredentialsNotFoundError asserts credentialsNotFoundError.

func IsInvalidConfig

func IsInvalidConfig(err error) bool

IsInvalidConfig asserts invalidConfigError.

func IsMissingOrganizationLabel

func IsMissingOrganizationLabel(err error) bool

IsMissingOrganizationLabel asserts missingOrganizationLabel.

func IsRequirementsNotMet

func IsRequirementsNotMet(err error) bool

IsRequirementsNotMet asserts requirementsNotMetError.

func IsTimeout

func IsTimeout(err error) bool

IsTimeout asserts timeoutError.

func IsTooManyCredentialsError

func IsTooManyCredentialsError(err error) bool

IsTooManyCredentialsError asserts tooManyCredentialsError.

func IsUnknownKindError

func IsUnknownKindError(err error) bool

IsUnknownKindError asserts unknownKindError.

func IsVnetCidrNotSetError

func IsVnetCidrNotSetError(err error) bool

IsCredentialsNotFoundError asserts credentialsNotFoundError.

Types

type Config

type Config struct {
	APIServerSecurePort int
	Azure               setting.Azure
	CalicoCIDRSize      int
	CalicoMTU           int
	CalicoSubnet        string
	CertsSearcher       certs.Interface
	ClusterIPRange      string
	CredentialProvider  credential.Provider
	CtrlClient          client.Client
	DockerhubToken      string
	EtcdPrefix          string
	Ignition            setting.Ignition
	Logger              micrologger.Logger
	OIDC                setting.OIDC
	RegistryDomain      string
	RegistryMirrors     []string
	SSHUserList         employees.SSHUserList
	SSOPublicKey        string
}

type Resource

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

Resource simulates a CAPI Bootstrap provider by rendering cloudconfig files while watching Spark CRs.

func New

func New(config Config) (*Resource, error)

func (*Resource) EnsureCreated

func (r *Resource) EnsureCreated(ctx context.Context, obj interface{}) error

EnsureCreated is checking if corresponding Spark CRD exists. In that case it renders k8scloudconfig for a node pool based on existing CAPI & CAPZ CRs. The rendered config is saved in a Secret, referenced by the Spark CRD.

func (*Resource) EnsureDeleted

func (r *Resource) EnsureDeleted(ctx context.Context, obj interface{}) error

EnsureDeleted will delete the `Spark` CR that was created for this specific node pool, and the `Secret` referenced by it.

func (*Resource) Name

func (r *Resource) Name() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL