utils

func BuildEnvoyGRPCHeaders ¶

func BuildEnvoyGRPCHeaders(headers map[string]string, rawValue bool) *pb.HttpHeaders

func CheckEnvoyGRPCHeaders ¶

func CheckEnvoyGRPCHeaders(t *testing.T, response *pb.CommonResponse, expectedHeaders map[string]string) bool

func DeleteObjects ¶

func DeleteObjects(testConfig *TestConfig, kindAndNames []string)

DeleteObjects deletes a set of Kubernetes objects in the form of kind/name.

func GetFreePort ¶

func GetFreePort() (string, error)

GetFreePort finds a free port to listen on

func GetStreamingServerClient ¶

func GetStreamingServerClient(ctx context.Context, t *testing.T) (pb.ExternalProcessor_ProcessClient, *grpc.ClientConn)

func LaunchTestGRPCServer ¶

func LaunchTestGRPCServer(ctx context.Context, s pb.ExternalProcessorServer, listener net.Listener) error

LaunchTestGRPCServer actually starts the server (enables testing)

func NewTestContext ¶

func NewTestContext(t *testing.T) context.Context

NewTestContext creates a new context with a logger associated with the testing.T. It simplifies the boilerplate of integrating klog/logr with unit tests.

func NewTestHandle ¶

func NewTestHandle(ctx context.Context) plugin.Handle

func PrepareForTestStreamingServer ¶

func PrepareForTestStreamingServer(t *testing.T, objectives []*v1alpha2.InferenceObjective, pods []*corev1.Pod, poolName string, namespace string,
	poolPort int32) (context.Context, context.CancelFunc, datastore.Datastore)

func SetupTestStreamingServer ¶

func SetupTestStreamingServer(ctx context.Context, t *testing.T, streamingServer pb.ExternalProcessorServer) (*bufconn.Listener, chan error)