v1alpha1

package
v0.6.252 Latest Latest
Warning

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

 Go to latest Published: Sep 21, 2023 License: Apache-2.0 Imports: 29 Imported by: 2

Documentation

Overview

+groupName=infra.modela.ai +kubebuilder:object:generate=true

Index

Constants

View Source 
const (
	AlertSent  = "Sent"
	AlertSaved = "Saved"
)
View Source 
const (
	VirtualBucketReady = "Ready"
)

Variables

View Source 
var (
	ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// SchemeBuilder registers our types
	SchemeBuilder = k8sruntime.NewSchemeBuilder(AddKnownTypes)
	// AddToScheme local alias for SchemeBuilder.AddToScheme
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: infra.GroupName, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects

Functions

func AddKnownTypes 

func AddKnownTypes(scheme *k8sruntime.Scheme) error

Adds the list of known types to api.Scheme.

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back a Group qualified GroupKind

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type Account 

type Account struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              AccountSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	//+optional
	Status AccountStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=accounts,shortName=acct,singular=account,categories={infra,modela} +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:printcolumn:name="Ready",type="string",JSONPath=".status.conditions[?(@.type==\"Ready\")].status",description="" +kubebuilder:printcolumn:name="Type",type="string",JSONPath=".spec.type",description="" +kubebuilder:printcolumn:name="Username",type="string",JSONPath=".spec.username",description="" +kubebuilder:printcolumn:name="Team",type="string",JSONPath=".spec.memberOf",description="" +kubebuilder:printcolumn:name="Phone",type="string",JSONPath=".spec.phone",description="",priority=1 +kubebuilder:printcolumn:name="Email",type="string",JSONPath=".spec.email",description="",priority=1 +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp",description="" Account represents a single user on the system or a team that other Accounts can be grouped under

func ParseAccountYaml 

func ParseAccountYaml(content []byte) (*Account, error)

func (*Account) AddFinalizer 

func (account *Account) AddFinalizer()

func (*Account) CreateOrUpdateCond 

func (account *Account) CreateOrUpdateCond(cond metav1.Condition)

Merge or update condition

func (*Account) DeepCopy 

func (in *Account) DeepCopy() *Account

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

func (*Account) DeepCopyInto 

func (in *Account) DeepCopyInto(out *Account)

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

func (*Account) DeepCopyObject 

func (in *Account) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Account) Default 

func (account *Account) Default()

func (*Account) Descriptor 

func (*Account) Descriptor() ([]byte, []int)

func (Account) GetCond 

func (account Account) GetCond(t AccountConditionType) metav1.Condition

func (Account) GetCondIdx 

func (account Account) GetCondIdx(t string) int

func (Account) GetObservedGeneration added in v0.6.252 

func (account Account) GetObservedGeneration() int64

func (Account) GetStatus added in v0.6.252 

func (account Account) GetStatus() proto.Message

func (Account) HasFinalizer 

func (account Account) HasFinalizer() bool

func (Account) IsReady 

func (account Account) IsReady() bool

func (Account) Key 

func (account Account) Key() string

func (Account) ManifestURI added in v0.5.472 

func (account Account) ManifestURI() string

func (*Account) MarkFailed added in v0.4.448 

func (account *Account) MarkFailed(err string)

func (*Account) MarkReady 

func (account *Account) MarkReady()

func (*Account) Marshal 

func (m *Account) Marshal() (dAtA []byte, err error)

func (*Account) MarshalTo 

func (m *Account) MarshalTo(dAtA []byte) (int, error)

func (*Account) MarshalToSizedBuffer 

func (m *Account) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Account) Populate 

func (account *Account) Populate(name string)

populate an empty account

func (*Account) ProtoMessage 

func (*Account) ProtoMessage()

func (*Account) RemoveFinalizer 

func (account *Account) RemoveFinalizer()

func (*Account) Reset 

func (m *Account) Reset()

func (Account) RootURI added in v0.5.472 

func (account Account) RootURI() string

func (*Account) SetObservedGeneration added in v0.6.252 

func (account *Account) SetObservedGeneration(generation int64)

func (*Account) SetStatus added in v0.6.252 

func (account *Account) SetStatus(status interface{})

func (*Account) SetUpdatedAt added in v0.6.252 

func (account *Account) SetUpdatedAt(time *metav1.Time)

func (*Account) SetupWebhookWithManager 

func (account *Account) SetupWebhookWithManager(mgr ctrl.Manager) error

Set up the webhook with the manager.

func (*Account) Size 

func (m *Account) Size() (n int)

func (*Account) String 

func (this *Account) String() string

func (*Account) Unmarshal 

func (m *Account) Unmarshal(dAtA []byte) error

func (Account) ValidateCreate 

func (account Account) ValidateCreate() error

func (Account) ValidateDelete 

func (account Account) ValidateDelete() error

func (Account) ValidateUpdate 

func (account Account) ValidateUpdate(old runtime.Object) error

func (*Account) XXX_DiscardUnknown 

func (m *Account) XXX_DiscardUnknown()

func (*Account) XXX_Marshal 

func (m *Account) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Account) XXX_Merge 

func (m *Account) XXX_Merge(src proto.Message)

func (*Account) XXX_Size 

func (m *Account) XXX_Size() int

func (*Account) XXX_Unmarshal 

func (m *Account) XXX_Unmarshal(b []byte) error

type AccountConditionType 

type AccountConditionType string

AccountCondition represents the state of the account 

const (
	AccountReady AccountConditionType = "Ready"
)

/ Account Condition

type AccountList 

type AccountList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Items           []Account `json:"items" protobuf:"bytes,2,rep,name=items"`
}

+kubebuilder:object:root=true AccountList represent list of accounts.

func (*AccountList) DeepCopy 

func (in *AccountList) DeepCopy() *AccountList

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

func (*AccountList) DeepCopyInto 

func (in *AccountList) DeepCopyInto(out *AccountList)

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

func (*AccountList) DeepCopyObject 

func (in *AccountList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*AccountList) Descriptor 

func (*AccountList) Descriptor() ([]byte, []int)

func (*AccountList) Marshal 

func (m *AccountList) Marshal() (dAtA []byte, err error)

func (*AccountList) MarshalTo 

func (m *AccountList) MarshalTo(dAtA []byte) (int, error)

func (*AccountList) MarshalToSizedBuffer 

func (m *AccountList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AccountList) ProtoMessage 

func (*AccountList) ProtoMessage()

func (*AccountList) Reset 

func (m *AccountList) Reset()

func (*AccountList) Size 

func (m *AccountList) Size() (n int)

func (*AccountList) String 

func (this *AccountList) String() string

func (*AccountList) Unmarshal 

func (m *AccountList) Unmarshal(dAtA []byte) error

func (*AccountList) XXX_DiscardUnknown 

func (m *AccountList) XXX_DiscardUnknown()

func (*AccountList) XXX_Marshal 

func (m *AccountList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AccountList) XXX_Merge 

func (m *AccountList) XXX_Merge(src proto.Message)

func (*AccountList) XXX_Size 

func (m *AccountList) XXX_Size() int

func (*AccountList) XXX_Unmarshal 

func (m *AccountList) XXX_Unmarshal(b []byte) error

type AccountSpec 

type AccountSpec struct {
	// The reference to the tenant which the object exists under
	// +kubebuilder:validation:Optional
	TenantRef *v1.ObjectReference `json:"tenantRef,omitempty" protobuf:"bytes,1,opt,name=tenantRef"`
	// The type of Account, which can be a user or a group
	// +kubebuilder:default:=user
	// +kubebuilder:validation:Optional
	Type *AccountType `json:"type,omitempty" protobuf:"bytes,3,opt,name=type,casttype=AccountType"`
	// The username of the account, which can be used to log into Modela
	// +kubebuilder:validation:MinLength=4
	// +kubebuilder:validation:MaxLength=64
	// +kubebuilder:validation:Required
	// +required
	Username *string `json:"username,omitempty" protobuf:"bytes,4,opt,name=username"`
	// The first name of the person using the Account
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	// +kubebuilder:validation:MaxLength=64
	FirstName *string `json:"firstName,omitempty" protobuf:"bytes,5,opt,name=firstName"`
	// The last name of the person using the Account
	// +kubebuilder:default:=""
	// +kubebuilder:validation:MaxLength=64
	// +kubebuilder:validation:Optional
	LastName *string `json:"lastName,omitempty" protobuf:"bytes,6,opt,name=lastName"`
	// The e-mail address of the person using the Account
	// +kubebuilder:default:=""
	// +kubebuilder:validation:MaxLength=64
	// +kubebuilder:validation:Required
	// +required
	Email *string `json:"email,omitempty" protobuf:"bytes,7,opt,name=email"`
	// The phone number of the person using the Account
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	// +kubebuilder:validation:MaxLength=64
	Phone *string `json:"phone,omitempty" protobuf:"bytes,8,opt,name=phone"`
	// Indicates if the Account has admin permissions. Admin accounts have unrestricted access
	// to all resources and full control to modify and create other Accounts
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Admin *bool `json:"admin,omitempty" protobuf:"varint,9,opt,name=admin"`
	// MemberOf specifies the name of the team that the Account belongs to.
	// The Account will assume all the permissions of the parent Account
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	MemberOf *string `json:"memberOf,omitempty" protobuf:"bytes,11,opt,name=memberOf"`
	// Indicates if the Account will be prompted to reset their password upon login
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	ResetPassword *bool `json:"resetPassword,omitempty" protobuf:"varint,13,opt,name=resetPassword"`
	// Avatar specifies the location of the Account's avatar image
	// +kubebuilder:validation:Optional
	Avatar *catalog.FileLocation `json:"avatar,omitempty" protobuf:"bytes,18,opt,name=avatar"`
	// The collection of DataProduct names that will be displayed with priority on the tenant dashboard for the Account
	// +kubebuilder:validation:Optional
	FavoriteProducts []string `json:"favoriteProducts,omitempty" protobuf:"bytes,19,rep,name=favoriteProducts"`
}

AccountSpec defines the desired state of an Account

func (*AccountSpec) DeepCopy 

func (in *AccountSpec) DeepCopy() *AccountSpec

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

func (*AccountSpec) DeepCopyInto 

func (in *AccountSpec) DeepCopyInto(out *AccountSpec)

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

func (*AccountSpec) Descriptor 

func (*AccountSpec) Descriptor() ([]byte, []int)

func (*AccountSpec) Marshal 

func (m *AccountSpec) Marshal() (dAtA []byte, err error)

func (*AccountSpec) MarshalTo 

func (m *AccountSpec) MarshalTo(dAtA []byte) (int, error)

func (*AccountSpec) MarshalToSizedBuffer 

func (m *AccountSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AccountSpec) ProtoMessage 

func (*AccountSpec) ProtoMessage()

func (*AccountSpec) Reset 

func (m *AccountSpec) Reset()

func (*AccountSpec) Size 

func (m *AccountSpec) Size() (n int)

func (*AccountSpec) String 

func (this *AccountSpec) String() string

func (*AccountSpec) Unmarshal 

func (m *AccountSpec) Unmarshal(dAtA []byte) error

func (*AccountSpec) XXX_DiscardUnknown 

func (m *AccountSpec) XXX_DiscardUnknown()

func (*AccountSpec) XXX_Marshal 

func (m *AccountSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AccountSpec) XXX_Merge 

func (m *AccountSpec) XXX_Merge(src proto.Message)

func (*AccountSpec) XXX_Size 

func (m *AccountSpec) XXX_Size() int

func (*AccountSpec) XXX_Unmarshal 

func (m *AccountSpec) XXX_Unmarshal(b []byte) error

type AccountStatus 

type AccountStatus struct {
	// The last time the object was updated
	//+kubebuilder:validation:Optional
	UpdatedAt *metav1.Time `json:"updatedAt,omitempty" protobuf:"bytes,1,opt,name=updatedAt"`
	// ObservedGeneration is the last generation that was acted on
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,2,opt,name=observedGeneration"`
	// In the case of failure, the Account resource controller will set this field with a failure reason
	//+kubebuilder:validation:Optional
	FailureReason *catalog.StatusError `json:"failureReason,omitempty" protobuf:"bytes,3,opt,name=failureReason"`
	// In the case of failure, the Account resource controller will set this field with a failure message
	//+kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,4,opt,name=failureMessage"`
	// Total models owned by this user
	//+kubebuilder:validation:Optional
	ModelsCount int32 `json:"modelsCount,omitempty" protobuf:"bytes,5,opt,name=modelsCount"`
	// Total model classes owned by this user
	//+kubebuilder:validation:Optional
	ModelClassesCount int32 `json:"modelClassessCount,omitempty" protobuf:"bytes,6,opt,name=modelClassesCount"`
	// Total number of feature groups that this user is owner of.
	//+kubebuilder:validation:Optional
	PredictorsCounts int32 `json:"predictorsCount,omitempty" protobuf:"bytes,7,opt,name=predictorsCount"`
	// Total number of feature groups that this user is responsible for.
	//+kubebuilder:validation:Optional
	FeatureGroupsCount int32 `json:"featureGroupsCount,omitempty" protobuf:"bytes,8,opt,name=featureGroupsCount"`
	// Total number of feature groups that this user is responsible for.
	//+kubebuilder:validation:Optional
	DatasetsCount int32 `json:"datasetsCount,omitempty" protobuf:"bytes,9,opt,name=datasetsCount"`
	// If the Account is a group account, the total number of Accounts that exist under the group
	//+kubebuilder:validation:Optional
	MembersCount int32 `json:"membersCount,omitempty" protobuf:"bytes,10,opt,name=membersCount"`
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,11,rep,name=conditions"`
}

AccountStatus defines the actual state of the api object

func (*AccountStatus) DeepCopy 

func (in *AccountStatus) DeepCopy() *AccountStatus

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

func (*AccountStatus) DeepCopyInto 

func (in *AccountStatus) DeepCopyInto(out *AccountStatus)

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

func (*AccountStatus) Descriptor 

func (*AccountStatus) Descriptor() ([]byte, []int)

func (*AccountStatus) Marshal 

func (m *AccountStatus) Marshal() (dAtA []byte, err error)

func (*AccountStatus) MarshalTo 

func (m *AccountStatus) MarshalTo(dAtA []byte) (int, error)

func (*AccountStatus) MarshalToSizedBuffer 

func (m *AccountStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AccountStatus) ProtoMessage 

func (*AccountStatus) ProtoMessage()

func (*AccountStatus) Reset 

func (m *AccountStatus) Reset()

func (*AccountStatus) Size 

func (m *AccountStatus) Size() (n int)

func (*AccountStatus) String 

func (this *AccountStatus) String() string

func (*AccountStatus) Unmarshal 

func (m *AccountStatus) Unmarshal(dAtA []byte) error

func (*AccountStatus) XXX_DiscardUnknown 

func (m *AccountStatus) XXX_DiscardUnknown()

func (*AccountStatus) XXX_Marshal 

func (m *AccountStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AccountStatus) XXX_Merge 

func (m *AccountStatus) XXX_Merge(src proto.Message)

func (*AccountStatus) XXX_Size 

func (m *AccountStatus) XXX_Size() int

func (*AccountStatus) XXX_Unmarshal 

func (m *AccountStatus) XXX_Unmarshal(b []byte) error

type AccountType 

type AccountType string

======= Account ======== +kubebuilder:validation:Enum="user";"group" 

const (
	User  AccountType = "user"
	Group AccountType = "group"
)

type Alert 

type Alert struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              AlertSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	//+optional
	Status AlertStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:resource:path=alerts,singular=alert,categories={infra,modela} +kubebuilder:storageversion +kubebuilder:printcolumn:name="Status",type="string",JSONPath=".status.phase",description="" +kubebuilder:printcolumn:name="Level",type="string",JSONPath=".spec.level",description="" +kubebuilder:printcolumn:name="Subject",type="string",JSONPath=".spec.subject",description="" +kubebuilder:printcolumn:name="Entity Namespace",type="string",JSONPath=".spec.entityRef.namespace",description="",priority=1 +kubebuilder:printcolumn:name="Entity Name",type="string",JSONPath=".spec.entityRef.name",description="",priority=1 +kubebuilder:printcolumn:name="Notifier",type="string",JSONPath=".spec.notifierName",description="",priority=1 +kubebuilder:printcolumn:name="FiredAt",type="date",JSONPath=".status.at",description="" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp",description="" Alert represents temporal information about an event that occurred with a Modela custom resource

func ParseAlertYaml 

func ParseAlertYaml(content []byte) (*Alert, error)

func (*Alert) AddFinalizer 

func (alert *Alert) AddFinalizer()

func (*Alert) CreateOrUpdateCond 

func (alert *Alert) CreateOrUpdateCond(cond metav1.Condition)

Merge or update condition

func (*Alert) DeepCopy 

func (in *Alert) DeepCopy() *Alert

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

func (*Alert) DeepCopyInto 

func (in *Alert) DeepCopyInto(out *Alert)

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

func (*Alert) DeepCopyObject 

func (in *Alert) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Alert) Default 

func (alert *Alert) Default()

func (*Alert) Descriptor 

func (*Alert) Descriptor() ([]byte, []int)

func (Alert) GetCond 

func (alert Alert) GetCond(t string) metav1.Condition

func (Alert) GetCondIdx 

func (alert Alert) GetCondIdx(t string) int

func (Alert) GetObservedGeneration added in v0.6.252 

func (alert Alert) GetObservedGeneration() int64

func (Alert) GetStatus added in v0.6.252 

func (alert Alert) GetStatus() proto.Message

func (*Alert) HasFinalizer 

func (alert *Alert) HasFinalizer() bool

func (Alert) IsReady 

func (alert Alert) IsReady() bool

func (Alert) ManifestURI added in v0.5.472 

func (alert Alert) ManifestURI() string

func (*Alert) MarkFailed added in v0.4.448 

func (alert *Alert) MarkFailed(reason string, err string)

func (*Alert) MarkSent 

func (alert *Alert) MarkSent()

func (*Alert) Marshal 

func (m *Alert) Marshal() (dAtA []byte, err error)

func (*Alert) MarshalTo 

func (m *Alert) MarshalTo(dAtA []byte) (int, error)

func (*Alert) MarshalToSizedBuffer 

func (m *Alert) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Alert) ProtoMessage 

func (*Alert) ProtoMessage()

func (*Alert) RemoveFinalizer 

func (alert *Alert) RemoveFinalizer()

func (*Alert) Reset 

func (m *Alert) Reset()

func (Alert) RootURI added in v0.5.472 

func (alert Alert) RootURI() string

func (*Alert) SetObservedGeneration added in v0.6.252 

func (alert *Alert) SetObservedGeneration(generation int64)

func (*Alert) SetStatus added in v0.6.252 

func (alert *Alert) SetStatus(status interface{})

func (*Alert) SetUpdatedAt added in v0.6.252 

func (alert *Alert) SetUpdatedAt(time *metav1.Time)

func (*Alert) SetupWebhookWithManager 

func (alert *Alert) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Alert) Size 

func (m *Alert) Size() (n int)

func (*Alert) String 

func (this *Alert) String() string

func (*Alert) Unmarshal 

func (m *Alert) Unmarshal(dAtA []byte) error

func (Alert) ValidateCreate 

func (alert Alert) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (Alert) ValidateDelete 

func (alert Alert) ValidateDelete() error

func (Alert) ValidateUpdate 

func (alert Alert) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

func (*Alert) XXX_DiscardUnknown 

func (m *Alert) XXX_DiscardUnknown()

func (*Alert) XXX_Marshal 

func (m *Alert) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Alert) XXX_Merge 

func (m *Alert) XXX_Merge(src proto.Message)

func (*Alert) XXX_Size 

func (m *Alert) XXX_Size() int

func (*Alert) XXX_Unmarshal 

func (m *Alert) XXX_Unmarshal(b []byte) error

type AlertLevel 

type AlertLevel string
const (
	InfoAlertLevel  AlertLevel = "normal"
	ErrorAlertLevel AlertLevel = "error"
)

type AlertList 

type AlertList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Items           []Alert `json:"items" protobuf:"bytes,2,rep,name=items"`
}

AlertList is a list of Alerts +kubebuilder:object:root=true

func (*AlertList) DeepCopy 

func (in *AlertList) DeepCopy() *AlertList

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

func (*AlertList) DeepCopyInto 

func (in *AlertList) DeepCopyInto(out *AlertList)

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

func (*AlertList) DeepCopyObject 

func (in *AlertList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*AlertList) Descriptor 

func (*AlertList) Descriptor() ([]byte, []int)

func (*AlertList) Marshal 

func (m *AlertList) Marshal() (dAtA []byte, err error)

func (*AlertList) MarshalTo 

func (m *AlertList) MarshalTo(dAtA []byte) (int, error)

func (*AlertList) MarshalToSizedBuffer 

func (m *AlertList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlertList) ProtoMessage 

func (*AlertList) ProtoMessage()

func (*AlertList) Reset 

func (m *AlertList) Reset()

func (*AlertList) Size 

func (m *AlertList) Size() (n int)

func (*AlertList) String 

func (this *AlertList) String() string

func (*AlertList) Unmarshal 

func (m *AlertList) Unmarshal(dAtA []byte) error

func (*AlertList) XXX_DiscardUnknown 

func (m *AlertList) XXX_DiscardUnknown()

func (*AlertList) XXX_Marshal 

func (m *AlertList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlertList) XXX_Merge 

func (m *AlertList) XXX_Merge(src proto.Message)

func (*AlertList) XXX_Size 

func (m *AlertList) XXX_Size() int

func (*AlertList) XXX_Unmarshal 

func (m *AlertList) XXX_Unmarshal(b []byte) error

type AlertSpec 

type AlertSpec struct {
	// Subject details the primary message of the Alert
	// +kubebuilder:default:=""
	Subject string `json:"subject,omitempty" protobuf:"bytes,1,opt,name=subject"`
	// Level specifies the significance of the Alert, which can be normal, warning, or error
	// +kubebuilder:default:="normal"
	Level *AlertLevel `json:"level,omitempty" protobuf:"bytes,2,opt,name=level"`
	// EntityRef references the custom resource relevant to the Alert
	EntityRef v1.ObjectReference `json:"entityRef,omitempty" protobuf:"bytes,3,opt,name=entityRef"`
	// Owner references the name of the Account which owns the Alert
	// +kubebuilder:default:="no-one"
	// +kubebuilder:validation:Optional
	Owner *string `json:"owner,omitempty" protobuf:"bytes,4,opt,name=owner"`
	// Fields defines additional key-value information about the event
	// +kubebuilder:validation:Optional
	Fields map[string]string `json:"fields,omitempty" protobuf:"bytes,5,opt,name=fields"`
	// URL specifies a link relevant to the subject
	// +kubebuilder:validation:Optional
	URL *string `json:"url,omitempty" protobuf:"bytes,6,opt,name=url"`
	// Image specifies the link to an image relevant to the subject
	// +kubebuilder:validation:Optional
	Image *string `json:"image,omitempty" protobuf:"bytes,7,opt,name=image"`
	// Notification defines to configuration to forward the Alert to an external Notifier
	// +kubebuilder:validation:Optional
	Notification catalog.NotificationSpec `json:"notification,omitempty" protobuf:"bytes,8,opt,name=notification"`
}

func (*AlertSpec) DeepCopy 

func (in *AlertSpec) DeepCopy() *AlertSpec

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

func (*AlertSpec) DeepCopyInto 

func (in *AlertSpec) DeepCopyInto(out *AlertSpec)

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

func (*AlertSpec) Descriptor 

func (*AlertSpec) Descriptor() ([]byte, []int)

func (*AlertSpec) Marshal 

func (m *AlertSpec) Marshal() (dAtA []byte, err error)

func (*AlertSpec) MarshalTo 

func (m *AlertSpec) MarshalTo(dAtA []byte) (int, error)

func (*AlertSpec) MarshalToSizedBuffer 

func (m *AlertSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlertSpec) ProtoMessage 

func (*AlertSpec) ProtoMessage()

func (*AlertSpec) Reset 

func (m *AlertSpec) Reset()

func (*AlertSpec) Size 

func (m *AlertSpec) Size() (n int)

func (*AlertSpec) String 

func (this *AlertSpec) String() string

func (*AlertSpec) Unmarshal 

func (m *AlertSpec) Unmarshal(dAtA []byte) error

func (*AlertSpec) XXX_DiscardUnknown 

func (m *AlertSpec) XXX_DiscardUnknown()

func (*AlertSpec) XXX_Marshal 

func (m *AlertSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlertSpec) XXX_Merge 

func (m *AlertSpec) XXX_Merge(src proto.Message)

func (*AlertSpec) XXX_Size 

func (m *AlertSpec) XXX_Size() int

func (*AlertSpec) XXX_Unmarshal 

func (m *AlertSpec) XXX_Unmarshal(b []byte) error

type AlertStatus 

type AlertStatus struct {
	// The time when the Alert was fired
	// +kubebuilder:validation:Optional
	FiredAt *metav1.Time `json:"firedAt" protobuf:"bytes,2,opt,name=firedAt"`
	// ObservedGeneration is the last generation that was acted on
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,3,opt,name=observedGeneration"`
	// The last time the object was updated
	//+kubebuilder:validation:Optional
	UpdatedAt *metav1.Time `json:"updatedAt,omitempty" protobuf:"bytes,4,opt,name=updatedAt"`
	// In the case of failure, the Alert resource controller will set this field with a failure message
	//+kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,5,opt,name=failureMessage"`
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,6,rep,name=conditions"`
}

AlertStatus is the observed state of an Alert

func (*AlertStatus) DeepCopy 

func (in *AlertStatus) DeepCopy() *AlertStatus

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

func (*AlertStatus) DeepCopyInto 

func (in *AlertStatus) DeepCopyInto(out *AlertStatus)

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

func (*AlertStatus) Descriptor 

func (*AlertStatus) Descriptor() ([]byte, []int)

func (*AlertStatus) Marshal 

func (m *AlertStatus) Marshal() (dAtA []byte, err error)

func (*AlertStatus) MarshalTo 

func (m *AlertStatus) MarshalTo(dAtA []byte) (int, error)

func (*AlertStatus) MarshalToSizedBuffer 

func (m *AlertStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlertStatus) ProtoMessage 

func (*AlertStatus) ProtoMessage()

func (*AlertStatus) Reset 

func (m *AlertStatus) Reset()

func (*AlertStatus) Size 

func (m *AlertStatus) Size() (n int)

func (*AlertStatus) String 

func (this *AlertStatus) String() string

func (*AlertStatus) Unmarshal 

func (m *AlertStatus) Unmarshal(dAtA []byte) error

func (*AlertStatus) XXX_DiscardUnknown 

func (m *AlertStatus) XXX_DiscardUnknown()

func (*AlertStatus) XXX_Marshal 

func (m *AlertStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlertStatus) XXX_Merge 

func (m *AlertStatus) XXX_Merge(src proto.Message)

func (*AlertStatus) XXX_Size 

func (m *AlertStatus) XXX_Size() int

func (*AlertStatus) XXX_Unmarshal 

func (m *AlertStatus) XXX_Unmarshal(b []byte) error

type Attachment 

type Attachment struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              AttachmentSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	//+optional
	Status AttachmentStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=attachments,singular=attachment,categories={infra,modela} +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:printcolumn:name="Ready",type="string",JSONPath=".status.conditions[?(@.type==\"Ready\")].status",description="" +kubebuilder:printcolumn:name="Entity Namespace",type="string",JSONPath=".spec.entityRef.name",description="" +kubebuilder:printcolumn:name="Entity Name",type="string",JSONPath=".spec.entityRef.namespace",description="" +kubebuilder:printcolumn:name="BucketName",type="string",JSONPath=".spec.bucketName",description="" +kubebuilder:printcolumn:name="Path",type="string",JSONPath=".spec.path",description="" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp",description="" Attachment represent an file attached to a resource.

func ParseAttachmentYaml 

func ParseAttachmentYaml(content []byte) (*Attachment, error)

func (*Attachment) AddFinalizer 

func (attachment *Attachment) AddFinalizer()

func (*Attachment) CreateOrUpdateCond 

func (attachment *Attachment) CreateOrUpdateCond(cond metav1.Condition)

Merge or update condition

func (*Attachment) DeepCopy 

func (in *Attachment) DeepCopy() *Attachment

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

func (*Attachment) DeepCopyInto 

func (in *Attachment) DeepCopyInto(out *Attachment)

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

func (*Attachment) DeepCopyObject 

func (in *Attachment) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Attachment) Default 

func (attachment *Attachment) Default()

func (*Attachment) Descriptor 

func (*Attachment) Descriptor() ([]byte, []int)

func (Attachment) GetCond 

func (attachment Attachment) GetCond(t AttachmentConditionType) metav1.Condition

func (Attachment) GetCondIdx 

func (attachment Attachment) GetCondIdx(t string) int

func (Attachment) GetObservedGeneration added in v0.6.252 

func (attachment Attachment) GetObservedGeneration() int64

func (Attachment) GetStatus added in v0.6.252 

func (attachment Attachment) GetStatus() proto.Message

func (*Attachment) HasFinalizer 

func (attachment *Attachment) HasFinalizer() bool

func (Attachment) IsReady 

func (attachment Attachment) IsReady() bool

func (Attachment) ManifestURI added in v0.5.472 

func (attachment Attachment) ManifestURI() string

func (*Attachment) MarkFailed added in v0.4.450 

func (attachment *Attachment) MarkFailed(err string)

func (*Attachment) MarkSent 

func (attachment *Attachment) MarkSent()

func (*Attachment) Marshal 

func (m *Attachment) Marshal() (dAtA []byte, err error)

func (*Attachment) MarshalTo 

func (m *Attachment) MarshalTo(dAtA []byte) (int, error)

func (*Attachment) MarshalToSizedBuffer 

func (m *Attachment) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Attachment) ProtoMessage 

func (*Attachment) ProtoMessage()

func (*Attachment) RemoveFinalizer 

func (attachment *Attachment) RemoveFinalizer()

func (*Attachment) Reset 

func (m *Attachment) Reset()

func (Attachment) RootURI added in v0.5.472 

func (attachment Attachment) RootURI() string

func (*Attachment) SetObservedGeneration added in v0.6.252 

func (attachment *Attachment) SetObservedGeneration(generation int64)

func (*Attachment) SetStatus added in v0.6.252 

func (attachment *Attachment) SetStatus(status interface{})

func (*Attachment) SetUpdatedAt added in v0.6.252 

func (attachment *Attachment) SetUpdatedAt(time *metav1.Time)

func (*Attachment) SetupWebhookWithManager 

func (attachment *Attachment) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Attachment) Size 

func (m *Attachment) Size() (n int)

func (*Attachment) String 

func (this *Attachment) String() string

func (*Attachment) Unmarshal 

func (m *Attachment) Unmarshal(dAtA []byte) error

func (*Attachment) ValidateCreate 

func (attachment *Attachment) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Attachment) ValidateDelete 

func (attachment *Attachment) ValidateDelete() error

func (*Attachment) ValidateUpdate 

func (attachment *Attachment) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

func (*Attachment) XXX_DiscardUnknown 

func (m *Attachment) XXX_DiscardUnknown()

func (*Attachment) XXX_Marshal 

func (m *Attachment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Attachment) XXX_Merge 

func (m *Attachment) XXX_Merge(src proto.Message)

func (*Attachment) XXX_Size 

func (m *Attachment) XXX_Size() int

func (*Attachment) XXX_Unmarshal 

func (m *Attachment) XXX_Unmarshal(b []byte) error

type AttachmentConditionType 

type AttachmentConditionType string

Attachment condition 

const (
	AttachmentSent  AttachmentConditionType = "Sent"
	AttachmentSaved AttachmentConditionType = "Saved"
)

/ Attachment Condition

type AttachmentList 

type AttachmentList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Items           []Attachment `json:"items" protobuf:"bytes,2,rep,name=items"`
}

+kubebuilder:object:root=true AttachmentList is a list of Attachments

func (*AttachmentList) DeepCopy 

func (in *AttachmentList) DeepCopy() *AttachmentList

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

func (*AttachmentList) DeepCopyInto 

func (in *AttachmentList) DeepCopyInto(out *AttachmentList)

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

func (*AttachmentList) DeepCopyObject 

func (in *AttachmentList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*AttachmentList) Descriptor 

func (*AttachmentList) Descriptor() ([]byte, []int)

func (*AttachmentList) Marshal 

func (m *AttachmentList) Marshal() (dAtA []byte, err error)

func (*AttachmentList) MarshalTo 

func (m *AttachmentList) MarshalTo(dAtA []byte) (int, error)

func (*AttachmentList) MarshalToSizedBuffer 

func (m *AttachmentList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AttachmentList) ProtoMessage 

func (*AttachmentList) ProtoMessage()

func (*AttachmentList) Reset 

func (m *AttachmentList) Reset()

func (*AttachmentList) Size 

func (m *AttachmentList) Size() (n int)

func (*AttachmentList) String 

func (this *AttachmentList) String() string

func (*AttachmentList) Unmarshal 

func (m *AttachmentList) Unmarshal(dAtA []byte) error

func (*AttachmentList) XXX_DiscardUnknown 

func (m *AttachmentList) XXX_DiscardUnknown()

func (*AttachmentList) XXX_Marshal 

func (m *AttachmentList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AttachmentList) XXX_Merge 

func (m *AttachmentList) XXX_Merge(src proto.Message)

func (*AttachmentList) XXX_Size 

func (m *AttachmentList) XXX_Size() int

func (*AttachmentList) XXX_Unmarshal 

func (m *AttachmentList) XXX_Unmarshal(b []byte) error

type AttachmentSpec 

type AttachmentSpec struct {
	// +kubebuilder:default:="no-one"
	// +kubebuilder:validation:Optional
	Owner *string `json:"owner,omitempty" protobuf:"bytes,1,opt,name=owner"`
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" protobuf:"bytes,2,opt,name=description"`
	// Entity ref
	EntityRef v1.ObjectReference `json:"entityRef,omitempty" protobuf:"bytes,3,opt,name=entityRef"`
	// +kubebuilder:default:=""
	// Bucketname is the name of the bucket
	// +kubebuilder:validation:Optional
	BucketName string `json:"bucketName" protobuf:"bytes,4,opt,name=bucketName"`
	// Path to the full data file (e.g. csv file).
	// +kubebuilder:validation:Optional
	Path string `json:"path" protobuf:"bytes,5,opt,name=path"`
	// TenantRef is the commit tenant
	// +kubebuilder:validation:Optional
	TenantRef *v1.ObjectReference `json:"tenantRef,omitempty" protobuf:"bytes,6,opt,name=tenantRef"`
}

AttachmentSpec defines the desired state of Attachment

func (*AttachmentSpec) DeepCopy 

func (in *AttachmentSpec) DeepCopy() *AttachmentSpec

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

func (*AttachmentSpec) DeepCopyInto 

func (in *AttachmentSpec) DeepCopyInto(out *AttachmentSpec)

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

func (*AttachmentSpec) Descriptor 

func (*AttachmentSpec) Descriptor() ([]byte, []int)

func (*AttachmentSpec) Marshal 

func (m *AttachmentSpec) Marshal() (dAtA []byte, err error)

func (*AttachmentSpec) MarshalTo 

func (m *AttachmentSpec) MarshalTo(dAtA []byte) (int, error)

func (*AttachmentSpec) MarshalToSizedBuffer 

func (m *AttachmentSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AttachmentSpec) ProtoMessage 

func (*AttachmentSpec) ProtoMessage()

func (*AttachmentSpec) Reset 

func (m *AttachmentSpec) Reset()

func (*AttachmentSpec) Size 

func (m *AttachmentSpec) Size() (n int)

func (*AttachmentSpec) String 

func (this *AttachmentSpec) String() string

func (*AttachmentSpec) Unmarshal 

func (m *AttachmentSpec) Unmarshal(dAtA []byte) error

func (*AttachmentSpec) XXX_DiscardUnknown 

func (m *AttachmentSpec) XXX_DiscardUnknown()

func (*AttachmentSpec) XXX_Marshal 

func (m *AttachmentSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AttachmentSpec) XXX_Merge 

func (m *AttachmentSpec) XXX_Merge(src proto.Message)

func (*AttachmentSpec) XXX_Size 

func (m *AttachmentSpec) XXX_Size() int

func (*AttachmentSpec) XXX_Unmarshal 

func (m *AttachmentSpec) XXX_Unmarshal(b []byte) error

type AttachmentStatus 

type AttachmentStatus struct {
	// ObservedGeneration is the Last generation that was acted on
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`
	// Last time the object was updated
	//+kubebuilder:validation:Optional
	UpdatedAt *metav1.Time `json:"updatedAt,omitempty" protobuf:"bytes,2,opt,name=updatedAt"`
	// UpdateUpdateStrategy in case of terminal failure
	// Borrowed from cluster api controller
	//+kubebuilder:validation:Optional
	FailureReason *catalog.StatusError `json:"failureReason,omitempty" protobuf:"bytes,3,opt,name=failureReason"`
	// UpdateUpdateStrategy in case of terminal failure message
	//+kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,4,opt,name=failureMessage"`
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,5,rep,name=conditions"`
}

AttachmentStatus is the observed state of a Attachment

func (*AttachmentStatus) DeepCopy 

func (in *AttachmentStatus) DeepCopy() *AttachmentStatus

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

func (*AttachmentStatus) DeepCopyInto 

func (in *AttachmentStatus) DeepCopyInto(out *AttachmentStatus)

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

func (*AttachmentStatus) Descriptor 

func (*AttachmentStatus) Descriptor() ([]byte, []int)

func (*AttachmentStatus) Marshal 

func (m *AttachmentStatus) Marshal() (dAtA []byte, err error)

func (*AttachmentStatus) MarshalTo 

func (m *AttachmentStatus) MarshalTo(dAtA []byte) (int, error)

func (*AttachmentStatus) MarshalToSizedBuffer 

func (m *AttachmentStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AttachmentStatus) ProtoMessage 

func (*AttachmentStatus) ProtoMessage()

func (*AttachmentStatus) Reset 

func (m *AttachmentStatus) Reset()

func (*AttachmentStatus) Size 

func (m *AttachmentStatus) Size() (n int)

func (*AttachmentStatus) String 

func (this *AttachmentStatus) String() string

func (*AttachmentStatus) Unmarshal 

func (m *AttachmentStatus) Unmarshal(dAtA []byte) error

func (*AttachmentStatus) XXX_DiscardUnknown 

func (m *AttachmentStatus) XXX_DiscardUnknown()

func (*AttachmentStatus) XXX_Marshal 

func (m *AttachmentStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AttachmentStatus) XXX_Merge 

func (m *AttachmentStatus) XXX_Merge(src proto.Message)

func (*AttachmentStatus) XXX_Size 

func (m *AttachmentStatus) XXX_Size() int

func (*AttachmentStatus) XXX_Unmarshal 

func (m *AttachmentStatus) XXX_Unmarshal(b []byte) error

type Connection 

type Connection struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              ConnectionSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	//+optional
	Status ConnectionStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:resource:path=connections,shortName=conn,singular=connection,categories={infra,modela} +kubebuilder:storageversion +kubebuilder:printcolumn:name="Ready",type="string",JSONPath=".status.conditions[?(@.type==\"Ready\")].status",description="" +kubebuilder:printcolumn:name="Provider",type="string",JSONPath=".spec.provider",description="" +kubebuilder:printcolumn:name="Category",type="string",JSONPath=".spec.category",description="" +kubebuilder:printcolumn:name="Secret",type="string",JSONPath=".spec.secretRef.name",description="",priority=1 +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp",description="" Connection defines a connection to an external system (e.g. database, public cloud)

func ParseConnectionYaml 

func ParseConnectionYaml(content []byte) (*Connection, error)

func (*Connection) AddFinalizer 

func (connection *Connection) AddFinalizer()

func (*Connection) CreateOrUpdateCond 

func (connection *Connection) CreateOrUpdateCond(cond metav1.Condition)

Merge or update condition

func (*Connection) DeepCopy 

func (in *Connection) DeepCopy() *Connection

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

func (*Connection) DeepCopyInto 

func (in *Connection) DeepCopyInto(out *Connection)

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

func (*Connection) DeepCopyObject 

func (in *Connection) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Connection) Default 

func (connection *Connection) Default()

No defaults for the current configuration

func (*Connection) Descriptor 

func (*Connection) Descriptor() ([]byte, []int)

func (*Connection) GetBoolOption added in v0.6.252 

func (connection *Connection) GetBoolOption(key string, defaultValue bool) bool

func (*Connection) GetCond 

func (connection *Connection) GetCond(t string) metav1.Condition

func (*Connection) GetCondIdx 

func (connection *Connection) GetCondIdx(t string) int

func (*Connection) GetIntOption added in v0.6.252 

func (connection *Connection) GetIntOption(key string, defaultValue int) int

func (Connection) GetObservedGeneration added in v0.6.252 

func (connection Connection) GetObservedGeneration() int64

func (Connection) GetStatus added in v0.6.252 

func (connection Connection) GetStatus() proto.Message

func (*Connection) GetStringOption added in v0.6.252 

func (connection *Connection) GetStringOption(key string, defaultValue string) string

func (*Connection) HasFinalizer 

func (connection *Connection) HasFinalizer() bool

func (*Connection) IsReady 

func (connection *Connection) IsReady() bool

func (*Connection) Key 

func (connection *Connection) Key() string

func (*Connection) ManifestURI added in v0.5.472 

func (connection *Connection) ManifestURI() string

func (*Connection) MarkReady 

func (connection *Connection) MarkReady()

func (*Connection) Marshal 

func (m *Connection) Marshal() (dAtA []byte, err error)

func (*Connection) MarshalTo 

func (m *Connection) MarshalTo(dAtA []byte) (int, error)

func (*Connection) MarshalToSizedBuffer 

func (m *Connection) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Connection) ProtoMessage 

func (*Connection) ProtoMessage()

func (*Connection) RemoveFinalizer 

func (connection *Connection) RemoveFinalizer()

func (*Connection) Reset 

func (m *Connection) Reset()

func (*Connection) RootURI added in v0.5.472 

func (connection *Connection) RootURI() string

func (*Connection) SetObservedGeneration added in v0.6.252 

func (connection *Connection) SetObservedGeneration(generation int64)

func (*Connection) SetStatus added in v0.6.252 

func (connection *Connection) SetStatus(status interface{})

func (*Connection) SetUpdatedAt added in v0.6.252 

func (connection *Connection) SetUpdatedAt(time *metav1.Time)

func (*Connection) SetupWebhookWithManager 

func (connection *Connection) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Connection) Size 

func (m *Connection) Size() (n int)

func (*Connection) String 

func (this *Connection) String() string

func (*Connection) Unmarshal 

func (m *Connection) Unmarshal(dAtA []byte) error

func (Connection) ValidateCreate 

func (connection Connection) ValidateCreate() error

func (Connection) ValidateDelete 

func (connection Connection) ValidateDelete() error

func (Connection) ValidateUpdate 

func (connection Connection) ValidateUpdate(old runtime.Object) error

func (*Connection) XXX_DiscardUnknown 

func (m *Connection) XXX_DiscardUnknown()

func (*Connection) XXX_Marshal 

func (m *Connection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Connection) XXX_Merge 

func (m *Connection) XXX_Merge(src proto.Message)

func (*Connection) XXX_Size 

func (m *Connection) XXX_Size() int

func (*Connection) XXX_Unmarshal 

func (m *Connection) XXX_Unmarshal(b []byte) error

type ConnectionConditionType 

type ConnectionConditionType string

ConnectionConditionType is the type of condition 

const (
	ConnectionReady ConnectionConditionType = "Ready"
	ConnectionSaved ConnectionConditionType = "Saved"
)

RegistryConnectionName Condition

type ConnectionList 

type ConnectionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Items           []Connection `json:"items" protobuf:"bytes,2,rep,name=items"`
}

+kubebuilder:object:root=true ConnectionList is a list of Connections.

func (*ConnectionList) DeepCopy 

func (in *ConnectionList) DeepCopy() *ConnectionList

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

func (*ConnectionList) DeepCopyInto 

func (in *ConnectionList) DeepCopyInto(out *ConnectionList)

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

func (*ConnectionList) DeepCopyObject 

func (in *ConnectionList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ConnectionList) Descriptor 

func (*ConnectionList) Descriptor() ([]byte, []int)

func (*ConnectionList) Marshal 

func (m *ConnectionList) Marshal() (dAtA []byte, err error)

func (*ConnectionList) MarshalTo 

func (m *ConnectionList) MarshalTo(dAtA []byte) (int, error)

func (*ConnectionList) MarshalToSizedBuffer 

func (m *ConnectionList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConnectionList) ProtoMessage 

func (*ConnectionList) ProtoMessage()

func (*ConnectionList) Reset 

func (m *ConnectionList) Reset()

func (*ConnectionList) Size 

func (m *ConnectionList) Size() (n int)

func (*ConnectionList) String 

func (this *ConnectionList) String() string

func (*ConnectionList) Unmarshal 

func (m *ConnectionList) Unmarshal(dAtA []byte) error

func (*ConnectionList) XXX_DiscardUnknown 

func (m *ConnectionList) XXX_DiscardUnknown()

func (*ConnectionList) XXX_Marshal 

func (m *ConnectionList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectionList) XXX_Merge 

func (m *ConnectionList) XXX_Merge(src proto.Message)

func (*ConnectionList) XXX_Size 

func (m *ConnectionList) XXX_Size() int

func (*ConnectionList) XXX_Unmarshal 

func (m *ConnectionList) XXX_Unmarshal(b []byte) error

type ConnectionSpec 

type ConnectionSpec struct {
	// The reference to the Tenant which owns the DataProduct. Defaults to `default-tenant`
	// +kubebuilder:validation:Optional
	TenantRef *corev1.ObjectReference `json:"tenantRef" protobuf:"bytes,1,opt,name=tenantRef"`
	// The type of external system which the connection references
	// +kubebuilder:default:="general"
	// +kubebuilder:validation:Optional
	Category *catalog.ConnectionCategory `json:"category" protobuf:"bytes,2,opt,name=category"`
	// Provider specifies the name of the provider to the external system
	// +kubebuilder:validation:Required
	// +required
	Provider *catalog.ProviderName `json:"provider,omitempty" protobuf:"bytes,3,opt,name=provider"`

	// SecretData contains a map of sensitive parameters relevant to the connection and their values. Modela
	// will automatically clear this map and transfer the values to Vault
	SecretData map[catalog.SecretKeyName]string `json:"secretData,omitempty" protobuf:"bytes,4,opt,name=secretData"`

	// Options contains non-sensitive options relevant to the Connection
	Options map[string]string `json:"options,omitempty" protobuf:"bytes,5,opt,name=options"`

	// +kubebuilder:default:="no-one"
	// +kubebuilder:validation:Optional
	Owner *string `json:"owner,omitempty" protobuf:"bytes,6,opt,name=owner"`

	SecretRef corev1.SecretReference `json:"secretRef,omitempty" protobuf:"bytes,7,opt,name=secretRef"`
}

ConnectionSpec defines the desired state of a Connection

func (*ConnectionSpec) DeepCopy 

func (in *ConnectionSpec) DeepCopy() *ConnectionSpec

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

func (*ConnectionSpec) DeepCopyInto 

func (in *ConnectionSpec) DeepCopyInto(out *ConnectionSpec)

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

func (*ConnectionSpec) Descriptor 

func (*ConnectionSpec) Descriptor() ([]byte, []int)

func (*ConnectionSpec) Marshal 

func (m *ConnectionSpec) Marshal() (dAtA []byte, err error)

func (*ConnectionSpec) MarshalTo 

func (m *ConnectionSpec) MarshalTo(dAtA []byte) (int, error)

func (*ConnectionSpec) MarshalToSizedBuffer 

func (m *ConnectionSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConnectionSpec) ProtoMessage 

func (*ConnectionSpec) ProtoMessage()

func (*ConnectionSpec) Reset 

func (m *ConnectionSpec) Reset()

func (*ConnectionSpec) Size 

func (m *ConnectionSpec) Size() (n int)

func (*ConnectionSpec) String 

func (this *ConnectionSpec) String() string

func (*ConnectionSpec) Unmarshal 

func (m *ConnectionSpec) Unmarshal(dAtA []byte) error

func (*ConnectionSpec) XXX_DiscardUnknown 

func (m *ConnectionSpec) XXX_DiscardUnknown()

func (*ConnectionSpec) XXX_Marshal 

func (m *ConnectionSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectionSpec) XXX_Merge 

func (m *ConnectionSpec) XXX_Merge(src proto.Message)

func (*ConnectionSpec) XXX_Size 

func (m *ConnectionSpec) XXX_Size() int

func (*ConnectionSpec) XXX_Unmarshal 

func (m *ConnectionSpec) XXX_Unmarshal(b []byte) error

type ConnectionStatus 

type ConnectionStatus struct {
	// ObservedGeneration is the Last generation that was acted on
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`
	// Last time the object was updated
	//+kubebuilder:validation:Optional
	UpdatedAt *metav1.Time `json:"updatedAt,omitempty" protobuf:"bytes,2,opt,name=updatedAt"`
	// UpdateUpdateStrategy in case of terminal failure
	// Borrowed from cluster api controller
	//+kubebuilder:validation:Optional
	FailureReason *catalog.StatusError `json:"failureReason,omitempty" protobuf:"bytes,3,opt,name=failureReason"`
	// UpdateUpdateStrategy in case of terminal failure message
	//+kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,4,opt,name=failureMessage"`

	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,5,rep,name=conditions"`
}

ConnectionStatus is the observed state of a Connection

func (*ConnectionStatus) DeepCopy 

func (in *ConnectionStatus) DeepCopy() *ConnectionStatus

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

func (*ConnectionStatus) DeepCopyInto 

func (in *ConnectionStatus) DeepCopyInto(out *ConnectionStatus)

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

func (*ConnectionStatus) Descriptor 

func (*ConnectionStatus) Descriptor() ([]byte, []int)

func (*ConnectionStatus) Marshal 

func (m *ConnectionStatus) Marshal() (dAtA []byte, err error)

func (*ConnectionStatus) MarshalTo 

func (m *ConnectionStatus) MarshalTo(dAtA []byte) (int, error)

func (*ConnectionStatus) MarshalToSizedBuffer 

func (m *ConnectionStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConnectionStatus) ProtoMessage 

func (*ConnectionStatus) ProtoMessage()

func (*ConnectionStatus) Reset 

func (m *ConnectionStatus) Reset()

func (*ConnectionStatus) Size 

func (m *ConnectionStatus) Size() (n int)

func (*ConnectionStatus) String 

func (this *ConnectionStatus) String() string

func (*ConnectionStatus) Unmarshal 

func (m *ConnectionStatus) Unmarshal(dAtA []byte) error

func (*ConnectionStatus) XXX_DiscardUnknown 

func (m *ConnectionStatus) XXX_DiscardUnknown()

func (*ConnectionStatus) XXX_Marshal 

func (m *ConnectionStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectionStatus) XXX_Merge 

func (m *ConnectionStatus) XXX_Merge(src proto.Message)

func (*ConnectionStatus) XXX_Size 

func (m *ConnectionStatus) XXX_Size() int

func (*ConnectionStatus) XXX_Unmarshal 

func (m *ConnectionStatus) XXX_Unmarshal(b []byte) error

type IngressSpec added in v0.4.682 

type IngressSpec struct {
	// FQDN specifies the fully-qualified domain name that the Serving Site's Ingress will use as the base host for the
	// endpoint of services deployed under the Serving Site. For example, setting the FQDN as `model-serving.modela.ai`
	// will automatically serve Predictors using the REST API at `predictors.model-serving.modela.ai`
	// +kubebuilder:default:="serving.vcap.me"
	// +kubebuilder:validation:Optional
	FQDN *string `json:"fqdn,omitempty" protobuf:"bytes,1,opt,name=fqdn"`
	// Grpc indicates if the Serving Site will create an Ingress resource to serve GRPC prediction traffic.
	// All Predictor resources created under the Serving Site will receive a unique host in the Ingress
	// determined by the name of the Predictor and the FQDN of the ServingSite (i.e. my-predictor.model-serving.modela.ai)
	// +kubebuilder:default:=true
	// +kubebuilder:validation:Optional
	GRPC *bool `json:"grpc,omitempty" protobuf:"varint,2,opt,name=grpc"`
	// HTTP indicates if the Serving Site will create an Ingress resource to serve HTTP prediction traffic.
	// All HTTP traffic will be served under a single host determined by the FQDN of the ServingSite
	// (i.e. predictors.model-serving.modela.ai). HTTP must be enabled to serve Data Apps over Ingress
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	HTTP *bool `json:"http,omitempty" protobuf:"varint,3,opt,name=http"`
	// IngressClassName is the name of the ingress class that will be applied to created Ingress resources
	// (defaults to nginx)
	// +kubebuilder:default:="nginx"
	IngressClassName *string `json:"ingressClassName,omitempty" protobuf:"bytes,4,opt,name=ingressClassName"`
	// IssuerName specifies the name of a cert-manager Issuer resource in the same namespace as the Serving Site
	// that will provide a TLS certificate to the ingress. This will be added as an annotation to the ingress.
	// +kubebuilder:validation:Optional
	IssuerName *string `json:"issuerName,omitempty" protobuf:"bytes,5,opt,name=issuerName"`
	// ClusterIssuerName specifies the name of a cert-manager ClusterIssuer resource
	// that will provide a TLS certificate to the ingress. This will be added as an annotation to the ingress.
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	ClusterIssuerName *string `json:"clusterIssuerName,omitempty" protobuf:"bytes,6,opt,name=clusterIssuerName"`
	// TlsSecretName specifies the name of the secret that contains the TLS certificate for the ingress.
	// If it does not exist, ClusterIssuerName or IssuerName must be specified for Cert Manager to
	// generate the serving certificate. If this field is specified, TLS will be implicitly enabled.
	// +kubebuilder:validation:Optional
	TlsSecretName string `json:"tlsSecretName,omitempty" protobuf:"bytes,7,opt,name=tlsSecretName"`
}

IngressSpec defines the configuration to for a Serving Site to create Ingress resources

func (*IngressSpec) DeepCopy added in v0.4.682 

func (in *IngressSpec) DeepCopy() *IngressSpec

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

func (*IngressSpec) DeepCopyInto added in v0.4.682 

func (in *IngressSpec) DeepCopyInto(out *IngressSpec)

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

func (*IngressSpec) Descriptor added in v0.4.682 

func (*IngressSpec) Descriptor() ([]byte, []int)

func (*IngressSpec) Marshal added in v0.4.682 

func (m *IngressSpec) Marshal() (dAtA []byte, err error)

func (*IngressSpec) MarshalTo added in v0.4.682 

func (m *IngressSpec) MarshalTo(dAtA []byte) (int, error)

func (*IngressSpec) MarshalToSizedBuffer added in v0.4.682 

func (m *IngressSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IngressSpec) ProtoMessage added in v0.4.682 

func (*IngressSpec) ProtoMessage()

func (*IngressSpec) Reset added in v0.4.682 

func (m *IngressSpec) Reset()

func (*IngressSpec) Size added in v0.4.682 

func (m *IngressSpec) Size() (n int)

func (*IngressSpec) String added in v0.4.682 

func (this *IngressSpec) String() string

func (*IngressSpec) Unmarshal added in v0.4.682 

func (m *IngressSpec) Unmarshal(dAtA []byte) error

func (*IngressSpec) XXX_DiscardUnknown added in v0.4.682 

func (m *IngressSpec) XXX_DiscardUnknown()

func (*IngressSpec) XXX_Marshal added in v0.4.682 

func (m *IngressSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IngressSpec) XXX_Merge added in v0.4.682 

func (m *IngressSpec) XXX_Merge(src proto.Message)

func (*IngressSpec) XXX_Size added in v0.4.682 

func (m *IngressSpec) XXX_Size() int

func (*IngressSpec) XXX_Unmarshal added in v0.4.682 

func (m *IngressSpec) XXX_Unmarshal(b []byte) error

type Lab 

type Lab struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              LabSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	//+optional
	Status LabStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:resource:path=labs,singular=lab,categories={infra,modela,all} +kubebuilder:storageversion +kubebuilder:printcolumn:name="Ready",type="string",JSONPath=".status.conditions[?(@.type==\"Ready\")].status",description="" +kubebuilder:printcolumn:name="Owner",type="string",JSONPath=".spec.owner" +kubebuilder:printcolumn:name="Cluster",type="string",JSONPath=".spec.clusterName" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp" Lab represents a single namespace where data analysis and model training workloads take place

func ParseLabYaml 

func ParseLabYaml(content []byte) (*Lab, error)

func (*Lab) AddFinalizer 

func (lab *Lab) AddFinalizer()

func (Lab) CreateNamespace 

func (lab Lab) CreateNamespace() *corev1.Namespace

func (*Lab) CreateOrUpdateCond 

func (lab *Lab) CreateOrUpdateCond(cond metav1.Condition)

func (*Lab) DeepCopy 

func (in *Lab) DeepCopy() *Lab

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

func (*Lab) DeepCopyInto 

func (in *Lab) DeepCopyInto(out *Lab)

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

func (*Lab) DeepCopyObject 

func (in *Lab) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Lab) Default 

func (lab *Lab) Default()

func (*Lab) Descriptor 

func (*Lab) Descriptor() ([]byte, []int)

func (*Lab) GetCond 

func (lab *Lab) GetCond(t LabConditionType) metav1.Condition

func (*Lab) GetCondIdx 

func (lab *Lab) GetCondIdx(t LabConditionType) int

func (Lab) GetObservedGeneration added in v0.6.252 

func (lab Lab) GetObservedGeneration() int64

func (Lab) GetStatus added in v0.6.252 

func (lab Lab) GetStatus() proto.Message

func (*Lab) HasFinalizer 

func (lab *Lab) HasFinalizer() bool

func (*Lab) Key 

func (lab *Lab) Key() string

func (Lab) LabClusterRole added in v0.6.252 

func (lab Lab) LabClusterRole() *rbacv1.ClusterRole

func (Lab) LabClusterRoleBinding added in v0.6.252 

func (lab Lab) LabClusterRoleBinding() *rbacv1.ClusterRoleBinding

func (Lab) LabRole added in v0.6.252 

func (lab Lab) LabRole() *rbacv1.Role

func (Lab) LabRoleBinding added in v0.6.252 

func (lab Lab) LabRoleBinding() *rbacv1.RoleBinding

func (Lab) LabServiceAccount 

func (lab Lab) LabServiceAccount() *corev1.ServiceAccount

func (Lab) LimitRange added in v0.6.252 

func (lab Lab) LimitRange() *corev1.LimitRange

func (Lab) LimitRangeEnabled added in v0.6.252 

func (lab Lab) LimitRangeEnabled() bool

func (Lab) LimitsEnabled added in v0.6.252 

func (lab Lab) LimitsEnabled() bool

func (Lab) ManifestURI added in v0.5.472 

func (lab Lab) ManifestURI() string

func (*Lab) MarkNamespaceNotReady added in v0.6.252 

func (lab *Lab) MarkNamespaceNotReady(reason string, message string)

func (*Lab) MarkNamespaceReady added in v0.6.252 

func (lab *Lab) MarkNamespaceReady()

func (*Lab) MarkRbacNotReady added in v0.6.252 

func (lab *Lab) MarkRbacNotReady(reason string, message string)

func (*Lab) MarkRbacReady added in v0.6.252 

func (lab *Lab) MarkRbacReady()

func (*Lab) Marshal 

func (m *Lab) Marshal() (dAtA []byte, err error)

func (*Lab) MarshalTo 

func (m *Lab) MarshalTo(dAtA []byte) (int, error)

func (*Lab) MarshalToSizedBuffer 

func (m *Lab) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Lab) ProtoMessage 

func (*Lab) ProtoMessage()

func (*Lab) RemoveFinalizer 

func (lab *Lab) RemoveFinalizer()

func (*Lab) Reset 

func (m *Lab) Reset()

func (Lab) ResourceQuota added in v0.6.252 

func (lab Lab) ResourceQuota() *corev1.ResourceQuota

func (Lab) ResourceQuotaEnabled added in v0.6.252 

func (lab Lab) ResourceQuotaEnabled() bool

func (Lab) RootURI added in v0.5.472 

func (lab Lab) RootURI() string

func (Lab) Selector 

func (lab Lab) Selector() *metav1.LabelSelector

func (*Lab) SetObservedGeneration added in v0.6.252 

func (lab *Lab) SetObservedGeneration(generation int64)

func (*Lab) SetStatus added in v0.6.252 

func (lab *Lab) SetStatus(status interface{})

func (*Lab) SetUpdatedAt added in v0.6.252 

func (lab *Lab) SetUpdatedAt(time *metav1.Time)

func (*Lab) SetupWebhookWithManager 

func (lab *Lab) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Lab) Size 

func (m *Lab) Size() (n int)

func (*Lab) String 

func (this *Lab) String() string

func (*Lab) Unmarshal 

func (m *Lab) Unmarshal(dAtA []byte) error

func (Lab) ValidateCreate 

func (lab Lab) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (Lab) ValidateDelete 

func (lab Lab) ValidateDelete() error

func (Lab) ValidateUpdate 

func (lab Lab) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

func (*Lab) XXX_DiscardUnknown 

func (m *Lab) XXX_DiscardUnknown()

func (*Lab) XXX_Marshal 

func (m *Lab) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Lab) XXX_Merge 

func (m *Lab) XXX_Merge(src proto.Message)

func (*Lab) XXX_Size 

func (m *Lab) XXX_Size() int

func (*Lab) XXX_Unmarshal 

func (m *Lab) XXX_Unmarshal(b []byte) error

type LabConditionType 

type LabConditionType string

type LabList 

type LabList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Items []Lab `json:"items" protobuf:"bytes,2,rep,name=items"`
}

+kubebuilder:object:root=true LabList is the list of Labs

func (*LabList) DeepCopy 

func (in *LabList) DeepCopy() *LabList

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

func (*LabList) DeepCopyInto 

func (in *LabList) DeepCopyInto(out *LabList)

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

func (*LabList) DeepCopyObject 

func (in *LabList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*LabList) Descriptor 

func (*LabList) Descriptor() ([]byte, []int)

func (*LabList) Marshal 

func (m *LabList) Marshal() (dAtA []byte, err error)

func (*LabList) MarshalTo 

func (m *LabList) MarshalTo(dAtA []byte) (int, error)

func (*LabList) MarshalToSizedBuffer 

func (m *LabList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabList) ProtoMessage 

func (*LabList) ProtoMessage()

func (*LabList) Reset 

func (m *LabList) Reset()

func (*LabList) Size 

func (m *LabList) Size() (n int)

func (*LabList) String 

func (this *LabList) String() string

func (*LabList) Unmarshal 

func (m *LabList) Unmarshal(dAtA []byte) error

func (*LabList) XXX_DiscardUnknown 

func (m *LabList) XXX_DiscardUnknown()

func (*LabList) XXX_Marshal 

func (m *LabList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabList) XXX_Merge 

func (m *LabList) XXX_Merge(src proto.Message)

func (*LabList) XXX_Size 

func (m *LabList) XXX_Size() int

func (*LabList) XXX_Unmarshal 

func (m *LabList) XXX_Unmarshal(b []byte) error

type LabSpec 

type LabSpec struct {
	// The user-provided description of the Lab
	// +kubebuilder:validation:Optional
	// +kubebuilder:default:=""
	// +kubebuilder:validation:MaxLength=256
	Description *string `json:"description,omitempty" protobuf:"bytes,1,opt,name=description"`
	// +kubebuilder:validation:Optional
	// The reference to the tenant which the object exists under
	TenantRef *corev1.ObjectReference `json:"tenantRef,omitempty" protobuf:"bytes,2,opt,name=tenantRef"`
	// Limits specifies the hard resource limits that can be allocated for workloads created under the Lab
	// +kubebuilder:validation:Optional
	Limits ResourceLimitSpec `json:"limits,omitempty" protobuf:"bytes,3,opt,name=limits"`
	// External cluster specify the spec for execution on a remote cluster.
	// +kubebuilder:validation:Optional
	ExternalCluster *VirtualClusterSpec `json:"externalCluster,omitempty" protobuf:"bytes,4,opt,name=externalCluster"`
	// The name of the Account which created the object, which exists in the same tenant as the object
	// +kubebuilder:default:="no-one"
	// +kubebuilder:validation:Optional
	Owner *string `json:"owner,omitempty" protobuf:"bytes,5,opt,name=owner"`
}

LabSpec defines the desired state of a Lab

func (*LabSpec) DeepCopy 

func (in *LabSpec) DeepCopy() *LabSpec

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

func (*LabSpec) DeepCopyInto 

func (in *LabSpec) DeepCopyInto(out *LabSpec)

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

func (*LabSpec) Descriptor 

func (*LabSpec) Descriptor() ([]byte, []int)

func (*LabSpec) Marshal 

func (m *LabSpec) Marshal() (dAtA []byte, err error)

func (*LabSpec) MarshalTo 

func (m *LabSpec) MarshalTo(dAtA []byte) (int, error)

func (*LabSpec) MarshalToSizedBuffer 

func (m *LabSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabSpec) ProtoMessage 

func (*LabSpec) ProtoMessage()

func (*LabSpec) Reset 

func (m *LabSpec) Reset()

func (*LabSpec) Size 

func (m *LabSpec) Size() (n int)

func (*LabSpec) String 

func (this *LabSpec) String() string

func (*LabSpec) Unmarshal 

func (m *LabSpec) Unmarshal(dAtA []byte) error

func (*LabSpec) XXX_DiscardUnknown 

func (m *LabSpec) XXX_DiscardUnknown()

func (*LabSpec) XXX_Marshal 

func (m *LabSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabSpec) XXX_Merge 

func (m *LabSpec) XXX_Merge(src proto.Message)

func (*LabSpec) XXX_Size 

func (m *LabSpec) XXX_Size() int

func (*LabSpec) XXX_Unmarshal 

func (m *LabSpec) XXX_Unmarshal(b []byte) error

type LabStatus 

type LabStatus struct {
	// ObservedGeneration is the last generation that was acted on
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`
	// The last time the object was updated
	//+kubebuilder:validation:Optional
	UpdatedAt *metav1.Time `json:"updatedAt,omitempty" protobuf:"bytes,2,opt,name=updatedAt"`
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,3,rep,name=conditions"`
}

LabStatus is the observed state of a Lab

func (*LabStatus) DeepCopy 

func (in *LabStatus) DeepCopy() *LabStatus

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

func (*LabStatus) DeepCopyInto 

func (in *LabStatus) DeepCopyInto(out *LabStatus)

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

func (*LabStatus) Descriptor 

func (*LabStatus) Descriptor() ([]byte, []int)

func (*LabStatus) Marshal 

func (m *LabStatus) Marshal() (dAtA []byte, err error)

func (*LabStatus) MarshalTo 

func (m *LabStatus) MarshalTo(dAtA []byte) (int, error)

func (*LabStatus) MarshalToSizedBuffer 

func (m *LabStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabStatus) ProtoMessage 

func (*LabStatus) ProtoMessage()

func (*LabStatus) Reset 

func (m *LabStatus) Reset()

func (*LabStatus) Size 

func (m *LabStatus) Size() (n int)

func (*LabStatus) String 

func (this *LabStatus) String() string

func (*LabStatus) Unmarshal 

func (m *LabStatus) Unmarshal(dAtA []byte) error

func (*LabStatus) XXX_DiscardUnknown 

func (m *LabStatus) XXX_DiscardUnknown()

func (*LabStatus) XXX_Marshal 

func (m *LabStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabStatus) XXX_Merge 

func (m *LabStatus) XXX_Merge(src proto.Message)

func (*LabStatus) XXX_Size 

func (m *LabStatus) XXX_Size() int

func (*LabStatus) XXX_Unmarshal 

func (m *LabStatus) XXX_Unmarshal(b []byte) error

type License 

type License struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              LicenseSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	//+optional
	Status LicenseStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:resource:path=licenses,singular=license,categories={infra,modela} +kubebuilder:storageversion +kubebuilder:printcolumn:name="Ready",type="string",JSONPath=".status.conditions[?(@.type==\"Valid\")].status",description="" +kubebuilder:printcolumn:name="Owner",type="string",JSONPath=".spec.owner",description="" +kubebuilder:printcolumn:name="Secret",type="string",JSONPath=".spec.secretRef.name",description="" +kubebuilder:printcolumn:name="Trial Start",type="string",JSONPath=".spec.trialStart",description="" +kubebuilder:printcolumn:name="Trial End",type="string",JSONPath=".spec.trialEnd",description="" +kubebuilder:printcolumn:name="ExpectedValueMax Trainers",type="string",JSONPath=".spec.maxTrainers",description="",priority=1 +kubebuilder:printcolumn:name="ExpectedValueMax Nodes",type="string",JSONPath=".spec.maxServers",description="",priority=1 +kubebuilder:printcolumn:name="ExpectedValueMax Users",type="string",JSONPath=".spec.maxUsers",description="",priority=1 +kubebuilder:printcolumn:name="Expire FiredAt",type="date",JSONPath=".spec.expireAt",description="" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp",description="" License represents the license key and limitations of a cluster-wide license obtained from Modela.ai

func ParseLicenseYaml 

func ParseLicenseYaml(content []byte) (*License, error)

func (*License) AddFinalizer 

func (license *License) AddFinalizer()

func (*License) CreateOrUpdateCond 

func (license *License) CreateOrUpdateCond(cond metav1.Condition)

Merge or update condition

func (*License) DeepCopy 

func (in *License) DeepCopy() *License

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

func (*License) DeepCopyInto 

func (in *License) DeepCopyInto(out *License)

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

func (*License) DeepCopyObject 

func (in *License) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*License) Default 

func (license *License) Default()

func (*License) Descriptor 

func (*License) Descriptor() ([]byte, []int)

func (License) GetCond 

func (license License) GetCond(t LicenseConditionType) metav1.Condition

func (License) GetCondIdx 

func (license License) GetCondIdx(t string) int

func (License) GetObservedGeneration added in v0.6.252 

func (license License) GetObservedGeneration() int64

func (License) GetStatus added in v0.6.252 

func (license License) GetStatus() proto.Message

func (License) HasExpired 

func (license License) HasExpired() bool

Check if the license has expired.

func (License) HasFinalizer 

func (license License) HasFinalizer() bool

func (License) IsFreeTrial 

func (license License) IsFreeTrial() bool

Check if we are still in free trial

func (License) IsValid 

func (license License) IsValid() bool

func (License) ManifestURI added in v0.5.472 

func (license License) ManifestURI() string

func (*License) MarkValid 

func (license *License) MarkValid()

func (*License) Marshal 

func (m *License) Marshal() (dAtA []byte, err error)

func (*License) MarshalTo 

func (m *License) MarshalTo(dAtA []byte) (int, error)

func (*License) MarshalToSizedBuffer 

func (m *License) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*License) ProtoMessage 

func (*License) ProtoMessage()

func (*License) RemoveFinalizer 

func (license *License) RemoveFinalizer()

func (*License) Reset 

func (m *License) Reset()

func (License) RootURI added in v0.5.472 

func (license License) RootURI() string

func (*License) SetObservedGeneration added in v0.6.252 

func (license *License) SetObservedGeneration(generation int64)

func (*License) SetStatus added in v0.6.252 

func (license *License) SetStatus(status interface{})

func (*License) SetUpdatedAt added in v0.6.252 

func (license *License) SetUpdatedAt(time *metav1.Time)

func (*License) SetupWebhookWithManager 

func (license *License) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*License) Size 

func (m *License) Size() (n int)

func (*License) String 

func (this *License) String() string

func (*License) Unmarshal 

func (m *License) Unmarshal(dAtA []byte) error

func (License) ValidateCreate 

func (license License) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (License) ValidateDelete 

func (license License) ValidateDelete() error

func (License) ValidateUpdate 

func (license License) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

func (*License) XXX_DiscardUnknown 

func (m *License) XXX_DiscardUnknown()

func (*License) XXX_Marshal 

func (m *License) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*License) XXX_Merge 

func (m *License) XXX_Merge(src proto.Message)

func (*License) XXX_Size 

func (m *License) XXX_Size() int

func (*License) XXX_Unmarshal 

func (m *License) XXX_Unmarshal(b []byte) error

type LicenseConditionType 

type LicenseConditionType string
const (
	LicenseValid LicenseConditionType = "Valid"
	LicenseSaved LicenseConditionType = "Saved"
)

/ License Condition

type LicenseList 

type LicenseList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Items []License `json:"items" protobuf:"bytes,2,rep,name=items"`
}

+kubebuilder:object:root=true LicenseList is a list of Licenses

func (*LicenseList) DeepCopy 

func (in *LicenseList) DeepCopy() *LicenseList

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

func (*LicenseList) DeepCopyInto 

func (in *LicenseList) DeepCopyInto(out *LicenseList)

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

func (*LicenseList) DeepCopyObject 

func (in *LicenseList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*LicenseList) Descriptor 

func (*LicenseList) Descriptor() ([]byte, []int)

func (*LicenseList) Marshal 

func (m *LicenseList) Marshal() (dAtA []byte, err error)

func (*LicenseList) MarshalTo 

func (m *LicenseList) MarshalTo(dAtA []byte) (int, error)

func (*LicenseList) MarshalToSizedBuffer 

func (m *LicenseList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LicenseList) ProtoMessage 

func (*LicenseList) ProtoMessage()

func (*LicenseList) Reset 

func (m *LicenseList) Reset()

func (*LicenseList) Size 

func (m *LicenseList) Size() (n int)

func (*LicenseList) String 

func (this *LicenseList) String() string

func (*LicenseList) Unmarshal 

func (m *LicenseList) Unmarshal(dAtA []byte) error

func (*LicenseList) XXX_DiscardUnknown 

func (m *LicenseList) XXX_DiscardUnknown()

func (*LicenseList) XXX_Marshal 

func (m *LicenseList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LicenseList) XXX_Merge 

func (m *LicenseList) XXX_Merge(src proto.Message)

func (*LicenseList) XXX_Size 

func (m *LicenseList) XXX_Size() int

func (*LicenseList) XXX_Unmarshal 

func (m *LicenseList) XXX_Unmarshal(b []byte) error

type LicenseSpec 

type LicenseSpec struct {
	// The reference to the secret containing the license token
	// +kubebuilder:validation:Optional
	SecretRef v1.SecretReference `json:"secretRef" protobuf:"bytes,2,opt,name=secretRef"`
	// The e-mail address of the Modela.ai account which owns the license
	// +kubebuilder:validation:Optional
	// +kubebuilder:default:=""
	Email *string `json:"email,omitempty" protobuf:"bytes,4,opt,name=email"`
	// TrialStartAt is the start date for of the free trial period, if active
	// +kubebuilder:validation:Optional
	TrialStartAt *metav1.Time `json:"trialStartAt,omitempty" protobuf:"bytes,5,opt,name=trialStartAt"`
	// TrialEndAt specifies when the free trial expires, if active
	// +kubebuilder:validation:Optional
	TrialEndAt *metav1.Time `json:"trialEndAt,omitempty" protobuf:"bytes,6,opt,name=trialEndAt"`
	// MaxProducts specifies the maximum number of DataProduct across the cluster
	// +kubebuilder:validation:Minimum=0
	// +kubebuilder:validation:Optional
	MaxProducts *int32 `json:"maxProducts,omitempty" protobuf:"varint,7,opt,name=maxProducts"`
	// MaxTrainers specifies the maximum number of parallel trainers that can be active at once
	// +kubebuilder:validation:Minimum=0
	// +kubebuilder:validation:Optional
	MaxTrainers *int32 `json:"maxTrainers,omitempty" protobuf:"varint,8,opt,name=maxTrainers"`
	// MaxServers specifies the maximum number of Kubernetes nodes that may be utilized at once
	// +kubebuilder:validation:Minimum=0
	// +kubebuilder:validation:Optional
	MaxServers *int32 `json:"maxServers,omitempty" protobuf:"varint,9,opt,name=maxServers"`
	// MaxUsers specifies the maximum number of Accounts that can be created across all tenants
	// +kubebuilder:validation:Minimum=0
	// +kubebuilder:validation:Optional
	MaxUsers *int32 `json:"maxUsers,omitempty" protobuf:"varint,10,opt,name=maxUsers"`
	// MaxDataPlanes specifies the maximum number of data plane replicas that may exist at once
	// +kubebuilder:validation:Minimum=0
	// +kubebuilder:validation:Optional
	MaxDataPlanes *int32 `json:"maxDataPlanes,omitempty" protobuf:"varint,11,opt,name=maxDataPlanes"`
	// Forecast indicates if Modela can generate forecasting models
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Forecast *bool `json:"forecast,omitempty" protobuf:"varint,12,opt,name=forecast"`
	// NLP indicates if natural language processing models are supported
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	NLP *bool `json:"nlp,omitempty" protobuf:"varint,13,opt,name=nlp"`
	// Vision indicates if computer vision models are supported
	// +kubebuilder:default:=false
	// +kubebuilder:validation:Optional
	Vision *bool `json:"vision,omitempty" protobuf:"varint,14,opt,name=vision"`
	// Chatbot indicates if chatbot models are supported
	// +kubebuilder:default:=false
	Chatbot *bool `json:"chatbot,omitempty" protobuf:"varint,15,opt,name=chatbot"`
	// The name of the license product, internal to Modela.ai
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	ProductName *string `json:"productName,omitempty" protobuf:"bytes,16,opt,name=productName"`
	// The name of the license price, internal to Modela.ai
	// +kubebuilder:validation:Optional
	PriceName *string `json:"priceName,omitempty" protobuf:"bytes,17,opt,name=priceName"`
	// The date at which the license expires
	// +kubebuilder:validation:Optional
	ExpireAt *metav1.Time `json:"expireAt,omitempty" protobuf:"bytes,18,opt,name=expireAt"`
	// The reference to a Notifier resource that receives Alerts for license expiration
	// +kubebuilder:validation:Optional
	NotifierName *string `json:"notifierName,omitempty" protobuf:"bytes,19,opt,name=notifierName"`
}

LicenseSpec defines the details of a License. The contents of the specification are derived from the actual license key, and changing the specification has no effect on the limitations of the license

func (*LicenseSpec) DeepCopy 

func (in *LicenseSpec) DeepCopy() *LicenseSpec

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

func (*LicenseSpec) DeepCopyInto 

func (in *LicenseSpec) DeepCopyInto(out *LicenseSpec)

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

func (*LicenseSpec) Descriptor 

func (*LicenseSpec) Descriptor() ([]byte, []int)

func (*LicenseSpec) Marshal 

func (m *LicenseSpec) Marshal() (dAtA []byte, err error)

func (*LicenseSpec) MarshalTo 

func (m *LicenseSpec) MarshalTo(dAtA []byte) (int, error)

func (*LicenseSpec) MarshalToSizedBuffer 

func (m *LicenseSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LicenseSpec) ProtoMessage 

func (*LicenseSpec) ProtoMessage()

func (*LicenseSpec) Reset 

func (m *LicenseSpec) Reset()

func (*LicenseSpec) Size 

func (m *LicenseSpec) Size() (n int)

func (*LicenseSpec) String 

func (this *LicenseSpec) String() string

func (*LicenseSpec) Unmarshal 

func (m *LicenseSpec) Unmarshal(dAtA []byte) error

func (*LicenseSpec) XXX_DiscardUnknown 

func (m *LicenseSpec) XXX_DiscardUnknown()

func (*LicenseSpec) XXX_Marshal 

func (m *LicenseSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LicenseSpec) XXX_Merge 

func (m *LicenseSpec) XXX_Merge(src proto.Message)

func (*LicenseSpec) XXX_Size 

func (m *LicenseSpec) XXX_Size() int

func (*LicenseSpec) XXX_Unmarshal 

func (m *LicenseSpec) XXX_Unmarshal(b []byte) error

type LicenseStatus 

type LicenseStatus struct {
	// The last time the object was updated
	//+kubebuilder:validation:Optional
	UpdatedAt *metav1.Time `json:"updatedAt,omitempty" protobuf:"bytes,1,opt,name=updatedAt"`
	// ObservedGeneration is the last generation that was acted on
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,2,opt,name=observedGeneration"`
	// In the case of failure, the License resource controller will set this field with a failure reason
	//+kubebuilder:validation:Optional
	FailureReason *catalog.StatusError `json:"failureReason,omitempty" protobuf:"bytes,3,opt,name=failureReason"`
	// In the case of failure, the License resource controller will set this field with a failure message
	//+kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,4,opt,name=failureMessage"`
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,5,rep,name=conditions"`
}

LicenseStatus is the observed state of a License

func (*LicenseStatus) DeepCopy 

func (in *LicenseStatus) DeepCopy() *LicenseStatus

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

func (*LicenseStatus) DeepCopyInto 

func (in *LicenseStatus) DeepCopyInto(out *LicenseStatus)

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

func (*LicenseStatus) Descriptor 

func (*LicenseStatus) Descriptor() ([]byte, []int)

func (*LicenseStatus) Marshal 

func (m *LicenseStatus) Marshal() (dAtA []byte, err error)

func (*LicenseStatus) MarshalTo 

func (m *LicenseStatus) MarshalTo(dAtA []byte) (int, error)

func (*LicenseStatus) MarshalToSizedBuffer 

func (m *LicenseStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LicenseStatus) ProtoMessage 

func (*LicenseStatus) ProtoMessage()

func (*LicenseStatus) Reset 

func (m *LicenseStatus) Reset()

func (*LicenseStatus) Size 

func (m *LicenseStatus) Size() (n int)

func (*LicenseStatus) String 

func (this *LicenseStatus) String() string

func (*LicenseStatus) Unmarshal 

func (m *LicenseStatus) Unmarshal(dAtA []byte) error

func (*LicenseStatus) XXX_DiscardUnknown 

func (m *LicenseStatus) XXX_DiscardUnknown()

func (*LicenseStatus) XXX_Marshal 

func (m *LicenseStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LicenseStatus) XXX_Merge 

func (m *LicenseStatus) XXX_Merge(src proto.Message)

func (*LicenseStatus) XXX_Size 

func (m *LicenseStatus) XXX_Size() int

func (*LicenseStatus) XXX_Unmarshal 

func (m *LicenseStatus) XXX_Unmarshal(b []byte) error

type LicenseType 

type LicenseType string

LicenseType is the type of license +kubebuilder:validation:Enum="lite";"pro";"enterprise" 

const (
	Lite       LicenseType = "lite"
	Pro        LicenseType = "pro"
	Enterprise LicenseType = "enterprise"
)

type NotificationChannelSpec added in v0.4.607 

type NotificationChannelSpec struct {
	// Indicates if the channel is enabled to send forwarded Alerts
	// +kubebuilder:default:=true
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// The name of the Connection resource which exists in the same tenant as the parent Notifier
	// +kubebuilder:validation:Required
	// +kubebuilder:default:=""
	ConnectionName *string `json:"connectionName" protobuf:"bytes,2,opt,name=connectionName"`
	// Indicates if the channel will send Alerts with the `info` level
	// +kubebuilder:default:= false
	// +kubebuilder:validation:Optional
	Info *bool `json:"info,omitempty" protobuf:"varint,3,opt,name=info"`
	// Indicates if the channel will send Alerts with the `error` level
	// +kubebuilder:default:= true
	// +kubebuilder:validation:Optional
	Error *bool `json:"error,omitempty" protobuf:"varint,4,opt,name=error"`
	// The destination channel that exists in the external system that ConnectionName references.
	// For example, a Slack channel name, a Discord channel ID, or an e-mail address
	Destination string `json:"destination,omitempty" protobuf:"bytes,7,opt,name=destination"`
}

NotificationChannelSpec describes a single Connection to an external messaging system and a destination channel within the system

func (*NotificationChannelSpec) DeepCopy added in v0.4.607 

func (in *NotificationChannelSpec) DeepCopy() *NotificationChannelSpec

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

func (*NotificationChannelSpec) DeepCopyInto added in v0.4.607 

func (in *NotificationChannelSpec) DeepCopyInto(out *NotificationChannelSpec)

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

func (*NotificationChannelSpec) Descriptor added in v0.4.607 

func (*NotificationChannelSpec) Descriptor() ([]byte, []int)

func (*NotificationChannelSpec) Marshal added in v0.4.607 

func (m *NotificationChannelSpec) Marshal() (dAtA []byte, err error)

func (*NotificationChannelSpec) MarshalTo added in v0.4.607 

func (m *NotificationChannelSpec) MarshalTo(dAtA []byte) (int, error)

func (*NotificationChannelSpec) MarshalToSizedBuffer added in v0.4.607 

func (m *NotificationChannelSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NotificationChannelSpec) ProtoMessage added in v0.4.607 

func (*NotificationChannelSpec) ProtoMessage()

func (*NotificationChannelSpec) Reset added in v0.4.607 

func (m *NotificationChannelSpec) Reset()

func (*NotificationChannelSpec) Size added in v0.4.607 

func (m *NotificationChannelSpec) Size() (n int)

func (*NotificationChannelSpec) String added in v0.4.607 

func (this *NotificationChannelSpec) String() string

func (*NotificationChannelSpec) Unmarshal added in v0.4.607 

func (m *NotificationChannelSpec) Unmarshal(dAtA []byte) error

func (*NotificationChannelSpec) XXX_DiscardUnknown added in v0.4.607 

func (m *NotificationChannelSpec) XXX_DiscardUnknown()

func (*NotificationChannelSpec) XXX_Marshal added in v0.4.607 

func (m *NotificationChannelSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NotificationChannelSpec) XXX_Merge added in v0.4.607 

func (m *NotificationChannelSpec) XXX_Merge(src proto.Message)

func (*NotificationChannelSpec) XXX_Size added in v0.4.607 

func (m *NotificationChannelSpec) XXX_Size() int

func (*NotificationChannelSpec) XXX_Unmarshal added in v0.4.607 

func (m *NotificationChannelSpec) XXX_Unmarshal(b []byte) error

type NotificationChannelStatus added in v0.4.607 

type NotificationChannelStatus struct {
	// The name of the Connection resource which exists in the same tenant as the parent Notifier
	// +kubebuilder:validation:Required
	// +kubebuilder:default:=""
	ConnectionName *string `json:"connectionName" protobuf:"bytes,2,opt,name=connectionName"`
	// The last time a message was sent on this channel
	LastMessageAt *metav1.Time `json:"lastMessageAt,omitempty" protobuf:"bytes,1,opt,name=lastMessageAt"`
	// In the case of failure, the Notifier resource controller will set this field with a failure message
	//+kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,3,opt,name=failureMessage"`
}

func (*NotificationChannelStatus) DeepCopy added in v0.4.607 

func (in *NotificationChannelStatus) DeepCopy() *NotificationChannelStatus

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

func (*NotificationChannelStatus) DeepCopyInto added in v0.4.607 

func (in *NotificationChannelStatus) DeepCopyInto(out *NotificationChannelStatus)

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

func (*NotificationChannelStatus) Descriptor added in v0.4.607 

func (*NotificationChannelStatus) Descriptor() ([]byte, []int)

func (*NotificationChannelStatus) Marshal added in v0.4.607 

func (m *NotificationChannelStatus) Marshal() (dAtA []byte, err error)

func (*NotificationChannelStatus) MarshalTo added in v0.4.607 

func (m *NotificationChannelStatus) MarshalTo(dAtA []byte) (int, error)

func (*NotificationChannelStatus) MarshalToSizedBuffer added in v0.4.607 

func (m *NotificationChannelStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NotificationChannelStatus) ProtoMessage added in v0.4.607 

func (*NotificationChannelStatus) ProtoMessage()

func (*NotificationChannelStatus) Reset added in v0.4.607 

func (m *NotificationChannelStatus) Reset()

func (*NotificationChannelStatus) Size added in v0.4.607 

func (m *NotificationChannelStatus) Size() (n int)

func (*NotificationChannelStatus) String added in v0.4.607 

func (this *NotificationChannelStatus) String() string

func (*NotificationChannelStatus) Unmarshal added in v0.4.607 

func (m *NotificationChannelStatus) Unmarshal(dAtA []byte) error

func (*NotificationChannelStatus) XXX_DiscardUnknown added in v0.4.607 

func (m *NotificationChannelStatus) XXX_DiscardUnknown()

func (*NotificationChannelStatus) XXX_Marshal added in v0.4.607 

func (m *NotificationChannelStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NotificationChannelStatus) XXX_Merge added in v0.4.607 

func (m *NotificationChannelStatus) XXX_Merge(src proto.Message)

func (*NotificationChannelStatus) XXX_Size added in v0.4.607 

func (m *NotificationChannelStatus) XXX_Size() int

func (*NotificationChannelStatus) XXX_Unmarshal added in v0.4.607 

func (m *NotificationChannelStatus) XXX_Unmarshal(b []byte) error

type Notifier 

type Notifier struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              NotifierSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	//+optional
	Status NotifierStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=notifiers,singular=notifier,categories={infra,modela} +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:printcolumn:name="Ready",type="string",JSONPath=".status.conditions[?(@.type==\"Ready\")].status",description="" +kubebuilder:printcolumn:name="Owner",type="string",JSONPath=".spec.owner",description="" +kubebuilder:printcolumn:name="Description",type="string",JSONPath=".spec.description",description="" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp",description="" The Notifier resource

func ParseNotifierYaml 

func ParseNotifierYaml(content []byte) (*Notifier, error)

func (*Notifier) AddFinalizer 

func (notifier *Notifier) AddFinalizer()

func (*Notifier) CreateOrUpdateCond 

func (notifier *Notifier) CreateOrUpdateCond(cond metav1.Condition)

Merge or update condition

func (*Notifier) DeepCopy 

func (in *Notifier) DeepCopy() *Notifier

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

func (*Notifier) DeepCopyInto 

func (in *Notifier) DeepCopyInto(out *Notifier)

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

func (*Notifier) DeepCopyObject 

func (in *Notifier) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Notifier) Default 

func (notifier *Notifier) Default()

func (*Notifier) Descriptor 

func (*Notifier) Descriptor() ([]byte, []int)

func (Notifier) GetCond 

func (notifier Notifier) GetCond(t string) metav1.Condition

func (Notifier) GetCondIdx 

func (notifier Notifier) GetCondIdx(t string) int

func (Notifier) GetObservedGeneration added in v0.6.252 

func (notifier Notifier) GetObservedGeneration() int64

func (Notifier) GetStatus added in v0.6.252 

func (notifier Notifier) GetStatus() proto.Message

func (Notifier) HasFinalizer 

func (notifier Notifier) HasFinalizer() bool

func (Notifier) IsReady 

func (notifier Notifier) IsReady() bool

func (Notifier) ManifestURI added in v0.5.472 

func (notifier Notifier) ManifestURI() string

func (*Notifier) MarkReady 

func (notifier *Notifier) MarkReady()

func (*Notifier) Marshal 

func (m *Notifier) Marshal() (dAtA []byte, err error)

func (*Notifier) MarshalTo 

func (m *Notifier) MarshalTo(dAtA []byte) (int, error)

func (*Notifier) MarshalToSizedBuffer 

func (m *Notifier) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Notifier) ProtoMessage 

func (*Notifier) ProtoMessage()

func (*Notifier) RemoveFinalizer 

func (notifier *Notifier) RemoveFinalizer()

func (*Notifier) Reset 

func (m *Notifier) Reset()

func (Notifier) RootURI added in v0.5.472 

func (notifier Notifier) RootURI() string

func (*Notifier) SetObservedGeneration added in v0.6.252 

func (notifier *Notifier) SetObservedGeneration(generation int64)

func (*Notifier) SetStatus added in v0.6.252 

func (notifier *Notifier) SetStatus(status interface{})

func (*Notifier) SetUpdatedAt added in v0.6.252 

func (notifier *Notifier) SetUpdatedAt(time *metav1.Time)

func (*Notifier) SetupWebhookWithManager 

func (notifier *Notifier) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Notifier) Size 

func (m *Notifier) Size() (n int)

func (*Notifier) String 

func (this *Notifier) String() string

func (*Notifier) Unmarshal 

func (m *Notifier) Unmarshal(dAtA []byte) error

func (Notifier) ValidateCreate 

func (notifier Notifier) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (Notifier) ValidateDelete 

func (notifier Notifier) ValidateDelete() error

func (Notifier) ValidateUpdate 

func (notifier Notifier) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

func (*Notifier) XXX_DiscardUnknown 

func (m *Notifier) XXX_DiscardUnknown()

func (*Notifier) XXX_Marshal 

func (m *Notifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Notifier) XXX_Merge 

func (m *Notifier) XXX_Merge(src proto.Message)

func (*Notifier) XXX_Size 

func (m *Notifier) XXX_Size() int

func (*Notifier) XXX_Unmarshal 

func (m *Notifier) XXX_Unmarshal(b []byte) error

type NotifierConditionType 

type NotifierConditionType string

Notifier condition 

const (
	NotifierReady NotifierConditionType = "Ready"
	NotifierSaved NotifierConditionType = "Saved"
)

/ Notifier Condition

type NotifierList 

type NotifierList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Items           []Notifier `json:"items" protobuf:"bytes,2,rep,name=items"`
}

+kubebuilder:object:root=true NotifierList is a list of Notifiers

func (*NotifierList) DeepCopy 

func (in *NotifierList) DeepCopy() *NotifierList

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

func (*NotifierList) DeepCopyInto 

func (in *NotifierList) DeepCopyInto(out *NotifierList)

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

func (*NotifierList) DeepCopyObject 

func (in *NotifierList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*NotifierList) Descriptor 

func (*NotifierList) Descriptor() ([]byte, []int)

func (*NotifierList) Marshal 

func (m *NotifierList) Marshal() (dAtA []byte, err error)

func (*NotifierList) MarshalTo 

func (m *NotifierList) MarshalTo(dAtA []byte) (int, error)

func (*NotifierList) MarshalToSizedBuffer 

func (m *NotifierList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NotifierList) ProtoMessage 

func (*NotifierList) ProtoMessage()

func (*NotifierList) Reset 

func (m *NotifierList) Reset()

func (*NotifierList) Size 

func (m *NotifierList) Size() (n int)

func (*NotifierList) String 

func (this *NotifierList) String() string

func (*NotifierList) Unmarshal 

func (m *NotifierList) Unmarshal(dAtA []byte) error

func (*NotifierList) XXX_DiscardUnknown 

func (m *NotifierList) XXX_DiscardUnknown()

func (*NotifierList) XXX_Marshal 

func (m *NotifierList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NotifierList) XXX_Merge 

func (m *NotifierList) XXX_Merge(src proto.Message)

func (*NotifierList) XXX_Size 

func (m *NotifierList) XXX_Size() int

func (*NotifierList) XXX_Unmarshal 

func (m *NotifierList) XXX_Unmarshal(b []byte) error

type NotifierSpec 

type NotifierSpec struct {
	// Indicates if the Notifier will send notifications
	// +kubebuilder:default:=true
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// The reference to the tenant which the object exists under
	// +kubebuilder:validation:Optional
	TenantRef *v1.ObjectReference `json:"tenantRef" protobuf:"bytes,2,opt,name=tenantRef"`
	// The user provided description of the object
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" protobuf:"varint,3,opt,name=description"`
	// The name of the Account which created the object, which exists in the same tenant as the object
	// +kubebuilder:default:="no-one"
	// +kubebuilder:validation:Optional
	Owner *string `json:"owner,omitempty" protobuf:"bytes,4,opt,name=owner"`
	// Channels specifies the list of notification channels that the Notifier will forward the information from Alerts to.
	// Each channel specifies a Connection resource for an external messaging system, and a destination channel within the system
	// to forward the information from Alerts to
	// +kubebuilder:validation:Optional
	Channels []NotificationChannelSpec `json:"channels,omitempty" protobuf:"bytes,5,rep,name=channels"`
}

NotifierSpec defines the desired state of a Notifier

func (*NotifierSpec) DeepCopy 

func (in *NotifierSpec) DeepCopy() *NotifierSpec

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

func (*NotifierSpec) DeepCopyInto 

func (in *NotifierSpec) DeepCopyInto(out *NotifierSpec)

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

func (*NotifierSpec) Descriptor 

func (*NotifierSpec) Descriptor() ([]byte, []int)

func (*NotifierSpec) Marshal 

func (m *NotifierSpec) Marshal() (dAtA []byte, err error)

func (*NotifierSpec) MarshalTo 

func (m *NotifierSpec) MarshalTo(dAtA []byte) (int, error)

func (*NotifierSpec) MarshalToSizedBuffer 

func (m *NotifierSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NotifierSpec) ProtoMessage 

func (*NotifierSpec) ProtoMessage()

func (*NotifierSpec) Reset 

func (m *NotifierSpec) Reset()

func (*NotifierSpec) Size 

func (m *NotifierSpec) Size() (n int)

func (*NotifierSpec) String 

func (this *NotifierSpec) String() string

func (*NotifierSpec) Unmarshal 

func (m *NotifierSpec) Unmarshal(dAtA []byte) error

func (*NotifierSpec) XXX_DiscardUnknown 

func (m *NotifierSpec) XXX_DiscardUnknown()

func (*NotifierSpec) XXX_Marshal 

func (m *NotifierSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NotifierSpec) XXX_Merge 

func (m *NotifierSpec) XXX_Merge(src proto.Message)

func (*NotifierSpec) XXX_Size 

func (m *NotifierSpec) XXX_Size() int

func (*NotifierSpec) XXX_Unmarshal 

func (m *NotifierSpec) XXX_Unmarshal(b []byte) error

type NotifierStatus 

type NotifierStatus struct {
	// ObservedGeneration is the last generation that was reconciled by Modela
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`
	// UpdatedAt specifies the last time the object was updated
	//+kubebuilder:validation:Optional
	UpdatedAt *metav1.Time `json:"updatedAt,omitempty" protobuf:"bytes,2,opt,name=updatedAt"`
	// ChannelsStatus describes the status of each notification channel (per individual Connection)
	//+kubebuilder:validation:Optional
	ChannelsStatus []NotificationChannelStatus `json:"channelsStatus,omitempty" protobuf:"bytes,3,rep,name=channelsStatus"`
	//+kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,4,rep,name=conditions"`
}

NotifierStatus is the observed state of a Notifier

func (*NotifierStatus) DeepCopy 

func (in *NotifierStatus) DeepCopy() *NotifierStatus

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

func (*NotifierStatus) DeepCopyInto 

func (in *NotifierStatus) DeepCopyInto(out *NotifierStatus)

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

func (*NotifierStatus) Descriptor 

func (*NotifierStatus) Descriptor() ([]byte, []int)

func (*NotifierStatus) Marshal 

func (m *NotifierStatus) Marshal() (dAtA []byte, err error)

func (*NotifierStatus) MarshalTo 

func (m *NotifierStatus) MarshalTo(dAtA []byte) (int, error)

func (*NotifierStatus) MarshalToSizedBuffer 

func (m *NotifierStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NotifierStatus) ProtoMessage 

func (*NotifierStatus) ProtoMessage()

func (*NotifierStatus) Reset 

func (m *NotifierStatus) Reset()

func (*NotifierStatus) Size 

func (m *NotifierStatus) Size() (n int)

func (*NotifierStatus) String 

func (this *NotifierStatus) String() string

func (*NotifierStatus) Unmarshal 

func (m *NotifierStatus) Unmarshal(dAtA []byte) error

func (*NotifierStatus) XXX_DiscardUnknown 

func (m *NotifierStatus) XXX_DiscardUnknown()

func (*NotifierStatus) XXX_Marshal 

func (m *NotifierStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NotifierStatus) XXX_Merge 

func (m *NotifierStatus) XXX_Merge(src proto.Message)

func (*NotifierStatus) XXX_Size 

func (m *NotifierStatus) XXX_Size() int

func (*NotifierStatus) XXX_Unmarshal 

func (m *NotifierStatus) XXX_Unmarshal(b []byte) error

type NotifierType added in v0.4.531 

type NotifierType string
const (
	EmailNotifierType   NotifierType = "email"
	SlackNotifierType   NotifierType = "slack"
	DiscordNotifierType NotifierType = "discord"
	WebhookNotifierType NotifierType = "webhook"
)

type ResourceLimitSpec 

type ResourceLimitSpec struct {
	// Indicates if the resource limit is enabled
	// +kubebuilder:validation:Optional
	// +kubebuilder:default:=false
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// The maximum quantity of memory that can be consumed under the namespace
	// +kubebuilder:validation:Optional
	MaxMem *resource.Quantity `json:"maxMem,omitempty" protobuf:"bytes,2,opt,name=maxMem"`
	// The maximum amount of CPU that can be consumed under the namespace
	// +kubebuilder:validation:Optional
	MaxCpu *resource.Quantity `json:"maxCpu,omitempty" protobuf:"bytes,3,opt,name=maxCpu"`
	// The maximum number of pods that can be created under the namespace
	// +kubebuilder:validation:Optional
	MaxPods *int32 `json:"maxPods,omitempty" protobuf:"varint,4,opt,name=maxPods"`
	// The maximum number of persistent volume claims that can be created under the namespace
	// +kubebuilder:validation:Optional
	MaxPvc *int32 `json:"maxPvc,omitempty" protobuf:"varint,5,opt,name=maxPvc"`
	// QuotaSpec defines the resource quota specification for the namespace
	// +kubebuilder:validation:Optional
	QuotaSpec *corev1.ResourceQuotaSpec `json:"quota,omitempty" protobuf:"bytes,6,opt,name=quota"`
	// +kubebuilder:validation:Optional
	LimitRangeSpec *corev1.LimitRangeSpec `json:"limitRange,omitempty" protobuf:"bytes,7,opt,name=limitRange"`
}

ResourceLimitSpec defines the resource limits for workloads created under Lab and ServingSite namespaces

func (*ResourceLimitSpec) DeepCopy 

func (in *ResourceLimitSpec) DeepCopy() *ResourceLimitSpec

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

func (*ResourceLimitSpec) DeepCopyInto 

func (in *ResourceLimitSpec) DeepCopyInto(out *ResourceLimitSpec)

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

func (*ResourceLimitSpec) Descriptor 

func (*ResourceLimitSpec) Descriptor() ([]byte, []int)

func (*ResourceLimitSpec) Marshal 

func (m *ResourceLimitSpec) Marshal() (dAtA []byte, err error)

func (*ResourceLimitSpec) MarshalTo 

func (m *ResourceLimitSpec) MarshalTo(dAtA []byte) (int, error)

func (*ResourceLimitSpec) MarshalToSizedBuffer 

func (m *ResourceLimitSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResourceLimitSpec) ProtoMessage 

func (*ResourceLimitSpec) ProtoMessage()

func (*ResourceLimitSpec) Reset 

func (m *ResourceLimitSpec) Reset()

func (*ResourceLimitSpec) Size 

func (m *ResourceLimitSpec) Size() (n int)

func (*ResourceLimitSpec) String 

func (this *ResourceLimitSpec) String() string

func (*ResourceLimitSpec) Unmarshal 

func (m *ResourceLimitSpec) Unmarshal(dAtA []byte) error

func (*ResourceLimitSpec) XXX_DiscardUnknown 

func (m *ResourceLimitSpec) XXX_DiscardUnknown()

func (*ResourceLimitSpec) XXX_Marshal 

func (m *ResourceLimitSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourceLimitSpec) XXX_Merge 

func (m *ResourceLimitSpec) XXX_Merge(src proto.Message)

func (*ResourceLimitSpec) XXX_Size 

func (m *ResourceLimitSpec) XXX_Size() int

func (*ResourceLimitSpec) XXX_Unmarshal 

func (m *ResourceLimitSpec) XXX_Unmarshal(b []byte) error

type RuleSpec added in v0.4.561 

type RuleSpec struct {
	// The kind of the resource
	Resource common.KindName `json:"resource,omitempty" protobuf:"bytes,1,opt,name=resource"`
	// List of allowed actions on the resource
	Verbs []common.VerbName `json:"verbs,omitempty" protobuf:"bytes,2,rep,name=verbs"`
}

RuleSpec defines the relation between a resource and the actions that can be performed on the resource

func (*RuleSpec) DeepCopy added in v0.4.561 

func (in *RuleSpec) DeepCopy() *RuleSpec

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

func (*RuleSpec) DeepCopyInto added in v0.4.561 

func (in *RuleSpec) DeepCopyInto(out *RuleSpec)

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

func (*RuleSpec) Descriptor added in v0.4.561 

func (*RuleSpec) Descriptor() ([]byte, []int)

func (*RuleSpec) Marshal added in v0.4.561 

func (m *RuleSpec) Marshal() (dAtA []byte, err error)

func (*RuleSpec) MarshalTo added in v0.4.561 

func (m *RuleSpec) MarshalTo(dAtA []byte) (int, error)

func (*RuleSpec) MarshalToSizedBuffer added in v0.4.561 

func (m *RuleSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RuleSpec) ProtoMessage added in v0.4.561 

func (*RuleSpec) ProtoMessage()

func (*RuleSpec) Reset added in v0.4.561 

func (m *RuleSpec) Reset()

func (*RuleSpec) Size added in v0.4.561 

func (m *RuleSpec) Size() (n int)

func (*RuleSpec) String added in v0.4.561 

func (this *RuleSpec) String() string

func (*RuleSpec) Unmarshal added in v0.4.561 

func (m *RuleSpec) Unmarshal(dAtA []byte) error

func (*RuleSpec) XXX_DiscardUnknown added in v0.4.561 

func (m *RuleSpec) XXX_DiscardUnknown()

func (*RuleSpec) XXX_Marshal added in v0.4.561 

func (m *RuleSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RuleSpec) XXX_Merge added in v0.4.561 

func (m *RuleSpec) XXX_Merge(src proto.Message)

func (*RuleSpec) XXX_Size added in v0.4.561 

func (m *RuleSpec) XXX_Size() int

func (*RuleSpec) XXX_Unmarshal added in v0.4.561 

func (m *RuleSpec) XXX_Unmarshal(b []byte) error

type ServingSite 

type ServingSite struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              ServingSiteSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	//+optional
	Status ServingSiteStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=servingsites,singular=servingsite,categories={infra,modela} +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:printcolumn:name="Ready",type="string",JSONPath=".status.conditions[?(@.type==\"Ready\")].status",description="" +kubebuilder:printcolumn:name="Owner",type="string",JSONPath=".spec.owner",description="owner" +kubebuilder:printcolumn:name="FQDN",type="string",JSONPath=".spec.ingress.fqdn",description="" +kubebuilder:printcolumn:name="GRPC Ingress",type="string",JSONPath=".status.grpcIngressName",description="" +kubebuilder:printcolumn:name="HTTP Ingress",type="string",JSONPath=".status.httpIngressName",description="" +kubebuilder:printcolumn:name="Predictors",type="number",JSONPath=".status.activePredictors",description="" +kubebuilder:printcolumn:name="Cluster",type="string",JSONPath=".spec.clusterName",description="" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp",description="" ServingSite represents a namespace where model serving workloads are executed under

func ParseServingSiteServingYaml 

func ParseServingSiteServingYaml(content []byte) (*ServingSite, error)

func (*ServingSite) AddFinalizer 

func (servingsite *ServingSite) AddFinalizer()

func (ServingSite) ConstructGrpcIngress added in v0.4.697 

func (servingsite ServingSite) ConstructGrpcIngress() *nwv1.Ingress

Create the ingress for GRPC traffic

func (ServingSite) ConstructRestIngress added in v0.4.697 

func (servingsite ServingSite) ConstructRestIngress() *nwv1.Ingress

Create the ingress for REST traffic

func (ServingSite) CreateNamespace 

func (servingsite ServingSite) CreateNamespace() *v1.Namespace

func (*ServingSite) CreateOrUpdateCond 

func (servingsite *ServingSite) CreateOrUpdateCond(cond metav1.Condition)

Merge or update condition

func (*ServingSite) DeepCopy 

func (in *ServingSite) DeepCopy() *ServingSite

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

func (*ServingSite) DeepCopyInto 

func (in *ServingSite) DeepCopyInto(out *ServingSite)

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

func (*ServingSite) DeepCopyObject 

func (in *ServingSite) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ServingSite) Default 

func (servingsite *ServingSite) Default()

func (*ServingSite) Descriptor 

func (*ServingSite) Descriptor() ([]byte, []int)

func (ServingSite) FullName 

func (servingsite ServingSite) FullName() string

func (ServingSite) GetCond 

func (servingsite ServingSite) GetCond(t string) metav1.Condition

func (ServingSite) GetCondIdx 

func (servingsite ServingSite) GetCondIdx(t string) int

func (ServingSite) GetObservedGeneration added in v0.6.252 

func (servingsite ServingSite) GetObservedGeneration() int64

func (ServingSite) GetStatus added in v0.6.252 

func (servingsite ServingSite) GetStatus() proto.Message

func (ServingSite) GrpcIngressEnabled added in v0.6.252 

func (servingsite ServingSite) GrpcIngressEnabled() bool

func (ServingSite) HasFinalizer 

func (servingsite ServingSite) HasFinalizer() bool

func (ServingSite) HttpIngressEnabled added in v0.6.252 

func (servingsite ServingSite) HttpIngressEnabled() bool

func (ServingSite) IsMarkedForDeletion 

func (servingsite ServingSite) IsMarkedForDeletion() bool

func (ServingSite) IsNamespaceReady added in v0.6.252 

func (servingsite ServingSite) IsNamespaceReady() bool

func (ServingSite) IsRbacReady added in v0.6.252 

func (servingsite ServingSite) IsRbacReady() bool

func (ServingSite) Key 

func (servingsite ServingSite) Key() string

func (ServingSite) LimitRange added in v0.6.252 

func (servingsite ServingSite) LimitRange() *v1.LimitRange

func (ServingSite) LimitRangeEnabled added in v0.6.252 

func (servingsite ServingSite) LimitRangeEnabled() bool

func (ServingSite) LimitsEnabled added in v0.6.252 

func (servingsite ServingSite) LimitsEnabled() bool

func (ServingSite) ManifestURI added in v0.5.472 

func (servingsite ServingSite) ManifestURI() string

func (*ServingSite) MarkIngressNotReady added in v0.6.252 

func (servingsite *ServingSite) MarkIngressNotReady(reason string, message string)

func (*ServingSite) MarkIngressReady added in v0.6.252 

func (servingsite *ServingSite) MarkIngressReady()

func (*ServingSite) MarkNamespaceNotReady added in v0.6.252 

func (servingsite *ServingSite) MarkNamespaceNotReady(reason string, message string)

func (*ServingSite) MarkNamespaceReady added in v0.6.252 

func (servingsite *ServingSite) MarkNamespaceReady()

func (*ServingSite) MarkRbacNotReady added in v0.6.252 

func (servingsite *ServingSite) MarkRbacNotReady(reason string, message string)

func (*ServingSite) MarkRbacReady added in v0.6.252 

func (servingsite *ServingSite) MarkRbacReady()

func (*ServingSite) Marshal 

func (m *ServingSite) Marshal() (dAtA []byte, err error)

func (*ServingSite) MarshalTo 

func (m *ServingSite) MarshalTo(dAtA []byte) (int, error)

func (*ServingSite) MarshalToSizedBuffer 

func (m *ServingSite) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (ServingSite) Payload 

func (servingsite ServingSite) Payload() string

func (ServingSite) Prefix 

func (servingsite ServingSite) Prefix() string

func (*ServingSite) ProtoMessage 

func (*ServingSite) ProtoMessage()

func (*ServingSite) RemoveFinalizer 

func (servingsite *ServingSite) RemoveFinalizer()

func (*ServingSite) Reset 

func (m *ServingSite) Reset()

func (ServingSite) ResourceQuota added in v0.6.252 

func (servingsite ServingSite) ResourceQuota() *v1.ResourceQuota

func (ServingSite) ResourceQuotaEnabled added in v0.6.252 

func (servingsite ServingSite) ResourceQuotaEnabled() bool

func (ServingSite) RootURI added in v0.5.472 

func (servingsite ServingSite) RootURI() string

func (ServingSite) ServingSiteAdmin 

func (servingsite ServingSite) ServingSiteAdmin() *rbacv1.Role

func (ServingSite) ServingSiteClusterRole added in v0.6.252 

func (servingsite ServingSite) ServingSiteClusterRole() *rbacv1.ClusterRole

func (ServingSite) ServingSiteClusterRoleBinding added in v0.6.252 

func (servingsite ServingSite) ServingSiteClusterRoleBinding() *rbacv1.ClusterRoleBinding

func (ServingSite) ServingSiteDev 

func (servingsite ServingSite) ServingSiteDev() *rbacv1.Role

func (ServingSite) ServingSiteOps 

func (servingsite ServingSite) ServingSiteOps() *rbacv1.Role

func (ServingSite) ServingSiteRole added in v0.6.252 

func (servingsite ServingSite) ServingSiteRole() *rbacv1.Role

func (ServingSite) ServingSiteRoleBinding added in v0.6.252 

func (servingsite ServingSite) ServingSiteRoleBinding() *rbacv1.RoleBinding

Create a role binding for a job

func (ServingSite) ServingSiteServiceAccount added in v0.6.252 

func (servingsite ServingSite) ServingSiteServiceAccount() *corev1.ServiceAccount

func (*ServingSite) SetObservedGeneration added in v0.6.252 

func (servingsite *ServingSite) SetObservedGeneration(generation int64)

func (*ServingSite) SetStatus added in v0.6.252 

func (servingsite *ServingSite) SetStatus(status interface{})

func (*ServingSite) SetUpdatedAt added in v0.6.252 

func (servingsite *ServingSite) SetUpdatedAt(time *metav1.Time)

func (*ServingSite) SetupWebhookWithManager 

func (servingsite *ServingSite) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*ServingSite) Size 

func (m *ServingSite) Size() (n int)

func (*ServingSite) String 

func (this *ServingSite) String() string

func (*ServingSite) Unmarshal 

func (m *ServingSite) Unmarshal(dAtA []byte) error

func (ServingSite) ValidateCreate 

func (servingsite ServingSite) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (ServingSite) ValidateDelete 

func (servingsite ServingSite) ValidateDelete() error

func (ServingSite) ValidateUpdate 

func (servingsite ServingSite) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

func (*ServingSite) XXX_DiscardUnknown 

func (m *ServingSite) XXX_DiscardUnknown()

func (*ServingSite) XXX_Marshal 

func (m *ServingSite) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServingSite) XXX_Merge 

func (m *ServingSite) XXX_Merge(src proto.Message)

func (*ServingSite) XXX_Size 

func (m *ServingSite) XXX_Size() int

func (*ServingSite) XXX_Unmarshal 

func (m *ServingSite) XXX_Unmarshal(b []byte) error

type ServingSiteConditionType 

type ServingSiteConditionType string
const (
	LabNamespaceReady ServingSiteConditionType = "NamespaceReady"
	LabRbacReady      ServingSiteConditionType = "RbacReady"
)
const (
	ServingSiteNamespaceReady ServingSiteConditionType = "NamespaceReady"
	ServingSiteRbacReady      ServingSiteConditionType = "RbacReady"
	ServingSiteIngressReady   ServingSiteConditionType = "IngressReady"
)

type ServingSiteList 

type ServingSiteList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Items []ServingSite `json:"items" protobuf:"bytes,2,rep,name=items"`
}

+kubebuilder:object:root=true ServingSiteList is a list of ServingSite

func (*ServingSiteList) DeepCopy 

func (in *ServingSiteList) DeepCopy() *ServingSiteList

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

func (*ServingSiteList) DeepCopyInto 

func (in *ServingSiteList) DeepCopyInto(out *ServingSiteList)

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

func (*ServingSiteList) DeepCopyObject 

func (in *ServingSiteList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ServingSiteList) Descriptor 

func (*ServingSiteList) Descriptor() ([]byte, []int)

func (*ServingSiteList) Marshal 

func (m *ServingSiteList) Marshal() (dAtA []byte, err error)

func (*ServingSiteList) MarshalTo 

func (m *ServingSiteList) MarshalTo(dAtA []byte) (int, error)

func (*ServingSiteList) MarshalToSizedBuffer 

func (m *ServingSiteList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServingSiteList) ProtoMessage 

func (*ServingSiteList) ProtoMessage()

func (*ServingSiteList) Reset 

func (m *ServingSiteList) Reset()

func (*ServingSiteList) Size 

func (m *ServingSiteList) Size() (n int)

func (*ServingSiteList) String 

func (this *ServingSiteList) String() string

func (*ServingSiteList) Unmarshal 

func (m *ServingSiteList) Unmarshal(dAtA []byte) error

func (*ServingSiteList) XXX_DiscardUnknown 

func (m *ServingSiteList) XXX_DiscardUnknown()

func (*ServingSiteList) XXX_Marshal 

func (m *ServingSiteList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServingSiteList) XXX_Merge 

func (m *ServingSiteList) XXX_Merge(src proto.Message)

func (*ServingSiteList) XXX_Size 

func (m *ServingSiteList) XXX_Size() int

func (*ServingSiteList) XXX_Unmarshal 

func (m *ServingSiteList) XXX_Unmarshal(b []byte) error

type ServingSiteSpec 

type ServingSiteSpec struct {
	// The user-provided description of the object
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" protobuf:"bytes,1,opt,name=description"`
	// The reference to the tenant which the object exists under
	// +kubebuilder:validation:Optional
	TenantRef *v1.ObjectReference `json:"tenantRef,omitempty" protobuf:"bytes,2,opt,name=tenantRef"`
	// Limits specifies the hard resource limits that can be allocated for workloads created under the ServingSite
	// +kubebuilder:validation:Optional
	Limits ResourceLimitSpec `json:"limits,omitempty" protobuf:"bytes,3,opt,name=limits"`
	// Ingress defines the specification to create Ingress resources that can route traffic
	// to the resources which exist under the ServingSite's namespace
	// +kubebuilder:validation:Optional
	Ingress IngressSpec `json:"ingress,omitempty" protobuf:"bytes,4,opt,name=ingress"`
	// External Cluster specify if the serving site will be served on external cluster using the cluster api.
	// assigned to the Lab will be executed inside the cluster (currently not implemented)
	// +kubebuilder:validation:Optional
	ExternalCluster *VirtualClusterSpec `json:"externalCluster,omitempty" protobuf:"bytes,5,opt,name=externalCluster"`
	// The name of the Account which created the object, which exists in the same tenant as the object
	// +kubebuilder:default:="no-one"
	// +kubebuilder:validation:Optional
	Owner *string `json:"owner,omitempty" protobuf:"bytes,7,opt,name=owner"`
	// The stage of the serving class
	// +kubebuilder:default:="no-one"
	// +kubebuilder:validation:Optional
	Stage *catalog.ServingSiteStage `json:"stage,omitempty" protobuf:"bytes,8,opt,name=stage"`
}

ServingSiteSpec defines the desired state of a ServingSite

func (*ServingSiteSpec) DeepCopy 

func (in *ServingSiteSpec) DeepCopy() *ServingSiteSpec

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

func (*ServingSiteSpec) DeepCopyInto 

func (in *ServingSiteSpec) DeepCopyInto(out *ServingSiteSpec)

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

func (*ServingSiteSpec) Descriptor 

func (*ServingSiteSpec) Descriptor() ([]byte, []int)

func (*ServingSiteSpec) Marshal 

func (m *ServingSiteSpec) Marshal() (dAtA []byte, err error)

func (*ServingSiteSpec) MarshalTo 

func (m *ServingSiteSpec) MarshalTo(dAtA []byte) (int, error)

func (*ServingSiteSpec) MarshalToSizedBuffer 

func (m *ServingSiteSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServingSiteSpec) ProtoMessage 

func (*ServingSiteSpec) ProtoMessage()

func (*ServingSiteSpec) Reset 

func (m *ServingSiteSpec) Reset()

func (*ServingSiteSpec) Size 

func (m *ServingSiteSpec) Size() (n int)

func (*ServingSiteSpec) String 

func (this *ServingSiteSpec) String() string

func (*ServingSiteSpec) Unmarshal 

func (m *ServingSiteSpec) Unmarshal(dAtA []byte) error

func (*ServingSiteSpec) XXX_DiscardUnknown 

func (m *ServingSiteSpec) XXX_DiscardUnknown()

func (*ServingSiteSpec) XXX_Marshal 

func (m *ServingSiteSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServingSiteSpec) XXX_Merge 

func (m *ServingSiteSpec) XXX_Merge(src proto.Message)

func (*ServingSiteSpec) XXX_Size 

func (m *ServingSiteSpec) XXX_Size() int

func (*ServingSiteSpec) XXX_Unmarshal 

func (m *ServingSiteSpec) XXX_Unmarshal(b []byte) error

type ServingSiteStatus 

type ServingSiteStatus struct {
	// ObservedGeneration is the last generation that was acted on
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`
	// The last time the object was updated
	//+kubebuilder:validation:Optional
	UpdatedAt *metav1.Time `json:"updatedAt,omitempty" protobuf:"bytes,2,opt,name=updatedAt"`
	// The number of active predictor services
	ActivePredictors int32 `json:"activePredictors,omitempty" protobuf:"varint,3,opt,name=activePredictors"`
	// The number of inactive (non-deployed) predictors
	InactivePredictors int32 `json:"inactivePredictors,omitempty" protobuf:"varint,4,opt,name=inactivePredictors"`
	// The number of predictor services that have failed/errored
	TotalPredictorServiceFailed int32 `json:"totalPredictorServiceFailed,omitempty" protobuf:"varint,5,opt,name=totalPredictorServiceFailed"`
	// The number of predictors that have detected a data drift
	TotalPredictorDataDriftFailed int32 `json:"totalPredictorDataDriftFailed,omitempty" protobuf:"varint,6,opt,name=totalPredictorDataDriftFailed"`
	// The number of predictors that have detected average inaccurate results
	TotalPredictorAccuracyFailed int32 `json:"totalPredictorAccuracyFailed,omitempty" protobuf:"varint,7,opt,name=totalPredictorAccuracyFailed"`
	// The collection of predictions from the last 7 days
	DailyPredictionsCounts []int32 `json:"dailyPredictionsCounts,omitempty" protobuf:"bytes,8,rep,name=dailyPredictionsCounts"`
	// In the case of failure, the ServingSite resource controller will set this field with a failure message
	//+kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,10,opt,name=failureMessage"`
	// GrpcIngressName specifies the name of the Kubernetes Ingress resource which the Serving Site uses to define
	// external access points for resources that accept GRPC-based traffic to their services (i.e. Predictors).
	// This field is set only after one or more resources are created which use the Ingress access method.
	// If there are no Ingress rules to serve then the Ingress will be destroyed
	//+kubebuilder:validation:Optional
	GrpcIngressName *string `json:"grpcIngressName,omitempty" protobuf:"bytes,11,opt,name=grpcIngressName"`
	// HttpIngressName specifies the name of the Kubernetes Ingress resource which the Serving Site uses to define
	// external access points for resources that accept HTTP-based traffic to their services (i.e. Data Apps).
	// This field is set only after one or more resources are created which use the Ingress access method to serve HTTP traffic.
	// If there are no Ingress rules to serve then the Ingress will be destroyed
	HttpIngressName *string `json:"restIngressName,omitempty" protobuf:"bytes,12,opt,name=restIngressName"`
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,15,rep,name=conditions"`
}

func (*ServingSiteStatus) DeepCopy 

func (in *ServingSiteStatus) DeepCopy() *ServingSiteStatus

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

func (*ServingSiteStatus) DeepCopyInto 

func (in *ServingSiteStatus) DeepCopyInto(out *ServingSiteStatus)

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

func (*ServingSiteStatus) Descriptor 

func (*ServingSiteStatus) Descriptor() ([]byte, []int)

func (*ServingSiteStatus) Marshal 

func (m *ServingSiteStatus) Marshal() (dAtA []byte, err error)

func (*ServingSiteStatus) MarshalTo 

func (m *ServingSiteStatus) MarshalTo(dAtA []byte) (int, error)

func (*ServingSiteStatus) MarshalToSizedBuffer 

func (m *ServingSiteStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServingSiteStatus) ProtoMessage 

func (*ServingSiteStatus) ProtoMessage()

func (*ServingSiteStatus) Reset 

func (m *ServingSiteStatus) Reset()

func (*ServingSiteStatus) Size 

func (m *ServingSiteStatus) Size() (n int)

func (*ServingSiteStatus) String 

func (this *ServingSiteStatus) String() string

func (*ServingSiteStatus) Unmarshal 

func (m *ServingSiteStatus) Unmarshal(dAtA []byte) error

func (*ServingSiteStatus) XXX_DiscardUnknown 

func (m *ServingSiteStatus) XXX_DiscardUnknown()

func (*ServingSiteStatus) XXX_Marshal 

func (m *ServingSiteStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServingSiteStatus) XXX_Merge 

func (m *ServingSiteStatus) XXX_Merge(src proto.Message)

func (*ServingSiteStatus) XXX_Size 

func (m *ServingSiteStatus) XXX_Size() int

func (*ServingSiteStatus) XXX_Unmarshal 

func (m *ServingSiteStatus) XXX_Unmarshal(b []byte) error

type Tenant 

type Tenant struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              TenantSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	//+optional
	Status TenantStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=tenants,singular=tenant,categories={infra,modela} +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:printcolumn:name="Ready",type="string",JSONPath=".status.conditions[?(@.type==\"Ready\")].status",description="" +kubebuilder:printcolumn:name="Default Lab",type="string",JSONPath=".spec.defaultLabRef.Name",description="" +kubebuilder:printcolumn:name="Default Serving Site",type="string",JSONPath=".spec.defaultServingSiteRef.Name",description="" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp",description="" Tenant represents a root namespace for tenant-level resources and child DataProduct namespaces

func ParseTenantYaml 

func ParseTenantYaml(content []byte) (*Tenant, error)

func (*Tenant) AddFinalizer 

func (tenant *Tenant) AddFinalizer()

func (*Tenant) CreateOrUpdateCond 

func (tenant *Tenant) CreateOrUpdateCond(cond metav1.Condition)

Merge or update condition

func (*Tenant) DeepCopy 

func (in *Tenant) DeepCopy() *Tenant

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

func (*Tenant) DeepCopyInto 

func (in *Tenant) DeepCopyInto(out *Tenant)

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

func (*Tenant) DeepCopyObject 

func (in *Tenant) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Tenant) Default 

func (tenant *Tenant) Default()

func (Tenant) DefaultLabRef added in v0.6.252 

func (tenant Tenant) DefaultLabRef() *v1.ObjectReference

func (Tenant) DefaultServingSiteRef added in v0.6.252 

func (tenant Tenant) DefaultServingSiteRef() *v1.ObjectReference

func (*Tenant) Descriptor 

func (*Tenant) Descriptor() ([]byte, []int)

func (Tenant) GetCond 

func (tenant Tenant) GetCond(t string) metav1.Condition

func (Tenant) GetCondIdx 

func (tenant Tenant) GetCondIdx(t string) int

func (Tenant) GetObservedGeneration added in v0.6.252 

func (tenant Tenant) GetObservedGeneration() int64

func (Tenant) GetRolesForAccount added in v0.4.556 

func (tenant Tenant) GetRolesForAccount(account *Account) []string

func (Tenant) GetStatus added in v0.6.252 

func (tenant Tenant) GetStatus() proto.Message

func (*Tenant) HasFinalizer 

func (tenant *Tenant) HasFinalizer() bool

func (Tenant) IsMetricDatabaseReady added in v0.5.536 

func (tenant Tenant) IsMetricDatabaseReady() bool

func (Tenant) IsReady 

func (tenant Tenant) IsReady() bool

func (Tenant) Key 

func (tenant Tenant) Key() string

func (Tenant) ManifestURI added in v0.5.472 

func (tenant Tenant) ManifestURI() string

func (*Tenant) MarkDatabaseReady added in v0.5.536 

func (tenant *Tenant) MarkDatabaseReady()

func (*Tenant) MarkReady 

func (tenant *Tenant) MarkReady()

func (*Tenant) Marshal 

func (m *Tenant) Marshal() (dAtA []byte, err error)

func (*Tenant) MarshalTo 

func (m *Tenant) MarshalTo(dAtA []byte) (int, error)

func (*Tenant) MarshalToSizedBuffer 

func (m *Tenant) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Tenant) Populate 

func (tenant *Tenant) Populate(name string)

populate an empty tenant

func (Tenant) PrefixLiveURI added in v0.6.252 

func (tenant Tenant) PrefixLiveURI() string

func (*Tenant) ProtoMessage 

func (*Tenant) ProtoMessage()

func (*Tenant) RemoveFinalizer 

func (tenant *Tenant) RemoveFinalizer()

func (*Tenant) Reset 

func (m *Tenant) Reset()

func (Tenant) RootURI added in v0.5.472 

func (tenant Tenant) RootURI() string

func (*Tenant) SetObservedGeneration added in v0.6.252 

func (tenant *Tenant) SetObservedGeneration(generation int64)

func (*Tenant) SetStatus added in v0.6.252 

func (tenant *Tenant) SetStatus(status interface{})

func (*Tenant) SetUpdatedAt added in v0.6.252 

func (tenant *Tenant) SetUpdatedAt(time *metav1.Time)

func (*Tenant) SetupWebhookWithManager 

func (r *Tenant) SetupWebhookWithManager(mgr ctrl.Manager) error

Set up the webhook with the manager.

func (*Tenant) Size 

func (m *Tenant) Size() (n int)

func (*Tenant) String 

func (this *Tenant) String() string

func (*Tenant) Unmarshal 

func (m *Tenant) Unmarshal(dAtA []byte) error

func (Tenant) ValidateCreate 

func (tenant Tenant) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (Tenant) ValidateDelete 

func (tenant Tenant) ValidateDelete() error

func (Tenant) ValidateUpdate 

func (tenant Tenant) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

func (*Tenant) XXX_DiscardUnknown 

func (m *Tenant) XXX_DiscardUnknown()

func (*Tenant) XXX_Marshal 

func (m *Tenant) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Tenant) XXX_Merge 

func (m *Tenant) XXX_Merge(src proto.Message)

func (*Tenant) XXX_Size 

func (m *Tenant) XXX_Size() int

func (*Tenant) XXX_Unmarshal 

func (m *Tenant) XXX_Unmarshal(b []byte) error

type TenantConditionType 

type TenantConditionType string
const (
	TenantReady               TenantConditionType = "Ready"
	TenantMetricDatabaseReady TenantConditionType = "MetricDatabaseReady"
)

/ Tenant Condition

type TenantList 

type TenantList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Items []Tenant `json:"items" protobuf:"bytes,2,rep,name=items"`
}

TenantList represent a list of Tenants +kubebuilder:object:root=true

func (*TenantList) DeepCopy 

func (in *TenantList) DeepCopy() *TenantList

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

func (*TenantList) DeepCopyInto 

func (in *TenantList) DeepCopyInto(out *TenantList)

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

func (*TenantList) DeepCopyObject 

func (in *TenantList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*TenantList) Descriptor 

func (*TenantList) Descriptor() ([]byte, []int)

func (*TenantList) Marshal 

func (m *TenantList) Marshal() (dAtA []byte, err error)

func (*TenantList) MarshalTo 

func (m *TenantList) MarshalTo(dAtA []byte) (int, error)

func (*TenantList) MarshalToSizedBuffer 

func (m *TenantList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TenantList) ProtoMessage 

func (*TenantList) ProtoMessage()

func (*TenantList) Reset 

func (m *TenantList) Reset()

func (*TenantList) Size 

func (m *TenantList) Size() (n int)

func (*TenantList) String 

func (this *TenantList) String() string

func (*TenantList) Unmarshal 

func (m *TenantList) Unmarshal(dAtA []byte) error

func (*TenantList) XXX_DiscardUnknown 

func (m *TenantList) XXX_DiscardUnknown()

func (*TenantList) XXX_Marshal 

func (m *TenantList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TenantList) XXX_Merge 

func (m *TenantList) XXX_Merge(src proto.Message)

func (*TenantList) XXX_Size 

func (m *TenantList) XXX_Size() int

func (*TenantList) XXX_Unmarshal 

func (m *TenantList) XXX_Unmarshal(b []byte) error

type TenantSpec 

type TenantSpec struct {
	// DefaultLabName specifies a Lab resource that will be used as a default for all resources that
	// do not specify a Lab or have a Data Product which specifies a default Lab
	// +kubebuilder:validation:Optional
	DefaultLabName *string `json:"defaultLabName,omitempty" protobuf:"bytes,1,opt,name=defaultLabName"`
	// DefaultServingSiteName specifies a Serving Site resource that will be used as a default for all resources that
	// do not specify a Serving Site and has a Data Product that does not specify a default Serving Site
	// +kubebuilder:validation:Optional
	DefaultServingSiteName *string `json:"defaultServingSiteName,omitempty" protobuf:"bytes,2,opt,name=defaultServingSiteName"`
	// DefaultBucketName specifies a Virtual Bucket resource that will be used as a default for all resources that
	// do not specify a Virtual Bucket and has a Data Product that does not specify a default Virtual Bucket
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	DefaultBucketName *string `json:"defaultBucketName,omitempty" protobuf:"bytes,3,opt,name=defaultBucketName"`
	// CacheBucketName specifies the name of the Virtual Bucket which workloads for resources under the Tenant
	// will use internally for caching workloads. Setting CacheBucketName to a valid Virtual Bucket is highly
	// recommended for stability and performance
	// +kubebuilder:validation:Required
	// +required
	CacheBucketName string `json:"cacheBucketName,omitempty" protobuf:"bytes,4,opt,name=cacheBucketName"`
	// Permissions defines the set of permissions applied to each Account when accessing resources within the Tenant
	// +kubebuilder:validation:Optional
	Permissions catalog.PermissionsSpec `json:"permissions,omitempty" protobuf:"bytes,5,opt,name=permissions"`
	// The default notification specification for all resources under the tenant
	// +kubebuilder:validation:Optional
	Notification *catalog.NotificationSpec `json:"notification,omitempty" protobuf:"bytes,6,opt,name=notification"`
	// OnlineStore references a Connection resource to an external database that the Modela online store microservice
	// will use as an online store. The online store service must be installed through the Modela Operator
	// +kubebuilder:validation:Optional
	OnlineStoreConnectionRef *v1.ObjectReference `json:"onlineStoreConnection,omitempty" protobuf:"bytes,7,opt,name=onlineStoreConnection"`
	// MetricStore references a Connection resource to an external database that will act as the metric store for the Tenant.
	// The metric store stores metadata about resources that perform workloads (i.e. datasets, models, studies, etc.)
	// +kubebuilder:validation:Optional
	MetricStoreConnectionRef *v1.ObjectReference `json:"metricStoreConnection,omitempty" protobuf:"bytes,8,opt,name=metricStoreConnection"`
}

TenantSpec defines the desired state of a Tenant

func (*TenantSpec) DeepCopy 

func (in *TenantSpec) DeepCopy() *TenantSpec

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

func (*TenantSpec) DeepCopyInto 

func (in *TenantSpec) DeepCopyInto(out *TenantSpec)

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

func (*TenantSpec) Descriptor 

func (*TenantSpec) Descriptor() ([]byte, []int)

func (*TenantSpec) Marshal 

func (m *TenantSpec) Marshal() (dAtA []byte, err error)

func (*TenantSpec) MarshalTo 

func (m *TenantSpec) MarshalTo(dAtA []byte) (int, error)

func (*TenantSpec) MarshalToSizedBuffer 

func (m *TenantSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TenantSpec) ProtoMessage 

func (*TenantSpec) ProtoMessage()

func (*TenantSpec) Reset 

func (m *TenantSpec) Reset()

func (*TenantSpec) Size 

func (m *TenantSpec) Size() (n int)

func (*TenantSpec) String 

func (this *TenantSpec) String() string

func (*TenantSpec) Unmarshal 

func (m *TenantSpec) Unmarshal(dAtA []byte) error

func (*TenantSpec) XXX_DiscardUnknown 

func (m *TenantSpec) XXX_DiscardUnknown()

func (*TenantSpec) XXX_Marshal 

func (m *TenantSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TenantSpec) XXX_Merge 

func (m *TenantSpec) XXX_Merge(src proto.Message)

func (*TenantSpec) XXX_Size 

func (m *TenantSpec) XXX_Size() int

func (*TenantSpec) XXX_Unmarshal 

func (m *TenantSpec) XXX_Unmarshal(b []byte) error

type TenantStatus 

type TenantStatus struct {
	// ObservedGeneration is the Last generation that was acted on
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`
	// Last time the object was updated
	//+kubebuilder:validation:Optional
	UpdatedAt *metav1.Time `json:"updatedAt,omitempty" protobuf:"bytes,2,opt,name=updatedAt"`
	// UpdateUpdateStrategy in case of terminal failure
	// Borrowed from cluster api controller
	//+kubebuilder:validation:Optional
	FailureReason *catalog.StatusError `json:"failureReason,omitempty" protobuf:"bytes,3,opt,name=failureReason"`
	// UpdateUpdateStrategy in case of terminal failure message
	//+kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,4,opt,name=failureMessage"`
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,5,rep,name=conditions"`
}

TenantStatus defines the actual state of a Tenant

func (*TenantStatus) DeepCopy 

func (in *TenantStatus) DeepCopy() *TenantStatus

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

func (*TenantStatus) DeepCopyInto 

func (in *TenantStatus) DeepCopyInto(out *TenantStatus)

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

func (*TenantStatus) Descriptor 

func (*TenantStatus) Descriptor() ([]byte, []int)

func (*TenantStatus) Marshal 

func (m *TenantStatus) Marshal() (dAtA []byte, err error)

func (*TenantStatus) MarshalTo 

func (m *TenantStatus) MarshalTo(dAtA []byte) (int, error)

func (*TenantStatus) MarshalToSizedBuffer 

func (m *TenantStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TenantStatus) ProtoMessage 

func (*TenantStatus) ProtoMessage()

func (*TenantStatus) Reset 

func (m *TenantStatus) Reset()

func (*TenantStatus) Size 

func (m *TenantStatus) Size() (n int)

func (*TenantStatus) String 

func (this *TenantStatus) String() string

func (*TenantStatus) Unmarshal 

func (m *TenantStatus) Unmarshal(dAtA []byte) error

func (*TenantStatus) XXX_DiscardUnknown 

func (m *TenantStatus) XXX_DiscardUnknown()

func (*TenantStatus) XXX_Marshal 

func (m *TenantStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TenantStatus) XXX_Merge 

func (m *TenantStatus) XXX_Merge(src proto.Message)

func (*TenantStatus) XXX_Size 

func (m *TenantStatus) XXX_Size() int

func (*TenantStatus) XXX_Unmarshal 

func (m *TenantStatus) XXX_Unmarshal(b []byte) error

type TenantType 

type TenantType string

type UserRoleClass added in v0.4.557 

type UserRoleClass struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              UserRoleClassSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
}

+kubebuilder:storageversion +kubebuilder:resource:path=userroleclasses,singular=userroleclass,categories={infra,modela,all} +kubebuilder:object:root=true UserRoleClass specifies the permissions that can be performed on a set of resources

func (*UserRoleClass) Allow added in v0.4.557 

func (role *UserRoleClass) Allow(action common.VerbName, resource common.KindName) bool

func (*UserRoleClass) DeepCopy added in v0.4.557 

func (in *UserRoleClass) DeepCopy() *UserRoleClass

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

func (*UserRoleClass) DeepCopyInto added in v0.4.557 

func (in *UserRoleClass) DeepCopyInto(out *UserRoleClass)

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

func (*UserRoleClass) DeepCopyObject added in v0.4.557 

func (in *UserRoleClass) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*UserRoleClass) Descriptor added in v0.4.557 

func (*UserRoleClass) Descriptor() ([]byte, []int)

func (*UserRoleClass) Marshal added in v0.4.557 

func (m *UserRoleClass) Marshal() (dAtA []byte, err error)

func (*UserRoleClass) MarshalTo added in v0.4.557 

func (m *UserRoleClass) MarshalTo(dAtA []byte) (int, error)

func (*UserRoleClass) MarshalToSizedBuffer added in v0.4.557 

func (m *UserRoleClass) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UserRoleClass) ProtoMessage added in v0.4.557 

func (*UserRoleClass) ProtoMessage()

func (*UserRoleClass) Reset added in v0.4.557 

func (m *UserRoleClass) Reset()

func (*UserRoleClass) Size added in v0.4.557 

func (m *UserRoleClass) Size() (n int)

func (*UserRoleClass) String added in v0.4.557 

func (this *UserRoleClass) String() string

func (*UserRoleClass) Unmarshal added in v0.4.557 

func (m *UserRoleClass) Unmarshal(dAtA []byte) error

func (*UserRoleClass) XXX_DiscardUnknown added in v0.4.557 

func (m *UserRoleClass) XXX_DiscardUnknown()

func (*UserRoleClass) XXX_Marshal added in v0.4.557 

func (m *UserRoleClass) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserRoleClass) XXX_Merge added in v0.4.557 

func (m *UserRoleClass) XXX_Merge(src proto.Message)

func (*UserRoleClass) XXX_Size added in v0.4.557 

func (m *UserRoleClass) XXX_Size() int

func (*UserRoleClass) XXX_Unmarshal added in v0.4.557 

func (m *UserRoleClass) XXX_Unmarshal(b []byte) error

type UserRoleClassList added in v0.4.557 

type UserRoleClassList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Items           []UserRoleClass `json:"items" protobuf:"bytes,2,rep,name=items"`
}

UserRoleClassList contains a list of UserRoleClasses +kubebuilder:object:root=true

func (*UserRoleClassList) DeepCopy added in v0.4.557 

func (in *UserRoleClassList) DeepCopy() *UserRoleClassList

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

func (*UserRoleClassList) DeepCopyInto added in v0.4.557 

func (in *UserRoleClassList) DeepCopyInto(out *UserRoleClassList)

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

func (*UserRoleClassList) DeepCopyObject added in v0.4.557 

func (in *UserRoleClassList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*UserRoleClassList) Descriptor added in v0.4.557 

func (*UserRoleClassList) Descriptor() ([]byte, []int)

func (*UserRoleClassList) Marshal added in v0.4.557 

func (m *UserRoleClassList) Marshal() (dAtA []byte, err error)

func (*UserRoleClassList) MarshalTo added in v0.4.557 

func (m *UserRoleClassList) MarshalTo(dAtA []byte) (int, error)

func (*UserRoleClassList) MarshalToSizedBuffer added in v0.4.557 

func (m *UserRoleClassList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UserRoleClassList) ProtoMessage added in v0.4.557 

func (*UserRoleClassList) ProtoMessage()

func (*UserRoleClassList) Reset added in v0.4.557 

func (m *UserRoleClassList) Reset()

func (*UserRoleClassList) Size added in v0.4.557 

func (m *UserRoleClassList) Size() (n int)

func (*UserRoleClassList) String added in v0.4.557 

func (this *UserRoleClassList) String() string

func (*UserRoleClassList) Unmarshal added in v0.4.557 

func (m *UserRoleClassList) Unmarshal(dAtA []byte) error

func (*UserRoleClassList) XXX_DiscardUnknown added in v0.4.557 

func (m *UserRoleClassList) XXX_DiscardUnknown()

func (*UserRoleClassList) XXX_Marshal added in v0.4.557 

func (m *UserRoleClassList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserRoleClassList) XXX_Merge added in v0.4.557 

func (m *UserRoleClassList) XXX_Merge(src proto.Message)

func (*UserRoleClassList) XXX_Size added in v0.4.557 

func (m *UserRoleClassList) XXX_Size() int

func (*UserRoleClassList) XXX_Unmarshal added in v0.4.557 

func (m *UserRoleClassList) XXX_Unmarshal(b []byte) error

type UserRoleClassSpec added in v0.4.557 

type UserRoleClassSpec struct {
	// The owner of the user role class
	// +kubebuilder:validation:Optional
	TenantRef *v1.ObjectReference `json:"tenantRef,omitempty" protobuf:"bytes,1,name=tenantRef"`
	// The description of the user role class.
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" protobuf:"bytes,2,opt,name=description"`
	// The name of the Account which created the object, which exists in the same tenant as the object
	// +kubebuilder:default:="admin"
	// +kubebuilder:validation:Optional
	Owner *string `json:"owner,omitempty" protobuf:"bytes,3,opt,name=owner"`
	// The collection of rules, consisting of a resource and the actions that can be performed on the resource
	// +kubebuilder:validation:Optional
	Rules []RuleSpec `json:"rules,omitempty" protobuf:"bytes,4,rep,name=rules"`
}

UserRoleClassSpec contains the permissions for a UserRoleClass

func (*UserRoleClassSpec) DeepCopy added in v0.4.557 

func (in *UserRoleClassSpec) DeepCopy() *UserRoleClassSpec

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

func (*UserRoleClassSpec) DeepCopyInto added in v0.4.557 

func (in *UserRoleClassSpec) DeepCopyInto(out *UserRoleClassSpec)

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

func (*UserRoleClassSpec) Descriptor added in v0.4.557 

func (*UserRoleClassSpec) Descriptor() ([]byte, []int)

func (*UserRoleClassSpec) Marshal added in v0.4.557 

func (m *UserRoleClassSpec) Marshal() (dAtA []byte, err error)

func (*UserRoleClassSpec) MarshalTo added in v0.4.557 

func (m *UserRoleClassSpec) MarshalTo(dAtA []byte) (int, error)

func (*UserRoleClassSpec) MarshalToSizedBuffer added in v0.4.557 

func (m *UserRoleClassSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UserRoleClassSpec) ProtoMessage added in v0.4.557 

func (*UserRoleClassSpec) ProtoMessage()

func (*UserRoleClassSpec) Reset added in v0.4.557 

func (m *UserRoleClassSpec) Reset()

func (*UserRoleClassSpec) Size added in v0.4.557 

func (m *UserRoleClassSpec) Size() (n int)

func (*UserRoleClassSpec) String added in v0.4.557 

func (this *UserRoleClassSpec) String() string

func (*UserRoleClassSpec) Unmarshal added in v0.4.557 

func (m *UserRoleClassSpec) Unmarshal(dAtA []byte) error

func (*UserRoleClassSpec) XXX_DiscardUnknown added in v0.4.557 

func (m *UserRoleClassSpec) XXX_DiscardUnknown()

func (*UserRoleClassSpec) XXX_Marshal added in v0.4.557 

func (m *UserRoleClassSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserRoleClassSpec) XXX_Merge added in v0.4.557 

func (m *UserRoleClassSpec) XXX_Merge(src proto.Message)

func (*UserRoleClassSpec) XXX_Size added in v0.4.557 

func (m *UserRoleClassSpec) XXX_Size() int

func (*UserRoleClassSpec) XXX_Unmarshal added in v0.4.557 

func (m *UserRoleClassSpec) XXX_Unmarshal(b []byte) error

type VirtualBucket 

type VirtualBucket struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Spec              VirtualBucketSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	//+optional
	Status VirtualBucketStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:path=virtualbuckets,shortName=vb,singular=virtualbucket,categories={infra,modela,all} +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:printcolumn:name="Ready",type="string",JSONPath=".status.conditions[?(@.type==\"Ready\")].status",description="" +kubebuilder:printcolumn:name="Owner",type="string",JSONPath=".spec.owner",description="owner" +kubebuilder:printcolumn:name="ConnectionName",type="string",JSONPath=".spec.connectionName",description="virtual bucket connections" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp",description="" VirtualBucket represents an abstract object storage system used to store flat-files

func (*VirtualBucket) AddFinalizer 

func (bucket *VirtualBucket) AddFinalizer()

func (*VirtualBucket) CreateOrUpdateCond 

func (bucket *VirtualBucket) CreateOrUpdateCond(cond metav1.Condition)

Merge or update condition

func (*VirtualBucket) DeepCopy 

func (in *VirtualBucket) DeepCopy() *VirtualBucket

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

func (*VirtualBucket) DeepCopyInto 

func (in *VirtualBucket) DeepCopyInto(out *VirtualBucket)

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

func (*VirtualBucket) DeepCopyObject 

func (in *VirtualBucket) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*VirtualBucket) Default 

func (bucket *VirtualBucket) Default()

func (*VirtualBucket) Descriptor 

func (*VirtualBucket) Descriptor() ([]byte, []int)

func (*VirtualBucket) GetCond 

func (bucket *VirtualBucket) GetCond(t string) metav1.Condition

func (*VirtualBucket) GetCondIdx 

func (bucket *VirtualBucket) GetCondIdx(t string) int

func (*VirtualBucket) GetConnection added in v0.6.252 

func (bucket *VirtualBucket) GetConnection() *Connection

func (VirtualBucket) GetObservedGeneration added in v0.6.252 

func (virtualbucket VirtualBucket) GetObservedGeneration() int64

func (VirtualBucket) GetStatus added in v0.6.252 

func (virtualbucket VirtualBucket) GetStatus() proto.Message

func (*VirtualBucket) HasFinalizer 

func (bucket *VirtualBucket) HasFinalizer() bool

func (*VirtualBucket) IsReady 

func (bucket *VirtualBucket) IsReady() bool

func (*VirtualBucket) ManifestURI added in v0.5.472 

func (bucket *VirtualBucket) ManifestURI() string

func (*VirtualBucket) MarkFailed added in v0.4.448 

func (bucket *VirtualBucket) MarkFailed(reason string, err string)

func (*VirtualBucket) MarkReady 

func (bucket *VirtualBucket) MarkReady()

func (*VirtualBucket) Marshal 

func (m *VirtualBucket) Marshal() (dAtA []byte, err error)

func (*VirtualBucket) MarshalTo 

func (m *VirtualBucket) MarshalTo(dAtA []byte) (int, error)

func (*VirtualBucket) MarshalToSizedBuffer 

func (m *VirtualBucket) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VirtualBucket) ProtoMessage 

func (*VirtualBucket) ProtoMessage()

func (*VirtualBucket) RemoveFinalizer 

func (bucket *VirtualBucket) RemoveFinalizer()

func (*VirtualBucket) Reset 

func (m *VirtualBucket) Reset()

func (*VirtualBucket) RootURI added in v0.5.472 

func (bucket *VirtualBucket) RootURI() string

func (*VirtualBucket) SetObservedGeneration added in v0.6.252 

func (virtualbucket *VirtualBucket) SetObservedGeneration(generation int64)

func (*VirtualBucket) SetStatus added in v0.6.252 

func (virtualbucket *VirtualBucket) SetStatus(status interface{})

func (*VirtualBucket) SetUpdatedAt added in v0.6.252 

func (virtualbucket *VirtualBucket) SetUpdatedAt(time *metav1.Time)

func (*VirtualBucket) SetupWebhookWithManager 

func (bucket *VirtualBucket) SetupWebhookWithManager(mgr ctrl.Manager) error

Set up the webhook with the manager.

func (*VirtualBucket) Size 

func (m *VirtualBucket) Size() (n int)

func (*VirtualBucket) String 

func (this *VirtualBucket) String() string

func (*VirtualBucket) Strip added in v0.6.252 

func (bucket *VirtualBucket) Strip() *VirtualBucket

func (*VirtualBucket) Unmarshal 

func (m *VirtualBucket) Unmarshal(dAtA []byte) error

func (*VirtualBucket) ValidateCreate 

func (bucket *VirtualBucket) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*VirtualBucket) ValidateDelete 

func (bucket *VirtualBucket) ValidateDelete() error

func (*VirtualBucket) ValidateUpdate 

func (bucket *VirtualBucket) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

func (*VirtualBucket) XXX_DiscardUnknown 

func (m *VirtualBucket) XXX_DiscardUnknown()

func (*VirtualBucket) XXX_Marshal 

func (m *VirtualBucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VirtualBucket) XXX_Merge 

func (m *VirtualBucket) XXX_Merge(src proto.Message)

func (*VirtualBucket) XXX_Size 

func (m *VirtualBucket) XXX_Size() int

func (*VirtualBucket) XXX_Unmarshal 

func (m *VirtualBucket) XXX_Unmarshal(b []byte) error

type VirtualBucketConditionType 

type VirtualBucketConditionType string

type VirtualBucketList 

type VirtualBucketList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Items []VirtualBucket `json:"items" protobuf:"bytes,2,rep,name=items"`
}

VirtualBucketList is a list of VirtualBuckets +kubebuilder:object:root=true

func (*VirtualBucketList) DeepCopy 

func (in *VirtualBucketList) DeepCopy() *VirtualBucketList

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

func (*VirtualBucketList) DeepCopyInto 

func (in *VirtualBucketList) DeepCopyInto(out *VirtualBucketList)

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

func (*VirtualBucketList) DeepCopyObject 

func (in *VirtualBucketList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*VirtualBucketList) Descriptor 

func (*VirtualBucketList) Descriptor() ([]byte, []int)

func (*VirtualBucketList) Marshal 

func (m *VirtualBucketList) Marshal() (dAtA []byte, err error)

func (*VirtualBucketList) MarshalTo 

func (m *VirtualBucketList) MarshalTo(dAtA []byte) (int, error)

func (*VirtualBucketList) MarshalToSizedBuffer 

func (m *VirtualBucketList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VirtualBucketList) ProtoMessage 

func (*VirtualBucketList) ProtoMessage()

func (*VirtualBucketList) Reset 

func (m *VirtualBucketList) Reset()

func (*VirtualBucketList) Size 

func (m *VirtualBucketList) Size() (n int)

func (*VirtualBucketList) String 

func (this *VirtualBucketList) String() string

func (*VirtualBucketList) Unmarshal 

func (m *VirtualBucketList) Unmarshal(dAtA []byte) error

func (*VirtualBucketList) XXX_DiscardUnknown 

func (m *VirtualBucketList) XXX_DiscardUnknown()

func (*VirtualBucketList) XXX_Marshal 

func (m *VirtualBucketList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VirtualBucketList) XXX_Merge 

func (m *VirtualBucketList) XXX_Merge(src proto.Message)

func (*VirtualBucketList) XXX_Size 

func (m *VirtualBucketList) XXX_Size() int

func (*VirtualBucketList) XXX_Unmarshal 

func (m *VirtualBucketList) XXX_Unmarshal(b []byte) error

type VirtualBucketSpec 

type VirtualBucketSpec struct {
	// The name of the Connection resource which exists under the same tenant as the object. The Connection
	// should represent the external location and access credentials of an object storage system
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:MaxLength=64
	// +kubebuilder:default:=""
	ConnectionName string `json:"connectionName,omitempty" protobuf:"bytes,2,opt,name=connectionName"`
	// User-provided description of the object
	// +kubebuilder:validation:MaxLength=512
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" protobuf:"bytes,3,opt,name=description"`
	// The name of the Account which created the object, which exists in the same tenant as the object
	// +kubebuilder:default:="no-one"
	// +kubebuilder:validation:Optional
	Owner *string `json:"owner,omitempty" protobuf:"bytes,4,opt,name=owner"`
}

VirtualBucketSpec defines the desired state of VirtualBucket

func (*VirtualBucketSpec) DeepCopy 

func (in *VirtualBucketSpec) DeepCopy() *VirtualBucketSpec

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

func (*VirtualBucketSpec) DeepCopyInto 

func (in *VirtualBucketSpec) DeepCopyInto(out *VirtualBucketSpec)

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

func (*VirtualBucketSpec) Descriptor 

func (*VirtualBucketSpec) Descriptor() ([]byte, []int)

func (*VirtualBucketSpec) Marshal 

func (m *VirtualBucketSpec) Marshal() (dAtA []byte, err error)

func (*VirtualBucketSpec) MarshalTo 

func (m *VirtualBucketSpec) MarshalTo(dAtA []byte) (int, error)

func (*VirtualBucketSpec) MarshalToSizedBuffer 

func (m *VirtualBucketSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VirtualBucketSpec) ProtoMessage 

func (*VirtualBucketSpec) ProtoMessage()

func (*VirtualBucketSpec) Reset 

func (m *VirtualBucketSpec) Reset()

func (*VirtualBucketSpec) Size 

func (m *VirtualBucketSpec) Size() (n int)

func (*VirtualBucketSpec) String 

func (this *VirtualBucketSpec) String() string

func (*VirtualBucketSpec) Unmarshal 

func (m *VirtualBucketSpec) Unmarshal(dAtA []byte) error

func (*VirtualBucketSpec) XXX_DiscardUnknown 

func (m *VirtualBucketSpec) XXX_DiscardUnknown()

func (*VirtualBucketSpec) XXX_Marshal 

func (m *VirtualBucketSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VirtualBucketSpec) XXX_Merge 

func (m *VirtualBucketSpec) XXX_Merge(src proto.Message)

func (*VirtualBucketSpec) XXX_Size 

func (m *VirtualBucketSpec) XXX_Size() int

func (*VirtualBucketSpec) XXX_Unmarshal 

func (m *VirtualBucketSpec) XXX_Unmarshal(b []byte) error

type VirtualBucketStatus 

type VirtualBucketStatus struct {
	// Last time the object was updated
	//+kubebuilder:validation:Optional
	UpdatedAt *metav1.Time `json:"updatedAt,omitempty" protobuf:"bytes,1,opt,name=updatedAt"`
	// ObservedGeneration is the Last generation that was acted on
	//+kubebuilder:validation:Optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty" protobuf:"varint,3,opt,name=observedGeneration"`
	// In the case of failure, the VirtualBucket resource controller will set this field with a failure message
	//+kubebuilder:validation:Optional
	FailureMessage *string `json:"failureMessage,omitempty" protobuf:"bytes,5,opt,name=failureMessage"`
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +kubebuilder:validation:Optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,6,rep,name=conditions"`
}

VirtualBucketStatus defines the observed state of a VirtualBucket

func (*VirtualBucketStatus) DeepCopy 

func (in *VirtualBucketStatus) DeepCopy() *VirtualBucketStatus

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

func (*VirtualBucketStatus) DeepCopyInto 

func (in *VirtualBucketStatus) DeepCopyInto(out *VirtualBucketStatus)

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

func (*VirtualBucketStatus) Descriptor 

func (*VirtualBucketStatus) Descriptor() ([]byte, []int)

func (*VirtualBucketStatus) Marshal 

func (m *VirtualBucketStatus) Marshal() (dAtA []byte, err error)

func (*VirtualBucketStatus) MarshalTo 

func (m *VirtualBucketStatus) MarshalTo(dAtA []byte) (int, error)

func (*VirtualBucketStatus) MarshalToSizedBuffer 

func (m *VirtualBucketStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VirtualBucketStatus) ProtoMessage 

func (*VirtualBucketStatus) ProtoMessage()

func (*VirtualBucketStatus) Reset 

func (m *VirtualBucketStatus) Reset()

func (*VirtualBucketStatus) Size 

func (m *VirtualBucketStatus) Size() (n int)

func (*VirtualBucketStatus) String 

func (this *VirtualBucketStatus) String() string

func (*VirtualBucketStatus) Unmarshal 

func (m *VirtualBucketStatus) Unmarshal(dAtA []byte) error

func (*VirtualBucketStatus) XXX_DiscardUnknown 

func (m *VirtualBucketStatus) XXX_DiscardUnknown()

func (*VirtualBucketStatus) XXX_Marshal 

func (m *VirtualBucketStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VirtualBucketStatus) XXX_Merge 

func (m *VirtualBucketStatus) XXX_Merge(src proto.Message)

func (*VirtualBucketStatus) XXX_Size 

func (m *VirtualBucketStatus) XXX_Size() int

func (*VirtualBucketStatus) XXX_Unmarshal 

func (m *VirtualBucketStatus) XXX_Unmarshal(b []byte) error

type VirtualClusterSpec 

type VirtualClusterSpec struct {
	// Indicates if the lab should run on its own virtual cluster.
	// Currently not supported
	// +kubebuilder:validation:Optional
	// +kubebuilder:default:=false
	Enabled *bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"`
	// Description is the user provided description
	//+kubebuilder:default:=""
	//+optional
	Description *string `json:"description.omitempty" protobuf:"bytes,2,opt,name=description"`
	// Nodes is the desired number of nodes
	//+kubebuilder:default:=1
	//+kubebuilder:validation:Minimum=1
	//+kubebuilder:validation:Maximum=10
	// +kubebuilder:validation:Optional
	Replicas *int32 `json:"nodes,omitempty" protobuf:"varint,3,opt,name=nodes"`
	// +kubebuilder:validation:Optional
	// NodeClassName is the class of nodes or vm
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	InstanceType *string `json:"instanceType,omitempty" protobuf:"bytes,4,opt,name=instanceType"`
	// +kubebuilder:validation:Optional
	// Gpus is the desired number of gpus
	//+kubebuilder:default:=0
	//+kubebuilder:validation:Minimum=0
	//+kubebuilder:validation:Maximum=10
	// +kubebuilder:validation:Optional
	Gpus *int32 `json:"gpus,omitempty" protobuf:"varint,5,opt,name=gpus"`
	// +kubebuilder:validation:Optional
	// GpuClassName is the The class of gpu.
	// +kubebuilder:default:=""
	// +kubebuilder:validation:Optional
	GpuClassName *string `json:"gpuClassName,omitempty" protobuf:"bytes,6,opt,name=gpuClassName"`
	// +kubebuilder:validation:Optional
	// VolumeSize is the size of the volume that would be mounted on all the node of the cluster
	//+kubebuilder:default:=0
	//+kubebuilder:validation:Minimum=0
	//+kubebuilder:validation:Maximum=10
	// +kubebuilder:validation:Optional
	VolumeSize *int32 `json:"volumeSize,omitempty" protobuf:"varint,7,opt,name=volumeSize"`
	// +kubebuilder:validation:Optional
	// Spot indicate if we should we use spot instances.
	//+kubebuilder:default:=false
	//+optional
	Spot *bool `json:"spot,omitempty" protobuf:"varint,8,opt,name=spot"`
	// ConnectionName refer to the name of the provider connection
	// +kubebuilder:default:=""
	ConnectionName *string `json:"connectionName,omitempty" protobuf:"bytes,9,opt,name=connectionName"`
	// Owner is the account name of the owner of this cluster
	// +kubebuilder:default:="no-one"
	// +kubebuilder:validation:Optional
	Owner *string `json:"owner,omitempty" protobuf:"bytes,10,opt,name=owner"`
	// Specify resource limits for the virtual cluster
	// +kubebuilder:validation:Optional
	Limits *ResourceLimitSpec `json:"limits,omitempty" protobuf:"bytes,11,opt,name=limits"`
	// The cloud region, if this cluster is created in a public cloud
	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" protobuf:"bytes,12,opt,name=region"`
	// The cloud AZ, if this cluster is created in a public cloud
	// +kubebuilder:validation:Optional
	Az *string `json:"az,omitempty" protobuf:"bytes,13,opt,name=az"`
	// The cluster kubernetes version
	// +kubebuilder:validation:Optional
	KubernetesVersion *string `json:"kubernetesVersion,omitempty" protobuf:"bytes,14,opt,name=kubernetesVersion"`
	// Set to true, for auto scaling cluster
	// +kubebuilder:validation:Optional
	AutoScale *bool `json:"autoscale,omitempty" protobuf:"varint,15,opt,name=autoscale"`
	// Minimum number of nodes for auto scaling
	// +kubebuilder:validation:Optional
	MinNodes *int32 `json:"minNodes,omitempty" protobuf:"varint,16,opt,name=minNodes"`
	// Maximum number of nodes for auto scaling
	// +kubebuilder:validation:Optional
	MaxNodes *int32 `json:"maxNodes,omitempty" protobuf:"varint,17,opt,name=maxNodes"`
	// a reference to the cloud object in the catalog that will host the external cluster
	// +kubebuilder:validation:Optional
	CloudRef corev1.ObjectReference `json:"cloudRef,omitempty" protobuf:"bytes,18,opt,name=cloudRef"`
	// a reference to the ssh key
	// +kubebuilder:validation:Optional
	SSHKey *string `json:"sshKey,omitempty" protobuf:"bytes,19,opt,name=sshKey"`
}

func (*VirtualClusterSpec) DeepCopy 

func (in *VirtualClusterSpec) DeepCopy() *VirtualClusterSpec

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

func (*VirtualClusterSpec) DeepCopyInto 

func (in *VirtualClusterSpec) DeepCopyInto(out *VirtualClusterSpec)

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

func (*VirtualClusterSpec) Descriptor 

func (*VirtualClusterSpec) Descriptor() ([]byte, []int)

func (*VirtualClusterSpec) Marshal 

func (m *VirtualClusterSpec) Marshal() (dAtA []byte, err error)

func (*VirtualClusterSpec) MarshalTo 

func (m *VirtualClusterSpec) MarshalTo(dAtA []byte) (int, error)

func (*VirtualClusterSpec) MarshalToSizedBuffer 

func (m *VirtualClusterSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VirtualClusterSpec) ProtoMessage 

func (*VirtualClusterSpec) ProtoMessage()

func (*VirtualClusterSpec) Reset 

func (m *VirtualClusterSpec) Reset()

func (*VirtualClusterSpec) Size 

func (m *VirtualClusterSpec) Size() (n int)

func (*VirtualClusterSpec) String 

func (this *VirtualClusterSpec) String() string

func (*VirtualClusterSpec) Unmarshal 

func (m *VirtualClusterSpec) Unmarshal(dAtA []byte) error

func (*VirtualClusterSpec) XXX_DiscardUnknown 

func (m *VirtualClusterSpec) XXX_DiscardUnknown()

func (*VirtualClusterSpec) XXX_Marshal 

func (m *VirtualClusterSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VirtualClusterSpec) XXX_Merge 

func (m *VirtualClusterSpec) XXX_Merge(src proto.Message)

func (*VirtualClusterSpec) XXX_Size 

func (m *VirtualClusterSpec) XXX_Size() int

func (*VirtualClusterSpec) XXX_Unmarshal 

func (m *VirtualClusterSpec) XXX_Unmarshal(b []byte) error

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.