Documentation
¶
Index ¶
- type RisingWaveObjectFactory
- func (f *RisingWaveObjectFactory) NewCompactorCloneSet(group string) *kruiseappsv1alpha1.CloneSet
- func (f *RisingWaveObjectFactory) NewCompactorDeployment(group string) *appsv1.Deployment
- func (f *RisingWaveObjectFactory) NewCompactorService() *corev1.Service
- func (f *RisingWaveObjectFactory) NewComputeAdvancedStatefulSet(group string) *kruiseappsv1beta1.StatefulSet
- func (f *RisingWaveObjectFactory) NewComputeService() *corev1.Service
- func (f *RisingWaveObjectFactory) NewComputeStatefulSet(group string) *appsv1.StatefulSet
- func (f *RisingWaveObjectFactory) NewConfigConfigMap(val string) *corev1.ConfigMap
- func (f *RisingWaveObjectFactory) NewFrontendCloneSet(group string) *kruiseappsv1alpha1.CloneSet
- func (f *RisingWaveObjectFactory) NewFrontendDeployment(group string) *appsv1.Deployment
- func (f *RisingWaveObjectFactory) NewFrontendService() *corev1.Service
- func (f *RisingWaveObjectFactory) NewMetaAdvancedStatefulSet(group string) *kruiseappsv1beta1.StatefulSet
- func (f *RisingWaveObjectFactory) NewMetaService() *corev1.Service
- func (f *RisingWaveObjectFactory) NewMetaStatefulSet(group string) *appsv1.StatefulSet
- func (f *RisingWaveObjectFactory) NewServiceMonitor() *prometheusv1.ServiceMonitor
- func (f *RisingWaveObjectFactory) NewStandaloneAdvancedStatefulSet() *kruiseappsv1beta1.StatefulSet
- func (f *RisingWaveObjectFactory) NewStandaloneService() *corev1.Service
- func (f *RisingWaveObjectFactory) NewStandaloneStatefulSet() *appsv1.StatefulSet
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RisingWaveObjectFactory ¶
type RisingWaveObjectFactory struct {
// contains filtered or unexported fields
}
RisingWaveObjectFactory is the object factory to help create owned objects like Deployments, StatefulSets, Services, etc.
func NewRisingWaveObjectFactory ¶
func NewRisingWaveObjectFactory(risingwave *risingwavev1alpha1.RisingWave, scheme *runtime.Scheme, operatorVersion string) *RisingWaveObjectFactory
NewRisingWaveObjectFactory creates a new RisingWaveObjectFactory.
func (*RisingWaveObjectFactory) NewCompactorCloneSet ¶ added in v0.2.4
func (f *RisingWaveObjectFactory) NewCompactorCloneSet(group string) *kruiseappsv1alpha1.CloneSet
NewCompactorCloneSet creates a new CloneSet for the compactor component and specified group.
func (*RisingWaveObjectFactory) NewCompactorDeployment ¶
func (f *RisingWaveObjectFactory) NewCompactorDeployment(group string) *appsv1.Deployment
NewCompactorDeployment creates a new Deployment for the compactor component and specified group.
func (*RisingWaveObjectFactory) NewCompactorService ¶
func (f *RisingWaveObjectFactory) NewCompactorService() *corev1.Service
NewCompactorService creates a new Service for the compactor.
func (*RisingWaveObjectFactory) NewComputeAdvancedStatefulSet ¶ added in v0.2.4
func (f *RisingWaveObjectFactory) NewComputeAdvancedStatefulSet(group string) *kruiseappsv1beta1.StatefulSet
NewComputeAdvancedStatefulSet creates a new OpenKruise StatefulSet for the compute component and specified group.
func (*RisingWaveObjectFactory) NewComputeService ¶
func (f *RisingWaveObjectFactory) NewComputeService() *corev1.Service
NewComputeService creates a new Service for the compute nodes.
func (*RisingWaveObjectFactory) NewComputeStatefulSet ¶
func (f *RisingWaveObjectFactory) NewComputeStatefulSet(group string) *appsv1.StatefulSet
NewComputeStatefulSet creates a new StatefulSet for the compute component and specified group.
func (*RisingWaveObjectFactory) NewConfigConfigMap ¶
func (f *RisingWaveObjectFactory) NewConfigConfigMap(val string) *corev1.ConfigMap
NewConfigConfigMap creates a new ConfigMap with the specified string value for risingwave.toml.
func (*RisingWaveObjectFactory) NewFrontendCloneSet ¶ added in v0.2.5
func (f *RisingWaveObjectFactory) NewFrontendCloneSet(group string) *kruiseappsv1alpha1.CloneSet
NewFrontendCloneSet creates a new CloneSet for the frontend component and specified group.
func (*RisingWaveObjectFactory) NewFrontendDeployment ¶
func (f *RisingWaveObjectFactory) NewFrontendDeployment(group string) *appsv1.Deployment
NewFrontendDeployment creates a new Deployment for the frontend component and specified group.
func (*RisingWaveObjectFactory) NewFrontendService ¶
func (f *RisingWaveObjectFactory) NewFrontendService() *corev1.Service
NewFrontendService creates a new Service for the frontend.
func (*RisingWaveObjectFactory) NewMetaAdvancedStatefulSet ¶ added in v0.2.5
func (f *RisingWaveObjectFactory) NewMetaAdvancedStatefulSet(group string) *kruiseappsv1beta1.StatefulSet
NewMetaAdvancedStatefulSet creates a new OpenKruise StatefulSet for the meta component and specified group.
func (*RisingWaveObjectFactory) NewMetaService ¶
func (f *RisingWaveObjectFactory) NewMetaService() *corev1.Service
NewMetaService creates a new Service for the meta.
func (*RisingWaveObjectFactory) NewMetaStatefulSet ¶ added in v0.2.5
func (f *RisingWaveObjectFactory) NewMetaStatefulSet(group string) *appsv1.StatefulSet
NewMetaStatefulSet creates a new StatefulSet for the meta component and specified group.
func (*RisingWaveObjectFactory) NewServiceMonitor ¶
func (f *RisingWaveObjectFactory) NewServiceMonitor() *prometheusv1.ServiceMonitor
NewServiceMonitor creates a new ServiceMonitor.
func (*RisingWaveObjectFactory) NewStandaloneAdvancedStatefulSet ¶ added in v0.5.4
func (f *RisingWaveObjectFactory) NewStandaloneAdvancedStatefulSet() *kruiseappsv1beta1.StatefulSet
NewStandaloneAdvancedStatefulSet creates an advanced StatefulSet for standalone component.
func (*RisingWaveObjectFactory) NewStandaloneService ¶ added in v0.5.4
func (f *RisingWaveObjectFactory) NewStandaloneService() *corev1.Service
NewStandaloneService creates a Service for standalone component.
func (*RisingWaveObjectFactory) NewStandaloneStatefulSet ¶ added in v0.5.4
func (f *RisingWaveObjectFactory) NewStandaloneStatefulSet() *appsv1.StatefulSet
NewStandaloneStatefulSet creates a StatefulSet for standalone component.
Source Files
Directories