knative

package

v0.1.12-pre Latest Latest Go to latest Published: Mar 15, 2021 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

func GetKnativeSvc(nn *types.NamespacedName) (*servingv1.Service, error)

GetKnativeSvc fetches the Knative service given its name and namespace.

func GetNamespacedNameForKsvc(e *experiment.Experiment) (*types.NamespacedName, error)

GetNamespacedNameForKsvc parses the target of the experiment and returns name and namespace of the ksvc.

func MakeInitExperiment(t *v2alpha2.TaskSpec) (base.Task, error)

MakeInitExperiment converts an InitExperiment task spec into an InitExperimentTask.

func MakeTask(t *v2alpha2.TaskSpec) (base.Task, error)

MakeTask constructs a Task from a TaskMeta or returns an error if any.

type InitExperimentTask struct {
	Library string `json:"library" yaml:"library"`
	Task    string `json:"task" yaml:"task"`
}

InitExperimentTask enables initialization of knative experiments.

func (t *InitExperimentTask) Run(ctx context.Context) error

Run executes an InitExperimentTask