proxy

Documentation

Index

• Constants
• func NewTransportForKubeconfig(config *clientcmdapi.Config) (*http.Transport, error)
• type Authentication
  • func NewAuthentication() *Authentication
  • func (c *Authentication) AddFlags(fs *pflag.FlagSet)
  • func (c *Authentication) AdditionalAuthEnabled() bool
  • func (c *Authentication) ApplyTo(authenticationInfo *genericapiserver.AuthenticationInfo, ...) error
  • func (c *Authentication) Validate() []error
• type Authenticator
• type Options
  • func NewOptions() *Options
  • func (o *Options) AddFlags(fs *pflag.FlagSet)
  • func (o *Options) Complete(ctx context.Context) error
  • func (o *Options) Validate() []error
• type Server
  • func NewServer(ctx context.Context, o Options) (*Server, error)
  • func (s *Server) PermissionClient() v1.PermissionsServiceClient
  • func (s *Server) Run(ctx context.Context) error

Constants

const (
	EmbeddedSpiceDBEndpoint = "embedded://"
)

Functions

func NewTransportForKubeconfig

func NewTransportForKubeconfig(config *clientcmdapi.Config) (*http.Transport, error)

Types

type Authentication

type Authentication struct {
	BuiltInOptions *kubeoptions.BuiltInAuthenticationOptions
}

func NewAuthentication

func NewAuthentication() *Authentication

func (*Authentication) AddFlags

func (c *Authentication) AddFlags(fs *pflag.FlagSet)

func (*Authentication) AdditionalAuthEnabled

func (c *Authentication) AdditionalAuthEnabled() bool

func (*Authentication) ApplyTo

func (c *Authentication) ApplyTo(authenticationInfo *genericapiserver.AuthenticationInfo, servingInfo *genericapiserver.SecureServingInfo) error

func (*Authentication) Validate

func (c *Authentication) Validate() []error

type Authenticator

type Authenticator struct{}

type Options

type Options struct {
	SecureServing  apiserveroptions.SecureServingOptionsWithLoopback
	Authentication Authentication
	Logs           *logs.Options

	BackendKubeconfigPath string
	RestConfigFunc        func() (*rest.Config, http.RoundTripper, error)
	OverrideUpstream      bool
	UseInClusterConfig    bool
	RuleConfigFile        string
	Matcher               rules.Matcher

	CertDir string

	AuthenticationInfo    genericapiserver.AuthenticationInfo
	ServingInfo           *genericapiserver.SecureServingInfo
	AdditionalAuthEnabled bool

	WatchClient       v1.WatchServiceClient
	PermissionsClient v1.PermissionsServiceClient
	SpiceDBEndpoint   string
	EmbeddedSpiceDB   server.RunnableServer

	WorkflowDatabasePath string
	LockMode             string
	// contains filtered or unexported fields
}

func NewOptions

func NewOptions() *Options

func (*Options) AddFlags

func (o *Options) AddFlags(fs *pflag.FlagSet)

func (*Options) Complete

func (o *Options) Complete(ctx context.Context) error

func (*Options) Validate

func (o *Options) Validate() []error

type Server

type Server struct {
	Handler        http.Handler
	WorkflowWorker *distributedtx.Worker
	KubeClient     *kubernetes.Clientset
	Matcher        *rules.Matcher
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctx context.Context, o Options) (*Server, error)

func (*Server) PermissionClient

func (s *Server) PermissionClient() v1.PermissionsServiceClient

func (*Server) Run

func (s *Server) Run(ctx context.Context) error