master

Documentation

Index

• Constants
• Variables
• func Run(version, buildDate string, opts Opts)
• type AuthProvider
• type BasicAuthProvider
  • func (p *BasicAuthProvider) Logout() http.Handler
  • func (p *BasicAuthProvider) Secure(handler http.Handler) http.Handler
• type BasicLdapAuthProvider
  • func NewBasicLdapAuthProvider(realm string, conn *ldap.Ldap) *BasicLdapAuthProvider
  • func (p *BasicLdapAuthProvider) Logout() http.Handler
  • func (p *BasicLdapAuthProvider) Secure(handler http.Handler) http.Handler
• type DBOpts
• type DefaultAz
  • func NewDefaultAz(directory az.Directory) *DefaultAz
  • func (a *DefaultAz) Authenticate(username string) string
  • func (a *DefaultAz) Identify(r *http.Request) (az.Principal, error)
• type DigestAuthProvider
  • func (p *DigestAuthProvider) Logout() http.Handler
  • func (p *DigestAuthProvider) Secure(handler http.Handler) http.Handler
• type DownloadHandler
  • func (s *DownloadHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Opts
• type UploadHandler
  • func (s *UploadHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type YarnOpts

Constants

const (
	DefaultPredictionServicePortsString = "1025:65535"
)

Variables

var DefaultConnection = data.Connection{
	"steam",
	"steam",
	"",
	"",
	"",
	"",
	"disable",
	"",
	"",
	"",
}

var DefaultOpts = &Opts{
	defaultWebAddress,
	"",
	"",
	"basic",
	"ldap.toml",
	path.Join(".", fs.VarDir, "master"),
	defaultClusterProxyAddress,
	defaultCompilationAddress,
	defaultPredictionServiceHost,
	defaultPredictionServicePorts,
	false,
	YarnOpts{false},
	DBOpts{DefaultConnection, "", ""},
}

Functions

func Run

func Run(version, buildDate string, opts Opts)

Types

type AuthProvider

type AuthProvider interface {
	Secure(handler http.Handler) http.Handler
	Logout() http.Handler
}

type BasicAuthProvider

type BasicAuthProvider struct {
	// contains filtered or unexported fields
}

func (*BasicAuthProvider) Logout

func (p *BasicAuthProvider) Logout() http.Handler

func (*BasicAuthProvider) Secure

func (p *BasicAuthProvider) Secure(handler http.Handler) http.Handler

type BasicLdapAuthProvider

type BasicLdapAuthProvider struct {
	// contains filtered or unexported fields
}

func NewBasicLdapAuthProvider

func NewBasicLdapAuthProvider(realm string, conn *ldap.Ldap) *BasicLdapAuthProvider

func (*BasicLdapAuthProvider) Logout

func (p *BasicLdapAuthProvider) Logout() http.Handler

Basic/Digest auth have no notion of logouts, so these handlers simply fail auth,

causing a 401 on the original realm, forcing the browser to re-auth.

func (*BasicLdapAuthProvider) Secure

func (p *BasicLdapAuthProvider) Secure(handler http.Handler) http.Handler

type DBOpts

type DBOpts struct {
	Connection        data.Connection
	SuperuserName     string
	SuperuserPassword string
}

type DefaultAz

type DefaultAz struct {
	// contains filtered or unexported fields
}

func NewDefaultAz

func NewDefaultAz(directory az.Directory) *DefaultAz

func (*DefaultAz) Authenticate

func (a *DefaultAz) Authenticate(username string) string

func (*DefaultAz) Identify

func (a *DefaultAz) Identify(r *http.Request) (az.Principal, error)

type DigestAuthProvider

type DigestAuthProvider struct {
	// contains filtered or unexported fields
}

func (*DigestAuthProvider) Logout

func (p *DigestAuthProvider) Logout() http.Handler

func (*DigestAuthProvider) Secure

func (p *DigestAuthProvider) Secure(handler http.Handler) http.Handler

type DownloadHandler

type DownloadHandler struct {
	// contains filtered or unexported fields
}

func (*DownloadHandler) ServeHTTP

func (s *DownloadHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Opts

type Opts struct {
	WebAddress                string
	WebTLSCertPath            string
	WebTLSKeyPath             string
	AuthProvider              string
	AuthConfig                string
	WorkingDirectory          string
	ClusterProxyAddress       string
	CompilationServiceAddress string
	PredictionServiceHost     string
	PredictionServicePorts    [2]int
	EnableProfiler            bool
	Yarn                      YarnOpts
	DB                        DBOpts
}

type UploadHandler

type UploadHandler struct {
	// contains filtered or unexported fields
}

func (*UploadHandler) ServeHTTP

func (s *UploadHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type YarnOpts

type YarnOpts struct {
	KerberosEnabled bool
}