journey

Documentation

Index

• Variables
• func ForkRepo(f *framework.Framework, repoUrl, repoRevision, username string) (string, error)
• func HandleApplication(ctx *PerApplicationContext) error
• func HandleComponent(ctx *PerComponentContext) error
• func HandleIntegrationTestScenario(ctx *PerApplicationContext) error
• func HandleNewFrameworkForApp(ctx *PerApplicationContext) error
• func HandleNewFrameworkForComp(ctx *PerComponentContext) error
• func HandlePerComponentCollection(ctx *PerComponentContext) error
• func HandlePersistentVolumeClaim(ctx *MainContext) error
• func HandlePipelineRun(ctx *PerComponentContext) error
• func HandleRepoForking(ctx *MainContext) error
• func HandleTest(ctx *PerComponentContext) error
• func HandleUser(ctx *MainContext) error
• func PerApplicationSetup(fn func(*PerApplicationContext), parentContext *MainContext) (string, error)
• func PerComponentSetup(fn func(*PerComponentContext), parentContext *PerApplicationContext) (string, error)
• func Purge() error
• func Setup(fn func(*MainContext), opts *options.Opts) (string, error)
• type MainContext
• type PerApplicationContext
• type PerComponentContext

Variables

var MainContexts []*MainContext

Pointers to all user journey thread contexts

Functions

func ForkRepo

func ForkRepo(f *framework.Framework, repoUrl, repoRevision, username string) (string, error)

func HandleApplication

func HandleApplication(ctx *PerApplicationContext) error

func HandleComponent

func HandleComponent(ctx *PerComponentContext) error

func HandleIntegrationTestScenario

func HandleIntegrationTestScenario(ctx *PerApplicationContext) error

func HandleNewFrameworkForApp

func HandleNewFrameworkForApp(ctx *PerApplicationContext) error

func HandleNewFrameworkForComp

func HandleNewFrameworkForComp(ctx *PerComponentContext) error

func HandlePerComponentCollection

func HandlePerComponentCollection(ctx *PerComponentContext) error

func HandlePersistentVolumeClaim

func HandlePersistentVolumeClaim(ctx *MainContext) error

func HandlePipelineRun

func HandlePipelineRun(ctx *PerComponentContext) error

func HandleRepoForking

func HandleRepoForking(ctx *MainContext) error

func HandleTest

func HandleTest(ctx *PerComponentContext) error

func HandleUser

func HandleUser(ctx *MainContext) error

func PerApplicationSetup

func PerApplicationSetup(fn func(*PerApplicationContext), parentContext *MainContext) (string, error)

Start all the threads to process all applications per user

func PerComponentSetup

func PerComponentSetup(fn func(*PerComponentContext), parentContext *PerApplicationContext) (string, error)

Start all the threads to process all components per application

func Purge

func Purge() error

func Setup

func Setup(fn func(*MainContext), opts *options.Opts) (string, error)

Start all the user journey threads TODO split this to two functions and get PurgeOnly code out

Types

type MainContext

type MainContext struct {
	ThreadsWG              *sync.WaitGroup
	ThreadIndex            int
	JourneyRepeatsCounter  int
	Opts                   *options.Opts
	StageUsers             *[]loadtestutils.User
	Framework              *framework.Framework
	Username               string
	Namespace              string
	ComponentRepoUrl       string // overrides same value from Opts, needed when templating repos
	PerApplicationContexts []*PerApplicationContext
}

Struct to hold user journey thread data

type PerApplicationContext

type PerApplicationContext struct {
	PerApplicationWG            *sync.WaitGroup
	ApplicationIndex            int
	Framework                   *framework.Framework
	ParentContext               *MainContext
	ApplicationName             string
	IntegrationTestScenarioName string
	PerComponentContexts        []*PerComponentContext
}

Struct to hold data for thread to process each application

type PerComponentContext

type PerComponentContext struct {
	PerComponentWG     *sync.WaitGroup
	ComponentIndex     int
	Framework          *framework.Framework
	ParentContext      *PerApplicationContext
	ComponentName      string
	SnapshotName       string
	MergeRequestNumber int
}

Struct to hold data for thread to process each component