nexus_ha

Documentation

Index

• Constants
• Variables
• func AddHaLabelToNodes() error
• func GetFioArguments(fioRunTime int) ([]string, error)
• func GetNonNexusNode() (string, string)
• func GetNonNexusNonTestPodNode(nexusNode string, testPodNode string) (string, error)
• func GetOnlineReplicasCount(uuid string) (int, error)
• func LabelIoEngineOnNode(nodeName string) error
• func RemoveHaLabelFromNodes() error
• func UnlabelIoEngineFromNode(nodeName string) (string, error)
• func VerifyMayastorAndPoolReady() (bool, error)
• func VerifyNewNexusCreated(uuid string, oldNexus string) bool
• func VerifyNexusRemoved(uuid string, oldNexus string) bool
• func VerifyNodeNotReady(nodeName string, timeoutSecs int) bool
• func VerifyNodeReady(nodeName string, timeoutSecs int) bool
• func VerifyOldNexusReCreated(uuid string, oldNexus string) bool
• func VerifyVolumeHealth(uuid string) bool
• func WaitForVolumeToBeHealthy(uuid string) (bool, error)
• type NexusHa
  • func (c *NexusHa) CleanUp() error
  • func (c *NexusHa) CreateAnotherPodAndNexus(replicas int, prefix string, fioArgs []string) error
  • func (c *NexusHa) CreateDeploymentAndNexusOnDifferentNode(replicas int, prefix string, fioArgs []string, volSizeMb int) error
  • func (c *NexusHa) CreateMongoPodAndNexusOnDifferentNode(replicas int, result *string, volSizeMb int, wg *sync.WaitGroup) (apps.MongoApp, error)
  • func (c *NexusHa) CreatePodAndNexusOnDifferentNode(replicas int, prefix string, fioArgs []string, volSizeMb int) error
  • func (c *NexusHa) CreateScAndVolume(prefix string, replicas int, volSizeMb int) error
  • func (c *NexusHa) DeleteScAndVolume() error
  • func (c *NexusHa) VerifyReplicasAdnCleanUp() error

Constants

const (
	TimeoutSecs             = 60  // in seconds
	DefTimeoutSecs          = 120 // in seconds
	ReplicaCheckTimeoutSecs = 180 // in seconds
	RefreshTimeout          = 15  // in seconds
	DefaultvolSizeMb        = 4096
	DefaultFsVolSizeMb      = 512
	DefaultFioRunTime       = 600   // in seconds
	DefaultFioSleepTime     = 10000 // in seconds
	HaNodeTestingLabelKey   = "mayastor.testing/e2e-ha-nexus"
	HaNodeTestingLabelValue = "ha-testing"
	DefRebuildTimeoutSecs   = 240 // in seconds
)

Variables

var (
	EngineLabel      = e2e_config.GetConfig().Product.EngineLabel
	EngineLabelValue = e2e_config.GetConfig().Product.EngineLabelValue

	IoEnginePodName = e2e_config.GetConfig().Product.IOEnginePodName
)

Functions

func AddHaLabelToNodes

func AddHaLabelToNodes() error

func GetFioArguments

func GetFioArguments(fioRunTime int) ([]string, error)

func GetNonNexusNode

func GetNonNexusNode() (string, string)

GetNonNexusNode return node where nexus is absent

func GetNonNexusNonTestPodNode

func GetNonNexusNonTestPodNode(nexusNode string, testPodNode string) (string, error)

GetNonNexusNonTestPodNode Get non nexus , non test pod node

func GetOnlineReplicasCount

func GetOnlineReplicasCount(uuid string) (int, error)

func LabelIoEngineOnNode

func LabelIoEngineOnNode(nodeName string) error

func RemoveHaLabelFromNodes

func RemoveHaLabelFromNodes() error

func UnlabelIoEngineFromNode

func UnlabelIoEngineFromNode(nodeName string) (string, error)

func VerifyMayastorAndPoolReady

func VerifyMayastorAndPoolReady() (bool, error)

func VerifyNewNexusCreated

func VerifyNewNexusCreated(uuid string, oldNexus string) bool

VerifyNewNexusCreated check new nexus is created on other node

func VerifyNexusRemoved

func VerifyNexusRemoved(uuid string, oldNexus string) bool

VerifyNexusRemoved verify old nexus has been removed

func VerifyNodeNotReady

func VerifyNodeNotReady(nodeName string, timeoutSecs int) bool

VerifyNodeNotReady verify node ready status

func VerifyNodeReady

func VerifyNodeReady(nodeName string, timeoutSecs int) bool

VerifyNodeReady verify node ready status

func VerifyOldNexusReCreated

func VerifyOldNexusReCreated(uuid string, oldNexus string) bool

VerifyOldNexusReCreated check old nexus is re created on same node

func VerifyVolumeHealth

func VerifyVolumeHealth(uuid string) bool

func WaitForVolumeToBeHealthy

func WaitForVolumeToBeHealthy(uuid string) (bool, error)

Types

type NexusHa

type NexusHa struct {
	TestPodName string
	TestNode    string

	TestDeployName   string
	TestPodAppLabels string

	NexusNode    string
	Uuid         string
	Platform     types.Platform
	NonNexusNode string
	// contains filtered or unexported fields
}

func (*NexusHa) CleanUp

func (c *NexusHa) CleanUp() error

func (*NexusHa) CreateAnotherPodAndNexus

func (c *NexusHa) CreateAnotherPodAndNexus(replicas int, prefix string, fioArgs []string) error

CreateAnotherPodAndNexus A function to create pod and nexus on different node

func (*NexusHa) CreateDeploymentAndNexusOnDifferentNode

func (c *NexusHa) CreateDeploymentAndNexusOnDifferentNode(replicas int, prefix string, fioArgs []string, volSizeMb int) error

CreateDeploymentAndNexusOnDifferentNode A function to create fio deployment and nexus on different node

func (*NexusHa) CreateMongoPodAndNexusOnDifferentNode

func (c *NexusHa) CreateMongoPodAndNexusOnDifferentNode(replicas int, result *string, volSizeMb int, wg *sync.WaitGroup) (apps.MongoApp, error)

CreateMongoPodAndNexusOnDifferentNode A function to create pod and nexus on different node

func (*NexusHa) CreatePodAndNexusOnDifferentNode

func (c *NexusHa) CreatePodAndNexusOnDifferentNode(replicas int, prefix string, fioArgs []string, volSizeMb int) error

CreatePodAndNexusOnDifferentNode A function to create pod and nexus on different node

func (*NexusHa) CreateScAndVolume

func (c *NexusHa) CreateScAndVolume(prefix string, replicas int, volSizeMb int) error

func (*NexusHa) DeleteScAndVolume

func (c *NexusHa) DeleteScAndVolume() error

func (*NexusHa) VerifyReplicasAdnCleanUp

func (c *NexusHa) VerifyReplicasAdnCleanUp() error