Documentation
¶
Index ¶
- func AmendCreationStatus(status *v1alpha1.PachydermPipelineStatus, ...)
- func AmendRunningStatus(status *v1alpha1.PachydermPipelineStatus, ...)
- func CheckPipelineEquality(newPipeline *v1alpha1.PachydermPipeline, existingPipeline *pps.PipelineInfo, ...) bool
- func CreateRequest(pipeline v1alpha1.PachydermPipeline) *pps.CreatePipelineRequest
- func CreateStatus() v1alpha1.PachydermPipelineStatus
- func PipelineInfoListToMap(list []*pps.PipelineInfo) (mapping map[string]*pps.PipelineInfo)
- func PrettyPrint(v interface{}) (err error)
- func RemoveStringFromSlice(ss []string, s string) []string
- func StringPresentInSlice(ss []string, s string) bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AmendCreationStatus ¶
func AmendCreationStatus(status *v1alpha1.PachydermPipelineStatus, statusCondition v1alpha1.PipelineStatus, message string, reason string)
ammend the Creation status inplace.
func AmendRunningStatus ¶
func AmendRunningStatus(status *v1alpha1.PachydermPipelineStatus, statusCondition v1alpha1.PipelineStatus, message string, reason string)
TODO: refactor these two functions into one function. ammend the running status inplace.
func CheckPipelineEquality ¶
func CheckPipelineEquality(newPipeline *v1alpha1.PachydermPipeline, existingPipeline *pps.PipelineInfo, logger *zap.Logger) bool
func CreateRequest ¶
func CreateRequest(pipeline v1alpha1.PachydermPipeline) *pps.CreatePipelineRequest
func CreateStatus ¶
func CreateStatus() v1alpha1.PachydermPipelineStatus
Returns an array with the PipelineStatus Object.
func PipelineInfoListToMap ¶
func PipelineInfoListToMap(list []*pps.PipelineInfo) (mapping map[string]*pps.PipelineInfo)
func PrettyPrint ¶
func PrettyPrint(v interface{}) (err error)
func RemoveStringFromSlice ¶
func StringPresentInSlice ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.