Versions in this module Expand all Collapse all v0 v0.0.3 Nov 22, 2022 Changes in this version + const ConsoleMarketplace + const ConsoleOperatorSAToken + const DirectPVMode + const KESImageVersion + const XFS + var FlatSwaggerJSON json.RawMessage + var GlobalPublicCerts []*x509.Certificate + var GlobalRootCAs *x509.CertPool + var GlobalTLSCertsManager *xcerts.Manager + var Hostname = "" + var LicenseKey = "" + var LogError = logError + var LogInfo = logInfo + var Port = "9090" + var SessionDuration = 45 * time.Minute + var SwaggerJSON json.RawMessage + var TLSPort = "9443" + var TLSRedirect = "on" + func GenerateTenantConfigurationFile(configuration map[string]string) string + func GetParityInfo(nodes int64, disksPerNode int64) (models.ParityResponse, error) + func GetTenantConfiguration(ctx context.Context, clientSet K8sClientI, tenant *miniov2.Tenant) (map[string]string, error) + func GetTenantServiceURL(mi *miniov2.Tenant) (svcURL string) + type Context struct + HTTPPort int + HTTPSPort int + Host string + TLSCertificate string + TLSKey string + TLSRedirect string + TLSca string + func (c *Context) Load(ctx *cli.Context) error + type DirectPVDrivesClientI interface + List func(ctx context.Context, opts metav1.ListOptions) (*v1beta4.DirectCSIDriveList, error) + Update func(ctx context.Context, driveItem *v1beta4.DirectCSIDrive, ...) (*v1beta4.DirectCSIDriveList, error) + type DirectPVVolumesClientI interface + List func(ctx context.Context, opts metav1.ListOptions) (*v1beta4.DirectCSIVolumeList, error) + type K8sClientI interface + type NodeResourceInfo struct + AllocatableCPU int64 + AllocatableMemory int64 + Name string + type OperatorClientI interface + TenantDelete func(ctx context.Context, namespace string, instanceName string, ...) error + TenantGet func(ctx context.Context, namespace string, instanceName string, ...) (*miniov2.Tenant, error) + TenantList func(ctx context.Context, namespace string, opts metav1.ListOptions) (*miniov2.TenantList, error) + TenantPatch func(ctx context.Context, namespace string, instanceName string, pt types.PatchType, ...) (*miniov2.Tenant, error) + TenantUpdate func(ctx context.Context, tenant *miniov2.Tenant, opts metav1.UpdateOptions) (*miniov2.Tenant, error) + type Server struct + CleanupTimeout time.Duration + EnabledListeners []string + GracefulTimeout time.Duration + Host string + KeepAlive time.Duration + ListenLimit int + MaxHeaderSize flagext.ByteSize + Port int + ReadTimeout time.Duration + SocketPath flags.Filename + TLSCACertificate flags.Filename + TLSCertificate flags.Filename + TLSCertificateKey flags.Filename + TLSHost string + TLSKeepAlive time.Duration + TLSListenLimit int + TLSPort int + TLSReadTimeout time.Duration + TLSWriteTimeout time.Duration + WriteTimeout time.Duration + func NewServer(api *operations.OperatorAPI) *Server + func (s *Server) ConfigureAPI() + func (s *Server) ConfigureFlags() + func (s *Server) Fatalf(f string, args ...interface{}) + func (s *Server) GetHandler() http.Handler + func (s *Server) HTTPListener() (net.Listener, error) + func (s *Server) Listen() error + func (s *Server) Logf(f string, args ...interface{}) + func (s *Server) Serve() (err error) + func (s *Server) SetAPI(api *operations.OperatorAPI) + func (s *Server) SetHandler(handler http.Handler) + func (s *Server) Shutdown() error + func (s *Server) TLSListener() (net.Listener, error) + func (s *Server) UnixListener() (net.Listener, error)
Go to main page