Documentation
¶
Index ¶
Constants ¶
View Source
const ( ActionPause = "pause" ActionResume = "resume" )
Variables ¶
This section is empty.
Functions ¶
func OperatorURI ¶ added in v0.1.4
func OperatorURI() string
Types ¶
type ApiCronJob ¶ added in v0.1.4
type ApiCronJob struct {
PipelineName string `json:"pipeline"`
CronJobName string `json:"name"`
// Schedule takes a Cron format
// https://kubernetes.io/docs/tasks/job/automated-tasks-with-cron-jobs/#schedule
// THE TIMEZONE used by Schedule are based the timezone of the kubernetes master
Schedule string `json:"schedule"`
// Action is used to Pause and Resume a pipeline
Action string `json:action`
}
func (*ApiCronJob) Validate ¶ added in v0.1.4
func (apiCronJob *ApiCronJob) Validate() error
type ApiPipeline ¶
type ApiPipeline struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec ApiPipelineSpec `json:"spec"`
Status api.PipelineStatus `json:"status"`
}
type ApiPipelineSpec ¶
type ApiPipelineSpec struct {
api.PipelineSpec
Config *json.RawMessage `json:"config,omitempty"`
}
type ApiServer ¶
type ApiServer struct {
// contains filtered or unexported fields
}
func NewApiServer ¶
func NewApiServer( namespace string, kubeclientset kubernetes.Interface, pipeclientset client.Interface, controller controller.Interface, port int) *ApiServer
Click to show internal directories.
Click to hide internal directories.