apiserver

package
v0.3.12 Latest Latest
Warning

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

Go to latest
Published: Aug 16, 2019 License: Apache-2.0 Imports: 30 Imported by: 0

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

func (*ApiServer) ServeHTTP

func (s *ApiServer) ServeHTTP(resp http.ResponseWriter, req *http.Request)

func (*ApiServer) Start

func (s *ApiServer) Start()

func (*ApiServer) Stop

func (s *ApiServer) Stop()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL