spark

Documentation

Index

• Constants
• func IsCredentialsNotFoundError(err error) bool
• func IsInvalidConfig(err error) bool
• func IsMissingOrganizationLabel(err error) bool
• func IsRequirementsNotMet(err error) bool
• func IsTimeout(err error) bool
• func IsTooManyCredentialsError(err error) bool
• func IsUnknownKindError(err error) bool
• func IsVnetCidrNotSetError(err error) bool
• type Config
• type Resource
  • func New(config Config) (*Resource, error)
  • func (r *Resource) EnsureCreated(ctx context.Context, obj interface{}) error
  • func (r *Resource) EnsureDeleted(ctx context.Context, obj interface{}) error
  • func (r *Resource) Name() string

Constants

const (
	Name = "spark"
)

const (
	ProviderAzure = "azure"
)

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
	ClientFactory       v5client.OrganizationFactory
	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