v1alpha1

package
v0.0.0-...-4ca9e16 Latest Latest
Warning

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

 Go to latest Published: Jun 24, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

+k8s:deepcopy-gen=package +groupName=adarga.ai +k8s:openapi-gen=true +versionName=v1alpha1

Index

Constants

View Source 
const (
	GroupName string = "adarga.ai"
	Version   string = "valpha1"
	Plural    string = "pachydermpipelines"
	Singluar  string = "pachydermpipeline"
	ShortName string = "pipe"
	Name      string = Plural + "." + GroupName
)

Variables

View Source 
var (
	// SchemeBuilder initializes a scheme builder
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	// AddToScheme is a global function that registers this API group & version to a scheme
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: kubecodegeneratorpachyderm.GroupName, Version: version}

SchemeGroupVersion is group version used to register these objects

Functions

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

func VersionKind 

func VersionKind(kind string) schema.GroupVersionKind

VersionKind takes an unqualified kind and returns back a Group qualified GroupVersionKind

Types

type Egress 

type Egress struct {
	// +kubebuilder:validation:Required
	URL string `json:"url"`
}

func (*Egress) DeepCopy 

func (in *Egress) DeepCopy() *Egress

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

func (*Egress) DeepCopyInto 

func (in *Egress) DeepCopyInto(out *Egress)

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

type GPU 

type GPU struct {
	GPUType string `json:"type"`
	Number  int64  `json:"number"`
}

func (*GPU) DeepCopy 

func (in *GPU) DeepCopy() *GPU

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

func (*GPU) DeepCopyInto 

func (in *GPU) DeepCopyInto(out *GPU)

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

type Input 

type Input struct {
	// +kubebuilder:validation:Optional
	PFS *PFS `json:"pfs,omitempty"`
	// +kubebuilder:validation:Optional
	Join []*PFS `json:"join,omitempty"`
	// +kubebuilder:validation:Optional
	Cross []*PFS `json:"cross,omitempty"`
}

func (*Input) DeepCopy 

func (in *Input) DeepCopy() *Input

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

func (*Input) DeepCopyInto 

func (in *Input) DeepCopyInto(out *Input)

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

type PFS 

type PFS struct {
	// +kubebuilder:validation:Required
	Repo string `json:"repo"`
	// +kubebuilder:validation:Required
	Glob string `json:"glob"`
	// +kubebuilder:validation:Required
	Branch string `json:"branch"`
}

func (*PFS) DeepCopy 

func (in *PFS) DeepCopy() *PFS

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

func (*PFS) DeepCopyInto 

func (in *PFS) DeepCopyInto(out *PFS)

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

type PachydermPipeline 

type PachydermPipeline struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec PachydermPipelineSpec `json:"spec"`

	// +kubebuilder:validation:Optional
	Status PachydermPipelineStatus `json:"status,omitempty"`
}

+crd +genclient +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +kubebuilder:resource:singular=pachydermpipeline,path=pachydermpipelines,shortName=pipe,scope=Namespaced +groupName=adarga.ai +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:printcolumn:name=Created,type="string",JSONPath=`.status.conditions[?(@.type=="Creation")].status` +kubebuilder:printcolumn:name=Condition,type="string",JSONPath=`.status.conditions[?(@.type=="Running")].status`

func (*PachydermPipeline) DeepCopy 

func (in *PachydermPipeline) DeepCopy() *PachydermPipeline

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

func (*PachydermPipeline) DeepCopyInto 

func (in *PachydermPipeline) DeepCopyInto(out *PachydermPipeline)

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

func (*PachydermPipeline) DeepCopyObject 

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

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

type PachydermPipelineCondition 

type PachydermPipelineCondition struct {
	Type PachydermPipelineConditionType `json:"type" protobuf:"bytes,1,opt,name=type,casttype=ReplicationControllerConditionType"`
	// Status of the condition, one of True, False, Unknown.
	Status PipelineStatus `json:"status" protobuf:"bytes,2,opt,name=status,casttype=ConditionStatus"`

	// +optional
	Reason string `json:"reason,omitempty" protobuf:"bytes,4,opt,name=reason"`

	// +optional
	Message string `json:"message,omitempty" protobuf:"bytes,5,opt,name=message"`
}

Describes the state of a pipeline condition at a certain point in time.

func (*PachydermPipelineCondition) DeepCopy 

func (in *PachydermPipelineCondition) DeepCopy() *PachydermPipelineCondition

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

func (*PachydermPipelineCondition) DeepCopyInto 

func (in *PachydermPipelineCondition) DeepCopyInto(out *PachydermPipelineCondition)

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

type PachydermPipelineConditionType 

type PachydermPipelineConditionType string

The valid conditions of a pachyderm pipeline failure 

const (
	// When the pipeline object is not being instantiated properly (bad repo)
	PachydermPipelineCreationCondition PachydermPipelineConditionType = "Creation"
	// When the pipeline object has a finaliser, but no running pipeline in pachd.
	PachydermPipelineRunningCondition PachydermPipelineConditionType = "Running"
)

type PachydermPipelineList 

type PachydermPipelineList struct {
	metav1.TypeMeta
	metav1.ListMeta

	Items []PachydermPipeline
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*PachydermPipelineList) DeepCopy 

func (in *PachydermPipelineList) DeepCopy() *PachydermPipelineList

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

func (*PachydermPipelineList) DeepCopyInto 

func (in *PachydermPipelineList) DeepCopyInto(out *PachydermPipelineList)

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

func (*PachydermPipelineList) DeepCopyObject 

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

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

type PachydermPipelineSpec 

type PachydermPipelineSpec struct {

	// +kubebuilder:validation:Required
	Name string `json:"name"`
	// +kubebuilder:validation:Required
	Transform Transform `json:"transform"`
	// +kubebuilder:validation:Required
	Input Input `json:"input"`
	// +kubebuilder:validation:Required
	EnableStats bool `json:"enable_stats"`

	// +kubebuilder:validation:Optional
	Egress *string `json:"egress,omitempty"`
	// +kubebuilder:validation:Optional
	ResourceLimits *ResourceLimits `json:"resource_limits,omitempty"`
	// +kubebuilder:validation:Optional
	Description string `json:"description,omitempty"`
}

func (*PachydermPipelineSpec) DeepCopy 

func (in *PachydermPipelineSpec) DeepCopy() *PachydermPipelineSpec

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

func (*PachydermPipelineSpec) DeepCopyInto 

func (in *PachydermPipelineSpec) DeepCopyInto(out *PachydermPipelineSpec)

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

type PachydermPipelineStatus 

type PachydermPipelineStatus struct {
	// Conditions represents the latest available observations of a replication controllers current state.
	// +kubebuilder:validation:Optional
	// +patchMergeKey=type
	// +patchStrategy=merge
	Conditions []PachydermPipelineCondition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
}

func (*PachydermPipelineStatus) DeepCopy 

func (in *PachydermPipelineStatus) DeepCopy() *PachydermPipelineStatus

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

func (*PachydermPipelineStatus) DeepCopyInto 

func (in *PachydermPipelineStatus) DeepCopyInto(out *PachydermPipelineStatus)

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

type PipelineStatus 

type PipelineStatus string
const (
	ConditionRunning       PipelineStatus = "Running"
	ConditionMissing       PipelineStatus = "Missing"
	ConditionStopped       PipelineStatus = "Stopped"
	ConditionCreated       PipelineStatus = "Success"
	ConditionCreationError PipelineStatus = "CreationError"
	ConditionUnknown       PipelineStatus = "Unknown"
)

potentially breaking API guidelines by going for this format

type ResourceLimits 

type ResourceLimits struct {
	// +kubebuilder:validation:Optional
	Memory *string `json:"memory,omitempty"`
	// +kubebuilder:validation:Optional
	GPU *GPU `json:"gpu,omitempty"`
}

add CPU?

func (*ResourceLimits) DeepCopy 

func (in *ResourceLimits) DeepCopy() *ResourceLimits

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

func (*ResourceLimits) DeepCopyInto 

func (in *ResourceLimits) DeepCopyInto(out *ResourceLimits)

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

type Transform 

type Transform struct {
	// +kubebuilder:validation:Required
	CMD []string `json:"cmd"`
	// +kubebuilder:validation:Required
	Image string `json:"image"`

	// +kubebuilder:validation:Optional
	Env []v1.EnvVar `json:"env,omitempty"`
}

func (*Transform) DeepCopy 

func (in *Transform) DeepCopy() *Transform

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

func (*Transform) DeepCopyInto 

func (in *Transform) DeepCopyInto(out *Transform)

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

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.