handler

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Dec 15, 2020 License: LGPL-3.0 Imports: 33 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	// EtcdSSLPath ssl file path for etcd
	EtcdSSLPath = "/run/ssl/etcd"
	// RegionDatabaseName -
	RegionDatabaseName = "region"
	// ConsoleDatabaseName -
	ConsoleDatabaseName = "console"
)

Variables

View Source 
var APIName = "rbd-api"

APIName name

View Source 
var AppUIDBMigrationsName = "rbd-app-ui-migrations"

AppUIDBMigrationsName -

View Source 
var AppUIName = "rbd-app-ui"

AppUIName name for rbd-app-ui resources.

View Source 
var ChaosName = "rbd-chaos"

ChaosName name for rbd-chaos

View Source 
var (
	// DBName name
	DBName = "rbd-db"
)
View Source 
var DashboardMetricsScraperName = "dashboard-metrics-scraper"

DashboardMetricsScraperName -

View Source 
var ErrNoDBEndpoints = errors.New("no ready endpoints for DB were found")

ErrNoDBEndpoints -

View Source 
var ErrV1beta1MetricsExists = errors.New("v1beta1.metrics.k8s.io already exists")

ErrV1beta1MetricsExists -

View Source 
var EtcdName = "rbd-etcd"

EtcdName name for rbd-etcd.

View Source 
var EventLogName = "rbd-eventlog"

EventLogName name for rbd-eventlog.

View Source 
var GatewayName = "rbd-gateway"

GatewayName name for rbd-gateway.

View Source 
var HubName = "rbd-hub"

HubName name

View Source 
var KubernetesDashboardName = "kubernetes-dashboard"

KubernetesDashboardName -

View Source 
var MQName = "rbd-mq"

MQName name for rbd-mq

View Source 
var MetricsServerName = "metrics-server"

MetricsServerName name for metrics-server

View Source 
var MonitorName = "rbd-monitor"

MonitorName name for rbd-monitor.

View Source 
var NFSName = "nfs-provisioner"

NFSName name for nfs provisioner

View Source 
var NodeName = "rbd-node"

NodeName name for rbd-node

View Source 
var ResourceProxyName = "rbd-resource-proxy"

ResourceProxyName name for rbd-resource-proxy.

View Source 
var WebCliName = "rbd-webcli"

WebCliName name for rbd-webcli.

View Source 
var WorkerName = "rbd-worker"

WorkerName name for rbd-worker.

Functions

func IsIgnoreError 

func IsIgnoreError(err error) bool

IsIgnoreError check if the given err is IgnoreError.

func IsRainbondVolumeNotFound 

func IsRainbondVolumeNotFound(e error) bool

IsRainbondVolumeNotFound checks if the given error is RainbondVolumeNotFound.

func LabelsForRainbondComponent 

func LabelsForRainbondComponent(cpt *rainbondv1alpha1.RbdComponent) map[string]string

LabelsForRainbondComponent returns the labels for the sub resources of rbdcomponent.

Types

type ClusterScopedResourcesCreator added in v1.3.0 

type ClusterScopedResourcesCreator interface {
	// returns the resources that should be created if not exists
	CreateClusterScoped() []interface{}
}

ClusterScopedResourcesCreator provides methods to create or update k8s resources which in cluster-scoped , such as daemonset, daemonset, etc.

type ComponentHandler 

type ComponentHandler interface {
	// Before will do something before creating component, such as checking the prerequisites, etc.
	Before() error
	Resources() []interface{}
	After() error
	ListPods() ([]corev1.Pod, error)
}

ComponentHandler will check the prerequisites, create resources for rbdcomponent.

func NewAPI 

func NewAPI(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewAPI new api handle

func NewAliyunCSIDiskPlugin 

func NewAliyunCSIDiskPlugin(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewAliyunCSIDiskPlugin creates a new aliyun csi disk plugin handler.

func NewAliyunCSINasPlugin 

func NewAliyunCSINasPlugin(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewAliyunCSINasPlugin creates a new aliyun csi nas plugin handler.

func NewAliyunCSINasProvisioner 

func NewAliyunCSINasProvisioner(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewAliyunCSINasProvisioner creates a new aliyun csi nas provisioner handler.

func NewAppUI 

func NewAppUI(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewAppUI creates a new rbd-app-ui handler.

func NewChaos 

func NewChaos(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewChaos creates a new rbd-chaos handler.

func NewDB 

func NewDB(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewDB new db

func NewDashboardMetricsScraper added in v1.3.0 

func NewDashboardMetricsScraper(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewDashboardMetricsScraper -

func NewETCD 

func NewETCD(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewETCD creates a new rbd-etcd handler.

func NewEventLog 

func NewEventLog(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewEventLog creates a new rbd-eventlog handler.

func NewGateway 

func NewGateway(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewGateway returns a new rbd-gateway handler.

func NewHub 

func NewHub(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewHub nw hub

func NewK8sDashboard added in v1.3.0 

func NewK8sDashboard(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewK8sDashboard -

func NewMQ 

func NewMQ(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewMQ creates a new rbd-mq handler.

func NewMetricsServer 

func NewMetricsServer(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewMetricsServer creates a new metrics-server handler

func NewMonitor 

func NewMonitor(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewMonitor returns a new rbd-monitor handler.

func NewNFS 

func NewNFS(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewNFS creates a new rbd-nfs handler.

func NewNode 

func NewNode(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewNode creates a new rbd-node handler.

func NewResourceProxy added in v1.3.0 

func NewResourceProxy(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewResourceProxy creates a new rbd-resourceProxy hanlder.

func NewWebCli 

func NewWebCli(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewWebCli creates a new rbd-webcli handler.

func NewWorker 

func NewWorker(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewWorker creates a new rbd-worker hanlder.

func NewaliyunCSIDiskProvisioner 

func NewaliyunCSIDiskProvisioner(ctx context.Context, client client.Client, component *rainbondv1alpha1.RbdComponent, cluster *rainbondv1alpha1.RainbondCluster) ComponentHandler

NewaliyunCSIDiskProvisioner creates a new aliyun csi disk provisioner handler.

type IgnoreError 

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

IgnoreError is the error with ignore by rbdcomponent controller.

func NewIgnoreError 

func NewIgnoreError(msg string) *IgnoreError

NewIgnoreError creates a new IgnoreError

func (*IgnoreError) Error 

func (i *IgnoreError) Error() string

type Replicaser 

type Replicaser interface {
	// return replicas for rbdcomponent.
	Replicas() *int32
}

Replicaser provides methods to get replicas for rbdcomponent. This interface is generally used when the actual number of component is different from the spec definition.

type ResourcesCreator added in v1.3.0 

type ResourcesCreator interface {
	// returns the resources that should be created if not exists
	ResourcesCreateIfNotExists() []interface{}
}

ResourcesCreator provides methods to create or update k8s resources, such as daemonset, daemonset, etc.

type ResourcesDeleter added in v1.3.0 

type ResourcesDeleter interface {
	// returns the resources that need to be delete if exists.
	ResourcesNeedDelete() []interface{}
}

ResourcesDeleter -

type StorageClassRWOer 

type StorageClassRWOer interface {
	SetStorageClassNameRWO(pvcParameters *pvcParameters)
}

StorageClassRWOer provides methods to setup storageclass with access mode RWO for rbdcomponent.

type StorageClassRWXer 

type StorageClassRWXer interface {
	SetStorageClassNameRWX(pvcParameters *pvcParameters)
}

StorageClassRWXer provides methods to setup storageclass with access mode RWX for rbdcomponent.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.