apiserver

Documentation

Index

• Constants
• Variables
• func DefaultCAConfig() *certificate.CAConfig
• type Config
  • func NewConfig(genericConfig *genericapiserver.Config, k8sClient kubernetes.Interface, ...) *Config
  • func (c Config) New() (*TheiaManagerAPIServer, error)
• type ExtraConfig
• type TheiaManagerAPIServer
  • func (s *TheiaManagerAPIServer) Run(ctx context.Context) error

Constants

const (
	CertDir           = "/var/run/theia/theia-manager-tls"
	SelfSignedCertDir = "/var/run/theia/theia-manager-self-signed"
	Name              = "theia-manager-api"
	// AuthenticationTimeout specifies a time limit for requests made by the authorization webhook client
	// The default value (10 seconds) is not long enough as defined in
	// https://pkg.go.dev/k8s.io/apiserver@v0.21.0/pkg/server/options#NewDelegatingAuthenticationOptions
	// A value of zero means no timeout.
	AuthenticationTimeout = 0
)

Variables

var (

	// Codecs provides methods for retrieving codecs and serializers for specific
	// versions and content types.
	Codecs = serializer.NewCodecFactory(scheme)

	// #nosec G101: false positive triggered by variable name which includes "token"
	TokenPath = "/var/run/antrea/apiserver/loopback-client-token"
)

Functions

func DefaultCAConfig

func DefaultCAConfig() *certificate.CAConfig

Types

type Config

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

Config defines the config for Theia manager apiserver.

func NewConfig

func NewConfig(
	genericConfig *genericapiserver.Config,
	k8sClient kubernetes.Interface,
	kubeConfig *clientrest.Config,
	caCertController *certificate.CACertController,
	npRecommendationQuerier querier.NPRecommendationQuerier,
	clickHouseStatQuerier querier.ClickHouseStatQuerier,
	throughputAnomalyDetectorQuerier querier.ThroughputAnomalyDetectorQuerier,
) *Config

func (Config) New

func (c Config) New() (*TheiaManagerAPIServer, error)

type ExtraConfig

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

ExtraConfig holds custom apiserver config.

type TheiaManagerAPIServer

type TheiaManagerAPIServer struct {
	GenericAPIServer *genericapiserver.GenericAPIServer

	NPRecommendationQuerier          querier.NPRecommendationQuerier
	ClickHouseStatusQuerier          querier.ClickHouseStatQuerier
	ThroughputAnomalyDetectorQuerier querier.ThroughputAnomalyDetectorQuerier
	// contains filtered or unexported fields
}

func (*TheiaManagerAPIServer) Run

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