minikubetestenv

Documentation

Index

• Constants
• func DetNodeportHttpUrl(t testing.TB, namespace string) *url.URL
• func GetPachAddress(t testing.TB) *grpcutil.PachdAddress
• func InstallRelease(t testing.TB, ctx context.Context, namespace string, ...) *client.APIClient
• func LeaseNamespace(t testing.TB, namespace string) bool
• func PutNamespace(t testing.TB, namespace string)
• func UpgradeRelease(t testing.TB, ctx context.Context, namespace string, ...) *client.APIClient
• type DeployOpts

Constants

const (
	MinioEndpoint = "minio.default.svc.cluster.local:9000"
	MinioBucket   = "pachyderm-test"
)

Functions

func DetNodeportHttpUrl

func DetNodeportHttpUrl(t testing.TB, namespace string) *url.URL

returns the Nodeport url for accessing the determined service via REST/HTTP with an empty Path

func GetPachAddress

func GetPachAddress(t testing.TB) *grpcutil.PachdAddress

func InstallRelease

func InstallRelease(t testing.TB, ctx context.Context, namespace string, kubeClient *kube.Clientset, opts *DeployOpts) *client.APIClient

Deploy pachyderm using a `helm install ...` returns an API Client corresponding to the deployment

func LeaseNamespace

func LeaseNamespace(t testing.TB, namespace string) bool

LeaseNamespace attempts to lock a namespace for exclusive use by a test. It creates a k8s lease that is cleaned up at the end of the test. Calling LeaseNamespace will create the namespace if it doesn't exist. It returns true if Lease was acquired, false if not. To block until a namespace lock can be acquired, retry for the desired amount of time. LeaseNamespace will force-acquire the namespace lock after the the lease duration has passed.

func PutNamespace

func PutNamespace(t testing.TB, namespace string)

Creates a Namespace if it doesn't exist. If it does exist, does nothing.

func UpgradeRelease

func UpgradeRelease(t testing.TB, ctx context.Context, namespace string, kubeClient *kube.Clientset, opts *DeployOpts) *client.APIClient

Deploy pachyderm using a `helm upgrade ...` returns an API Client corresponding to the deployment

Types

type DeployOpts

type DeployOpts struct {
	Version string
	// Necessarry to enable auth and activate enterprise.
	// EnterpriseServer and EnterpriseMember can be used
	// without this flag to test manual enterprise/auth activation.
	Enterprise         bool
	Console            bool
	AuthUser           string
	CleanupAfter       bool
	UseLeftoverCluster bool
	// Because NodePorts are cluster-wide, we use a PortOffset to
	// assign separate ports per deployment.
	// NOTE: it might make more sense to declare port instead of offset
	PortOffset        uint16
	DisableLoki       bool
	EnterpriseMember  bool
	EnterpriseServer  bool
	Determined        bool
	ValueOverrides    map[string]string
	TLS               bool
	CertPool          *x509.CertPool
	ValuesFiles       []string
	InstallPrometheus bool
}