mocks

Documentation

Index

• type Client
  • func NewFakeKubeClient() *Client
  • func (_m *Client) GetCache() cache.Cache
  • func (_m *Client) GetClient() client.Client
• type Node
  • func (_m *Node) AbortHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, ...) error
  • func (_m *Node) FinalizeHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, ...) error
  • func (_m *Node) Initialize(ctx context.Context) error
  • func (_m *Node) OnFinalizeHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, ...) *Node_FinalizeHandler
  • func (_m *Node) OnFinalizeHandlerMatch(matchers ...interface{}) *Node_FinalizeHandler
  • func (_m *Node) OnInitialize(ctx context.Context) *Node_Initialize
  • func (_m *Node) OnInitializeMatch(matchers ...interface{}) *Node_Initialize
  • 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_FinalizeHandler
  • func (_m Node_FinalizeHandler) Return(_a0 error) *Node_FinalizeHandler
• type Node_Initialize
  • func (_m Node_Initialize) Return(_a0 error) *Node_Initialize
• 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

Types

type Client

type Client struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func NewFakeKubeClient

func NewFakeKubeClient() *Client

func (*Client) GetCache

func (_m *Client) GetCache() cache.Cache

GetCache provides a mock function with given fields:

func (*Client) GetClient

func (_m *Client) GetClient() client.Client

GetClient provides a mock function with given fields:

type Node

type Node struct {
	mock.Mock
}

Node is an autogenerated mock type for the Node type

func (*Node) AbortHandler

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) FinalizeHandler

func (_m *Node) FinalizeHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, currentNode v1alpha1.ExecutableNode) error

FinalizeHandler provides a mock function with given fields: ctx, w, currentNode

func (*Node) Initialize

func (_m *Node) Initialize(ctx context.Context) error

Initialize provides a mock function with given fields: ctx

func (*Node) OnFinalizeHandler

func (_m *Node) OnFinalizeHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, currentNode v1alpha1.ExecutableNode) *Node_FinalizeHandler

func (*Node) OnFinalizeHandlerMatch

func (_m *Node) OnFinalizeHandlerMatch(matchers ...interface{}) *Node_FinalizeHandler

func (*Node) OnInitialize

func (_m *Node) OnInitialize(ctx context.Context) *Node_Initialize

func (*Node) OnInitializeMatch

func (_m *Node) OnInitializeMatch(matchers ...interface{}) *Node_Initialize

func (*Node) RecursiveNodeHandler

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

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_FinalizeHandler

type Node_FinalizeHandler struct {
	*mock.Call
}

func (Node_FinalizeHandler) Return

func (_m Node_FinalizeHandler) Return(_a0 error) *Node_FinalizeHandler

type Node_Initialize

type Node_Initialize struct {
	*mock.Call
}

func (Node_Initialize) Return

func (_m Node_Initialize) Return(_a0 error) *Node_Initialize

type Workflow

type Workflow struct {
	mock.Mock
}

Workflow is an autogenerated mock type for the Workflow type

func (*Workflow) HandleAbortedWorkflow

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

func (_m *Workflow) HandleFlyteWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow) error

HandleFlyteWorkflow provides a mock function with given fields: ctx, w

func (*Workflow) Initialize

func (_m *Workflow) Initialize(ctx context.Context) error

Initialize provides a mock function with given fields: ctx