helpers

package

v0.4.0 Latest Latest Go to latest Published: May 13, 2022 License: Apache-2.0 Imports: 17 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/cloud-bulldozer/ocm-api-load

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func BuildConnection(ctx context.Context, gateway, clientID, clientSecret, token string, ...) (*sdk.Connection, error)
func Cleanup(ctx context.Context, connection *sdk.Connection)
func CreateCluster(ctx context.Context, body string, gatewayConnection *sdk.Connection) (string, map[string]interface{}, error)
func CreateFile(name, path string) (*os.File, error)
func CreateFolder(ctx context.Context, path string, logger logging.Logger) error
func DeleteCluster(ctx context.Context, id string, deprovision bool, connection *sdk.Connection)
func DeletedSubscription(ctx context.Context, id string, connection *sdk.Connection)
func GetServerVersion(ctx context.Context, connection *sdk.Connection) string
func Parse(data []byte) (map[string]interface{}, error)
func ParseRate(rate string) (vegeta.Rate, error)
type CleanTestTransport
- func (t *CleanTestTransport) RoundTrip(request *http.Request) (*http.Response, error)

Constants ¶

View Source

const (
	AccountUsername  = "rhn-support-tiwillia"
	DefaultAWSRegion = "us-east-1"

	// Cluster Auhtorization
	M5XLargeResource           = "m5.xlarge"
	AWSComputeNodeResourceType = "compute.node.aws"
	DefaultClusterCount        = 4
	StandardBillingModel       = "standard"
	OsdProductID               = "osd"
	AWSCloudProvider           = "aws"
	ClusterAuthAccountUsername = "rh-perfscale"
	ClusterAuthManaged         = true
	ClusterAuthReserve         = true
	ClusterAuthBYOC            = true
	SingleAvailabilityZone     = "single"
)

View Source

const (
	ClustersEndpoint     = "/api/clusters_mgmt/v1/clusters/"
	SubscriptionEndpoint = "/api/accounts_mgmt/v1/subscriptions/"
)

Variables ¶

This section is empty.

Functions ¶

func BuildConnection ¶

func BuildConnection(ctx context.Context, gateway, clientID, clientSecret, token string, logger logging.Logger) (*sdk.Connection, error)

BuildConnection build the vegeta connection that is going to be used for testing

func Cleanup ¶

func Cleanup(ctx context.Context, connection *sdk.Connection)

func CreateCluster ¶

func CreateCluster(ctx context.Context, body string, gatewayConnection *sdk.Connection) (string, map[string]interface{}, error)

func CreateFile ¶

func CreateFile(name, path string) (*os.File, error)

CreateFile creates the file with the given name

func CreateFolder ¶

func CreateFolder(ctx context.Context, path string, logger logging.Logger) error

CreateFolder creates folder in the system

func DeleteCluster ¶

func DeleteCluster(ctx context.Context, id string, deprovision bool, connection *sdk.Connection)

func DeletedSubscription ¶ added in v0.4.0

func DeletedSubscription(ctx context.Context, id string, connection *sdk.Connection)

func GetServerVersion ¶ added in v0.4.0

func GetServerVersion(ctx context.Context, connection *sdk.Connection) string

func Parse ¶

func Parse(data []byte) (map[string]interface{}, error)

Parse parses the given JSON data and returns a map of strings containing the result.

func ParseRate ¶

func ParseRate(rate string) (vegeta.Rate, error)

ParseRate addapted `rateFlag` from tsenart/vegeta since the `rateFlag` is not exported it is not possible to reuse the same method, but to match and correctly generate the rate we decided to use the same function. https://github.com/tsenart/vegeta/blob/d73edf2bc2663d83848da2a97a8401a7ed1440bc/flags.go#L68

Types ¶

type CleanTestTransport ¶ added in v0.4.0

type CleanTestTransport struct {
	Wrapped http.RoundTripper
	Logger  logging.Logger
}

func (*CleanTestTransport) RoundTrip ¶ added in v0.4.0

func (t *CleanTestTransport) RoundTrip(request *http.Request) (*http.Response, error)

Source Files ¶

View all Source files

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