apiserver

Documentation

Index

• Constants
• func OperatorURI() string
• type ApiCronJob
  • func (apiCronJob *ApiCronJob) Validate() error
• type ApiPipeline
• type ApiPipelineSpec
• type ApiServer
  • func NewApiServer(namespace string, kubeclientset kubernetes.Interface, ...) *ApiServer
  • func (s *ApiServer) ServeHTTP(resp http.ResponseWriter, req *http.Request)
  • func (s *ApiServer) Start()
  • func (s *ApiServer) Stop()

Constants

const (
	ActionPause  = "pause"
	ActionResume = "resume"
)

Functions

func OperatorURI

func OperatorURI() string

Types

type ApiCronJob

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

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()