http

Documentation

Index

• Constants
• func GenericAPIServer(port int, reportPath string) manager.Runnable
• func SetupProfiling(r *mux.Router)
• func StaticFileServer(port int, path string) manager.Runnable
• type Event
  • func (e *Event) Type() string
  • func (e *Event) Validate() error
• type PostServer
  • func (s *PostServer) InjectCache(cache lifecycle.Cache)
  • func (s *PostServer) InjectConfig(cfg *config.Config)
  • func (s *PostServer) InjectEventRecorder(er record.EventRecorder)
  • func (s *PostServer) InjectReader(reader client.Reader)
  • func (s *PostServer) SaveFile(executionID, name string, data []byte) (string, error)
• type Server
  • func (s *Server) Start(stop <-chan struct{}) error

Constants

const (
	// CallbackBasePath callback path
	CallbackBasePath = "/report/{node}/{executionID}"
	// CallbackBaseResultSubPath result sub path
	CallbackBaseResultSubPath = "/result"
	// CallbackBaseFileSubPath file sub path
	CallbackBaseFileSubPath = "/file"
	// CallbackBaseEventSubPath event sub path
	CallbackBaseEventSubPath = "/event"

	// FileName query parameter name
	FileName = "name"
)

Functions

func GenericAPIServer

func GenericAPIServer(port int, reportPath string) manager.Runnable

GenericAPIServer prepare the generic api server

func SetupProfiling

func SetupProfiling(r *mux.Router)

SetupProfiling setup profiling

func StaticFileServer

func StaticFileServer(port int, path string) manager.Runnable

StaticFileServer prepare the static file server

Types

type Event

type Event struct {
	Waring  bool     `json:"warning"`
	Reason  string   `json:"reason" validate:"required,first_char_must_be_uppercase"`
	Message string   `json:"message,omitEmpty" validate:"required"`
	Args    []string `json:"args,omitEmpty"`
}

Event to be sent as k8s event

func (*Event) Type

func (e *Event) Type() string

func (*Event) Validate

func (e *Event) Validate() error

Validate the event

type PostServer

type PostServer struct {
	Server
	Cache         lifecycle.Cache
	ReportPath    string
	EventRecorder record.EventRecorder
	Config        *config.Config
	Client        client.Reader
}

PostServer post server

func (*PostServer) InjectCache

func (s *PostServer) InjectCache(cache lifecycle.Cache)

func (*PostServer) InjectConfig

func (s *PostServer) InjectConfig(cfg *config.Config)

func (*PostServer) InjectEventRecorder

func (s *PostServer) InjectEventRecorder(er record.EventRecorder)

func (*PostServer) InjectReader

func (s *PostServer) InjectReader(reader client.Reader)

func (*PostServer) SaveFile

func (s *PostServer) SaveFile(executionID, name string, data []byte) (string, error)

SaveFile save a received file

type Server

type Server struct {
	Port    int
	Kind    string
	Handler http.Handler
}

Server default server

func (*Server) Start

func (s *Server) Start(stop <-chan struct{}) error

Start the server