e2e

package

v0.70.1-alpha Latest Latest Go to latest Published: Apr 3, 2019 License: BSD-3-Clause Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/sky-uk/cassandra-operator

Documentation ¶

Index ¶

Constants
Variables
func BackdateSnapshotsForPods(pods []*v1.Pod, backdatePeriod time.Duration)
func CassandraPodExistsWithLabels(labelsAndValues ...string) *v1.Pod
func DeleteCassandraResourcesInNamespace(namespace string)
func Kubectl(namespace, podName string, command ...string) (*exec.Cmd, []byte, error)
func PodIsReady(podToCheck *v1.Pod) func() (bool, error)
func PodIsTerminatedSuccessfully(podToCheck *v1.Pod) func() (bool, error)
func PodIsTerminatedUnsuccessfully(podToCheck *v1.Pod) func() (bool, error)
func RenameSnapshotsForPod(pod *v1.Pod, snapshotName string)
func RunCommandInCassandraSnapshotPod(clusterName, command string, arg ...string) *v1.Pod
type Snapshot
- func SnapshotListForPod(pod *v1.Pod) ([]Snapshot, error)
type SnapshotMatcher
- func BeForKeyspace(keyspace string) *SnapshotMatcher

Constants ¶

View Source

const (
	Namespace     = "test-cassandra-operator"
	OperatorLabel = "cassandra-snapshot-test"
)

View Source

const (
	NodeStartDuration       = 120 * time.Second
	NodeTerminationDuration = 60 * time.Second
)

Variables ¶

View Source

var (
	KubeClientset           *kubernetes.Clientset
	UseMockedImage          bool
	CassandraImageName      string
	CassandraReadinessProbe *v1.Probe
	RenameSnapshotCmd       string

	ImageUnderTest       string
	ResourceRequirements *v1.ResourceRequirements
)

View Source

var (
	TerminateImmediately = int64(0)
)

Functions ¶

func BackdateSnapshotsForPods ¶

func BackdateSnapshotsForPods(pods []*v1.Pod, backdatePeriod time.Duration)

func CassandraPodExistsWithLabels ¶

func CassandraPodExistsWithLabels(labelsAndValues ...string) *v1.Pod

func DeleteCassandraResourcesInNamespace ¶

func DeleteCassandraResourcesInNamespace(namespace string)

func Kubectl ¶

func Kubectl(namespace, podName string, command ...string) (*exec.Cmd, []byte, error)

func PodIsReady ¶

func PodIsReady(podToCheck *v1.Pod) func() (bool, error)

func PodIsTerminatedSuccessfully ¶

func PodIsTerminatedSuccessfully(podToCheck *v1.Pod) func() (bool, error)

func PodIsTerminatedUnsuccessfully ¶

func PodIsTerminatedUnsuccessfully(podToCheck *v1.Pod) func() (bool, error)

func RenameSnapshotsForPod ¶

func RenameSnapshotsForPod(pod *v1.Pod, snapshotName string)

func RunCommandInCassandraSnapshotPod ¶

func RunCommandInCassandraSnapshotPod(clusterName, command string, arg ...string) *v1.Pod

Types ¶

type Snapshot ¶

type Snapshot struct {
	Name         string
	Keyspace     string
	ColumnFamily string
}

func SnapshotListForPod ¶

func SnapshotListForPod(pod *v1.Pod) ([]Snapshot, error)

type SnapshotMatcher ¶

type SnapshotMatcher struct {
	// contains filtered or unexported fields
}

func BeForKeyspace ¶

func BeForKeyspace(keyspace string) *SnapshotMatcher

func (*SnapshotMatcher) AndWithinTimeRange ¶

func (m *SnapshotMatcher) AndWithinTimeRange(earliestTime time.Time, latestTime time.Time) types.GomegaMatcher

func (*SnapshotMatcher) FailureMessage ¶

func (m *SnapshotMatcher) FailureMessage(actual interface{}) (message string)

func (*SnapshotMatcher) Match ¶

func (m *SnapshotMatcher) Match(actual interface{}) (success bool, err error)

func (*SnapshotMatcher) NegatedFailureMessage ¶

func (m *SnapshotMatcher) NegatedFailureMessage(actual interface{}) (message string)

Source Files ¶

View all Source files

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