apiserver

Documentation

Index

• Constants
• Variables
• func LogRequestMiddleware(next http.Handler) http.Handler
• func NewFlowifyServer(k8Client kubernetes.Interface, namespace string, ...) (flowifyServer, error)
• func NewFlowifyServerFromConfig(cfg Config) (flowifyServer, error)
• func SetCustomHeaders(next http.Handler) http.Handler
• type Config
  • func LoadConfigFromPath(path string) (Config, error)
  • func LoadConfigFromReader(stream io.Reader) (Config, error)
  • func (cfg Config) Dump(path string) error
  • func (cfg Config) String() string
• type KubernetesKonfig
• type LogConfig
• type ServerConfig

Constants

const ApiV1Path string = "/api/v1"

Variables

var BuildTime = "unknown"

var CommitSHA = "unknown"

Functions

func LogRequestMiddleware

func LogRequestMiddleware(next http.Handler) http.Handler

func NewFlowifyServer

func NewFlowifyServer(k8Client kubernetes.Interface,
	namespace string,
	wfclient argo_workflow.Interface,
	nodeStorage storage.ComponentClient,
	volumeStorage storage.VolumeClient,
	portnumber int,
	sec auth.AuthenticationClient) (flowifyServer, error)

func NewFlowifyServerFromConfig

func NewFlowifyServerFromConfig(cfg Config) (flowifyServer, error)

func SetCustomHeaders

func SetCustomHeaders(next http.Handler) http.Handler

Types

type Config

type Config struct {
	DbConfig         storage.DbConfig `mapstructure:"db"`
	KubernetesKonfig KubernetesKonfig `mapstructure:"kubernetes"`
	AuthConfig       auth.AuthConfig  `mapstructure:"auth"`

	LogConfig    LogConfig    `mapstructure:"logging"`
	ServerConfig ServerConfig `mapstructure:"server"`
}

func LoadConfigFromPath

func LoadConfigFromPath(path string) (Config, error)

func LoadConfigFromReader

func LoadConfigFromReader(stream io.Reader) (Config, error)

func (Config) Dump

func (cfg Config) Dump(path string) error

func (Config) String

func (cfg Config) String() string

type KubernetesKonfig

type KubernetesKonfig struct {
	KubeConfigPath string `mapstructure:"kubeconfigpath"`
	Namespace      string `mapstructure:"namespace"`
}

type LogConfig

type LogConfig struct {
	LogLevel string `mapstructure:"loglevel"`
}

type ServerConfig

type ServerConfig struct {
	Port int `mapstructure:"port"`
}