mocks

package
v1.0.0-beta1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 22, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AssetEventsClient 

type AssetEventsClient struct {
	mock.Mock
}

AssetEventsClient is an autogenerated mock type for the AssetEventsClient type

func NewAssetEventsClient 

func NewAssetEventsClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *AssetEventsClient

NewAssetEventsClient creates a new instance of AssetEventsClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*AssetEventsClient) EXPECT 

func (_m *AssetEventsClient) EXPECT() *AssetEventsClient_Expecter

func (*AssetEventsClient) GetByAssetAlias 

func (_mock *AssetEventsClient) GetByAssetAlias(ctx context.Context, params *api.GetAssetEventByAssetAliasParams) (*api.AssetEventsResponse, error)

GetByAssetAlias provides a mock function for the type AssetEventsClient

func (*AssetEventsClient) GetByAssetAliasResponse 

func (_mock *AssetEventsClient) GetByAssetAliasResponse(ctx context.Context, params *api.GetAssetEventByAssetAliasParams) (*resty.Response, error)

GetByAssetAliasResponse provides a mock function for the type AssetEventsClient

func (*AssetEventsClient) GetByAssetNameUri 

func (_mock *AssetEventsClient) GetByAssetNameUri(ctx context.Context, params *api.GetAssetEventByAssetNameUriParams) (*api.AssetEventsResponse, error)

GetByAssetNameUri provides a mock function for the type AssetEventsClient

func (*AssetEventsClient) GetByAssetNameUriResponse 

func (_mock *AssetEventsClient) GetByAssetNameUriResponse(ctx context.Context, params *api.GetAssetEventByAssetNameUriParams) (*resty.Response, error)

GetByAssetNameUriResponse provides a mock function for the type AssetEventsClient

type AssetEventsClient_Expecter 

type AssetEventsClient_Expecter struct {
	// contains filtered or unexported fields
}

func (*AssetEventsClient_Expecter) GetByAssetAlias 

func (_e *AssetEventsClient_Expecter) GetByAssetAlias(ctx interface{}, params interface{}) *AssetEventsClient_GetByAssetAlias_Call

GetByAssetAlias is a helper method to define mock.On call

  • ctx context.Context
  • params *api.GetAssetEventByAssetAliasParams

func (*AssetEventsClient_Expecter) GetByAssetAliasResponse 

func (_e *AssetEventsClient_Expecter) GetByAssetAliasResponse(ctx interface{}, params interface{}) *AssetEventsClient_GetByAssetAliasResponse_Call

GetByAssetAliasResponse is a helper method to define mock.On call

  • ctx context.Context
  • params *api.GetAssetEventByAssetAliasParams

func (*AssetEventsClient_Expecter) GetByAssetNameUri 

func (_e *AssetEventsClient_Expecter) GetByAssetNameUri(ctx interface{}, params interface{}) *AssetEventsClient_GetByAssetNameUri_Call

GetByAssetNameUri is a helper method to define mock.On call

  • ctx context.Context
  • params *api.GetAssetEventByAssetNameUriParams

func (*AssetEventsClient_Expecter) GetByAssetNameUriResponse 

func (_e *AssetEventsClient_Expecter) GetByAssetNameUriResponse(ctx interface{}, params interface{}) *AssetEventsClient_GetByAssetNameUriResponse_Call

GetByAssetNameUriResponse is a helper method to define mock.On call

  • ctx context.Context
  • params *api.GetAssetEventByAssetNameUriParams

type AssetEventsClient_GetByAssetAliasResponse_Call 

type AssetEventsClient_GetByAssetAliasResponse_Call struct {
	*mock.Call
}

AssetEventsClient_GetByAssetAliasResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetByAssetAliasResponse'

func (*AssetEventsClient_GetByAssetAliasResponse_Call) Return 

func (_c *AssetEventsClient_GetByAssetAliasResponse_Call) Return(response *resty.Response, err error) *AssetEventsClient_GetByAssetAliasResponse_Call

func (*AssetEventsClient_GetByAssetAliasResponse_Call) Run 

func (_c *AssetEventsClient_GetByAssetAliasResponse_Call) Run(run func(ctx context.Context, params *api.GetAssetEventByAssetAliasParams)) *AssetEventsClient_GetByAssetAliasResponse_Call

func (*AssetEventsClient_GetByAssetAliasResponse_Call) RunAndReturn 

func (_c *AssetEventsClient_GetByAssetAliasResponse_Call) RunAndReturn(run func(ctx context.Context, params *api.GetAssetEventByAssetAliasParams) (*resty.Response, error)) *AssetEventsClient_GetByAssetAliasResponse_Call

type AssetEventsClient_GetByAssetAlias_Call 

type AssetEventsClient_GetByAssetAlias_Call struct {
	*mock.Call
}

AssetEventsClient_GetByAssetAlias_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetByAssetAlias'

func (*AssetEventsClient_GetByAssetAlias_Call) Return 

func (_c *AssetEventsClient_GetByAssetAlias_Call) Return(assetEventsResponse *api.AssetEventsResponse, err error) *AssetEventsClient_GetByAssetAlias_Call

func (*AssetEventsClient_GetByAssetAlias_Call) Run 

func (_c *AssetEventsClient_GetByAssetAlias_Call) Run(run func(ctx context.Context, params *api.GetAssetEventByAssetAliasParams)) *AssetEventsClient_GetByAssetAlias_Call

func (*AssetEventsClient_GetByAssetAlias_Call) RunAndReturn 

func (_c *AssetEventsClient_GetByAssetAlias_Call) RunAndReturn(run func(ctx context.Context, params *api.GetAssetEventByAssetAliasParams) (*api.AssetEventsResponse, error)) *AssetEventsClient_GetByAssetAlias_Call

type AssetEventsClient_GetByAssetNameUriResponse_Call 

type AssetEventsClient_GetByAssetNameUriResponse_Call struct {
	*mock.Call
}

AssetEventsClient_GetByAssetNameUriResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetByAssetNameUriResponse'

func (*AssetEventsClient_GetByAssetNameUriResponse_Call) Return 

func (_c *AssetEventsClient_GetByAssetNameUriResponse_Call) Return(response *resty.Response, err error) *AssetEventsClient_GetByAssetNameUriResponse_Call

func (*AssetEventsClient_GetByAssetNameUriResponse_Call) Run 

func (_c *AssetEventsClient_GetByAssetNameUriResponse_Call) Run(run func(ctx context.Context, params *api.GetAssetEventByAssetNameUriParams)) *AssetEventsClient_GetByAssetNameUriResponse_Call

func (*AssetEventsClient_GetByAssetNameUriResponse_Call) RunAndReturn 

func (_c *AssetEventsClient_GetByAssetNameUriResponse_Call) RunAndReturn(run func(ctx context.Context, params *api.GetAssetEventByAssetNameUriParams) (*resty.Response, error)) *AssetEventsClient_GetByAssetNameUriResponse_Call

type AssetEventsClient_GetByAssetNameUri_Call 

type AssetEventsClient_GetByAssetNameUri_Call struct {
	*mock.Call
}

AssetEventsClient_GetByAssetNameUri_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetByAssetNameUri'

func (*AssetEventsClient_GetByAssetNameUri_Call) Return 

func (_c *AssetEventsClient_GetByAssetNameUri_Call) Return(assetEventsResponse *api.AssetEventsResponse, err error) *AssetEventsClient_GetByAssetNameUri_Call

func (*AssetEventsClient_GetByAssetNameUri_Call) Run 

func (_c *AssetEventsClient_GetByAssetNameUri_Call) Run(run func(ctx context.Context, params *api.GetAssetEventByAssetNameUriParams)) *AssetEventsClient_GetByAssetNameUri_Call

func (*AssetEventsClient_GetByAssetNameUri_Call) RunAndReturn 

func (_c *AssetEventsClient_GetByAssetNameUri_Call) RunAndReturn(run func(ctx context.Context, params *api.GetAssetEventByAssetNameUriParams) (*api.AssetEventsResponse, error)) *AssetEventsClient_GetByAssetNameUri_Call

type AssetsClient 

type AssetsClient struct {
	mock.Mock
}

AssetsClient is an autogenerated mock type for the AssetsClient type

func NewAssetsClient 

func NewAssetsClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *AssetsClient

NewAssetsClient creates a new instance of AssetsClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*AssetsClient) EXPECT 

func (_m *AssetsClient) EXPECT() *AssetsClient_Expecter

func (*AssetsClient) GetByName 

func (_mock *AssetsClient) GetByName(ctx context.Context, params *api.GetAssetByNameParams) (*api.AssetResponse, error)

GetByName provides a mock function for the type AssetsClient

func (*AssetsClient) GetByNameResponse 

func (_mock *AssetsClient) GetByNameResponse(ctx context.Context, params *api.GetAssetByNameParams) (*resty.Response, error)

GetByNameResponse provides a mock function for the type AssetsClient

func (*AssetsClient) GetByUri 

func (_mock *AssetsClient) GetByUri(ctx context.Context, params *api.GetAssetByUriParams) (*api.AssetResponse, error)

GetByUri provides a mock function for the type AssetsClient

func (*AssetsClient) GetByUriResponse 

func (_mock *AssetsClient) GetByUriResponse(ctx context.Context, params *api.GetAssetByUriParams) (*resty.Response, error)

GetByUriResponse provides a mock function for the type AssetsClient

type AssetsClient_Expecter 

type AssetsClient_Expecter struct {
	// contains filtered or unexported fields
}

func (*AssetsClient_Expecter) GetByName 

func (_e *AssetsClient_Expecter) GetByName(ctx interface{}, params interface{}) *AssetsClient_GetByName_Call

GetByName is a helper method to define mock.On call

  • ctx context.Context
  • params *api.GetAssetByNameParams

func (*AssetsClient_Expecter) GetByNameResponse 

func (_e *AssetsClient_Expecter) GetByNameResponse(ctx interface{}, params interface{}) *AssetsClient_GetByNameResponse_Call

GetByNameResponse is a helper method to define mock.On call

  • ctx context.Context
  • params *api.GetAssetByNameParams

func (*AssetsClient_Expecter) GetByUri 

func (_e *AssetsClient_Expecter) GetByUri(ctx interface{}, params interface{}) *AssetsClient_GetByUri_Call

GetByUri is a helper method to define mock.On call

  • ctx context.Context
  • params *api.GetAssetByUriParams

func (*AssetsClient_Expecter) GetByUriResponse 

func (_e *AssetsClient_Expecter) GetByUriResponse(ctx interface{}, params interface{}) *AssetsClient_GetByUriResponse_Call

GetByUriResponse is a helper method to define mock.On call

  • ctx context.Context
  • params *api.GetAssetByUriParams

type AssetsClient_GetByNameResponse_Call 

type AssetsClient_GetByNameResponse_Call struct {
	*mock.Call
}

AssetsClient_GetByNameResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetByNameResponse'

func (*AssetsClient_GetByNameResponse_Call) Return 

func (_c *AssetsClient_GetByNameResponse_Call) Return(response *resty.Response, err error) *AssetsClient_GetByNameResponse_Call

func (*AssetsClient_GetByNameResponse_Call) Run 

func (_c *AssetsClient_GetByNameResponse_Call) Run(run func(ctx context.Context, params *api.GetAssetByNameParams)) *AssetsClient_GetByNameResponse_Call

func (*AssetsClient_GetByNameResponse_Call) RunAndReturn 

func (_c *AssetsClient_GetByNameResponse_Call) RunAndReturn(run func(ctx context.Context, params *api.GetAssetByNameParams) (*resty.Response, error)) *AssetsClient_GetByNameResponse_Call

type AssetsClient_GetByName_Call 

type AssetsClient_GetByName_Call struct {
	*mock.Call
}

AssetsClient_GetByName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetByName'

func (*AssetsClient_GetByName_Call) Return 

func (_c *AssetsClient_GetByName_Call) Return(assetResponse *api.AssetResponse, err error) *AssetsClient_GetByName_Call

func (*AssetsClient_GetByName_Call) Run 

func (_c *AssetsClient_GetByName_Call) Run(run func(ctx context.Context, params *api.GetAssetByNameParams)) *AssetsClient_GetByName_Call

func (*AssetsClient_GetByName_Call) RunAndReturn 

func (_c *AssetsClient_GetByName_Call) RunAndReturn(run func(ctx context.Context, params *api.GetAssetByNameParams) (*api.AssetResponse, error)) *AssetsClient_GetByName_Call

type AssetsClient_GetByUriResponse_Call 

type AssetsClient_GetByUriResponse_Call struct {
	*mock.Call
}

AssetsClient_GetByUriResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetByUriResponse'

func (*AssetsClient_GetByUriResponse_Call) Return 

func (_c *AssetsClient_GetByUriResponse_Call) Return(response *resty.Response, err error) *AssetsClient_GetByUriResponse_Call

func (*AssetsClient_GetByUriResponse_Call) Run 

func (_c *AssetsClient_GetByUriResponse_Call) Run(run func(ctx context.Context, params *api.GetAssetByUriParams)) *AssetsClient_GetByUriResponse_Call

func (*AssetsClient_GetByUriResponse_Call) RunAndReturn 

func (_c *AssetsClient_GetByUriResponse_Call) RunAndReturn(run func(ctx context.Context, params *api.GetAssetByUriParams) (*resty.Response, error)) *AssetsClient_GetByUriResponse_Call

type AssetsClient_GetByUri_Call 

type AssetsClient_GetByUri_Call struct {
	*mock.Call
}

AssetsClient_GetByUri_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetByUri'

func (*AssetsClient_GetByUri_Call) Return 

func (_c *AssetsClient_GetByUri_Call) Return(assetResponse *api.AssetResponse, err error) *AssetsClient_GetByUri_Call

func (*AssetsClient_GetByUri_Call) Run 

func (_c *AssetsClient_GetByUri_Call) Run(run func(ctx context.Context, params *api.GetAssetByUriParams)) *AssetsClient_GetByUri_Call

func (*AssetsClient_GetByUri_Call) RunAndReturn 

func (_c *AssetsClient_GetByUri_Call) RunAndReturn(run func(ctx context.Context, params *api.GetAssetByUriParams) (*api.AssetResponse, error)) *AssetsClient_GetByUri_Call

type ClientInterface 

type ClientInterface struct {
	mock.Mock
}

ClientInterface is an autogenerated mock type for the ClientInterface type

func NewClientInterface 

func NewClientInterface(t interface {
	mock.TestingT
	Cleanup(func())
}) *ClientInterface

NewClientInterface creates a new instance of ClientInterface. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ClientInterface) AssetEvents 

func (_mock *ClientInterface) AssetEvents() api.AssetEventsClient

AssetEvents provides a mock function for the type ClientInterface

func (*ClientInterface) Assets 

func (_mock *ClientInterface) Assets() api.AssetsClient

Assets provides a mock function for the type ClientInterface

func (*ClientInterface) Connections 

func (_mock *ClientInterface) Connections() api.ConnectionsClient

Connections provides a mock function for the type ClientInterface

func (*ClientInterface) DagRuns 

func (_mock *ClientInterface) DagRuns() api.DagRunsClient

DagRuns provides a mock function for the type ClientInterface

func (*ClientInterface) EXPECT 

func (_m *ClientInterface) EXPECT() *ClientInterface_Expecter

func (*ClientInterface) TaskInstances 

func (_mock *ClientInterface) TaskInstances() api.TaskInstancesClient

TaskInstances provides a mock function for the type ClientInterface

func (*ClientInterface) TaskReschedules 

func (_mock *ClientInterface) TaskReschedules() api.TaskReschedulesClient

TaskReschedules provides a mock function for the type ClientInterface

func (*ClientInterface) Variables 

func (_mock *ClientInterface) Variables() api.VariablesClient

Variables provides a mock function for the type ClientInterface

func (*ClientInterface) Xcoms 

func (_mock *ClientInterface) Xcoms() api.XcomsClient

Xcoms provides a mock function for the type ClientInterface

type ClientInterface_AssetEvents_Call 

type ClientInterface_AssetEvents_Call struct {
	*mock.Call
}

ClientInterface_AssetEvents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AssetEvents'

func (*ClientInterface_AssetEvents_Call) Return 

func (_c *ClientInterface_AssetEvents_Call) Return(assetEventsClient api.AssetEventsClient) *ClientInterface_AssetEvents_Call

func (*ClientInterface_AssetEvents_Call) Run 

func (_c *ClientInterface_AssetEvents_Call) Run(run func()) *ClientInterface_AssetEvents_Call

func (*ClientInterface_AssetEvents_Call) RunAndReturn 

func (_c *ClientInterface_AssetEvents_Call) RunAndReturn(run func() api.AssetEventsClient) *ClientInterface_AssetEvents_Call

type ClientInterface_Assets_Call 

type ClientInterface_Assets_Call struct {
	*mock.Call
}

ClientInterface_Assets_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Assets'

func (*ClientInterface_Assets_Call) Return 

func (_c *ClientInterface_Assets_Call) Return(assetsClient api.AssetsClient) *ClientInterface_Assets_Call

func (*ClientInterface_Assets_Call) Run 

func (_c *ClientInterface_Assets_Call) Run(run func()) *ClientInterface_Assets_Call

func (*ClientInterface_Assets_Call) RunAndReturn 

func (_c *ClientInterface_Assets_Call) RunAndReturn(run func() api.AssetsClient) *ClientInterface_Assets_Call

type ClientInterface_Connections_Call 

type ClientInterface_Connections_Call struct {
	*mock.Call
}

ClientInterface_Connections_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Connections'

func (*ClientInterface_Connections_Call) Return 

func (_c *ClientInterface_Connections_Call) Return(connectionsClient api.ConnectionsClient) *ClientInterface_Connections_Call

func (*ClientInterface_Connections_Call) Run 

func (_c *ClientInterface_Connections_Call) Run(run func()) *ClientInterface_Connections_Call

func (*ClientInterface_Connections_Call) RunAndReturn 

func (_c *ClientInterface_Connections_Call) RunAndReturn(run func() api.ConnectionsClient) *ClientInterface_Connections_Call

type ClientInterface_DagRuns_Call 

type ClientInterface_DagRuns_Call struct {
	*mock.Call
}

ClientInterface_DagRuns_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DagRuns'

func (*ClientInterface_DagRuns_Call) Return 

func (_c *ClientInterface_DagRuns_Call) Return(dagRunsClient api.DagRunsClient) *ClientInterface_DagRuns_Call

func (*ClientInterface_DagRuns_Call) Run 

func (_c *ClientInterface_DagRuns_Call) Run(run func()) *ClientInterface_DagRuns_Call

func (*ClientInterface_DagRuns_Call) RunAndReturn 

func (_c *ClientInterface_DagRuns_Call) RunAndReturn(run func() api.DagRunsClient) *ClientInterface_DagRuns_Call

type ClientInterface_Expecter 

type ClientInterface_Expecter struct {
	// contains filtered or unexported fields
}

func (*ClientInterface_Expecter) AssetEvents 

func (_e *ClientInterface_Expecter) AssetEvents() *ClientInterface_AssetEvents_Call

AssetEvents is a helper method to define mock.On call

func (*ClientInterface_Expecter) Assets 

func (_e *ClientInterface_Expecter) Assets() *ClientInterface_Assets_Call

Assets is a helper method to define mock.On call

func (*ClientInterface_Expecter) Connections 

func (_e *ClientInterface_Expecter) Connections() *ClientInterface_Connections_Call

Connections is a helper method to define mock.On call

func (*ClientInterface_Expecter) DagRuns 

func (_e *ClientInterface_Expecter) DagRuns() *ClientInterface_DagRuns_Call

DagRuns is a helper method to define mock.On call

func (*ClientInterface_Expecter) TaskInstances 

func (_e *ClientInterface_Expecter) TaskInstances() *ClientInterface_TaskInstances_Call

TaskInstances is a helper method to define mock.On call

func (*ClientInterface_Expecter) TaskReschedules 

func (_e *ClientInterface_Expecter) TaskReschedules() *ClientInterface_TaskReschedules_Call

TaskReschedules is a helper method to define mock.On call

func (*ClientInterface_Expecter) Variables 

func (_e *ClientInterface_Expecter) Variables() *ClientInterface_Variables_Call

Variables is a helper method to define mock.On call

func (*ClientInterface_Expecter) Xcoms 

func (_e *ClientInterface_Expecter) Xcoms() *ClientInterface_Xcoms_Call

Xcoms is a helper method to define mock.On call

type ClientInterface_TaskInstances_Call 

type ClientInterface_TaskInstances_Call struct {
	*mock.Call
}

ClientInterface_TaskInstances_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TaskInstances'

func (*ClientInterface_TaskInstances_Call) Return 

func (_c *ClientInterface_TaskInstances_Call) Return(taskInstancesClient api.TaskInstancesClient) *ClientInterface_TaskInstances_Call

func (*ClientInterface_TaskInstances_Call) Run 

func (_c *ClientInterface_TaskInstances_Call) Run(run func()) *ClientInterface_TaskInstances_Call

func (*ClientInterface_TaskInstances_Call) RunAndReturn 

func (_c *ClientInterface_TaskInstances_Call) RunAndReturn(run func() api.TaskInstancesClient) *ClientInterface_TaskInstances_Call

type ClientInterface_TaskReschedules_Call 

type ClientInterface_TaskReschedules_Call struct {
	*mock.Call
}

ClientInterface_TaskReschedules_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TaskReschedules'

func (*ClientInterface_TaskReschedules_Call) Return 

func (_c *ClientInterface_TaskReschedules_Call) Return(taskReschedulesClient api.TaskReschedulesClient) *ClientInterface_TaskReschedules_Call

func (*ClientInterface_TaskReschedules_Call) Run 

func (_c *ClientInterface_TaskReschedules_Call) Run(run func()) *ClientInterface_TaskReschedules_Call

func (*ClientInterface_TaskReschedules_Call) RunAndReturn 

func (_c *ClientInterface_TaskReschedules_Call) RunAndReturn(run func() api.TaskReschedulesClient) *ClientInterface_TaskReschedules_Call

type ClientInterface_Variables_Call 

type ClientInterface_Variables_Call struct {
	*mock.Call
}

ClientInterface_Variables_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Variables'

func (*ClientInterface_Variables_Call) Return 

func (_c *ClientInterface_Variables_Call) Return(variablesClient api.VariablesClient) *ClientInterface_Variables_Call

func (*ClientInterface_Variables_Call) Run 

func (_c *ClientInterface_Variables_Call) Run(run func()) *ClientInterface_Variables_Call

func (*ClientInterface_Variables_Call) RunAndReturn 

func (_c *ClientInterface_Variables_Call) RunAndReturn(run func() api.VariablesClient) *ClientInterface_Variables_Call

type ClientInterface_Xcoms_Call 

type ClientInterface_Xcoms_Call struct {
	*mock.Call
}

ClientInterface_Xcoms_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Xcoms'

func (*ClientInterface_Xcoms_Call) Return 

func (_c *ClientInterface_Xcoms_Call) Return(xcomsClient api.XcomsClient) *ClientInterface_Xcoms_Call

func (*ClientInterface_Xcoms_Call) Run 

func (_c *ClientInterface_Xcoms_Call) Run(run func()) *ClientInterface_Xcoms_Call

func (*ClientInterface_Xcoms_Call) RunAndReturn 

func (_c *ClientInterface_Xcoms_Call) RunAndReturn(run func() api.XcomsClient) *ClientInterface_Xcoms_Call

type ConnectionsClient 

type ConnectionsClient struct {
	mock.Mock
}

ConnectionsClient is an autogenerated mock type for the ConnectionsClient type

func NewConnectionsClient 

func NewConnectionsClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConnectionsClient

NewConnectionsClient creates a new instance of ConnectionsClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ConnectionsClient) EXPECT 

func (_m *ConnectionsClient) EXPECT() *ConnectionsClient_Expecter

func (*ConnectionsClient) Get 

func (_mock *ConnectionsClient) Get(ctx context.Context, connectionId string) (*api.ConnectionResponse, error)

Get provides a mock function for the type ConnectionsClient

func (*ConnectionsClient) GetResponse 

func (_mock *ConnectionsClient) GetResponse(ctx context.Context, connectionId string) (*resty.Response, error)

GetResponse provides a mock function for the type ConnectionsClient

type ConnectionsClient_Expecter 

type ConnectionsClient_Expecter struct {
	// contains filtered or unexported fields
}

func (*ConnectionsClient_Expecter) Get 

func (_e *ConnectionsClient_Expecter) Get(ctx interface{}, connectionId interface{}) *ConnectionsClient_Get_Call

Get is a helper method to define mock.On call

  • ctx context.Context
  • connectionId string

func (*ConnectionsClient_Expecter) GetResponse 

func (_e *ConnectionsClient_Expecter) GetResponse(ctx interface{}, connectionId interface{}) *ConnectionsClient_GetResponse_Call

GetResponse is a helper method to define mock.On call

  • ctx context.Context
  • connectionId string

type ConnectionsClient_GetResponse_Call 

type ConnectionsClient_GetResponse_Call struct {
	*mock.Call
}

ConnectionsClient_GetResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetResponse'

func (*ConnectionsClient_GetResponse_Call) Return 

func (_c *ConnectionsClient_GetResponse_Call) Return(response *resty.Response, err error) *ConnectionsClient_GetResponse_Call

func (*ConnectionsClient_GetResponse_Call) Run 

func (_c *ConnectionsClient_GetResponse_Call) Run(run func(ctx context.Context, connectionId string)) *ConnectionsClient_GetResponse_Call

func (*ConnectionsClient_GetResponse_Call) RunAndReturn 

func (_c *ConnectionsClient_GetResponse_Call) RunAndReturn(run func(ctx context.Context, connectionId string) (*resty.Response, error)) *ConnectionsClient_GetResponse_Call

type ConnectionsClient_Get_Call 

type ConnectionsClient_Get_Call struct {
	*mock.Call
}

ConnectionsClient_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'

func (*ConnectionsClient_Get_Call) Return 

func (_c *ConnectionsClient_Get_Call) Return(connectionResponse *api.ConnectionResponse, err error) *ConnectionsClient_Get_Call

func (*ConnectionsClient_Get_Call) Run 

func (_c *ConnectionsClient_Get_Call) Run(run func(ctx context.Context, connectionId string)) *ConnectionsClient_Get_Call

func (*ConnectionsClient_Get_Call) RunAndReturn 

func (_c *ConnectionsClient_Get_Call) RunAndReturn(run func(ctx context.Context, connectionId string) (*api.ConnectionResponse, error)) *ConnectionsClient_Get_Call

type DagRunsClient 

type DagRunsClient struct {
	mock.Mock
}

DagRunsClient is an autogenerated mock type for the DagRunsClient type

func NewDagRunsClient 

func NewDagRunsClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *DagRunsClient

NewDagRunsClient creates a new instance of DagRunsClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*DagRunsClient) Clear 

func (_mock *DagRunsClient) Clear(ctx context.Context, dagId string, runId string) error

Clear provides a mock function for the type DagRunsClient

func (*DagRunsClient) ClearResponse 

func (_mock *DagRunsClient) ClearResponse(ctx context.Context, dagId string, runId string) (*resty.Response, error)

ClearResponse provides a mock function for the type DagRunsClient

func (*DagRunsClient) EXPECT 

func (_m *DagRunsClient) EXPECT() *DagRunsClient_Expecter

func (*DagRunsClient) GetDrCount 

func (_mock *DagRunsClient) GetDrCount(ctx context.Context, params *api.GetDrCountParams) (*int, error)

GetDrCount provides a mock function for the type DagRunsClient

func (*DagRunsClient) GetDrCountResponse 

func (_mock *DagRunsClient) GetDrCountResponse(ctx context.Context, params *api.GetDrCountParams) (*resty.Response, error)

GetDrCountResponse provides a mock function for the type DagRunsClient

func (*DagRunsClient) GetState 

func (_mock *DagRunsClient) GetState(ctx context.Context, dagId string, runId string) (*api.DagRunStateResponse, error)

GetState provides a mock function for the type DagRunsClient

func (*DagRunsClient) GetStateResponse 

func (_mock *DagRunsClient) GetStateResponse(ctx context.Context, dagId string, runId string) (*resty.Response, error)

GetStateResponse provides a mock function for the type DagRunsClient

func (*DagRunsClient) Trigger 

func (_mock *DagRunsClient) Trigger(ctx context.Context, dagId string, runId string, body *api.TriggerDAGRunPayload) error

Trigger provides a mock function for the type DagRunsClient

func (*DagRunsClient) TriggerResponse 

func (_mock *DagRunsClient) TriggerResponse(ctx context.Context, dagId string, runId string, body *api.TriggerDAGRunPayload) (*resty.Response, error)

TriggerResponse provides a mock function for the type DagRunsClient

type DagRunsClient_ClearResponse_Call 

type DagRunsClient_ClearResponse_Call struct {
	*mock.Call
}

DagRunsClient_ClearResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ClearResponse'

func (*DagRunsClient_ClearResponse_Call) Return 

func (_c *DagRunsClient_ClearResponse_Call) Return(response *resty.Response, err error) *DagRunsClient_ClearResponse_Call

func (*DagRunsClient_ClearResponse_Call) Run 

func (_c *DagRunsClient_ClearResponse_Call) Run(run func(ctx context.Context, dagId string, runId string)) *DagRunsClient_ClearResponse_Call

func (*DagRunsClient_ClearResponse_Call) RunAndReturn 

func (_c *DagRunsClient_ClearResponse_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string) (*resty.Response, error)) *DagRunsClient_ClearResponse_Call

type DagRunsClient_Clear_Call 

type DagRunsClient_Clear_Call struct {
	*mock.Call
}

DagRunsClient_Clear_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Clear'

func (*DagRunsClient_Clear_Call) Return 

func (_c *DagRunsClient_Clear_Call) Return(err error) *DagRunsClient_Clear_Call

func (*DagRunsClient_Clear_Call) Run 

func (_c *DagRunsClient_Clear_Call) Run(run func(ctx context.Context, dagId string, runId string)) *DagRunsClient_Clear_Call

func (*DagRunsClient_Clear_Call) RunAndReturn 

func (_c *DagRunsClient_Clear_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string) error) *DagRunsClient_Clear_Call

type DagRunsClient_Expecter 

type DagRunsClient_Expecter struct {
	// contains filtered or unexported fields
}

func (*DagRunsClient_Expecter) Clear 

func (_e *DagRunsClient_Expecter) Clear(ctx interface{}, dagId interface{}, runId interface{}) *DagRunsClient_Clear_Call

Clear is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string

func (*DagRunsClient_Expecter) ClearResponse 

func (_e *DagRunsClient_Expecter) ClearResponse(ctx interface{}, dagId interface{}, runId interface{}) *DagRunsClient_ClearResponse_Call

ClearResponse is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string

func (*DagRunsClient_Expecter) GetDrCount 

func (_e *DagRunsClient_Expecter) GetDrCount(ctx interface{}, params interface{}) *DagRunsClient_GetDrCount_Call

GetDrCount is a helper method to define mock.On call

  • ctx context.Context
  • params *api.GetDrCountParams

func (*DagRunsClient_Expecter) GetDrCountResponse 

func (_e *DagRunsClient_Expecter) GetDrCountResponse(ctx interface{}, params interface{}) *DagRunsClient_GetDrCountResponse_Call

GetDrCountResponse is a helper method to define mock.On call

  • ctx context.Context
  • params *api.GetDrCountParams

func (*DagRunsClient_Expecter) GetState 

func (_e *DagRunsClient_Expecter) GetState(ctx interface{}, dagId interface{}, runId interface{}) *DagRunsClient_GetState_Call

GetState is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string

func (*DagRunsClient_Expecter) GetStateResponse 

func (_e *DagRunsClient_Expecter) GetStateResponse(ctx interface{}, dagId interface{}, runId interface{}) *DagRunsClient_GetStateResponse_Call

GetStateResponse is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string

func (*DagRunsClient_Expecter) Trigger 

func (_e *DagRunsClient_Expecter) Trigger(ctx interface{}, dagId interface{}, runId interface{}, body interface{}) *DagRunsClient_Trigger_Call

Trigger is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string
  • body *api.TriggerDAGRunPayload

func (*DagRunsClient_Expecter) TriggerResponse 

func (_e *DagRunsClient_Expecter) TriggerResponse(ctx interface{}, dagId interface{}, runId interface{}, body interface{}) *DagRunsClient_TriggerResponse_Call

TriggerResponse is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string
  • body *api.TriggerDAGRunPayload

type DagRunsClient_GetDrCountResponse_Call 

type DagRunsClient_GetDrCountResponse_Call struct {
	*mock.Call
}

DagRunsClient_GetDrCountResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetDrCountResponse'

func (*DagRunsClient_GetDrCountResponse_Call) Return 

func (_c *DagRunsClient_GetDrCountResponse_Call) Return(response *resty.Response, err error) *DagRunsClient_GetDrCountResponse_Call

func (*DagRunsClient_GetDrCountResponse_Call) Run 

func (_c *DagRunsClient_GetDrCountResponse_Call) Run(run func(ctx context.Context, params *api.GetDrCountParams)) *DagRunsClient_GetDrCountResponse_Call

func (*DagRunsClient_GetDrCountResponse_Call) RunAndReturn 

func (_c *DagRunsClient_GetDrCountResponse_Call) RunAndReturn(run func(ctx context.Context, params *api.GetDrCountParams) (*resty.Response, error)) *DagRunsClient_GetDrCountResponse_Call

type DagRunsClient_GetDrCount_Call 

type DagRunsClient_GetDrCount_Call struct {
	*mock.Call
}

DagRunsClient_GetDrCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetDrCount'

func (*DagRunsClient_GetDrCount_Call) Return 

func (_c *DagRunsClient_GetDrCount_Call) Return(n *int, err error) *DagRunsClient_GetDrCount_Call

func (*DagRunsClient_GetDrCount_Call) Run 

func (_c *DagRunsClient_GetDrCount_Call) Run(run func(ctx context.Context, params *api.GetDrCountParams)) *DagRunsClient_GetDrCount_Call

func (*DagRunsClient_GetDrCount_Call) RunAndReturn 

func (_c *DagRunsClient_GetDrCount_Call) RunAndReturn(run func(ctx context.Context, params *api.GetDrCountParams) (*int, error)) *DagRunsClient_GetDrCount_Call

type DagRunsClient_GetStateResponse_Call 

type DagRunsClient_GetStateResponse_Call struct {
	*mock.Call
}

DagRunsClient_GetStateResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetStateResponse'

func (*DagRunsClient_GetStateResponse_Call) Return 

func (_c *DagRunsClient_GetStateResponse_Call) Return(response *resty.Response, err error) *DagRunsClient_GetStateResponse_Call

func (*DagRunsClient_GetStateResponse_Call) Run 

func (_c *DagRunsClient_GetStateResponse_Call) Run(run func(ctx context.Context, dagId string, runId string)) *DagRunsClient_GetStateResponse_Call

func (*DagRunsClient_GetStateResponse_Call) RunAndReturn 

func (_c *DagRunsClient_GetStateResponse_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string) (*resty.Response, error)) *DagRunsClient_GetStateResponse_Call

type DagRunsClient_GetState_Call 

type DagRunsClient_GetState_Call struct {
	*mock.Call
}

DagRunsClient_GetState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetState'

func (*DagRunsClient_GetState_Call) Return 

func (_c *DagRunsClient_GetState_Call) Return(dagRunStateResponse *api.DagRunStateResponse, err error) *DagRunsClient_GetState_Call

func (*DagRunsClient_GetState_Call) Run 

func (_c *DagRunsClient_GetState_Call) Run(run func(ctx context.Context, dagId string, runId string)) *DagRunsClient_GetState_Call

func (*DagRunsClient_GetState_Call) RunAndReturn 

func (_c *DagRunsClient_GetState_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string) (*api.DagRunStateResponse, error)) *DagRunsClient_GetState_Call

type DagRunsClient_TriggerResponse_Call 

type DagRunsClient_TriggerResponse_Call struct {
	*mock.Call
}

DagRunsClient_TriggerResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TriggerResponse'

func (*DagRunsClient_TriggerResponse_Call) Return 

func (_c *DagRunsClient_TriggerResponse_Call) Return(response *resty.Response, err error) *DagRunsClient_TriggerResponse_Call

func (*DagRunsClient_TriggerResponse_Call) Run 

func (_c *DagRunsClient_TriggerResponse_Call) Run(run func(ctx context.Context, dagId string, runId string, body *api.TriggerDAGRunPayload)) *DagRunsClient_TriggerResponse_Call

func (*DagRunsClient_TriggerResponse_Call) RunAndReturn 

func (_c *DagRunsClient_TriggerResponse_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string, body *api.TriggerDAGRunPayload) (*resty.Response, error)) *DagRunsClient_TriggerResponse_Call

type DagRunsClient_Trigger_Call 

type DagRunsClient_Trigger_Call struct {
	*mock.Call
}

DagRunsClient_Trigger_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Trigger'

func (*DagRunsClient_Trigger_Call) Return 

func (_c *DagRunsClient_Trigger_Call) Return(err error) *DagRunsClient_Trigger_Call

func (*DagRunsClient_Trigger_Call) Run 

func (_c *DagRunsClient_Trigger_Call) Run(run func(ctx context.Context, dagId string, runId string, body *api.TriggerDAGRunPayload)) *DagRunsClient_Trigger_Call

func (*DagRunsClient_Trigger_Call) RunAndReturn 

func (_c *DagRunsClient_Trigger_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string, body *api.TriggerDAGRunPayload) error) *DagRunsClient_Trigger_Call

type TaskInstancesClient 

type TaskInstancesClient struct {
	mock.Mock
}

TaskInstancesClient is an autogenerated mock type for the TaskInstancesClient type

func NewTaskInstancesClient 

func NewTaskInstancesClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *TaskInstancesClient

NewTaskInstancesClient creates a new instance of TaskInstancesClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*TaskInstancesClient) EXPECT 

func (_m *TaskInstancesClient) EXPECT() *TaskInstancesClient_Expecter

func (*TaskInstancesClient) GetCount 

func (_mock *TaskInstancesClient) GetCount(ctx context.Context, params *api.GetTaskInstanceCountParams) (*int, error)

GetCount provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) GetCountResponse 

func (_mock *TaskInstancesClient) GetCountResponse(ctx context.Context, params *api.GetTaskInstanceCountParams) (*resty.Response, error)

GetCountResponse provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) GetPreviousSuccessfulDagrun 

func (_mock *TaskInstancesClient) GetPreviousSuccessfulDagrun(ctx context.Context, taskInstanceId types.UUID) (*api.PrevSuccessfulDagRunResponse, error)

GetPreviousSuccessfulDagrun provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) GetPreviousSuccessfulDagrunResponse 

func (_mock *TaskInstancesClient) GetPreviousSuccessfulDagrunResponse(ctx context.Context, taskInstanceId types.UUID) (*resty.Response, error)

GetPreviousSuccessfulDagrunResponse provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) GetStates 

func (_mock *TaskInstancesClient) GetStates(ctx context.Context, params *api.GetTaskInstanceStatesParams) (*api.TaskStatesResponse, error)

GetStates provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) GetStatesResponse 

func (_mock *TaskInstancesClient) GetStatesResponse(ctx context.Context, params *api.GetTaskInstanceStatesParams) (*resty.Response, error)

GetStatesResponse provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) Heartbeat 

func (_mock *TaskInstancesClient) Heartbeat(ctx context.Context, taskInstanceId types.UUID, body *api.TIHeartbeatInfo) error

Heartbeat provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) HeartbeatResponse 

func (_mock *TaskInstancesClient) HeartbeatResponse(ctx context.Context, taskInstanceId types.UUID, body *api.TIHeartbeatInfo) (*resty.Response, error)

HeartbeatResponse provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) PutRenderedFields 

func (_mock *TaskInstancesClient) PutRenderedFields(ctx context.Context, taskInstanceId types.UUID, body *map[string]*api.JsonValue) (*interface{}, error)

PutRenderedFields provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) PutRenderedFieldsResponse 

func (_mock *TaskInstancesClient) PutRenderedFieldsResponse(ctx context.Context, taskInstanceId types.UUID, body *map[string]*api.JsonValue) (*resty.Response, error)

PutRenderedFieldsResponse provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) Run 

func (_mock *TaskInstancesClient) Run(ctx context.Context, taskInstanceId types.UUID, body *api.TIEnterRunningPayload) (*api.TIRunContext, error)

Run provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) RunResponse 

func (_mock *TaskInstancesClient) RunResponse(ctx context.Context, taskInstanceId types.UUID, body *api.TIEnterRunningPayload) (*resty.Response, error)

RunResponse provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) SkipDownstream 

func (_mock *TaskInstancesClient) SkipDownstream(ctx context.Context, taskInstanceId types.UUID, body *api.TISkippedDownstreamTasksStatePayload) error

SkipDownstream provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) SkipDownstreamResponse 

func (_mock *TaskInstancesClient) SkipDownstreamResponse(ctx context.Context, taskInstanceId types.UUID, body *api.TISkippedDownstreamTasksStatePayload) (*resty.Response, error)

SkipDownstreamResponse provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) UpdateState 

func (_mock *TaskInstancesClient) UpdateState(ctx context.Context, taskInstanceId types.UUID, body *api.TIUpdateStatePayload) error

UpdateState provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) UpdateStateResponse 

func (_mock *TaskInstancesClient) UpdateStateResponse(ctx context.Context, taskInstanceId types.UUID, body *api.TIUpdateStatePayload) (*resty.Response, error)

UpdateStateResponse provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) ValidateInletsAndOutlets 

func (_mock *TaskInstancesClient) ValidateInletsAndOutlets(ctx context.Context, taskInstanceId types.UUID) (*api.InactiveAssetsResponse, error)

ValidateInletsAndOutlets provides a mock function for the type TaskInstancesClient

func (*TaskInstancesClient) ValidateInletsAndOutletsResponse 

func (_mock *TaskInstancesClient) ValidateInletsAndOutletsResponse(ctx context.Context, taskInstanceId types.UUID) (*resty.Response, error)

ValidateInletsAndOutletsResponse provides a mock function for the type TaskInstancesClient

type TaskInstancesClient_Expecter 

type TaskInstancesClient_Expecter struct {
	// contains filtered or unexported fields
}

func (*TaskInstancesClient_Expecter) GetCount 

func (_e *TaskInstancesClient_Expecter) GetCount(ctx interface{}, params interface{}) *TaskInstancesClient_GetCount_Call

GetCount is a helper method to define mock.On call

  • ctx context.Context
  • params *api.GetTaskInstanceCountParams

func (*TaskInstancesClient_Expecter) GetCountResponse 

func (_e *TaskInstancesClient_Expecter) GetCountResponse(ctx interface{}, params interface{}) *TaskInstancesClient_GetCountResponse_Call

GetCountResponse is a helper method to define mock.On call

  • ctx context.Context
  • params *api.GetTaskInstanceCountParams

func (*TaskInstancesClient_Expecter) GetPreviousSuccessfulDagrun 

func (_e *TaskInstancesClient_Expecter) GetPreviousSuccessfulDagrun(ctx interface{}, taskInstanceId interface{}) *TaskInstancesClient_GetPreviousSuccessfulDagrun_Call

GetPreviousSuccessfulDagrun is a helper method to define mock.On call

  • ctx context.Context
  • taskInstanceId types.UUID

func (*TaskInstancesClient_Expecter) GetPreviousSuccessfulDagrunResponse 

func (_e *TaskInstancesClient_Expecter) GetPreviousSuccessfulDagrunResponse(ctx interface{}, taskInstanceId interface{}) *TaskInstancesClient_GetPreviousSuccessfulDagrunResponse_Call

GetPreviousSuccessfulDagrunResponse is a helper method to define mock.On call

  • ctx context.Context
  • taskInstanceId types.UUID

func (*TaskInstancesClient_Expecter) GetStates 

func (_e *TaskInstancesClient_Expecter) GetStates(ctx interface{}, params interface{}) *TaskInstancesClient_GetStates_Call

GetStates is a helper method to define mock.On call

  • ctx context.Context
  • params *api.GetTaskInstanceStatesParams

func (*TaskInstancesClient_Expecter) GetStatesResponse 

func (_e *TaskInstancesClient_Expecter) GetStatesResponse(ctx interface{}, params interface{}) *TaskInstancesClient_GetStatesResponse_Call

GetStatesResponse is a helper method to define mock.On call

  • ctx context.Context
  • params *api.GetTaskInstanceStatesParams

func (*TaskInstancesClient_Expecter) Heartbeat 

func (_e *TaskInstancesClient_Expecter) Heartbeat(ctx interface{}, taskInstanceId interface{}, body interface{}) *TaskInstancesClient_Heartbeat_Call

Heartbeat is a helper method to define mock.On call

  • ctx context.Context
  • taskInstanceId types.UUID
  • body *api.TIHeartbeatInfo

func (*TaskInstancesClient_Expecter) HeartbeatResponse 

func (_e *TaskInstancesClient_Expecter) HeartbeatResponse(ctx interface{}, taskInstanceId interface{}, body interface{}) *TaskInstancesClient_HeartbeatResponse_Call

HeartbeatResponse is a helper method to define mock.On call

  • ctx context.Context
  • taskInstanceId types.UUID
  • body *api.TIHeartbeatInfo

func (*TaskInstancesClient_Expecter) PutRenderedFields 

func (_e *TaskInstancesClient_Expecter) PutRenderedFields(ctx interface{}, taskInstanceId interface{}, body interface{}) *TaskInstancesClient_PutRenderedFields_Call

PutRenderedFields is a helper method to define mock.On call

  • ctx context.Context
  • taskInstanceId types.UUID
  • body *map[string]*api.JsonValue

func (*TaskInstancesClient_Expecter) PutRenderedFieldsResponse 

func (_e *TaskInstancesClient_Expecter) PutRenderedFieldsResponse(ctx interface{}, taskInstanceId interface{}, body interface{}) *TaskInstancesClient_PutRenderedFieldsResponse_Call

PutRenderedFieldsResponse is a helper method to define mock.On call

  • ctx context.Context
  • taskInstanceId types.UUID
  • body *map[string]*api.JsonValue

func (*TaskInstancesClient_Expecter) Run 

func (_e *TaskInstancesClient_Expecter) Run(ctx interface{}, taskInstanceId interface{}, body interface{}) *TaskInstancesClient_Run_Call

Run is a helper method to define mock.On call

  • ctx context.Context
  • taskInstanceId types.UUID
  • body *api.TIEnterRunningPayload

func (*TaskInstancesClient_Expecter) RunResponse 

func (_e *TaskInstancesClient_Expecter) RunResponse(ctx interface{}, taskInstanceId interface{}, body interface{}) *TaskInstancesClient_RunResponse_Call

RunResponse is a helper method to define mock.On call

  • ctx context.Context
  • taskInstanceId types.UUID
  • body *api.TIEnterRunningPayload

func (*TaskInstancesClient_Expecter) SkipDownstream 

func (_e *TaskInstancesClient_Expecter) SkipDownstream(ctx interface{}, taskInstanceId interface{}, body interface{}) *TaskInstancesClient_SkipDownstream_Call

SkipDownstream is a helper method to define mock.On call

  • ctx context.Context
  • taskInstanceId types.UUID
  • body *api.TISkippedDownstreamTasksStatePayload

func (*TaskInstancesClient_Expecter) SkipDownstreamResponse 

func (_e *TaskInstancesClient_Expecter) SkipDownstreamResponse(ctx interface{}, taskInstanceId interface{}, body interface{}) *TaskInstancesClient_SkipDownstreamResponse_Call

SkipDownstreamResponse is a helper method to define mock.On call

  • ctx context.Context
  • taskInstanceId types.UUID
  • body *api.TISkippedDownstreamTasksStatePayload

func (*TaskInstancesClient_Expecter) UpdateState 

func (_e *TaskInstancesClient_Expecter) UpdateState(ctx interface{}, taskInstanceId interface{}, body interface{}) *TaskInstancesClient_UpdateState_Call

UpdateState is a helper method to define mock.On call

  • ctx context.Context
  • taskInstanceId types.UUID
  • body *api.TIUpdateStatePayload

func (*TaskInstancesClient_Expecter) UpdateStateResponse 

func (_e *TaskInstancesClient_Expecter) UpdateStateResponse(ctx interface{}, taskInstanceId interface{}, body interface{}) *TaskInstancesClient_UpdateStateResponse_Call

UpdateStateResponse is a helper method to define mock.On call

  • ctx context.Context
  • taskInstanceId types.UUID
  • body *api.TIUpdateStatePayload

func (*TaskInstancesClient_Expecter) ValidateInletsAndOutlets 

func (_e *TaskInstancesClient_Expecter) ValidateInletsAndOutlets(ctx interface{}, taskInstanceId interface{}) *TaskInstancesClient_ValidateInletsAndOutlets_Call

ValidateInletsAndOutlets is a helper method to define mock.On call

  • ctx context.Context
  • taskInstanceId types.UUID

func (*TaskInstancesClient_Expecter) ValidateInletsAndOutletsResponse 

func (_e *TaskInstancesClient_Expecter) ValidateInletsAndOutletsResponse(ctx interface{}, taskInstanceId interface{}) *TaskInstancesClient_ValidateInletsAndOutletsResponse_Call

ValidateInletsAndOutletsResponse is a helper method to define mock.On call

  • ctx context.Context
  • taskInstanceId types.UUID

type TaskInstancesClient_GetCountResponse_Call 

type TaskInstancesClient_GetCountResponse_Call struct {
	*mock.Call
}

TaskInstancesClient_GetCountResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCountResponse'

func (*TaskInstancesClient_GetCountResponse_Call) Return 

func (_c *TaskInstancesClient_GetCountResponse_Call) Return(response *resty.Response, err error) *TaskInstancesClient_GetCountResponse_Call

func (*TaskInstancesClient_GetCountResponse_Call) Run 

func (_c *TaskInstancesClient_GetCountResponse_Call) Run(run func(ctx context.Context, params *api.GetTaskInstanceCountParams)) *TaskInstancesClient_GetCountResponse_Call

func (*TaskInstancesClient_GetCountResponse_Call) RunAndReturn 

func (_c *TaskInstancesClient_GetCountResponse_Call) RunAndReturn(run func(ctx context.Context, params *api.GetTaskInstanceCountParams) (*resty.Response, error)) *TaskInstancesClient_GetCountResponse_Call

type TaskInstancesClient_GetCount_Call 

type TaskInstancesClient_GetCount_Call struct {
	*mock.Call
}

TaskInstancesClient_GetCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCount'

func (*TaskInstancesClient_GetCount_Call) Return 

func (_c *TaskInstancesClient_GetCount_Call) Return(n *int, err error) *TaskInstancesClient_GetCount_Call

func (*TaskInstancesClient_GetCount_Call) Run 

func (_c *TaskInstancesClient_GetCount_Call) Run(run func(ctx context.Context, params *api.GetTaskInstanceCountParams)) *TaskInstancesClient_GetCount_Call

func (*TaskInstancesClient_GetCount_Call) RunAndReturn 

func (_c *TaskInstancesClient_GetCount_Call) RunAndReturn(run func(ctx context.Context, params *api.GetTaskInstanceCountParams) (*int, error)) *TaskInstancesClient_GetCount_Call

type TaskInstancesClient_GetPreviousSuccessfulDagrunResponse_Call 

type TaskInstancesClient_GetPreviousSuccessfulDagrunResponse_Call struct {
	*mock.Call
}

TaskInstancesClient_GetPreviousSuccessfulDagrunResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPreviousSuccessfulDagrunResponse'

func (*TaskInstancesClient_GetPreviousSuccessfulDagrunResponse_Call) Return 

func (_c *TaskInstancesClient_GetPreviousSuccessfulDagrunResponse_Call) Return(response *resty.Response, err error) *TaskInstancesClient_GetPreviousSuccessfulDagrunResponse_Call

func (*TaskInstancesClient_GetPreviousSuccessfulDagrunResponse_Call) Run 

func (_c *TaskInstancesClient_GetPreviousSuccessfulDagrunResponse_Call) Run(run func(ctx context.Context, taskInstanceId types.UUID)) *TaskInstancesClient_GetPreviousSuccessfulDagrunResponse_Call

func (*TaskInstancesClient_GetPreviousSuccessfulDagrunResponse_Call) RunAndReturn 

func (_c *TaskInstancesClient_GetPreviousSuccessfulDagrunResponse_Call) RunAndReturn(run func(ctx context.Context, taskInstanceId types.UUID) (*resty.Response, error)) *TaskInstancesClient_GetPreviousSuccessfulDagrunResponse_Call

type TaskInstancesClient_GetPreviousSuccessfulDagrun_Call 

type TaskInstancesClient_GetPreviousSuccessfulDagrun_Call struct {
	*mock.Call
}

TaskInstancesClient_GetPreviousSuccessfulDagrun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPreviousSuccessfulDagrun'

func (*TaskInstancesClient_GetPreviousSuccessfulDagrun_Call) Return 

func (_c *TaskInstancesClient_GetPreviousSuccessfulDagrun_Call) Return(prevSuccessfulDagRunResponse *api.PrevSuccessfulDagRunResponse, err error) *TaskInstancesClient_GetPreviousSuccessfulDagrun_Call

func (*TaskInstancesClient_GetPreviousSuccessfulDagrun_Call) Run 

func (_c *TaskInstancesClient_GetPreviousSuccessfulDagrun_Call) Run(run func(ctx context.Context, taskInstanceId types.UUID)) *TaskInstancesClient_GetPreviousSuccessfulDagrun_Call

func (*TaskInstancesClient_GetPreviousSuccessfulDagrun_Call) RunAndReturn 

func (_c *TaskInstancesClient_GetPreviousSuccessfulDagrun_Call) RunAndReturn(run func(ctx context.Context, taskInstanceId types.UUID) (*api.PrevSuccessfulDagRunResponse, error)) *TaskInstancesClient_GetPreviousSuccessfulDagrun_Call

type TaskInstancesClient_GetStatesResponse_Call 

type TaskInstancesClient_GetStatesResponse_Call struct {
	*mock.Call
}

TaskInstancesClient_GetStatesResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetStatesResponse'

func (*TaskInstancesClient_GetStatesResponse_Call) Return 

func (_c *TaskInstancesClient_GetStatesResponse_Call) Return(response *resty.Response, err error) *TaskInstancesClient_GetStatesResponse_Call

func (*TaskInstancesClient_GetStatesResponse_Call) Run 

func (_c *TaskInstancesClient_GetStatesResponse_Call) Run(run func(ctx context.Context, params *api.GetTaskInstanceStatesParams)) *TaskInstancesClient_GetStatesResponse_Call

func (*TaskInstancesClient_GetStatesResponse_Call) RunAndReturn 

func (_c *TaskInstancesClient_GetStatesResponse_Call) RunAndReturn(run func(ctx context.Context, params *api.GetTaskInstanceStatesParams) (*resty.Response, error)) *TaskInstancesClient_GetStatesResponse_Call

type TaskInstancesClient_GetStates_Call 

type TaskInstancesClient_GetStates_Call struct {
	*mock.Call
}

TaskInstancesClient_GetStates_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetStates'

func (*TaskInstancesClient_GetStates_Call) Return 

func (_c *TaskInstancesClient_GetStates_Call) Return(taskStatesResponse *api.TaskStatesResponse, err error) *TaskInstancesClient_GetStates_Call

func (*TaskInstancesClient_GetStates_Call) Run 

func (_c *TaskInstancesClient_GetStates_Call) Run(run func(ctx context.Context, params *api.GetTaskInstanceStatesParams)) *TaskInstancesClient_GetStates_Call

func (*TaskInstancesClient_GetStates_Call) RunAndReturn 

func (_c *TaskInstancesClient_GetStates_Call) RunAndReturn(run func(ctx context.Context, params *api.GetTaskInstanceStatesParams) (*api.TaskStatesResponse, error)) *TaskInstancesClient_GetStates_Call

type TaskInstancesClient_HeartbeatResponse_Call 

type TaskInstancesClient_HeartbeatResponse_Call struct {
	*mock.Call
}

TaskInstancesClient_HeartbeatResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HeartbeatResponse'

func (*TaskInstancesClient_HeartbeatResponse_Call) Return 

func (_c *TaskInstancesClient_HeartbeatResponse_Call) Return(response *resty.Response, err error) *TaskInstancesClient_HeartbeatResponse_Call

func (*TaskInstancesClient_HeartbeatResponse_Call) Run 

func (_c *TaskInstancesClient_HeartbeatResponse_Call) Run(run func(ctx context.Context, taskInstanceId types.UUID, body *api.TIHeartbeatInfo)) *TaskInstancesClient_HeartbeatResponse_Call

func (*TaskInstancesClient_HeartbeatResponse_Call) RunAndReturn 

func (_c *TaskInstancesClient_HeartbeatResponse_Call) RunAndReturn(run func(ctx context.Context, taskInstanceId types.UUID, body *api.TIHeartbeatInfo) (*resty.Response, error)) *TaskInstancesClient_HeartbeatResponse_Call

type TaskInstancesClient_Heartbeat_Call 

type TaskInstancesClient_Heartbeat_Call struct {
	*mock.Call
}

TaskInstancesClient_Heartbeat_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Heartbeat'

func (*TaskInstancesClient_Heartbeat_Call) Return 

func (_c *TaskInstancesClient_Heartbeat_Call) Return(err error) *TaskInstancesClient_Heartbeat_Call

func (*TaskInstancesClient_Heartbeat_Call) Run 

func (_c *TaskInstancesClient_Heartbeat_Call) Run(run func(ctx context.Context, taskInstanceId types.UUID, body *api.TIHeartbeatInfo)) *TaskInstancesClient_Heartbeat_Call

func (*TaskInstancesClient_Heartbeat_Call) RunAndReturn 

func (_c *TaskInstancesClient_Heartbeat_Call) RunAndReturn(run func(ctx context.Context, taskInstanceId types.UUID, body *api.TIHeartbeatInfo) error) *TaskInstancesClient_Heartbeat_Call

type TaskInstancesClient_PutRenderedFieldsResponse_Call 

type TaskInstancesClient_PutRenderedFieldsResponse_Call struct {
	*mock.Call
}

TaskInstancesClient_PutRenderedFieldsResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutRenderedFieldsResponse'

func (*TaskInstancesClient_PutRenderedFieldsResponse_Call) Return 

func (_c *TaskInstancesClient_PutRenderedFieldsResponse_Call) Return(response *resty.Response, err error) *TaskInstancesClient_PutRenderedFieldsResponse_Call

func (*TaskInstancesClient_PutRenderedFieldsResponse_Call) Run 

func (_c *TaskInstancesClient_PutRenderedFieldsResponse_Call) Run(run func(ctx context.Context, taskInstanceId types.UUID, body *map[string]*api.JsonValue)) *TaskInstancesClient_PutRenderedFieldsResponse_Call

func (*TaskInstancesClient_PutRenderedFieldsResponse_Call) RunAndReturn 

func (_c *TaskInstancesClient_PutRenderedFieldsResponse_Call) RunAndReturn(run func(ctx context.Context, taskInstanceId types.UUID, body *map[string]*api.JsonValue) (*resty.Response, error)) *TaskInstancesClient_PutRenderedFieldsResponse_Call

type TaskInstancesClient_PutRenderedFields_Call 

type TaskInstancesClient_PutRenderedFields_Call struct {
	*mock.Call
}

TaskInstancesClient_PutRenderedFields_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutRenderedFields'

func (*TaskInstancesClient_PutRenderedFields_Call) Return 

func (_c *TaskInstancesClient_PutRenderedFields_Call) Return(ifaceVal *interface{}, err error) *TaskInstancesClient_PutRenderedFields_Call

func (*TaskInstancesClient_PutRenderedFields_Call) Run 

func (_c *TaskInstancesClient_PutRenderedFields_Call) Run(run func(ctx context.Context, taskInstanceId types.UUID, body *map[string]*api.JsonValue)) *TaskInstancesClient_PutRenderedFields_Call

func (*TaskInstancesClient_PutRenderedFields_Call) RunAndReturn 

func (_c *TaskInstancesClient_PutRenderedFields_Call) RunAndReturn(run func(ctx context.Context, taskInstanceId types.UUID, body *map[string]*api.JsonValue) (*interface{}, error)) *TaskInstancesClient_PutRenderedFields_Call

type TaskInstancesClient_RunResponse_Call 

type TaskInstancesClient_RunResponse_Call struct {
	*mock.Call
}

TaskInstancesClient_RunResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RunResponse'

func (*TaskInstancesClient_RunResponse_Call) Return 

func (_c *TaskInstancesClient_RunResponse_Call) Return(response *resty.Response, err error) *TaskInstancesClient_RunResponse_Call

func (*TaskInstancesClient_RunResponse_Call) Run 

func (_c *TaskInstancesClient_RunResponse_Call) Run(run func(ctx context.Context, taskInstanceId types.UUID, body *api.TIEnterRunningPayload)) *TaskInstancesClient_RunResponse_Call

func (*TaskInstancesClient_RunResponse_Call) RunAndReturn 

func (_c *TaskInstancesClient_RunResponse_Call) RunAndReturn(run func(ctx context.Context, taskInstanceId types.UUID, body *api.TIEnterRunningPayload) (*resty.Response, error)) *TaskInstancesClient_RunResponse_Call

type TaskInstancesClient_Run_Call 

type TaskInstancesClient_Run_Call struct {
	*mock.Call
}

TaskInstancesClient_Run_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Run'

func (*TaskInstancesClient_Run_Call) Return 

func (_c *TaskInstancesClient_Run_Call) Return(tIRunContext *api.TIRunContext, err error) *TaskInstancesClient_Run_Call

func (*TaskInstancesClient_Run_Call) Run 

func (_c *TaskInstancesClient_Run_Call) Run(run func(ctx context.Context, taskInstanceId types.UUID, body *api.TIEnterRunningPayload)) *TaskInstancesClient_Run_Call

func (*TaskInstancesClient_Run_Call) RunAndReturn 

func (_c *TaskInstancesClient_Run_Call) RunAndReturn(run func(ctx context.Context, taskInstanceId types.UUID, body *api.TIEnterRunningPayload) (*api.TIRunContext, error)) *TaskInstancesClient_Run_Call

type TaskInstancesClient_SkipDownstreamResponse_Call 

type TaskInstancesClient_SkipDownstreamResponse_Call struct {
	*mock.Call
}

TaskInstancesClient_SkipDownstreamResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SkipDownstreamResponse'

func (*TaskInstancesClient_SkipDownstreamResponse_Call) Return 

func (_c *TaskInstancesClient_SkipDownstreamResponse_Call) Return(response *resty.Response, err error) *TaskInstancesClient_SkipDownstreamResponse_Call

func (*TaskInstancesClient_SkipDownstreamResponse_Call) Run 

func (_c *TaskInstancesClient_SkipDownstreamResponse_Call) Run(run func(ctx context.Context, taskInstanceId types.UUID, body *api.TISkippedDownstreamTasksStatePayload)) *TaskInstancesClient_SkipDownstreamResponse_Call

func (*TaskInstancesClient_SkipDownstreamResponse_Call) RunAndReturn 

func (_c *TaskInstancesClient_SkipDownstreamResponse_Call) RunAndReturn(run func(ctx context.Context, taskInstanceId types.UUID, body *api.TISkippedDownstreamTasksStatePayload) (*resty.Response, error)) *TaskInstancesClient_SkipDownstreamResponse_Call

type TaskInstancesClient_SkipDownstream_Call 

type TaskInstancesClient_SkipDownstream_Call struct {
	*mock.Call
}

TaskInstancesClient_SkipDownstream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SkipDownstream'

func (*TaskInstancesClient_SkipDownstream_Call) Return 

func (_c *TaskInstancesClient_SkipDownstream_Call) Return(err error) *TaskInstancesClient_SkipDownstream_Call

func (*TaskInstancesClient_SkipDownstream_Call) Run 

func (_c *TaskInstancesClient_SkipDownstream_Call) Run(run func(ctx context.Context, taskInstanceId types.UUID, body *api.TISkippedDownstreamTasksStatePayload)) *TaskInstancesClient_SkipDownstream_Call

func (*TaskInstancesClient_SkipDownstream_Call) RunAndReturn 

func (_c *TaskInstancesClient_SkipDownstream_Call) RunAndReturn(run func(ctx context.Context, taskInstanceId types.UUID, body *api.TISkippedDownstreamTasksStatePayload) error) *TaskInstancesClient_SkipDownstream_Call

type TaskInstancesClient_UpdateStateResponse_Call 

type TaskInstancesClient_UpdateStateResponse_Call struct {
	*mock.Call
}

TaskInstancesClient_UpdateStateResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateStateResponse'

func (*TaskInstancesClient_UpdateStateResponse_Call) Return 

func (_c *TaskInstancesClient_UpdateStateResponse_Call) Return(response *resty.Response, err error) *TaskInstancesClient_UpdateStateResponse_Call

func (*TaskInstancesClient_UpdateStateResponse_Call) Run 

func (_c *TaskInstancesClient_UpdateStateResponse_Call) Run(run func(ctx context.Context, taskInstanceId types.UUID, body *api.TIUpdateStatePayload)) *TaskInstancesClient_UpdateStateResponse_Call

func (*TaskInstancesClient_UpdateStateResponse_Call) RunAndReturn 

func (_c *TaskInstancesClient_UpdateStateResponse_Call) RunAndReturn(run func(ctx context.Context, taskInstanceId types.UUID, body *api.TIUpdateStatePayload) (*resty.Response, error)) *TaskInstancesClient_UpdateStateResponse_Call

type TaskInstancesClient_UpdateState_Call 

type TaskInstancesClient_UpdateState_Call struct {
	*mock.Call
}

TaskInstancesClient_UpdateState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateState'

func (*TaskInstancesClient_UpdateState_Call) Return 

func (_c *TaskInstancesClient_UpdateState_Call) Return(err error) *TaskInstancesClient_UpdateState_Call

func (*TaskInstancesClient_UpdateState_Call) Run 

func (_c *TaskInstancesClient_UpdateState_Call) Run(run func(ctx context.Context, taskInstanceId types.UUID, body *api.TIUpdateStatePayload)) *TaskInstancesClient_UpdateState_Call

func (*TaskInstancesClient_UpdateState_Call) RunAndReturn 

func (_c *TaskInstancesClient_UpdateState_Call) RunAndReturn(run func(ctx context.Context, taskInstanceId types.UUID, body *api.TIUpdateStatePayload) error) *TaskInstancesClient_UpdateState_Call

type TaskInstancesClient_ValidateInletsAndOutletsResponse_Call 

type TaskInstancesClient_ValidateInletsAndOutletsResponse_Call struct {
	*mock.Call
}

TaskInstancesClient_ValidateInletsAndOutletsResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ValidateInletsAndOutletsResponse'

func (*TaskInstancesClient_ValidateInletsAndOutletsResponse_Call) Return 

func (_c *TaskInstancesClient_ValidateInletsAndOutletsResponse_Call) Return(response *resty.Response, err error) *TaskInstancesClient_ValidateInletsAndOutletsResponse_Call

func (*TaskInstancesClient_ValidateInletsAndOutletsResponse_Call) Run 

func (_c *TaskInstancesClient_ValidateInletsAndOutletsResponse_Call) Run(run func(ctx context.Context, taskInstanceId types.UUID)) *TaskInstancesClient_ValidateInletsAndOutletsResponse_Call

func (*TaskInstancesClient_ValidateInletsAndOutletsResponse_Call) RunAndReturn 

func (_c *TaskInstancesClient_ValidateInletsAndOutletsResponse_Call) RunAndReturn(run func(ctx context.Context, taskInstanceId types.UUID) (*resty.Response, error)) *TaskInstancesClient_ValidateInletsAndOutletsResponse_Call

type TaskInstancesClient_ValidateInletsAndOutlets_Call 

type TaskInstancesClient_ValidateInletsAndOutlets_Call struct {
	*mock.Call
}

TaskInstancesClient_ValidateInletsAndOutlets_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ValidateInletsAndOutlets'

func (*TaskInstancesClient_ValidateInletsAndOutlets_Call) Return 

func (_c *TaskInstancesClient_ValidateInletsAndOutlets_Call) Return(inactiveAssetsResponse *api.InactiveAssetsResponse, err error) *TaskInstancesClient_ValidateInletsAndOutlets_Call

func (*TaskInstancesClient_ValidateInletsAndOutlets_Call) Run 

func (_c *TaskInstancesClient_ValidateInletsAndOutlets_Call) Run(run func(ctx context.Context, taskInstanceId types.UUID)) *TaskInstancesClient_ValidateInletsAndOutlets_Call

func (*TaskInstancesClient_ValidateInletsAndOutlets_Call) RunAndReturn 

func (_c *TaskInstancesClient_ValidateInletsAndOutlets_Call) RunAndReturn(run func(ctx context.Context, taskInstanceId types.UUID) (*api.InactiveAssetsResponse, error)) *TaskInstancesClient_ValidateInletsAndOutlets_Call

type TaskReschedulesClient 

type TaskReschedulesClient struct {
	mock.Mock
}

TaskReschedulesClient is an autogenerated mock type for the TaskReschedulesClient type

func NewTaskReschedulesClient 

func NewTaskReschedulesClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *TaskReschedulesClient

NewTaskReschedulesClient creates a new instance of TaskReschedulesClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*TaskReschedulesClient) EXPECT 

func (_m *TaskReschedulesClient) EXPECT() *TaskReschedulesClient_Expecter

func (*TaskReschedulesClient) GetStartDate 

func (_mock *TaskReschedulesClient) GetStartDate(ctx context.Context, taskInstanceId types.UUID) (*time.Time, error)

GetStartDate provides a mock function for the type TaskReschedulesClient

func (*TaskReschedulesClient) GetStartDateResponse 

func (_mock *TaskReschedulesClient) GetStartDateResponse(ctx context.Context, taskInstanceId types.UUID) (*resty.Response, error)

GetStartDateResponse provides a mock function for the type TaskReschedulesClient

type TaskReschedulesClient_Expecter 

type TaskReschedulesClient_Expecter struct {
	// contains filtered or unexported fields
}

func (*TaskReschedulesClient_Expecter) GetStartDate 

func (_e *TaskReschedulesClient_Expecter) GetStartDate(ctx interface{}, taskInstanceId interface{}) *TaskReschedulesClient_GetStartDate_Call

GetStartDate is a helper method to define mock.On call

  • ctx context.Context
  • taskInstanceId types.UUID

func (*TaskReschedulesClient_Expecter) GetStartDateResponse 

func (_e *TaskReschedulesClient_Expecter) GetStartDateResponse(ctx interface{}, taskInstanceId interface{}) *TaskReschedulesClient_GetStartDateResponse_Call

GetStartDateResponse is a helper method to define mock.On call

  • ctx context.Context
  • taskInstanceId types.UUID

type TaskReschedulesClient_GetStartDateResponse_Call 

type TaskReschedulesClient_GetStartDateResponse_Call struct {
	*mock.Call
}

TaskReschedulesClient_GetStartDateResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetStartDateResponse'

func (*TaskReschedulesClient_GetStartDateResponse_Call) Return 

func (_c *TaskReschedulesClient_GetStartDateResponse_Call) Return(response *resty.Response, err error) *TaskReschedulesClient_GetStartDateResponse_Call

func (*TaskReschedulesClient_GetStartDateResponse_Call) Run 

func (_c *TaskReschedulesClient_GetStartDateResponse_Call) Run(run func(ctx context.Context, taskInstanceId types.UUID)) *TaskReschedulesClient_GetStartDateResponse_Call

func (*TaskReschedulesClient_GetStartDateResponse_Call) RunAndReturn 

func (_c *TaskReschedulesClient_GetStartDateResponse_Call) RunAndReturn(run func(ctx context.Context, taskInstanceId types.UUID) (*resty.Response, error)) *TaskReschedulesClient_GetStartDateResponse_Call

type TaskReschedulesClient_GetStartDate_Call 

type TaskReschedulesClient_GetStartDate_Call struct {
	*mock.Call
}

TaskReschedulesClient_GetStartDate_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetStartDate'

func (*TaskReschedulesClient_GetStartDate_Call) Return 

func (_c *TaskReschedulesClient_GetStartDate_Call) Return(time1 *time.Time, err error) *TaskReschedulesClient_GetStartDate_Call

func (*TaskReschedulesClient_GetStartDate_Call) Run 

func (_c *TaskReschedulesClient_GetStartDate_Call) Run(run func(ctx context.Context, taskInstanceId types.UUID)) *TaskReschedulesClient_GetStartDate_Call

func (*TaskReschedulesClient_GetStartDate_Call) RunAndReturn 

func (_c *TaskReschedulesClient_GetStartDate_Call) RunAndReturn(run func(ctx context.Context, taskInstanceId types.UUID) (*time.Time, error)) *TaskReschedulesClient_GetStartDate_Call

type VariablesClient 

type VariablesClient struct {
	mock.Mock
}

VariablesClient is an autogenerated mock type for the VariablesClient type

func NewVariablesClient 

func NewVariablesClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *VariablesClient

NewVariablesClient creates a new instance of VariablesClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*VariablesClient) Delete 

func (_mock *VariablesClient) Delete(ctx context.Context, variableKey string) (*api.HTTPValidationError, error)

Delete provides a mock function for the type VariablesClient

func (*VariablesClient) DeleteResponse 

func (_mock *VariablesClient) DeleteResponse(ctx context.Context, variableKey string) (*resty.Response, error)

DeleteResponse provides a mock function for the type VariablesClient

func (*VariablesClient) EXPECT 

func (_m *VariablesClient) EXPECT() *VariablesClient_Expecter

func (*VariablesClient) Get 

func (_mock *VariablesClient) Get(ctx context.Context, variableKey string) (*api.VariableResponse, error)

Get provides a mock function for the type VariablesClient

func (*VariablesClient) GetResponse 

func (_mock *VariablesClient) GetResponse(ctx context.Context, variableKey string) (*resty.Response, error)

GetResponse provides a mock function for the type VariablesClient

func (*VariablesClient) Put 

func (_mock *VariablesClient) Put(ctx context.Context, variableKey string, body *api.VariablePostBody) (*interface{}, error)

Put provides a mock function for the type VariablesClient

func (*VariablesClient) PutResponse 

func (_mock *VariablesClient) PutResponse(ctx context.Context, variableKey string, body *api.VariablePostBody) (*resty.Response, error)

PutResponse provides a mock function for the type VariablesClient

type VariablesClient_DeleteResponse_Call 

type VariablesClient_DeleteResponse_Call struct {
	*mock.Call
}

VariablesClient_DeleteResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteResponse'

func (*VariablesClient_DeleteResponse_Call) Return 

func (_c *VariablesClient_DeleteResponse_Call) Return(response *resty.Response, err error) *VariablesClient_DeleteResponse_Call

func (*VariablesClient_DeleteResponse_Call) Run 

func (_c *VariablesClient_DeleteResponse_Call) Run(run func(ctx context.Context, variableKey string)) *VariablesClient_DeleteResponse_Call

func (*VariablesClient_DeleteResponse_Call) RunAndReturn 

func (_c *VariablesClient_DeleteResponse_Call) RunAndReturn(run func(ctx context.Context, variableKey string) (*resty.Response, error)) *VariablesClient_DeleteResponse_Call

type VariablesClient_Delete_Call 

type VariablesClient_Delete_Call struct {
	*mock.Call
}

VariablesClient_Delete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Delete'

func (*VariablesClient_Delete_Call) Return 

func (_c *VariablesClient_Delete_Call) Return(hTTPValidationError *api.HTTPValidationError, err error) *VariablesClient_Delete_Call

func (*VariablesClient_Delete_Call) Run 

func (_c *VariablesClient_Delete_Call) Run(run func(ctx context.Context, variableKey string)) *VariablesClient_Delete_Call

func (*VariablesClient_Delete_Call) RunAndReturn 

func (_c *VariablesClient_Delete_Call) RunAndReturn(run func(ctx context.Context, variableKey string) (*api.HTTPValidationError, error)) *VariablesClient_Delete_Call

type VariablesClient_Expecter 

type VariablesClient_Expecter struct {
	// contains filtered or unexported fields
}

func (*VariablesClient_Expecter) Delete 

func (_e *VariablesClient_Expecter) Delete(ctx interface{}, variableKey interface{}) *VariablesClient_Delete_Call

Delete is a helper method to define mock.On call

  • ctx context.Context
  • variableKey string

func (*VariablesClient_Expecter) DeleteResponse 

func (_e *VariablesClient_Expecter) DeleteResponse(ctx interface{}, variableKey interface{}) *VariablesClient_DeleteResponse_Call

DeleteResponse is a helper method to define mock.On call

  • ctx context.Context
  • variableKey string

func (*VariablesClient_Expecter) Get 

func (_e *VariablesClient_Expecter) Get(ctx interface{}, variableKey interface{}) *VariablesClient_Get_Call

Get is a helper method to define mock.On call

  • ctx context.Context
  • variableKey string

func (*VariablesClient_Expecter) GetResponse 

func (_e *VariablesClient_Expecter) GetResponse(ctx interface{}, variableKey interface{}) *VariablesClient_GetResponse_Call

GetResponse is a helper method to define mock.On call

  • ctx context.Context
  • variableKey string

func (*VariablesClient_Expecter) Put 

func (_e *VariablesClient_Expecter) Put(ctx interface{}, variableKey interface{}, body interface{}) *VariablesClient_Put_Call

Put is a helper method to define mock.On call

  • ctx context.Context
  • variableKey string
  • body *api.VariablePostBody

func (*VariablesClient_Expecter) PutResponse 

func (_e *VariablesClient_Expecter) PutResponse(ctx interface{}, variableKey interface{}, body interface{}) *VariablesClient_PutResponse_Call

PutResponse is a helper method to define mock.On call

  • ctx context.Context
  • variableKey string
  • body *api.VariablePostBody

type VariablesClient_GetResponse_Call 

type VariablesClient_GetResponse_Call struct {
	*mock.Call
}

VariablesClient_GetResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetResponse'

func (*VariablesClient_GetResponse_Call) Return 

func (_c *VariablesClient_GetResponse_Call) Return(response *resty.Response, err error) *VariablesClient_GetResponse_Call

func (*VariablesClient_GetResponse_Call) Run 

func (_c *VariablesClient_GetResponse_Call) Run(run func(ctx context.Context, variableKey string)) *VariablesClient_GetResponse_Call

func (*VariablesClient_GetResponse_Call) RunAndReturn 

func (_c *VariablesClient_GetResponse_Call) RunAndReturn(run func(ctx context.Context, variableKey string) (*resty.Response, error)) *VariablesClient_GetResponse_Call

type VariablesClient_Get_Call 

type VariablesClient_Get_Call struct {
	*mock.Call
}

VariablesClient_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'

func (*VariablesClient_Get_Call) Return 

func (_c *VariablesClient_Get_Call) Return(variableResponse *api.VariableResponse, err error) *VariablesClient_Get_Call

func (*VariablesClient_Get_Call) Run 

func (_c *VariablesClient_Get_Call) Run(run func(ctx context.Context, variableKey string)) *VariablesClient_Get_Call

func (*VariablesClient_Get_Call) RunAndReturn 

func (_c *VariablesClient_Get_Call) RunAndReturn(run func(ctx context.Context, variableKey string) (*api.VariableResponse, error)) *VariablesClient_Get_Call

type VariablesClient_PutResponse_Call 

type VariablesClient_PutResponse_Call struct {
	*mock.Call
}

VariablesClient_PutResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutResponse'

func (*VariablesClient_PutResponse_Call) Return 

func (_c *VariablesClient_PutResponse_Call) Return(response *resty.Response, err error) *VariablesClient_PutResponse_Call

func (*VariablesClient_PutResponse_Call) Run 

func (_c *VariablesClient_PutResponse_Call) Run(run func(ctx context.Context, variableKey string, body *api.VariablePostBody)) *VariablesClient_PutResponse_Call

func (*VariablesClient_PutResponse_Call) RunAndReturn 

func (_c *VariablesClient_PutResponse_Call) RunAndReturn(run func(ctx context.Context, variableKey string, body *api.VariablePostBody) (*resty.Response, error)) *VariablesClient_PutResponse_Call

type VariablesClient_Put_Call 

type VariablesClient_Put_Call struct {
	*mock.Call
}

VariablesClient_Put_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Put'

func (*VariablesClient_Put_Call) Return 

func (_c *VariablesClient_Put_Call) Return(ifaceVal *interface{}, err error) *VariablesClient_Put_Call

func (*VariablesClient_Put_Call) Run 

func (_c *VariablesClient_Put_Call) Run(run func(ctx context.Context, variableKey string, body *api.VariablePostBody)) *VariablesClient_Put_Call

func (*VariablesClient_Put_Call) RunAndReturn 

func (_c *VariablesClient_Put_Call) RunAndReturn(run func(ctx context.Context, variableKey string, body *api.VariablePostBody) (*interface{}, error)) *VariablesClient_Put_Call

type XcomsClient 

type XcomsClient struct {
	mock.Mock
}

XcomsClient is an autogenerated mock type for the XcomsClient type

func NewXcomsClient 

func NewXcomsClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *XcomsClient

NewXcomsClient creates a new instance of XcomsClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*XcomsClient) Delete 

func (_mock *XcomsClient) Delete(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.DeleteXcomParams) (*interface{}, error)

Delete provides a mock function for the type XcomsClient

func (*XcomsClient) DeleteResponse 

func (_mock *XcomsClient) DeleteResponse(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.DeleteXcomParams) (*resty.Response, error)

DeleteResponse provides a mock function for the type XcomsClient

func (*XcomsClient) EXPECT 

func (_m *XcomsClient) EXPECT() *XcomsClient_Expecter

func (*XcomsClient) Get 

func (_mock *XcomsClient) Get(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.GetXcomParams) (*api.XComResponse, error)

Get provides a mock function for the type XcomsClient

func (*XcomsClient) GetMappedByIndex 

func (_mock *XcomsClient) GetMappedByIndex(ctx context.Context, dagId string, runId string, taskId string, key string, offset int) (*api.XComSequenceIndexResponse, error)

GetMappedByIndex provides a mock function for the type XcomsClient

func (*XcomsClient) GetMappedByIndexResponse 

func (_mock *XcomsClient) GetMappedByIndexResponse(ctx context.Context, dagId string, runId string, taskId string, key string, offset int) (*resty.Response, error)

GetMappedByIndexResponse provides a mock function for the type XcomsClient

func (*XcomsClient) GetMappedBySlice 

func (_mock *XcomsClient) GetMappedBySlice(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.GetMappedXcomBySliceParams) (*api.XComSequenceSliceResponse, error)

GetMappedBySlice provides a mock function for the type XcomsClient

func (*XcomsClient) GetMappedBySliceResponse 

func (_mock *XcomsClient) GetMappedBySliceResponse(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.GetMappedXcomBySliceParams) (*resty.Response, error)

GetMappedBySliceResponse provides a mock function for the type XcomsClient

func (*XcomsClient) GetResponse 

func (_mock *XcomsClient) GetResponse(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.GetXcomParams) (*resty.Response, error)

GetResponse provides a mock function for the type XcomsClient

func (*XcomsClient) Head 

func (_mock *XcomsClient) Head(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.HeadXcomParams) (*interface{}, error)

Head provides a mock function for the type XcomsClient

func (*XcomsClient) HeadResponse 

func (_mock *XcomsClient) HeadResponse(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.HeadXcomParams) (*resty.Response, error)

HeadResponse provides a mock function for the type XcomsClient

func (*XcomsClient) Set 

func (_mock *XcomsClient) Set(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.SetXcomParams, body *interface{}) (*interface{}, error)

Set provides a mock function for the type XcomsClient

func (*XcomsClient) SetResponse 

func (_mock *XcomsClient) SetResponse(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.SetXcomParams, body *interface{}) (*resty.Response, error)

SetResponse provides a mock function for the type XcomsClient

type XcomsClient_DeleteResponse_Call 

type XcomsClient_DeleteResponse_Call struct {
	*mock.Call
}

XcomsClient_DeleteResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteResponse'

func (*XcomsClient_DeleteResponse_Call) Return 

func (_c *XcomsClient_DeleteResponse_Call) Return(response *resty.Response, err error) *XcomsClient_DeleteResponse_Call

func (*XcomsClient_DeleteResponse_Call) Run 

func (_c *XcomsClient_DeleteResponse_Call) Run(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.DeleteXcomParams)) *XcomsClient_DeleteResponse_Call

func (*XcomsClient_DeleteResponse_Call) RunAndReturn 

func (_c *XcomsClient_DeleteResponse_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.DeleteXcomParams) (*resty.Response, error)) *XcomsClient_DeleteResponse_Call

type XcomsClient_Delete_Call 

type XcomsClient_Delete_Call struct {
	*mock.Call
}

XcomsClient_Delete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Delete'

func (*XcomsClient_Delete_Call) Return 

func (_c *XcomsClient_Delete_Call) Return(ifaceVal *interface{}, err error) *XcomsClient_Delete_Call

func (*XcomsClient_Delete_Call) Run 

func (_c *XcomsClient_Delete_Call) Run(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.DeleteXcomParams)) *XcomsClient_Delete_Call

func (*XcomsClient_Delete_Call) RunAndReturn 

func (_c *XcomsClient_Delete_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.DeleteXcomParams) (*interface{}, error)) *XcomsClient_Delete_Call

type XcomsClient_Expecter 

type XcomsClient_Expecter struct {
	// contains filtered or unexported fields
}

func (*XcomsClient_Expecter) Delete 

func (_e *XcomsClient_Expecter) Delete(ctx interface{}, dagId interface{}, runId interface{}, taskId interface{}, key interface{}, params interface{}) *XcomsClient_Delete_Call

Delete is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string
  • taskId string
  • key string
  • params *api.DeleteXcomParams

func (*XcomsClient_Expecter) DeleteResponse 

func (_e *XcomsClient_Expecter) DeleteResponse(ctx interface{}, dagId interface{}, runId interface{}, taskId interface{}, key interface{}, params interface{}) *XcomsClient_DeleteResponse_Call

DeleteResponse is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string
  • taskId string
  • key string
  • params *api.DeleteXcomParams

func (*XcomsClient_Expecter) Get 

func (_e *XcomsClient_Expecter) Get(ctx interface{}, dagId interface{}, runId interface{}, taskId interface{}, key interface{}, params interface{}) *XcomsClient_Get_Call

Get is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string
  • taskId string
  • key string
  • params *api.GetXcomParams

func (*XcomsClient_Expecter) GetMappedByIndex 

func (_e *XcomsClient_Expecter) GetMappedByIndex(ctx interface{}, dagId interface{}, runId interface{}, taskId interface{}, key interface{}, offset interface{}) *XcomsClient_GetMappedByIndex_Call

GetMappedByIndex is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string
  • taskId string
  • key string
  • offset int

func (*XcomsClient_Expecter) GetMappedByIndexResponse 

func (_e *XcomsClient_Expecter) GetMappedByIndexResponse(ctx interface{}, dagId interface{}, runId interface{}, taskId interface{}, key interface{}, offset interface{}) *XcomsClient_GetMappedByIndexResponse_Call

GetMappedByIndexResponse is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string
  • taskId string
  • key string
  • offset int

func (*XcomsClient_Expecter) GetMappedBySlice 

func (_e *XcomsClient_Expecter) GetMappedBySlice(ctx interface{}, dagId interface{}, runId interface{}, taskId interface{}, key interface{}, params interface{}) *XcomsClient_GetMappedBySlice_Call

GetMappedBySlice is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string
  • taskId string
  • key string
  • params *api.GetMappedXcomBySliceParams

func (*XcomsClient_Expecter) GetMappedBySliceResponse 

func (_e *XcomsClient_Expecter) GetMappedBySliceResponse(ctx interface{}, dagId interface{}, runId interface{}, taskId interface{}, key interface{}, params interface{}) *XcomsClient_GetMappedBySliceResponse_Call

GetMappedBySliceResponse is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string
  • taskId string
  • key string
  • params *api.GetMappedXcomBySliceParams

func (*XcomsClient_Expecter) GetResponse 

func (_e *XcomsClient_Expecter) GetResponse(ctx interface{}, dagId interface{}, runId interface{}, taskId interface{}, key interface{}, params interface{}) *XcomsClient_GetResponse_Call

GetResponse is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string
  • taskId string
  • key string
  • params *api.GetXcomParams

func (*XcomsClient_Expecter) Head 

func (_e *XcomsClient_Expecter) Head(ctx interface{}, dagId interface{}, runId interface{}, taskId interface{}, key interface{}, params interface{}) *XcomsClient_Head_Call

Head is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string
  • taskId string
  • key string
  • params *api.HeadXcomParams

func (*XcomsClient_Expecter) HeadResponse 

func (_e *XcomsClient_Expecter) HeadResponse(ctx interface{}, dagId interface{}, runId interface{}, taskId interface{}, key interface{}, params interface{}) *XcomsClient_HeadResponse_Call

HeadResponse is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string
  • taskId string
  • key string
  • params *api.HeadXcomParams

func (*XcomsClient_Expecter) Set 

func (_e *XcomsClient_Expecter) Set(ctx interface{}, dagId interface{}, runId interface{}, taskId interface{}, key interface{}, params interface{}, body interface{}) *XcomsClient_Set_Call

Set is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string
  • taskId string
  • key string
  • params *api.SetXcomParams
  • body *interface{}

func (*XcomsClient_Expecter) SetResponse 

func (_e *XcomsClient_Expecter) SetResponse(ctx interface{}, dagId interface{}, runId interface{}, taskId interface{}, key interface{}, params interface{}, body interface{}) *XcomsClient_SetResponse_Call

SetResponse is a helper method to define mock.On call

  • ctx context.Context
  • dagId string
  • runId string
  • taskId string
  • key string
  • params *api.SetXcomParams
  • body *interface{}

type XcomsClient_GetMappedByIndexResponse_Call 

type XcomsClient_GetMappedByIndexResponse_Call struct {
	*mock.Call
}

XcomsClient_GetMappedByIndexResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetMappedByIndexResponse'

func (*XcomsClient_GetMappedByIndexResponse_Call) Return 

func (_c *XcomsClient_GetMappedByIndexResponse_Call) Return(response *resty.Response, err error) *XcomsClient_GetMappedByIndexResponse_Call

func (*XcomsClient_GetMappedByIndexResponse_Call) Run 

func (_c *XcomsClient_GetMappedByIndexResponse_Call) Run(run func(ctx context.Context, dagId string, runId string, taskId string, key string, offset int)) *XcomsClient_GetMappedByIndexResponse_Call

func (*XcomsClient_GetMappedByIndexResponse_Call) RunAndReturn 

func (_c *XcomsClient_GetMappedByIndexResponse_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string, taskId string, key string, offset int) (*resty.Response, error)) *XcomsClient_GetMappedByIndexResponse_Call

type XcomsClient_GetMappedByIndex_Call 

type XcomsClient_GetMappedByIndex_Call struct {
	*mock.Call
}

XcomsClient_GetMappedByIndex_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetMappedByIndex'

func (*XcomsClient_GetMappedByIndex_Call) Return 

func (_c *XcomsClient_GetMappedByIndex_Call) Return(v *api.XComSequenceIndexResponse, err error) *XcomsClient_GetMappedByIndex_Call

func (*XcomsClient_GetMappedByIndex_Call) Run 

func (_c *XcomsClient_GetMappedByIndex_Call) Run(run func(ctx context.Context, dagId string, runId string, taskId string, key string, offset int)) *XcomsClient_GetMappedByIndex_Call

func (*XcomsClient_GetMappedByIndex_Call) RunAndReturn 

func (_c *XcomsClient_GetMappedByIndex_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string, taskId string, key string, offset int) (*api.XComSequenceIndexResponse, error)) *XcomsClient_GetMappedByIndex_Call

type XcomsClient_GetMappedBySliceResponse_Call 

type XcomsClient_GetMappedBySliceResponse_Call struct {
	*mock.Call
}

XcomsClient_GetMappedBySliceResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetMappedBySliceResponse'

func (*XcomsClient_GetMappedBySliceResponse_Call) Return 

func (_c *XcomsClient_GetMappedBySliceResponse_Call) Return(response *resty.Response, err error) *XcomsClient_GetMappedBySliceResponse_Call

func (*XcomsClient_GetMappedBySliceResponse_Call) Run 

func (_c *XcomsClient_GetMappedBySliceResponse_Call) Run(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.GetMappedXcomBySliceParams)) *XcomsClient_GetMappedBySliceResponse_Call

func (*XcomsClient_GetMappedBySliceResponse_Call) RunAndReturn 

func (_c *XcomsClient_GetMappedBySliceResponse_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.GetMappedXcomBySliceParams) (*resty.Response, error)) *XcomsClient_GetMappedBySliceResponse_Call

type XcomsClient_GetMappedBySlice_Call 

type XcomsClient_GetMappedBySlice_Call struct {
	*mock.Call
}

XcomsClient_GetMappedBySlice_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetMappedBySlice'

func (*XcomsClient_GetMappedBySlice_Call) Return 

func (_c *XcomsClient_GetMappedBySlice_Call) Return(v *api.XComSequenceSliceResponse, err error) *XcomsClient_GetMappedBySlice_Call

func (*XcomsClient_GetMappedBySlice_Call) Run 

func (_c *XcomsClient_GetMappedBySlice_Call) Run(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.GetMappedXcomBySliceParams)) *XcomsClient_GetMappedBySlice_Call

func (*XcomsClient_GetMappedBySlice_Call) RunAndReturn 

func (_c *XcomsClient_GetMappedBySlice_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.GetMappedXcomBySliceParams) (*api.XComSequenceSliceResponse, error)) *XcomsClient_GetMappedBySlice_Call

type XcomsClient_GetResponse_Call 

type XcomsClient_GetResponse_Call struct {
	*mock.Call
}

XcomsClient_GetResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetResponse'

func (*XcomsClient_GetResponse_Call) Return 

func (_c *XcomsClient_GetResponse_Call) Return(response *resty.Response, err error) *XcomsClient_GetResponse_Call

func (*XcomsClient_GetResponse_Call) Run 

func (_c *XcomsClient_GetResponse_Call) Run(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.GetXcomParams)) *XcomsClient_GetResponse_Call

func (*XcomsClient_GetResponse_Call) RunAndReturn 

func (_c *XcomsClient_GetResponse_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.GetXcomParams) (*resty.Response, error)) *XcomsClient_GetResponse_Call

type XcomsClient_Get_Call 

type XcomsClient_Get_Call struct {
	*mock.Call
}

XcomsClient_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'

func (*XcomsClient_Get_Call) Return 

func (_c *XcomsClient_Get_Call) Return(xComResponse *api.XComResponse, err error) *XcomsClient_Get_Call

func (*XcomsClient_Get_Call) Run 

func (_c *XcomsClient_Get_Call) Run(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.GetXcomParams)) *XcomsClient_Get_Call

func (*XcomsClient_Get_Call) RunAndReturn 

func (_c *XcomsClient_Get_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.GetXcomParams) (*api.XComResponse, error)) *XcomsClient_Get_Call

type XcomsClient_HeadResponse_Call 

type XcomsClient_HeadResponse_Call struct {
	*mock.Call
}

XcomsClient_HeadResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HeadResponse'

func (*XcomsClient_HeadResponse_Call) Return 

func (_c *XcomsClient_HeadResponse_Call) Return(response *resty.Response, err error) *XcomsClient_HeadResponse_Call

func (*XcomsClient_HeadResponse_Call) Run 

func (_c *XcomsClient_HeadResponse_Call) Run(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.HeadXcomParams)) *XcomsClient_HeadResponse_Call

func (*XcomsClient_HeadResponse_Call) RunAndReturn 

func (_c *XcomsClient_HeadResponse_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.HeadXcomParams) (*resty.Response, error)) *XcomsClient_HeadResponse_Call

type XcomsClient_Head_Call 

type XcomsClient_Head_Call struct {
	*mock.Call
}

XcomsClient_Head_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Head'

func (*XcomsClient_Head_Call) Return 

func (_c *XcomsClient_Head_Call) Return(ifaceVal *interface{}, err error) *XcomsClient_Head_Call

func (*XcomsClient_Head_Call) Run 

func (_c *XcomsClient_Head_Call) Run(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.HeadXcomParams)) *XcomsClient_Head_Call

func (*XcomsClient_Head_Call) RunAndReturn 

func (_c *XcomsClient_Head_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.HeadXcomParams) (*interface{}, error)) *XcomsClient_Head_Call

type XcomsClient_SetResponse_Call 

type XcomsClient_SetResponse_Call struct {
	*mock.Call
}

XcomsClient_SetResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetResponse'

func (*XcomsClient_SetResponse_Call) Return 

func (_c *XcomsClient_SetResponse_Call) Return(response *resty.Response, err error) *XcomsClient_SetResponse_Call

func (*XcomsClient_SetResponse_Call) Run 

func (_c *XcomsClient_SetResponse_Call) Run(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.SetXcomParams, body *interface{})) *XcomsClient_SetResponse_Call

func (*XcomsClient_SetResponse_Call) RunAndReturn 

func (_c *XcomsClient_SetResponse_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.SetXcomParams, body *interface{}) (*resty.Response, error)) *XcomsClient_SetResponse_Call

type XcomsClient_Set_Call 

type XcomsClient_Set_Call struct {
	*mock.Call
}

XcomsClient_Set_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Set'

func (*XcomsClient_Set_Call) Return 

func (_c *XcomsClient_Set_Call) Return(ifaceVal *interface{}, err error) *XcomsClient_Set_Call

func (*XcomsClient_Set_Call) Run 

func (_c *XcomsClient_Set_Call) Run(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.SetXcomParams, body *interface{})) *XcomsClient_Set_Call

func (*XcomsClient_Set_Call) RunAndReturn 

func (_c *XcomsClient_Set_Call) RunAndReturn(run func(ctx context.Context, dagId string, runId string, taskId string, key string, params *api.SetXcomParams, body *interface{}) (*interface{}, error)) *XcomsClient_Set_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.