api_server

Documentation

Index

• Constants
• Variables
• func CreateErrorCouldNotRecoverAPIStatus(err error) error
• func CreateErrorFromAPIStatus(error string, code int32) error
• func NewHTTPRuntime(clientConfig clientcmd.ClientConfig, debug bool) (*httptransport.Runtime, error)
• func NewKubeflowInClusterHTTPRuntime(namespace string, debug bool) *httptransport.Runtime

Constants

const (
	APIServerDefaultTimeout = 35 * time.Second
)

Variables

var PassThroughAuth runtime.ClientAuthInfoWriter = runtime.ClientAuthInfoWriterFunc(
	func(_ runtime.ClientRequest, _ strfmt.Registry) error { return nil })

PassThroughAuth never manipulates the request

var SATokenVolumeProjectionAuth runtime.ClientAuthInfoWriter = runtime.ClientAuthInfoWriterFunc(
	func(r runtime.ClientRequest, _ strfmt.Registry) error {
		var projectedPath string
		if projectedPath = os.Getenv(saTokenPathEnvVar); projectedPath == "" {
			projectedPath = saDefaultTokenPath
		}

		content, err := ioutil.ReadFile(projectedPath)
		if err != nil {
			return fmt.Errorf("Failed to read projected SA token at %s: %w", projectedPath, err)
		}

		r.SetHeaderParam("Authorization", "Bearer "+string(content))
		return nil
	})

Functions

func CreateErrorCouldNotRecoverAPIStatus

func CreateErrorCouldNotRecoverAPIStatus(err error) error

func CreateErrorFromAPIStatus

func CreateErrorFromAPIStatus(error string, code int32) error

func NewHTTPRuntime

func NewHTTPRuntime(clientConfig clientcmd.ClientConfig, debug bool) (
	*httptransport.Runtime, error)

func NewKubeflowInClusterHTTPRuntime

func NewKubeflowInClusterHTTPRuntime(namespace string, debug bool) *httptransport.Runtime