handler

Documentation

Index

• Constants
• Variables
• func IsIgnoreError(err error) bool
• type ComponentHandler
  • func NewAPI(ctx context.Context, client client.Client, ...) ComponentHandler
  • func NewAppUI(ctx context.Context, client client.Client, ...) ComponentHandler
  • func NewChaos(ctx context.Context, client client.Client, ...) ComponentHandler
  • func NewDB(ctx context.Context, client client.Client, ...) ComponentHandler
  • func NewDNS(ctx context.Context, client client.Client, ...) ComponentHandler
  • func NewETCD(ctx context.Context, client client.Client, ...) ComponentHandler
  • func NewEventLog(ctx context.Context, client client.Client, ...) ComponentHandler
  • func NewGateway(ctx context.Context, client client.Client, ...) ComponentHandler
  • func NewHub(ctx context.Context, client client.Client, ...) ComponentHandler
  • func NewMQ(ctx context.Context, client client.Client, ...) ComponentHandler
  • func NewMonitor(ctx context.Context, client client.Client, ...) ComponentHandler
  • func NewNFSProvisioner(ctx context.Context, client client.Client, ...) ComponentHandler
  • func NewNode(ctx context.Context, client client.Client, ...) ComponentHandler
  • func NewRepo(ctx context.Context, client client.Client, ...) ComponentHandler
  • func NewWebCli(ctx context.Context, client client.Client, ...) ComponentHandler
  • func NewWorker(ctx context.Context, client client.Client, ...) ComponentHandler
• type IgnoreError
  • func NewIgnoreError(msg string) *IgnoreError
  • func (i *IgnoreError) Error() string

Constants

const (
	EtcdSSLPath = "/run/ssl/etcd"
)

Variables

var APIName = "rbd-api"

var AppUIName = "rbd-app-ui"

var ChaosName = "rbd-chaos"

var DBName = "rbd-db"

var DNSName = "rbd-dns"

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

var EtcdName = "rbd-etcd"

var EventLogName = "rbd-eventlog"

var GatewayName = "rbd-gateway"

var HubName = "rbd-hub"

var MQName = "rbd-mq"

var MonitorName = "rbd-monitor"

var NFSName = constants.DefStorageClass

var NodeName = "rbd-node"

var RepoName = "rbd-repo"

var WebCliName = "rbd-webcli"

var WorkerName = "rbd-worker"

Functions

func IsIgnoreError

func IsIgnoreError(err error) bool

IsIgnoreError check if the given err is IgnoreError.

Types

type ComponentHandler

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

func NewAPI

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

func NewAppUI

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

func NewChaos

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

func NewDB

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

func NewDNS

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

func NewETCD

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

func NewEventLog

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

func NewGateway

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

func NewHub

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

func NewMQ

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

func NewMonitor

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

func NewNFSProvisioner

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

func NewNode

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

func NewRepo

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

func NewWebCli

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

func NewWorker

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

type IgnoreError

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

func NewIgnoreError

func NewIgnoreError(msg string) *IgnoreError

func (*IgnoreError) Error

func (i *IgnoreError) Error() string