fake

Documentation

Index

• type FakeClient
  • func NewFakeClient() *FakeClient
  • func (c *FakeClient) GetKubeRayOperatorVersion(_ context.Context) (string, error)
  • func (c *FakeClient) GetRayHeadSvcName(_ context.Context, _ string, _ util.ResourceType, _ string) (string, error)
  • func (c *FakeClient) KubernetesClient() kubernetes.Interface
  • func (c *FakeClient) RayClient() rayclient.Interface
  • func (c *FakeClient) WaitRayClusterProvisioned(_ context.Context, _ string, _ string, _ time.Duration) error
  • func (c *FakeClient) WithKubeRayImageVersion(version string) *FakeClient
  • func (c *FakeClient) WithKubeRayOperatorVersionError(err error) *FakeClient

Types

type FakeClient

type FakeClient struct {
	// contains filtered or unexported fields
}

func NewFakeClient

func NewFakeClient() *FakeClient

func (*FakeClient) GetKubeRayOperatorVersion

func (c *FakeClient) GetKubeRayOperatorVersion(_ context.Context) (string, error)

func (*FakeClient) GetRayHeadSvcName

func (c *FakeClient) GetRayHeadSvcName(_ context.Context, _ string, _ util.ResourceType, _ string) (string, error)

func (*FakeClient) KubernetesClient

func (c *FakeClient) KubernetesClient() kubernetes.Interface

func (*FakeClient) RayClient

func (c *FakeClient) RayClient() rayclient.Interface

func (*FakeClient) WaitRayClusterProvisioned

func (c *FakeClient) WaitRayClusterProvisioned(_ context.Context, _ string, _ string, _ time.Duration) error

func (*FakeClient) WithKubeRayImageVersion

func (c *FakeClient) WithKubeRayImageVersion(version string) *FakeClient

func (*FakeClient) WithKubeRayOperatorVersionError

func (c *FakeClient) WithKubeRayOperatorVersionError(err error) *FakeClient