Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExecutionInterface ¶
type ExecutionInterface interface {
CreateExecution(ctx context.Context, request admin.ExecutionCreateRequest, requestedAt time.Time) (
*admin.ExecutionCreateResponse, error)
RelaunchExecution(ctx context.Context, request admin.ExecutionRelaunchRequest, requestedAt time.Time) (
*admin.ExecutionCreateResponse, error)
CreateWorkflowEvent(ctx context.Context, request admin.WorkflowExecutionEventRequest) (
*admin.WorkflowExecutionEventResponse, error)
GetExecution(ctx context.Context, request admin.WorkflowExecutionGetRequest) (*admin.Execution, error)
GetExecutionData(ctx context.Context, request admin.WorkflowExecutionGetDataRequest) (
*admin.WorkflowExecutionGetDataResponse, error)
ListExecutions(ctx context.Context, request admin.ResourceListRequest) (*admin.ExecutionList, error)
TerminateExecution(
ctx context.Context, request admin.ExecutionTerminateRequest) (*admin.ExecutionTerminateResponse, error)
}
Interface for managing Flyte Workflow Executions
type LaunchPlanInterface ¶
type LaunchPlanInterface interface {
// Interface to create Launch Plans based on the request.
CreateLaunchPlan(ctx context.Context, request admin.LaunchPlanCreateRequest) (
*admin.LaunchPlanCreateResponse, error)
UpdateLaunchPlan(ctx context.Context, request admin.LaunchPlanUpdateRequest) (
*admin.LaunchPlanUpdateResponse, error)
GetLaunchPlan(ctx context.Context, request admin.ObjectGetRequest) (
*admin.LaunchPlan, error)
GetActiveLaunchPlan(ctx context.Context, request admin.ActiveLaunchPlanRequest) (
*admin.LaunchPlan, error)
ListLaunchPlans(ctx context.Context, request admin.ResourceListRequest) (
*admin.LaunchPlanList, error)
ListActiveLaunchPlans(ctx context.Context, request admin.ActiveLaunchPlanListRequest) (
*admin.LaunchPlanList, error)
ListLaunchPlanIds(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (
*admin.NamedEntityIdentifierList, error)
}
Interface for managing Flyte Launch Plans
type NodeExecutionInterface ¶
type NodeExecutionInterface interface {
CreateNodeEvent(ctx context.Context, request admin.NodeExecutionEventRequest) (
*admin.NodeExecutionEventResponse, error)
GetNodeExecution(ctx context.Context, request admin.NodeExecutionGetRequest) (*admin.NodeExecution, error)
ListNodeExecutions(ctx context.Context, request admin.NodeExecutionListRequest) (*admin.NodeExecutionList, error)
ListNodeExecutionsForTask(ctx context.Context, request admin.NodeExecutionForTaskListRequest) (*admin.NodeExecutionList, error)
GetNodeExecutionData(
ctx context.Context, request admin.NodeExecutionGetDataRequest) (*admin.NodeExecutionGetDataResponse, error)
}
Interface for managing Flyte Workflow NodeExecutions
type ProjectInterface ¶
type ProjectInterface interface {
CreateProject(ctx context.Context, request admin.ProjectRegisterRequest) (*admin.ProjectRegisterResponse, error)
ListProjects(ctx context.Context, request admin.ProjectListRequest) (*admin.Projects, error)
}
Interface for managing projects (and domains).
type TaskExecutionInterface ¶
type TaskExecutionInterface interface {
CreateTaskExecutionEvent(ctx context.Context, request admin.TaskExecutionEventRequest) (
*admin.TaskExecutionEventResponse, error)
GetTaskExecution(ctx context.Context, request admin.TaskExecutionGetRequest) (*admin.TaskExecution, error)
ListTaskExecutions(ctx context.Context, request admin.TaskExecutionListRequest) (*admin.TaskExecutionList, error)
GetTaskExecutionData(
ctx context.Context, request admin.TaskExecutionGetDataRequest) (*admin.TaskExecutionGetDataResponse, error)
}
Interface for managing Flyte Workflow TaskExecutions
type TaskInterface ¶
type TaskInterface interface {
CreateTask(ctx context.Context, request admin.TaskCreateRequest) (*admin.TaskCreateResponse, error)
GetTask(ctx context.Context, request admin.ObjectGetRequest) (*admin.Task, error)
ListTasks(ctx context.Context, request admin.ResourceListRequest) (*admin.TaskList, error)
ListUniqueTaskIdentifiers(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (
*admin.NamedEntityIdentifierList, error)
}
Interface for managing Flyte Tasks
type WorkflowInterface ¶
type WorkflowInterface interface {
CreateWorkflow(ctx context.Context, request admin.WorkflowCreateRequest) (*admin.WorkflowCreateResponse, error)
GetWorkflow(ctx context.Context, request admin.ObjectGetRequest) (*admin.Workflow, error)
ListWorkflows(ctx context.Context, request admin.ResourceListRequest) (*admin.WorkflowList, error)
ListWorkflowIdentifiers(ctx context.Context, request admin.NamedEntityIdentifierListRequest) (
*admin.NamedEntityIdentifierList, error)
}
Interface for managing Flyte Workflows
Click to show internal directories.
Click to hide internal directories.