support

package

Go to main page

Versions in this module

v1

v1.0.0-rc.4

Oct 23, 2023

v1.0.0-rc.3

Oct 20, 2023

v1.0.0-rc.2

Oct 12, 2023

v1.0.0-rc.1

Sep 20, 2023

v0

v0.2.3

Sep 11, 2023

Changes in this version

+ func AppWrapperName(aw *mcadv1beta1.AppWrapper) string

+ func AppWrappers(t Test, namespace *corev1.Namespace) func(g gomega.Gomega) []mcadv1beta1.AppWrapper

type Client

+ Dynamic func() dynamic.Interface

+ Image func() imagev1.Interface

v0.2.2

Aug 30, 2023

v0.2.0

Aug 29, 2023

Changes in this version

+ func GetIngress(t Test, namespace, name string) *networkingv1.Ingress

+ func GetRayJobId(t Test, namespace, name string) string

+ func GetRoute(t Test, namespace, name string) *routev1.Route

+ func Ingress(t Test, namespace, name string) func(g gomega.Gomega) *networkingv1.Ingress

+ func LoadBalancerIngresses(ingress *networkingv1.Ingress) []networkingv1.IngressLoadBalancerIngress

v0.1.0

Aug 8, 2023

Changes in this version

+ func GetRayCluster(t Test, namespace, name string) *rayv1alpha1.RayCluster

+ func GetRayJobAPIDetailsStatus(jobDetails *RayJobDetailsResponse) string

+ func RayCluster(t Test, namespace, name string) func(g gomega.Gomega) *rayv1alpha1.RayCluster

+ func RayClusterState(cluster *rayv1alpha1.RayCluster) rayv1alpha1.ClusterState

+ func RayJobAPIDetails(t Test, rayClient RayClusterClient, jobID string) func(g gomega.Gomega) *RayJobDetailsResponse

+ func Route(t Test, namespace, name string) func(g gomega.Gomega) *routev1.Route

+ func WriteRayJobAPILogs(t Test, rayClient RayClusterClient, jobID string)

type Client

+ Route func() routev1.Interface

+ type RayClusterClient interface

+ CreateJob func(job *RayJobSetup) (*RayJobResponse, error)

+ GetJobDetails func(jobID string) (*RayJobDetailsResponse, error)

+ GetJobLogs func(jobID string) (string, error)

+ func NewRayClusterClient(dashboardEndpoint url.URL) RayClusterClient

+ type RayJobDetailsResponse struct

+ JobID string

+ Status string

+ SubmissionID string

+ func GetRayJobAPIDetails(t Test, rayClient RayClusterClient, jobID string) *RayJobDetailsResponse

+ type RayJobLogsResponse struct

+ Logs string

+ type RayJobResponse struct

+ JobID string

+ SubmissionID string

+ type RayJobSetup struct

+ EntryPoint string

+ RuntimeEnv map[string]any

v0.0.6

Jul 10, 2023

v0.0.5

Jul 7, 2023

Changes in this version

+ const CodeFlareSDKVersion

+ const CodeFlareTestOutputDir

+ const CodeFlareTestPyTorchImage

+ const CodeFlareTestRayImage

+ const CodeFlareTestRayVersion

+ const CodeFlareTestSdkVersion

+ const RayImage

+ const RayJobDefaultClusterSelectorKey

+ const RayVersion

+ var ApplyOptions = metav1.ApplyOptions

+ var TestTimeoutLong = 5 * time.Minute

+ var TestTimeoutMedium = 2 * time.Minute

+ var TestTimeoutShort = 1 * time.Minute

+ func AppWrapper(t Test, namespace *corev1.Namespace, name string) func(g gomega.Gomega) *mcadv1beta1.AppWrapper

+ func AppWrapperState(aw *mcadv1beta1.AppWrapper) mcadv1beta1.AppWrapperState

+ func ConditionStatus(conditionType T) func(any) corev1.ConditionStatus

+ func GetCodeFlareSDKVersion() string

+ func GetJob(t Test, namespace, name string) *batchv1.Job

+ func GetPodLogs(t Test, pod *corev1.Pod, options corev1.PodLogOptions) []byte

+ func GetPods(t Test, namespace string, options metav1.ListOptions) []corev1.Pod

+ func GetPyTorchImage() string

+ func GetRayImage() string

+ func GetRayJob(t Test, namespace, name string) *rayv1alpha1.RayJob

+ func GetRayJobLogs(t Test, namespace, name string) []byte

+ func GetRayVersion() string

+ func IsOpenShift(test Test) bool

+ func Job(t Test, namespace, name string) func(g gomega.Gomega) *batchv1.Job

+ func Ptr(v T) *T

+ func Raw(t Test, obj runtime.Object) runtime.RawExtension

+ func RayJob(t Test, namespace, name string) func(g gomega.Gomega) *rayv1alpha1.RayJob

+ func RayJobStatus(job *rayv1alpha1.RayJob) rayv1alpha1.JobStatus

+ func WriteJobLogs(t Test, namespace, name string)

+ func WriteRayJobLogs(t Test, namespace, name string)

+ func WriteToOutputDir(t Test, fileName string, fileType OutputType, data []byte)

+ type Client interface

+ CodeFlare func() codeflareclient.Interface

+ Core func() kubernetes.Interface

+ MCAD func() mcadclient.Interface

+ Ray func() rayclient.Interface

+ type Option interface

+ type OutputType string

+ const Log

+ type T struct

+ func (t *T) Client() Client

+ func (t *T) Ctx() context.Context

+ func (t *T) NewTestNamespace(options ...Option[*corev1.Namespace]) *corev1.Namespace

+ func (t *T) OutputDir() string

+ func (t *T) T() *testing.T

+ type Test interface

+ Client func() Client

+ Ctx func() context.Context

+ NewTestNamespace func(...Option[*corev1.Namespace]) *corev1.Namespace

+ OutputDir func() string

+ T func() *testing.T

+ func With(t *testing.T) Test

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