testutils

Documentation

Index

• Variables
• func DeepEqual[T any](x, y T) bool
• func FakeRisingWave() *risingwavev1alpha1.RisingWave
• func FakeRisingWaveOpenKruiseDisabled() *risingwavev1alpha1.RisingWave
• func FakeRisingWaveOpenKruiseEnabled() *risingwavev1alpha1.RisingWave
• func FakeRisingWaveWithMutate(mutate func(wave *risingwavev1alpha1.RisingWave)) *risingwavev1alpha1.RisingWave
• func GetNodeGroupName(i int) string
• func JSONMustPrettyPrint(x any) string
• func NewFakeRisingWaveScaleViewFor(risingwave *risingwavev1alpha1.RisingWave, component string, ...) *risingwavev1alpha1.RisingWaveScaleView

Variables

var Scheme = runtime.NewScheme()

Scheme for test only.

Functions

func DeepEqual

func DeepEqual[T any](x, y T) bool

DeepEqual returns true when the two objects are semantically equal.

func FakeRisingWave

func FakeRisingWave() *risingwavev1alpha1.RisingWave

FakeRisingWave returns a new fake Risingwave.

func FakeRisingWaveOpenKruiseDisabled

func FakeRisingWaveOpenKruiseDisabled() *risingwavev1alpha1.RisingWave

FakeRisingWaveOpenKruiseDisabled returns a new fake RisingWave with OpenKruise disabled.

func FakeRisingWaveOpenKruiseEnabled

func FakeRisingWaveOpenKruiseEnabled() *risingwavev1alpha1.RisingWave

FakeRisingWaveOpenKruiseEnabled returns a new fake RisingWave with OpenKruise enabled.

func FakeRisingWaveWithMutate

func FakeRisingWaveWithMutate(mutate func(wave *risingwavev1alpha1.RisingWave)) *risingwavev1alpha1.RisingWave

FakeRisingWaveWithMutate creates a new fake RisingWave and applies the mutate function. It's for test purposes.

func GetNodeGroupName

func GetNodeGroupName(i int) string

GetNodeGroupName returns the group name for a specified index.

func JSONMustPrettyPrint

func JSONMustPrettyPrint(x any) string

JSONMustPrettyPrint serializes the given object into JSON string. It will panic with error if serialization fails.

func NewFakeRisingWaveScaleViewFor

func NewFakeRisingWaveScaleViewFor(risingwave *risingwavev1alpha1.RisingWave, component string, mutates ...func(*risingwavev1alpha1.RisingWave, *risingwavev1alpha1.RisingWaveScaleView)) *risingwavev1alpha1.RisingWaveScaleView

NewFakeRisingWaveScaleViewFor creates a new fake RisingWaveScaleView object for the target RisingWave and component. It applies the given mutations before returning.