Documentation ¶
Index ¶
- type Client
- func (_m *Client) GetCache() cache.Cache
- func (_m *Client) GetClient() client.Client
- func (_m *Client) OnGetCache() *Client_GetCache
- func (_m *Client) OnGetCacheMatch(matchers ...interface{}) *Client_GetCache
- func (_m *Client) OnGetClient() *Client_GetClient
- func (_m *Client) OnGetClientMatch(matchers ...interface{}) *Client_GetClient
- type Client_GetCache
- type Client_GetClient
- type Node
- func (_m *Node) AbortHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, ...) error
- func (_m *Node) Initialize(ctx context.Context) error
- func (_m *Node) OnAbortHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, ...) *Node_AbortHandler
- func (_m *Node) OnAbortHandlerMatch(matchers ...interface{}) *Node_AbortHandler
- func (_m *Node) OnInitialize(ctx context.Context) *Node_Initialize
- func (_m *Node) OnInitializeMatch(matchers ...interface{}) *Node_Initialize
- func (_m *Node) OnRecursiveNodeHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, ...) *Node_RecursiveNodeHandler
- func (_m *Node) OnRecursiveNodeHandlerMatch(matchers ...interface{}) *Node_RecursiveNodeHandler
- func (_m *Node) OnSetInputsForStartNode(ctx context.Context, w v1alpha1.BaseWorkflowWithStatus, ...) *Node_SetInputsForStartNode
- func (_m *Node) OnSetInputsForStartNodeMatch(matchers ...interface{}) *Node_SetInputsForStartNode
- func (_m *Node) RecursiveNodeHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, ...) (executors.NodeStatus, error)
- func (_m *Node) SetInputsForStartNode(ctx context.Context, w v1alpha1.BaseWorkflowWithStatus, ...) (executors.NodeStatus, error)
- type Node_AbortHandler
- type Node_Initialize
- type Node_RecursiveNodeHandler
- type Node_SetInputsForStartNode
- type Workflow
- func (_m *Workflow) HandleAbortedWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow, maxRetries uint32) error
- func (_m *Workflow) HandleFlyteWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow) error
- func (_m *Workflow) Initialize(ctx context.Context) error
- func (_m *Workflow) OnHandleAbortedWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow, maxRetries uint32) *Workflow_HandleAbortedWorkflow
- func (_m *Workflow) OnHandleAbortedWorkflowMatch(matchers ...interface{}) *Workflow_HandleAbortedWorkflow
- func (_m *Workflow) OnHandleFlyteWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow) *Workflow_HandleFlyteWorkflow
- func (_m *Workflow) OnHandleFlyteWorkflowMatch(matchers ...interface{}) *Workflow_HandleFlyteWorkflow
- func (_m *Workflow) OnInitialize(ctx context.Context) *Workflow_Initialize
- func (_m *Workflow) OnInitializeMatch(matchers ...interface{}) *Workflow_Initialize
- type Workflow_HandleAbortedWorkflow
- type Workflow_HandleFlyteWorkflow
- type Workflow_Initialize
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
Client is an autogenerated mock type for the Client type
func NewFakeKubeClient ¶
func NewFakeKubeClient() *Client
func (*Client) OnGetCache ¶ added in v0.1.13
func (_m *Client) OnGetCache() *Client_GetCache
func (*Client) OnGetCacheMatch ¶ added in v0.1.13
func (_m *Client) OnGetCacheMatch(matchers ...interface{}) *Client_GetCache
func (*Client) OnGetClient ¶ added in v0.1.13
func (_m *Client) OnGetClient() *Client_GetClient
func (*Client) OnGetClientMatch ¶ added in v0.1.13
func (_m *Client) OnGetClientMatch(matchers ...interface{}) *Client_GetClient
type Client_GetCache ¶ added in v0.1.13
func (Client_GetCache) Return ¶ added in v0.1.13
func (_m Client_GetCache) Return(_a0 cache.Cache) *Client_GetCache
type Client_GetClient ¶ added in v0.1.13
func (Client_GetClient) Return ¶ added in v0.1.13
func (_m Client_GetClient) Return(_a0 client.Client) *Client_GetClient
type Node ¶ added in v0.1.13
Node is an autogenerated mock type for the Node type
func (*Node) AbortHandler ¶ added in v0.1.13
func (_m *Node) AbortHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, currentNode v1alpha1.ExecutableNode, reason string) error
AbortHandler provides a mock function with given fields: ctx, w, currentNode, reason
func (*Node) Initialize ¶ added in v0.1.13
Initialize provides a mock function with given fields: ctx
func (*Node) OnAbortHandler ¶ added in v0.1.13
func (_m *Node) OnAbortHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, currentNode v1alpha1.ExecutableNode, reason string) *Node_AbortHandler
func (*Node) OnAbortHandlerMatch ¶ added in v0.1.13
func (_m *Node) OnAbortHandlerMatch(matchers ...interface{}) *Node_AbortHandler
func (*Node) OnInitialize ¶ added in v0.1.13
func (_m *Node) OnInitialize(ctx context.Context) *Node_Initialize
func (*Node) OnInitializeMatch ¶ added in v0.1.13
func (_m *Node) OnInitializeMatch(matchers ...interface{}) *Node_Initialize
func (*Node) OnRecursiveNodeHandler ¶ added in v0.1.13
func (_m *Node) OnRecursiveNodeHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, currentNode v1alpha1.ExecutableNode) *Node_RecursiveNodeHandler
func (*Node) OnRecursiveNodeHandlerMatch ¶ added in v0.1.13
func (_m *Node) OnRecursiveNodeHandlerMatch(matchers ...interface{}) *Node_RecursiveNodeHandler
func (*Node) OnSetInputsForStartNode ¶ added in v0.1.13
func (_m *Node) OnSetInputsForStartNode(ctx context.Context, w v1alpha1.BaseWorkflowWithStatus, inputs *core.LiteralMap) *Node_SetInputsForStartNode
func (*Node) OnSetInputsForStartNodeMatch ¶ added in v0.1.13
func (_m *Node) OnSetInputsForStartNodeMatch(matchers ...interface{}) *Node_SetInputsForStartNode
func (*Node) RecursiveNodeHandler ¶ added in v0.1.13
func (_m *Node) RecursiveNodeHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, currentNode v1alpha1.ExecutableNode) (executors.NodeStatus, error)
RecursiveNodeHandler provides a mock function with given fields: ctx, w, currentNode
func (*Node) SetInputsForStartNode ¶ added in v0.1.13
func (_m *Node) SetInputsForStartNode(ctx context.Context, w v1alpha1.BaseWorkflowWithStatus, inputs *core.LiteralMap) (executors.NodeStatus, error)
SetInputsForStartNode provides a mock function with given fields: ctx, w, inputs
type Node_AbortHandler ¶ added in v0.1.13
func (Node_AbortHandler) Return ¶ added in v0.1.13
func (_m Node_AbortHandler) Return(_a0 error) *Node_AbortHandler
type Node_Initialize ¶ added in v0.1.13
func (Node_Initialize) Return ¶ added in v0.1.13
func (_m Node_Initialize) Return(_a0 error) *Node_Initialize
type Node_RecursiveNodeHandler ¶ added in v0.1.13
func (Node_RecursiveNodeHandler) Return ¶ added in v0.1.13
func (_m Node_RecursiveNodeHandler) Return(_a0 executors.NodeStatus, _a1 error) *Node_RecursiveNodeHandler
type Node_SetInputsForStartNode ¶ added in v0.1.13
func (Node_SetInputsForStartNode) Return ¶ added in v0.1.13
func (_m Node_SetInputsForStartNode) Return(_a0 executors.NodeStatus, _a1 error) *Node_SetInputsForStartNode
type Workflow ¶ added in v0.1.13
Workflow is an autogenerated mock type for the Workflow type
func (*Workflow) HandleAbortedWorkflow ¶ added in v0.1.13
func (_m *Workflow) HandleAbortedWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow, maxRetries uint32) error
HandleAbortedWorkflow provides a mock function with given fields: ctx, w, maxRetries
func (*Workflow) HandleFlyteWorkflow ¶ added in v0.1.13
HandleFlyteWorkflow provides a mock function with given fields: ctx, w
func (*Workflow) Initialize ¶ added in v0.1.13
Initialize provides a mock function with given fields: ctx
func (*Workflow) OnHandleAbortedWorkflow ¶ added in v0.1.13
func (_m *Workflow) OnHandleAbortedWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow, maxRetries uint32) *Workflow_HandleAbortedWorkflow
func (*Workflow) OnHandleAbortedWorkflowMatch ¶ added in v0.1.13
func (_m *Workflow) OnHandleAbortedWorkflowMatch(matchers ...interface{}) *Workflow_HandleAbortedWorkflow
func (*Workflow) OnHandleFlyteWorkflow ¶ added in v0.1.13
func (_m *Workflow) OnHandleFlyteWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow) *Workflow_HandleFlyteWorkflow
func (*Workflow) OnHandleFlyteWorkflowMatch ¶ added in v0.1.13
func (_m *Workflow) OnHandleFlyteWorkflowMatch(matchers ...interface{}) *Workflow_HandleFlyteWorkflow
func (*Workflow) OnInitialize ¶ added in v0.1.13
func (_m *Workflow) OnInitialize(ctx context.Context) *Workflow_Initialize
func (*Workflow) OnInitializeMatch ¶ added in v0.1.13
func (_m *Workflow) OnInitializeMatch(matchers ...interface{}) *Workflow_Initialize
type Workflow_HandleAbortedWorkflow ¶ added in v0.1.13
func (Workflow_HandleAbortedWorkflow) Return ¶ added in v0.1.13
func (_m Workflow_HandleAbortedWorkflow) Return(_a0 error) *Workflow_HandleAbortedWorkflow
type Workflow_HandleFlyteWorkflow ¶ added in v0.1.13
func (Workflow_HandleFlyteWorkflow) Return ¶ added in v0.1.13
func (_m Workflow_HandleFlyteWorkflow) Return(_a0 error) *Workflow_HandleFlyteWorkflow
type Workflow_Initialize ¶ added in v0.1.13
func (Workflow_Initialize) Return ¶ added in v0.1.13
func (_m Workflow_Initialize) Return(_a0 error) *Workflow_Initialize