util

Documentation

Index

• Constants
• func ConvertRisingwave(rw *v1alpha1.RisingWave) *v1alpha1.RisingWave
• func FakeRW() *v1alpha1.RisingWave
• func IsValidComputeGroup(groupName string, groups []v1alpha1.RisingWaveComputeGroup) bool
• func IsValidRWGroup(groupName string, groups []v1alpha1.RisingWaveComponentGroup) bool
• func NewFakeClient() client.Client

Constants

const (
	Compute      = "compute"
	Meta         = "meta"
	Frontend     = "frontend"
	Compactor    = "compactor"
	Connector    = "connector"
	Global       = "global"
	DefaultGroup = "inner_global"
)

Functions

func ConvertRisingwave

func ConvertRisingwave(rw *v1alpha1.RisingWave) *v1alpha1.RisingWave

ConvertRisingwave will mv the risingwave Global replicas into each component group.

func FakeRW

func FakeRW() *v1alpha1.RisingWave

func IsValidComputeGroup

func IsValidComputeGroup(groupName string, groups []v1alpha1.RisingWaveComputeGroup) bool

func IsValidRWGroup

func IsValidRWGroup(groupName string, groups []v1alpha1.RisingWaveComponentGroup) bool

func NewFakeClient

func NewFakeClient() client.Client