test

package
v0.0.0-...-c55d01b Latest Latest
Warning

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

Go to latest
Published: Apr 18, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CheckHazelcastCR

func CheckHazelcastCR(h *hazelcastv1alpha1.Hazelcast, expected *HazelcastSpecValues, ee bool)

func CheckManagementCenterCR

func CheckManagementCenterCR(mc *hazelcastv1alpha1.ManagementCenter, expected *MCSpecValues, ee bool)

func ContainVolumeClaimTemplate

func ContainVolumeClaimTemplate(pvc string) types.GomegaMatcher

func ContainVolumeMount

func ContainVolumeMount(name, path string) types.GomegaMatcher

func EqualSpecs

func EqualSpecs(expected *HazelcastSpecValues, ee bool) types.GomegaMatcher

func EventuallyInLogs

func EventuallyInLogs(lr *LogReader, intervals ...interface{}) AsyncAssertion

func EventuallyInLogsUnordered

func EventuallyInLogsUnordered(lr *LogReader, intervals ...interface{}) AsyncAssertion

func ManagementCenterSpec

func ManagementCenterSpec(values *MCSpecValues, ee bool) hazelcastv1alpha1.ManagementCenterSpec

Types

type HazelcastSpecEqual

type HazelcastSpecEqual struct {
	Expected *HazelcastSpecValues
	// contains filtered or unexported fields
}

func (HazelcastSpecEqual) FailureMessage

func (matcher HazelcastSpecEqual) FailureMessage(actual interface{}) (message string)

func (HazelcastSpecEqual) Match

func (matcher HazelcastSpecEqual) Match(actual interface{}) (success bool, err error)

func (HazelcastSpecEqual) NegatedFailureMessage

func (matcher HazelcastSpecEqual) NegatedFailureMessage(actual interface{}) (message string)

type HazelcastSpecValues

type HazelcastSpecValues struct {
	ClusterSize     int32
	Repository      string
	Version         string
	LicenseKey      string
	ImagePullPolicy corev1.PullPolicy
}

type LogReader

type LogReader struct {
	History []string
	// contains filtered or unexported fields
}

func NewLogReader

func NewLogReader(r io.ReadCloser) *LogReader

func (*LogReader) Close

func (lr *LogReader) Close() error

func (*LogReader) Read

func (lr *LogReader) Read() string

Read returns the new line of the logs in a non-blocking fashion. It polls the next line and returns it. If the next line doesn't exist, it returns empty string.

type MCSpecValues

type MCSpecValues struct {
	Repository      string
	Version         string
	LicenseKey      string
	ImagePullPolicy corev1.PullPolicy
}

Directories

Path Synopsis
e2e

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL