factory

package
v0.2.7 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2023 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

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) *RisingWaveObjectFactory

NewRisingWaveObjectFactory creates a new RisingWaveObjectFactory.

func (*RisingWaveObjectFactory) NewCompactorCloneSet added in v0.2.4 

func (f *RisingWaveObjectFactory) NewCompactorCloneSet(group string, podTemplates map[string]risingwavev1alpha1.RisingWavePodTemplate) *kruiseappsv1alpha1.CloneSet

NewCompactorCloneSet creates a new CloneSet for the compactor component and specified group.

func (*RisingWaveObjectFactory) NewCompactorDeployment 

func (f *RisingWaveObjectFactory) NewCompactorDeployment(group string, podTemplates map[string]risingwavev1alpha1.RisingWavePodTemplate) *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, podTemplates map[string]risingwavev1alpha1.RisingWavePodTemplate) *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.

func (*RisingWaveObjectFactory) NewComputeStatefulSet 

func (f *RisingWaveObjectFactory) NewComputeStatefulSet(group string, podTemplates map[string]risingwavev1alpha1.RisingWavePodTemplate) *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) NewConnectorCloneSet added in v0.2.6 

func (f *RisingWaveObjectFactory) NewConnectorCloneSet(group string, podTemplates map[string]risingwavev1alpha1.RisingWavePodTemplate) *kruiseappsv1alpha1.CloneSet

NewConnectorCloneSet creates a new CloneSet for the connector component and specified group.

func (*RisingWaveObjectFactory) NewConnectorDeployment added in v0.2.6 

func (f *RisingWaveObjectFactory) NewConnectorDeployment(group string, podTemplates map[string]risingwavev1alpha1.RisingWavePodTemplate) *appsv1.Deployment

NewConnectorDeployment creates a new Deployment for the connector component and specified group.

func (*RisingWaveObjectFactory) NewConnectorService added in v0.2.6 

func (f *RisingWaveObjectFactory) NewConnectorService() *corev1.Service

NewConnectorService creates a new Service for the connector.

func (*RisingWaveObjectFactory) NewFrontendCloneSet added in v0.2.5 

func (f *RisingWaveObjectFactory) NewFrontendCloneSet(group string, podTemplates map[string]risingwavev1alpha1.RisingWavePodTemplate) *kruiseappsv1alpha1.CloneSet

NewFrontendCloneSet creates a new CloneSet for the frontend component and specified group.

func (*RisingWaveObjectFactory) NewFrontendDeployment 

func (f *RisingWaveObjectFactory) NewFrontendDeployment(group string, podTemplates map[string]risingwavev1alpha1.RisingWavePodTemplate) *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, podTemplates map[string]risingwavev1alpha1.RisingWavePodTemplate) *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, podTemplates map[string]risingwavev1alpha1.RisingWavePodTemplate) *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.

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.