test

Documentation

Index

• func CheckHazelcastCR(h *hazelcastv1alpha1.Hazelcast, expected *HazelcastSpecValues)
• func CheckManagementCenterCR(mc *hazelcastv1alpha1.ManagementCenter, expected *MCSpecValues)
• func ContainVolumeClaimTemplate(pvc string) types.GomegaMatcher
• func ContainVolumeMount(name, path string) types.GomegaMatcher
• func EqualSpecs(expected *HazelcastSpecValues) types.GomegaMatcher
• func EventuallyInLogs(lr *LogReader, intervals ...interface{}) AsyncAssertion
• func EventuallyInLogsUnordered(lr *LogReader, intervals ...interface{}) AsyncAssertion
• func HazelcastSpec(values *HazelcastSpecValues) hazelcastv1alpha1.HazelcastSpec
• func ManagementCenterSpec(values *MCSpecValues) hazelcastv1alpha1.ManagementCenterSpec
• type HazelcastSpecEqual
  • func (matcher HazelcastSpecEqual) FailureMessage(actual interface{}) (message string)
  • func (matcher HazelcastSpecEqual) Match(actual interface{}) (success bool, err error)
  • func (matcher HazelcastSpecEqual) NegatedFailureMessage(actual interface{}) (message string)
• type HazelcastSpecValues
• type LogReader
  • func NewLogReader(r io.ReadCloser) *LogReader
  • func (lr *LogReader) Close() error
  • func (lr *LogReader) Read() string
• type MCSpecValues

Functions

func CheckHazelcastCR

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

func CheckManagementCenterCR

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

func ContainVolumeClaimTemplate

func ContainVolumeClaimTemplate(pvc string) types.GomegaMatcher

func ContainVolumeMount

func ContainVolumeMount(name, path string) types.GomegaMatcher

func EqualSpecs

func EqualSpecs(expected *HazelcastSpecValues) types.GomegaMatcher

func EventuallyInLogs

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

func EventuallyInLogsUnordered

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

func HazelcastSpec

func HazelcastSpec(values *HazelcastSpecValues) hazelcastv1alpha1.HazelcastSpec

func ManagementCenterSpec

func ManagementCenterSpec(values *MCSpecValues) hazelcastv1alpha1.ManagementCenterSpec

Types

type HazelcastSpecEqual

type HazelcastSpecEqual struct {
	Expected *HazelcastSpecValues
}

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
}