fvt

package

Go to main page

Versions in this module

v0

v0.12.0-rc0

Apr 26, 2024

v0.11.2

Jan 10, 2024

v0.11.1

Oct 3, 2023

v0.11.0

Aug 7, 2023

Changes in this version

+ const ClusterServingRuntimeKind

+ const PredictorTimeout

+ const StorageConfigSecretName

+ const TimeForStatusToStabilize

+ var StorageConfigDataMinio = map[string]interface

+ var StorageConfigDataPVC = map[string]interface

+ func CreateIsvcAndWaitAndExpectFailed(isvcManifest *unstructured.Unstructured) *unstructured.Unstructured

+ func ExpectIsvcFailureInfo(obj *unstructured.Unstructured, reason string, hasLocation bool, hasTime bool, ...)

+ func ExpectIsvcState(obj *unstructured.Unstructured, ...)

+ func ExpectSuccessfulInference_torchserveMARPredict(predictorName string)

+ func InitializeFVTClient()

+ func SetMap(obj *unstructured.Unstructured, value map[string]interface{}, ...)

+ func WaitForIsvcState(watcher watch.Interface, anyOfDesiredStates []api.ModelState, name string, ...) *unstructured.Unstructured

+ func WaitForRuntimeDeploymentsToBeStable(timeToStabilize time.Duration, watcher watch.Interface)

type FVTClient

+ func (fvt *FVTClient) ApplyClusterServingRuntimeExpectSuccess(clusterServingRuntime *unstructured.Unstructured) *unstructured.Unstructured

+ func (fvt *FVTClient) ApplyServingRuntimeExpectSuccess(servingRuntime *unstructured.Unstructured) *unstructured.Unstructured

+ func (fvt *FVTClient) CreateStorageConfigSecret(storageConfigData map[string]interface{})

+ func (fvt *FVTClient) DeleteStorageConfigSecret()

+ func (fvt *FVTClient) GetClusterServingRuntime(name string) *unstructured.Unstructured

+ func (fvt *FVTClient) GetRandomReadyRuntimePod() string

+ func (fvt *FVTClient) ListHPAs() hpav2.HorizontalPodAutoscalerList

+ func (fvt *FVTClient) ListReadyRuntimePods() corev1.PodList

+ func (fvt *FVTClient) PrintDescribeIsvc(name string)

+ func (fvt *FVTClient) PrintHPAs()

+ func (fvt *FVTClient) RunTorchserveInference(req *torchserveapi.PredictionsRequest) (*torchserveapi.PredictionResponse, error)

+ func (fvt *FVTClient) SetServingRuntimeAnnotation(expectedRuntimeName string, annotations map[string]interface{})

v0.11.0-rc1

Jul 25, 2023

v0.11.0-rc0

Jun 2, 2023

v0.11.0-alpha

Mar 23, 2023

v0.10.0

Jan 12, 2023

Changes in this version

+ var NameSpaceScopeMode = false

type FVTClient

+ func (fvt *FVTClient) ListClusterServingRuntimes(options metav1.ListOptions) (*unstructured.UnstructuredList, error)

v0.10.0-rc0

Jan 9, 2023

v0.9.0

Jul 21, 2022

Changes in this version

+ const IsvcKind

+ const IsvcSamplesPath

+ const RuntimeSamplesPath

+ const SamplesPath

+ const TLSSecretName

+ const UserConfigMapName

+ var BasicTLSConfig = map[string]interface

+ var DefaultConfig = map[string]interface

+ var DefaultTimeout = int64(120)

+ var Log logr.Logger

+ var MutualTLSConfig = map[string]interface

+ func CreateIsvcAndWaitAndExpectReady(isvcManifest *unstructured.Unstructured) *unstructured.Unstructured

+ func CreateSecret(secret *corev1.Secret, namespace string, fvt *FVTClient)

+ func ExpectSuccessfulInference_kerasMnist(predictorName string)

+ func ExpectSuccessfulInference_openvinoMnistTFSPredict(predictorName string)

+ func ExpectSuccessfulRESTInference_sklearnMnistSvm(predictorName string)

+ func ExpectSuccessfulRESTInference_xgboostMushroom(predictorName string, tls bool)

+ func GetSlice(obj *unstructured.Unstructured, fieldPath ...string) ([]interface{}, bool)

+ func NewIsvcForFVT(filename string) *unstructured.Unstructured

+ func TestDataPath(resourcePathWithinTestData string) string

+ func WaitForIsvcReady(watcher watch.Interface) *unstructured.Unstructured

+ type CertGenerator struct

+ CAPEM *bytes.Buffer

+ Namespaces []string

+ PrivateKeyPEM *bytes.Buffer

+ PublicKeyPEM *bytes.Buffer

+ ServiceName string

type FVTClient

+ var FVTClientInstance *FVTClient

+ func (fvt *FVTClient) CreateIsvcExpectSuccess(resource *unstructured.Unstructured) *unstructured.Unstructured

+ func (fvt *FVTClient) DeleteAllIsvcs()

+ func (fvt *FVTClient) DeleteIsvc(resourceName string)

+ func (fvt *FVTClient) GetRandomReadyRuntimePodNameFromEndpoints() string

+ func (fvt *FVTClient) PrintDescribeNodes()

+ func (fvt *FVTClient) PrintEvents()

+ func (fvt *FVTClient) PrintIsvcs()

+ func (fvt *FVTClient) PrintPods()

+ func (fvt *FVTClient) RunKfsModelMetadata(req *inference.ModelMetadataRequest) (*inference.ModelMetadataResponse, error)

+ func (fvt *FVTClient) RunKfsRestInference(modelName string, body []byte, tls bool) (string, error)

+ func (fvt *FVTClient) RunTfsInference(req *tfsapi.PredictRequest) (*tfsapi.PredictResponse, error)

+ func (fvt *FVTClient) SetDefaultUserConfigMap()

+ func (fvt *FVTClient) StartWatchingIsvcs(options metav1.ListOptions, timeoutSeconds int64) watch.Interface

+ type ModelMeshPortForward struct

+ func NewModelMeshPortForward(namespace string, podName string, localPort int, targetPort int, ...) *ModelMeshPortForward

+ func (pf *ModelMeshPortForward) EnsureStarted() error

+ func (pf *ModelMeshPortForward) EnsureStopped()

v0.9.0-rc0

Jul 1, 2022

v0.8.0

Feb 12, 2022

Changes in this version

+ const ConfigMapKind

+ const DefaultControllerNamespace

+ const DefaultTestNamespace

+ const DefaultTestServiceName

+ const EPSILON

+ const PredictorKind

+ const SecretKind

+ const ServingRuntimeKind

+ func CreatePredictorAndWaitAndExpectFailed(predictorManifest *unstructured.Unstructured) *unstructured.Unstructured

+ func CreatePredictorAndWaitAndExpectInvalidSpec(predictorManifest *unstructured.Unstructured) *unstructured.Unstructured

+ func CreatePredictorAndWaitAndExpectLoaded(predictorManifest *unstructured.Unstructured) *unstructured.Unstructured

+ func DecodeResourceFromFile(resourcePath string) *unstructured.Unstructured

+ func ExpectPredictorFailureInfo(obj *unstructured.Unstructured, reason string, hasLocation bool, hasTime bool, ...)

+ func ExpectPredictorState(obj *unstructured.Unstructured, available bool, ...)

+ func ExpectSuccessfulInference_lightgbmMushroom(predictorName string)

+ func ExpectSuccessfulInference_onnxMnist(predictorName string)

+ func ExpectSuccessfulInference_pytorchCifar(predictorName string)

+ func ExpectSuccessfulInference_sklearnMnistSvm(predictorName string)

+ func ExpectSuccessfulInference_tensorflowMnist(predictorName string)

+ func ExpectSuccessfulInference_xgboostMushroom(predictorName string)

+ func GetBool(obj *unstructured.Unstructured, fieldPath ...string) bool

+ func GetInt64(obj *unstructured.Unstructured, fieldPath ...string) int64

+ func GetMap(obj *unstructured.Unstructured, fieldPath ...string) map[string]interface

+ func GetString(obj *unstructured.Unstructured, fieldPath ...string) string

+ func LoadCifarImage(index int) []float32

+ func LoadMnistImage(index int) []float32

+ func MakeUniquePredictorName(base string) string

+ func NewPredictorForFVT(filename string) *unstructured.Unstructured

+ func SetString(obj *unstructured.Unstructured, value string, fieldPath ...string)

+ func UpdatePredictorAndWaitAndExpectFailed(predictorManifest *unstructured.Unstructured) *unstructured.Unstructured

+ func UpdatePredictorAndWaitAndExpectLoaded(predictorManifest *unstructured.Unstructured) *unstructured.Unstructured

+ func WaitForDeployStatus(watcher watch.Interface, timeToStabilize time.Duration)

+ func WaitForLastStateInExpectedList(statusAttribute string, expectedStates []string, watcher watch.Interface) *unstructured.Unstructured

+ func WaitForStableActiveDeployState()

+ type FVTClient struct

+ func GetFVTClient(log logr.Logger, namespace, serviceName, controllerNamespace string) (*FVTClient, error)

+ func (fvt *FVTClient) ApplyPredictorExpectSuccess(predictor *unstructured.Unstructured) *unstructured.Unstructured

+ func (fvt *FVTClient) ApplyUserConfigMap(config map[string]interface{})

+ func (fvt *FVTClient) ConnectToModelServing(connectionType ModelServingConnectionType) error

+ func (fvt *FVTClient) CreateConfigMapTLS(tlsSecretName string, tlsClientAuth string) *unstructured.Unstructured

+ func (fvt *FVTClient) CreatePredictorExpectSuccess(resource *unstructured.Unstructured) *unstructured.Unstructured

+ func (fvt *FVTClient) CreateTLSSecrets()

+ func (fvt *FVTClient) DeleteAllPredictors()

+ func (fvt *FVTClient) DeleteConfigMap(resourceName string) error

+ func (fvt *FVTClient) DeletePredictor(resourceName string)

+ func (fvt *FVTClient) DeleteSecret(resourceName string) error

+ func (fvt *FVTClient) DisconnectFromModelServing()

+ func (fvt *FVTClient) GetPredictor(name string) *unstructured.Unstructured

+ func (fvt *FVTClient) GetServingRuntime(name string) *unstructured.Unstructured

+ func (fvt *FVTClient) ListDeploys() appsv1.DeploymentList

+ func (fvt *FVTClient) ListPredictors(options metav1.ListOptions) *unstructured.UnstructuredList

+ func (fvt *FVTClient) ListServingRuntimes(options metav1.ListOptions) (*unstructured.UnstructuredList, error)

+ func (fvt *FVTClient) PrintPredictors()

+ func (fvt *FVTClient) RestartDeploys()

+ func (fvt *FVTClient) RunKfsInference(req *inference.ModelInferRequest) (*inference.ModelInferResponse, error)

+ func (fvt *FVTClient) RunKubectl(args ...string) error

+ func (fvt *FVTClient) StartWatchingDeploys() watch.Interface

+ func (fvt *FVTClient) StartWatchingPredictors(options metav1.ListOptions, timeoutSeconds int64) watch.Interface

+ func (fvt *FVTClient) TailPodLogs(sinceTime string)

+ func (fvt *FVTClient) UpdateConfigMapTLS(tlsSecretName string, tlsClientAuth string) *unstructured.Unstructured

+ func (fvt *FVTClient) UpdatePredictorExpectSuccess(resource *unstructured.Unstructured) *unstructured.Unstructured

+ func (fvt *FVTClient) WatchPredictorsAsync(c chan *unstructured.Unstructured, options metav1.ListOptions, ...)

+ func (fvt FVTClient) DeleteTLSSecrets() error

+ type ModelServingConnectionType int

+ const Insecure

+ const MutualTLS

+ const TLS

v0.8.0-rc0

Jan 21, 2022

v0.7.0

Sep 23, 2021

v0.7.0-rc1

Oct 7, 2021

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