proxy

package
v0.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 19, 2024 License: Apache-2.0 Imports: 48 Imported by: 0

Documentation

Index

Constants

View Source
const (
	EmbeddedSpiceDBEndpoint = "embedded://"
)

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL