mocks

package
Version: v0.0.0-...-abfb793 Latest Latest
Warning

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

Go to latest
Published: Oct 2, 2017 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockContainerInstanceLoader

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

Mock of ContainerInstanceLoader interface

func NewMockContainerInstanceLoader

func NewMockContainerInstanceLoader(ctrl *gomock.Controller) *MockContainerInstanceLoader

func (*MockContainerInstanceLoader) EXPECT

func (_m *MockContainerInstanceLoader) EXPECT() *_MockContainerInstanceLoaderRecorder

func (*MockContainerInstanceLoader) LoadContainerInstances

func (_m *MockContainerInstanceLoader) LoadContainerInstances() error

type MockContainerInstanceStore

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

Mock of ContainerInstanceStore interface

func NewMockContainerInstanceStore

func NewMockContainerInstanceStore(ctrl *gomock.Controller) *MockContainerInstanceStore

func (*MockContainerInstanceStore) AddContainerInstance

func (_m *MockContainerInstanceStore) AddContainerInstance(instance string) error

func (*MockContainerInstanceStore) DeleteContainerInstance

func (_m *MockContainerInstanceStore) DeleteContainerInstance(cluster string, instanceARN string) error

func (*MockContainerInstanceStore) EXPECT

func (_m *MockContainerInstanceStore) EXPECT() *_MockContainerInstanceStoreRecorder

func (*MockContainerInstanceStore) FilterContainerInstances

func (_m *MockContainerInstanceStore) FilterContainerInstances(filterMap map[string]string) ([]types.VersionedContainerInstance, error)

func (*MockContainerInstanceStore) GetContainerInstance

func (_m *MockContainerInstanceStore) GetContainerInstance(cluster string, instanceARN string) (*types.VersionedContainerInstance, error)

func (*MockContainerInstanceStore) ListContainerInstances

func (_m *MockContainerInstanceStore) ListContainerInstances() ([]types.VersionedContainerInstance, error)

func (*MockContainerInstanceStore) StreamContainerInstances

func (_m *MockContainerInstanceStore) StreamContainerInstances(ctx context.Context, entityVersion string) (chan types.VersionedContainerInstance, error)

type MockDataStore

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

Mock of DataStore interface

func NewMockDataStore

func NewMockDataStore(ctrl *gomock.Controller) *MockDataStore

func (*MockDataStore) Add

func (_m *MockDataStore) Add(_param0 string, _param1 string) error

func (*MockDataStore) Delete

func (_m *MockDataStore) Delete(_param0 string) (int64, error)

func (*MockDataStore) EXPECT

func (_m *MockDataStore) EXPECT() *_MockDataStoreRecorder

func (*MockDataStore) Get

func (_m *MockDataStore) Get(_param0 string) (map[string]types.Entity, error)

func (*MockDataStore) GetV3Client

func (_m *MockDataStore) GetV3Client() *clientv3.Client

func (*MockDataStore) GetWithPrefix

func (_m *MockDataStore) GetWithPrefix(_param0 string) (map[string]types.Entity, error)

func (*MockDataStore) NewSTMRepeatable

func (_m *MockDataStore) NewSTMRepeatable(_param0 context.Context, _param1 *clientv3.Client, _param2 func(concurrency.STM) error) (*clientv3.TxnResponse, error)

func (*MockDataStore) StreamWithPrefix

func (_m *MockDataStore) StreamWithPrefix(_param0 context.Context, _param1 string, _param2 string) (chan map[string]types.Entity, error)

type MockECSAPI

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

Mock of ECSAPI interface

func NewMockECSAPI

func NewMockECSAPI(ctrl *gomock.Controller) *MockECSAPI

func (*MockECSAPI) CreateCluster

func (_m *MockECSAPI) CreateCluster(_param0 *ecs.CreateClusterInput) (*ecs.CreateClusterOutput, error)

func (*MockECSAPI) CreateClusterRequest

func (_m *MockECSAPI) CreateClusterRequest(_param0 *ecs.CreateClusterInput) (*request.Request, *ecs.CreateClusterOutput)

func (*MockECSAPI) CreateClusterWithContext

func (_m *MockECSAPI) CreateClusterWithContext(_param0 aws.Context, _param1 *ecs.CreateClusterInput, _param2 ...request.Option) (*ecs.CreateClusterOutput, error)

func (*MockECSAPI) CreateService

func (_m *MockECSAPI) CreateService(_param0 *ecs.CreateServiceInput) (*ecs.CreateServiceOutput, error)

func (*MockECSAPI) CreateServiceRequest

func (_m *MockECSAPI) CreateServiceRequest(_param0 *ecs.CreateServiceInput) (*request.Request, *ecs.CreateServiceOutput)

func (*MockECSAPI) CreateServiceWithContext

func (_m *MockECSAPI) CreateServiceWithContext(_param0 aws.Context, _param1 *ecs.CreateServiceInput, _param2 ...request.Option) (*ecs.CreateServiceOutput, error)

func (*MockECSAPI) DeleteAttributes

func (_m *MockECSAPI) DeleteAttributes(_param0 *ecs.DeleteAttributesInput) (*ecs.DeleteAttributesOutput, error)

func (*MockECSAPI) DeleteAttributesRequest

func (_m *MockECSAPI) DeleteAttributesRequest(_param0 *ecs.DeleteAttributesInput) (*request.Request, *ecs.DeleteAttributesOutput)

func (*MockECSAPI) DeleteAttributesWithContext

func (_m *MockECSAPI) DeleteAttributesWithContext(_param0 aws.Context, _param1 *ecs.DeleteAttributesInput, _param2 ...request.Option) (*ecs.DeleteAttributesOutput, error)

func (*MockECSAPI) DeleteCluster

func (_m *MockECSAPI) DeleteCluster(_param0 *ecs.DeleteClusterInput) (*ecs.DeleteClusterOutput, error)

func (*MockECSAPI) DeleteClusterRequest

func (_m *MockECSAPI) DeleteClusterRequest(_param0 *ecs.DeleteClusterInput) (*request.Request, *ecs.DeleteClusterOutput)

func (*MockECSAPI) DeleteClusterWithContext

func (_m *MockECSAPI) DeleteClusterWithContext(_param0 aws.Context, _param1 *ecs.DeleteClusterInput, _param2 ...request.Option) (*ecs.DeleteClusterOutput, error)

func (*MockECSAPI) DeleteService

func (_m *MockECSAPI) DeleteService(_param0 *ecs.DeleteServiceInput) (*ecs.DeleteServiceOutput, error)

func (*MockECSAPI) DeleteServiceRequest

func (_m *MockECSAPI) DeleteServiceRequest(_param0 *ecs.DeleteServiceInput) (*request.Request, *ecs.DeleteServiceOutput)

func (*MockECSAPI) DeleteServiceWithContext

func (_m *MockECSAPI) DeleteServiceWithContext(_param0 aws.Context, _param1 *ecs.DeleteServiceInput, _param2 ...request.Option) (*ecs.DeleteServiceOutput, error)

func (*MockECSAPI) DeregisterContainerInstance

func (_m *MockECSAPI) DeregisterContainerInstance(_param0 *ecs.DeregisterContainerInstanceInput) (*ecs.DeregisterContainerInstanceOutput, error)

func (*MockECSAPI) DeregisterContainerInstanceRequest

func (_m *MockECSAPI) DeregisterContainerInstanceRequest(_param0 *ecs.DeregisterContainerInstanceInput) (*request.Request, *ecs.DeregisterContainerInstanceOutput)

func (*MockECSAPI) DeregisterContainerInstanceWithContext

func (_m *MockECSAPI) DeregisterContainerInstanceWithContext(_param0 aws.Context, _param1 *ecs.DeregisterContainerInstanceInput, _param2 ...request.Option) (*ecs.DeregisterContainerInstanceOutput, error)

func (*MockECSAPI) DeregisterTaskDefinition

func (_m *MockECSAPI) DeregisterTaskDefinition(_param0 *ecs.DeregisterTaskDefinitionInput) (*ecs.DeregisterTaskDefinitionOutput, error)

func (*MockECSAPI) DeregisterTaskDefinitionRequest

func (_m *MockECSAPI) DeregisterTaskDefinitionRequest(_param0 *ecs.DeregisterTaskDefinitionInput) (*request.Request, *ecs.DeregisterTaskDefinitionOutput)

func (*MockECSAPI) DeregisterTaskDefinitionWithContext

func (_m *MockECSAPI) DeregisterTaskDefinitionWithContext(_param0 aws.Context, _param1 *ecs.DeregisterTaskDefinitionInput, _param2 ...request.Option) (*ecs.DeregisterTaskDefinitionOutput, error)

func (*MockECSAPI) DescribeClusters

func (_m *MockECSAPI) DescribeClusters(_param0 *ecs.DescribeClustersInput) (*ecs.DescribeClustersOutput, error)

func (*MockECSAPI) DescribeClustersRequest

func (_m *MockECSAPI) DescribeClustersRequest(_param0 *ecs.DescribeClustersInput) (*request.Request, *ecs.DescribeClustersOutput)

func (*MockECSAPI) DescribeClustersWithContext

func (_m *MockECSAPI) DescribeClustersWithContext(_param0 aws.Context, _param1 *ecs.DescribeClustersInput, _param2 ...request.Option) (*ecs.DescribeClustersOutput, error)

func (*MockECSAPI) DescribeContainerInstances

func (_m *MockECSAPI) DescribeContainerInstances(_param0 *ecs.DescribeContainerInstancesInput) (*ecs.DescribeContainerInstancesOutput, error)

func (*MockECSAPI) DescribeContainerInstancesRequest

func (_m *MockECSAPI) DescribeContainerInstancesRequest(_param0 *ecs.DescribeContainerInstancesInput) (*request.Request, *ecs.DescribeContainerInstancesOutput)

func (*MockECSAPI) DescribeContainerInstancesWithContext

func (_m *MockECSAPI) DescribeContainerInstancesWithContext(_param0 aws.Context, _param1 *ecs.DescribeContainerInstancesInput, _param2 ...request.Option) (*ecs.DescribeContainerInstancesOutput, error)

func (*MockECSAPI) DescribeServices

func (_m *MockECSAPI) DescribeServices(_param0 *ecs.DescribeServicesInput) (*ecs.DescribeServicesOutput, error)

func (*MockECSAPI) DescribeServicesRequest

func (_m *MockECSAPI) DescribeServicesRequest(_param0 *ecs.DescribeServicesInput) (*request.Request, *ecs.DescribeServicesOutput)

func (*MockECSAPI) DescribeServicesWithContext

func (_m *MockECSAPI) DescribeServicesWithContext(_param0 aws.Context, _param1 *ecs.DescribeServicesInput, _param2 ...request.Option) (*ecs.DescribeServicesOutput, error)

func (*MockECSAPI) DescribeTaskDefinition

func (_m *MockECSAPI) DescribeTaskDefinition(_param0 *ecs.DescribeTaskDefinitionInput) (*ecs.DescribeTaskDefinitionOutput, error)

func (*MockECSAPI) DescribeTaskDefinitionRequest

func (_m *MockECSAPI) DescribeTaskDefinitionRequest(_param0 *ecs.DescribeTaskDefinitionInput) (*request.Request, *ecs.DescribeTaskDefinitionOutput)

func (*MockECSAPI) DescribeTaskDefinitionWithContext

func (_m *MockECSAPI) DescribeTaskDefinitionWithContext(_param0 aws.Context, _param1 *ecs.DescribeTaskDefinitionInput, _param2 ...request.Option) (*ecs.DescribeTaskDefinitionOutput, error)

func (*MockECSAPI) DescribeTasks

func (_m *MockECSAPI) DescribeTasks(_param0 *ecs.DescribeTasksInput) (*ecs.DescribeTasksOutput, error)

func (*MockECSAPI) DescribeTasksRequest

func (_m *MockECSAPI) DescribeTasksRequest(_param0 *ecs.DescribeTasksInput) (*request.Request, *ecs.DescribeTasksOutput)

func (*MockECSAPI) DescribeTasksWithContext

func (_m *MockECSAPI) DescribeTasksWithContext(_param0 aws.Context, _param1 *ecs.DescribeTasksInput, _param2 ...request.Option) (*ecs.DescribeTasksOutput, error)

func (*MockECSAPI) DiscoverPollEndpoint

func (_m *MockECSAPI) DiscoverPollEndpoint(_param0 *ecs.DiscoverPollEndpointInput) (*ecs.DiscoverPollEndpointOutput, error)

func (*MockECSAPI) DiscoverPollEndpointRequest

func (_m *MockECSAPI) DiscoverPollEndpointRequest(_param0 *ecs.DiscoverPollEndpointInput) (*request.Request, *ecs.DiscoverPollEndpointOutput)

func (*MockECSAPI) DiscoverPollEndpointWithContext

func (_m *MockECSAPI) DiscoverPollEndpointWithContext(_param0 aws.Context, _param1 *ecs.DiscoverPollEndpointInput, _param2 ...request.Option) (*ecs.DiscoverPollEndpointOutput, error)

func (*MockECSAPI) EXPECT

func (_m *MockECSAPI) EXPECT() *_MockECSAPIRecorder

func (*MockECSAPI) ListAttributes

func (_m *MockECSAPI) ListAttributes(_param0 *ecs.ListAttributesInput) (*ecs.ListAttributesOutput, error)

func (*MockECSAPI) ListAttributesRequest

func (_m *MockECSAPI) ListAttributesRequest(_param0 *ecs.ListAttributesInput) (*request.Request, *ecs.ListAttributesOutput)

func (*MockECSAPI) ListAttributesWithContext

func (_m *MockECSAPI) ListAttributesWithContext(_param0 aws.Context, _param1 *ecs.ListAttributesInput, _param2 ...request.Option) (*ecs.ListAttributesOutput, error)

func (*MockECSAPI) ListClusters

func (_m *MockECSAPI) ListClusters(_param0 *ecs.ListClustersInput) (*ecs.ListClustersOutput, error)

func (*MockECSAPI) ListClustersPages

func (_m *MockECSAPI) ListClustersPages(_param0 *ecs.ListClustersInput, _param1 func(*ecs.ListClustersOutput, bool) bool) error

func (*MockECSAPI) ListClustersPagesWithContext

func (_m *MockECSAPI) ListClustersPagesWithContext(_param0 aws.Context, _param1 *ecs.ListClustersInput, _param2 func(*ecs.ListClustersOutput, bool) bool, _param3 ...request.Option) error

func (*MockECSAPI) ListClustersRequest

func (_m *MockECSAPI) ListClustersRequest(_param0 *ecs.ListClustersInput) (*request.Request, *ecs.ListClustersOutput)

func (*MockECSAPI) ListClustersWithContext

func (_m *MockECSAPI) ListClustersWithContext(_param0 aws.Context, _param1 *ecs.ListClustersInput, _param2 ...request.Option) (*ecs.ListClustersOutput, error)

func (*MockECSAPI) ListContainerInstances

func (_m *MockECSAPI) ListContainerInstances(_param0 *ecs.ListContainerInstancesInput) (*ecs.ListContainerInstancesOutput, error)

func (*MockECSAPI) ListContainerInstancesPages

func (_m *MockECSAPI) ListContainerInstancesPages(_param0 *ecs.ListContainerInstancesInput, _param1 func(*ecs.ListContainerInstancesOutput, bool) bool) error

func (*MockECSAPI) ListContainerInstancesPagesWithContext

func (_m *MockECSAPI) ListContainerInstancesPagesWithContext(_param0 aws.Context, _param1 *ecs.ListContainerInstancesInput, _param2 func(*ecs.ListContainerInstancesOutput, bool) bool, _param3 ...request.Option) error

func (*MockECSAPI) ListContainerInstancesRequest

func (_m *MockECSAPI) ListContainerInstancesRequest(_param0 *ecs.ListContainerInstancesInput) (*request.Request, *ecs.ListContainerInstancesOutput)

func (*MockECSAPI) ListContainerInstancesWithContext

func (_m *MockECSAPI) ListContainerInstancesWithContext(_param0 aws.Context, _param1 *ecs.ListContainerInstancesInput, _param2 ...request.Option) (*ecs.ListContainerInstancesOutput, error)

func (*MockECSAPI) ListServices

func (_m *MockECSAPI) ListServices(_param0 *ecs.ListServicesInput) (*ecs.ListServicesOutput, error)

func (*MockECSAPI) ListServicesPages

func (_m *MockECSAPI) ListServicesPages(_param0 *ecs.ListServicesInput, _param1 func(*ecs.ListServicesOutput, bool) bool) error

func (*MockECSAPI) ListServicesPagesWithContext

func (_m *MockECSAPI) ListServicesPagesWithContext(_param0 aws.Context, _param1 *ecs.ListServicesInput, _param2 func(*ecs.ListServicesOutput, bool) bool, _param3 ...request.Option) error

func (*MockECSAPI) ListServicesRequest

func (_m *MockECSAPI) ListServicesRequest(_param0 *ecs.ListServicesInput) (*request.Request, *ecs.ListServicesOutput)

func (*MockECSAPI) ListServicesWithContext

func (_m *MockECSAPI) ListServicesWithContext(_param0 aws.Context, _param1 *ecs.ListServicesInput, _param2 ...request.Option) (*ecs.ListServicesOutput, error)

func (*MockECSAPI) ListTaskDefinitionFamilies

func (_m *MockECSAPI) ListTaskDefinitionFamilies(_param0 *ecs.ListTaskDefinitionFamiliesInput) (*ecs.ListTaskDefinitionFamiliesOutput, error)

func (*MockECSAPI) ListTaskDefinitionFamiliesPages

func (_m *MockECSAPI) ListTaskDefinitionFamiliesPages(_param0 *ecs.ListTaskDefinitionFamiliesInput, _param1 func(*ecs.ListTaskDefinitionFamiliesOutput, bool) bool) error

func (*MockECSAPI) ListTaskDefinitionFamiliesPagesWithContext

func (_m *MockECSAPI) ListTaskDefinitionFamiliesPagesWithContext(_param0 aws.Context, _param1 *ecs.ListTaskDefinitionFamiliesInput, _param2 func(*ecs.ListTaskDefinitionFamiliesOutput, bool) bool, _param3 ...request.Option) error

func (*MockECSAPI) ListTaskDefinitionFamiliesRequest

func (_m *MockECSAPI) ListTaskDefinitionFamiliesRequest(_param0 *ecs.ListTaskDefinitionFamiliesInput) (*request.Request, *ecs.ListTaskDefinitionFamiliesOutput)

func (*MockECSAPI) ListTaskDefinitionFamiliesWithContext

func (_m *MockECSAPI) ListTaskDefinitionFamiliesWithContext(_param0 aws.Context, _param1 *ecs.ListTaskDefinitionFamiliesInput, _param2 ...request.Option) (*ecs.ListTaskDefinitionFamiliesOutput, error)

func (*MockECSAPI) ListTaskDefinitions

func (_m *MockECSAPI) ListTaskDefinitions(_param0 *ecs.ListTaskDefinitionsInput) (*ecs.ListTaskDefinitionsOutput, error)

func (*MockECSAPI) ListTaskDefinitionsPages

func (_m *MockECSAPI) ListTaskDefinitionsPages(_param0 *ecs.ListTaskDefinitionsInput, _param1 func(*ecs.ListTaskDefinitionsOutput, bool) bool) error

func (*MockECSAPI) ListTaskDefinitionsPagesWithContext

func (_m *MockECSAPI) ListTaskDefinitionsPagesWithContext(_param0 aws.Context, _param1 *ecs.ListTaskDefinitionsInput, _param2 func(*ecs.ListTaskDefinitionsOutput, bool) bool, _param3 ...request.Option) error

func (*MockECSAPI) ListTaskDefinitionsRequest

func (_m *MockECSAPI) ListTaskDefinitionsRequest(_param0 *ecs.ListTaskDefinitionsInput) (*request.Request, *ecs.ListTaskDefinitionsOutput)

func (*MockECSAPI) ListTaskDefinitionsWithContext

func (_m *MockECSAPI) ListTaskDefinitionsWithContext(_param0 aws.Context, _param1 *ecs.ListTaskDefinitionsInput, _param2 ...request.Option) (*ecs.ListTaskDefinitionsOutput, error)

func (*MockECSAPI) ListTasks

func (_m *MockECSAPI) ListTasks(_param0 *ecs.ListTasksInput) (*ecs.ListTasksOutput, error)

func (*MockECSAPI) ListTasksPages

func (_m *MockECSAPI) ListTasksPages(_param0 *ecs.ListTasksInput, _param1 func(*ecs.ListTasksOutput, bool) bool) error

func (*MockECSAPI) ListTasksPagesWithContext

func (_m *MockECSAPI) ListTasksPagesWithContext(_param0 aws.Context, _param1 *ecs.ListTasksInput, _param2 func(*ecs.ListTasksOutput, bool) bool, _param3 ...request.Option) error

func (*MockECSAPI) ListTasksRequest

func (_m *MockECSAPI) ListTasksRequest(_param0 *ecs.ListTasksInput) (*request.Request, *ecs.ListTasksOutput)

func (*MockECSAPI) ListTasksWithContext

func (_m *MockECSAPI) ListTasksWithContext(_param0 aws.Context, _param1 *ecs.ListTasksInput, _param2 ...request.Option) (*ecs.ListTasksOutput, error)

func (*MockECSAPI) PutAttributes

func (_m *MockECSAPI) PutAttributes(_param0 *ecs.PutAttributesInput) (*ecs.PutAttributesOutput, error)

func (*MockECSAPI) PutAttributesRequest

func (_m *MockECSAPI) PutAttributesRequest(_param0 *ecs.PutAttributesInput) (*request.Request, *ecs.PutAttributesOutput)

func (*MockECSAPI) PutAttributesWithContext

func (_m *MockECSAPI) PutAttributesWithContext(_param0 aws.Context, _param1 *ecs.PutAttributesInput, _param2 ...request.Option) (*ecs.PutAttributesOutput, error)

func (*MockECSAPI) RegisterContainerInstance

func (_m *MockECSAPI) RegisterContainerInstance(_param0 *ecs.RegisterContainerInstanceInput) (*ecs.RegisterContainerInstanceOutput, error)

func (*MockECSAPI) RegisterContainerInstanceRequest

func (_m *MockECSAPI) RegisterContainerInstanceRequest(_param0 *ecs.RegisterContainerInstanceInput) (*request.Request, *ecs.RegisterContainerInstanceOutput)

func (*MockECSAPI) RegisterContainerInstanceWithContext

func (_m *MockECSAPI) RegisterContainerInstanceWithContext(_param0 aws.Context, _param1 *ecs.RegisterContainerInstanceInput, _param2 ...request.Option) (*ecs.RegisterContainerInstanceOutput, error)

func (*MockECSAPI) RegisterTaskDefinition

func (_m *MockECSAPI) RegisterTaskDefinition(_param0 *ecs.RegisterTaskDefinitionInput) (*ecs.RegisterTaskDefinitionOutput, error)

func (*MockECSAPI) RegisterTaskDefinitionRequest

func (_m *MockECSAPI) RegisterTaskDefinitionRequest(_param0 *ecs.RegisterTaskDefinitionInput) (*request.Request, *ecs.RegisterTaskDefinitionOutput)

func (*MockECSAPI) RegisterTaskDefinitionWithContext

func (_m *MockECSAPI) RegisterTaskDefinitionWithContext(_param0 aws.Context, _param1 *ecs.RegisterTaskDefinitionInput, _param2 ...request.Option) (*ecs.RegisterTaskDefinitionOutput, error)

func (*MockECSAPI) RunTask

func (_m *MockECSAPI) RunTask(_param0 *ecs.RunTaskInput) (*ecs.RunTaskOutput, error)

func (*MockECSAPI) RunTaskRequest

func (_m *MockECSAPI) RunTaskRequest(_param0 *ecs.RunTaskInput) (*request.Request, *ecs.RunTaskOutput)

func (*MockECSAPI) RunTaskWithContext

func (_m *MockECSAPI) RunTaskWithContext(_param0 aws.Context, _param1 *ecs.RunTaskInput, _param2 ...request.Option) (*ecs.RunTaskOutput, error)

func (*MockECSAPI) StartTask

func (_m *MockECSAPI) StartTask(_param0 *ecs.StartTaskInput) (*ecs.StartTaskOutput, error)

func (*MockECSAPI) StartTaskRequest

func (_m *MockECSAPI) StartTaskRequest(_param0 *ecs.StartTaskInput) (*request.Request, *ecs.StartTaskOutput)

func (*MockECSAPI) StartTaskWithContext

func (_m *MockECSAPI) StartTaskWithContext(_param0 aws.Context, _param1 *ecs.StartTaskInput, _param2 ...request.Option) (*ecs.StartTaskOutput, error)

func (*MockECSAPI) StopTask

func (_m *MockECSAPI) StopTask(_param0 *ecs.StopTaskInput) (*ecs.StopTaskOutput, error)

func (*MockECSAPI) StopTaskRequest

func (_m *MockECSAPI) StopTaskRequest(_param0 *ecs.StopTaskInput) (*request.Request, *ecs.StopTaskOutput)

func (*MockECSAPI) StopTaskWithContext

func (_m *MockECSAPI) StopTaskWithContext(_param0 aws.Context, _param1 *ecs.StopTaskInput, _param2 ...request.Option) (*ecs.StopTaskOutput, error)

func (*MockECSAPI) SubmitContainerStateChange

func (_m *MockECSAPI) SubmitContainerStateChange(_param0 *ecs.SubmitContainerStateChangeInput) (*ecs.SubmitContainerStateChangeOutput, error)

func (*MockECSAPI) SubmitContainerStateChangeRequest

func (_m *MockECSAPI) SubmitContainerStateChangeRequest(_param0 *ecs.SubmitContainerStateChangeInput) (*request.Request, *ecs.SubmitContainerStateChangeOutput)

func (*MockECSAPI) SubmitContainerStateChangeWithContext

func (_m *MockECSAPI) SubmitContainerStateChangeWithContext(_param0 aws.Context, _param1 *ecs.SubmitContainerStateChangeInput, _param2 ...request.Option) (*ecs.SubmitContainerStateChangeOutput, error)

func (*MockECSAPI) SubmitTaskStateChange

func (_m *MockECSAPI) SubmitTaskStateChange(_param0 *ecs.SubmitTaskStateChangeInput) (*ecs.SubmitTaskStateChangeOutput, error)

func (*MockECSAPI) SubmitTaskStateChangeRequest

func (_m *MockECSAPI) SubmitTaskStateChangeRequest(_param0 *ecs.SubmitTaskStateChangeInput) (*request.Request, *ecs.SubmitTaskStateChangeOutput)

func (*MockECSAPI) SubmitTaskStateChangeWithContext

func (_m *MockECSAPI) SubmitTaskStateChangeWithContext(_param0 aws.Context, _param1 *ecs.SubmitTaskStateChangeInput, _param2 ...request.Option) (*ecs.SubmitTaskStateChangeOutput, error)

func (*MockECSAPI) UpdateContainerAgent

func (_m *MockECSAPI) UpdateContainerAgent(_param0 *ecs.UpdateContainerAgentInput) (*ecs.UpdateContainerAgentOutput, error)

func (*MockECSAPI) UpdateContainerAgentRequest

func (_m *MockECSAPI) UpdateContainerAgentRequest(_param0 *ecs.UpdateContainerAgentInput) (*request.Request, *ecs.UpdateContainerAgentOutput)

func (*MockECSAPI) UpdateContainerAgentWithContext

func (_m *MockECSAPI) UpdateContainerAgentWithContext(_param0 aws.Context, _param1 *ecs.UpdateContainerAgentInput, _param2 ...request.Option) (*ecs.UpdateContainerAgentOutput, error)

func (*MockECSAPI) UpdateContainerInstancesState

func (_m *MockECSAPI) UpdateContainerInstancesState(_param0 *ecs.UpdateContainerInstancesStateInput) (*ecs.UpdateContainerInstancesStateOutput, error)

func (*MockECSAPI) UpdateContainerInstancesStateRequest

func (_m *MockECSAPI) UpdateContainerInstancesStateRequest(_param0 *ecs.UpdateContainerInstancesStateInput) (*request.Request, *ecs.UpdateContainerInstancesStateOutput)

func (*MockECSAPI) UpdateContainerInstancesStateWithContext

func (_m *MockECSAPI) UpdateContainerInstancesStateWithContext(_param0 aws.Context, _param1 *ecs.UpdateContainerInstancesStateInput, _param2 ...request.Option) (*ecs.UpdateContainerInstancesStateOutput, error)

func (*MockECSAPI) UpdateService

func (_m *MockECSAPI) UpdateService(_param0 *ecs.UpdateServiceInput) (*ecs.UpdateServiceOutput, error)

func (*MockECSAPI) UpdateServiceRequest

func (_m *MockECSAPI) UpdateServiceRequest(_param0 *ecs.UpdateServiceInput) (*request.Request, *ecs.UpdateServiceOutput)

func (*MockECSAPI) UpdateServiceWithContext

func (_m *MockECSAPI) UpdateServiceWithContext(_param0 aws.Context, _param1 *ecs.UpdateServiceInput, _param2 ...request.Option) (*ecs.UpdateServiceOutput, error)

func (*MockECSAPI) WaitUntilServicesInactive

func (_m *MockECSAPI) WaitUntilServicesInactive(_param0 *ecs.DescribeServicesInput) error

func (*MockECSAPI) WaitUntilServicesInactiveWithContext

func (_m *MockECSAPI) WaitUntilServicesInactiveWithContext(_param0 aws.Context, _param1 *ecs.DescribeServicesInput, _param2 ...request.WaiterOption) error

func (*MockECSAPI) WaitUntilServicesStable

func (_m *MockECSAPI) WaitUntilServicesStable(_param0 *ecs.DescribeServicesInput) error

func (*MockECSAPI) WaitUntilServicesStableWithContext

func (_m *MockECSAPI) WaitUntilServicesStableWithContext(_param0 aws.Context, _param1 *ecs.DescribeServicesInput, _param2 ...request.WaiterOption) error

func (*MockECSAPI) WaitUntilTasksRunning

func (_m *MockECSAPI) WaitUntilTasksRunning(_param0 *ecs.DescribeTasksInput) error

func (*MockECSAPI) WaitUntilTasksRunningWithContext

func (_m *MockECSAPI) WaitUntilTasksRunningWithContext(_param0 aws.Context, _param1 *ecs.DescribeTasksInput, _param2 ...request.WaiterOption) error

func (*MockECSAPI) WaitUntilTasksStopped

func (_m *MockECSAPI) WaitUntilTasksStopped(_param0 *ecs.DescribeTasksInput) error

func (*MockECSAPI) WaitUntilTasksStoppedWithContext

func (_m *MockECSAPI) WaitUntilTasksStoppedWithContext(_param0 aws.Context, _param1 *ecs.DescribeTasksInput, _param2 ...request.WaiterOption) error

type MockECSWrapper

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

Mock of ECSWrapper interface

func NewMockECSWrapper

func NewMockECSWrapper(ctrl *gomock.Controller) *MockECSWrapper

func (*MockECSWrapper) DescribeContainerInstances

func (_m *MockECSWrapper) DescribeContainerInstances(_param0 *string, _param1 []*string) ([]types.ContainerInstance, []string, error)

func (*MockECSWrapper) DescribeTasks

func (_m *MockECSWrapper) DescribeTasks(_param0 *string, _param1 []*string) ([]types.Task, []string, error)

func (*MockECSWrapper) EXPECT

func (_m *MockECSWrapper) EXPECT() *_MockECSWrapperRecorder

func (*MockECSWrapper) ListAllClusters

func (_m *MockECSWrapper) ListAllClusters() ([]*string, error)

func (*MockECSWrapper) ListAllContainerInstances

func (_m *MockECSWrapper) ListAllContainerInstances(_param0 *string) ([]*string, error)

func (*MockECSWrapper) ListTasksWithDesiredStatus

func (_m *MockECSWrapper) ListTasksWithDesiredStatus(_param0 *string, _param1 *string) ([]*string, error)

type MockEtcdInterface

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

Mock of EtcdInterface interface

func NewMockEtcdInterface

func NewMockEtcdInterface(ctrl *gomock.Controller) *MockEtcdInterface

func (*MockEtcdInterface) Close

func (_m *MockEtcdInterface) Close() error

func (*MockEtcdInterface) Delete

func (_m *MockEtcdInterface) Delete(_param0 context.Context, _param1 string, _param2 ...clientv3.OpOption) (*clientv3.DeleteResponse, error)

func (*MockEtcdInterface) EXPECT

func (_m *MockEtcdInterface) EXPECT() *_MockEtcdInterfaceRecorder

func (*MockEtcdInterface) Get

func (_m *MockEtcdInterface) Get(_param0 context.Context, _param1 string, _param2 ...clientv3.OpOption) (*clientv3.GetResponse, error)

func (*MockEtcdInterface) Put

func (_m *MockEtcdInterface) Put(_param0 context.Context, _param1 string, _param2 string, _param3 ...clientv3.OpOption) (*clientv3.PutResponse, error)

func (*MockEtcdInterface) Watch

func (_m *MockEtcdInterface) Watch(_param0 context.Context, _param1 string, _param2 ...clientv3.OpOption) clientv3.WatchChan

type MockEtcdTXStore

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

Mock of EtcdTXStore interface

func NewMockEtcdTXStore

func NewMockEtcdTXStore(ctrl *gomock.Controller) *MockEtcdTXStore

func (*MockEtcdTXStore) EXPECT

func (_m *MockEtcdTXStore) EXPECT() *_MockEtcdTXStoreRecorder

func (*MockEtcdTXStore) GetV3Client

func (_m *MockEtcdTXStore) GetV3Client() *clientv3.Client

func (*MockEtcdTXStore) NewSTMRepeatable

func (_m *MockEtcdTXStore) NewSTMRepeatable(_param0 context.Context, _param1 *clientv3.Client, _param2 func(concurrency.STM) error) (*clientv3.TxnResponse, error)

type MockKinesisAPI

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

Mock of KinesisAPI interface

func NewMockKinesisAPI

func NewMockKinesisAPI(ctrl *gomock.Controller) *MockKinesisAPI

func (*MockKinesisAPI) AddTagsToStream

func (*MockKinesisAPI) AddTagsToStreamRequest

func (_m *MockKinesisAPI) AddTagsToStreamRequest(_param0 *kinesis.AddTagsToStreamInput) (*request.Request, *kinesis.AddTagsToStreamOutput)

func (*MockKinesisAPI) AddTagsToStreamWithContext

func (_m *MockKinesisAPI) AddTagsToStreamWithContext(_param0 aws.Context, _param1 *kinesis.AddTagsToStreamInput, _param2 ...request.Option) (*kinesis.AddTagsToStreamOutput, error)

func (*MockKinesisAPI) CreateStream

func (*MockKinesisAPI) CreateStreamRequest

func (_m *MockKinesisAPI) CreateStreamRequest(_param0 *kinesis.CreateStreamInput) (*request.Request, *kinesis.CreateStreamOutput)

func (*MockKinesisAPI) CreateStreamWithContext

func (_m *MockKinesisAPI) CreateStreamWithContext(_param0 aws.Context, _param1 *kinesis.CreateStreamInput, _param2 ...request.Option) (*kinesis.CreateStreamOutput, error)

func (*MockKinesisAPI) DecreaseStreamRetentionPeriodWithContext

func (_m *MockKinesisAPI) DecreaseStreamRetentionPeriodWithContext(_param0 aws.Context, _param1 *kinesis.DecreaseStreamRetentionPeriodInput, _param2 ...request.Option) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)

func (*MockKinesisAPI) DeleteStream

func (*MockKinesisAPI) DeleteStreamRequest

func (_m *MockKinesisAPI) DeleteStreamRequest(_param0 *kinesis.DeleteStreamInput) (*request.Request, *kinesis.DeleteStreamOutput)

func (*MockKinesisAPI) DeleteStreamWithContext

func (_m *MockKinesisAPI) DeleteStreamWithContext(_param0 aws.Context, _param1 *kinesis.DeleteStreamInput, _param2 ...request.Option) (*kinesis.DeleteStreamOutput, error)

func (*MockKinesisAPI) DescribeLimits

func (*MockKinesisAPI) DescribeLimitsRequest

func (_m *MockKinesisAPI) DescribeLimitsRequest(_param0 *kinesis.DescribeLimitsInput) (*request.Request, *kinesis.DescribeLimitsOutput)

func (*MockKinesisAPI) DescribeLimitsWithContext

func (_m *MockKinesisAPI) DescribeLimitsWithContext(_param0 aws.Context, _param1 *kinesis.DescribeLimitsInput, _param2 ...request.Option) (*kinesis.DescribeLimitsOutput, error)

func (*MockKinesisAPI) DescribeStream

func (*MockKinesisAPI) DescribeStreamPages

func (_m *MockKinesisAPI) DescribeStreamPages(_param0 *kinesis.DescribeStreamInput, _param1 func(*kinesis.DescribeStreamOutput, bool) bool) error

func (*MockKinesisAPI) DescribeStreamPagesWithContext

func (_m *MockKinesisAPI) DescribeStreamPagesWithContext(_param0 aws.Context, _param1 *kinesis.DescribeStreamInput, _param2 func(*kinesis.DescribeStreamOutput, bool) bool, _param3 ...request.Option) error

func (*MockKinesisAPI) DescribeStreamRequest

func (_m *MockKinesisAPI) DescribeStreamRequest(_param0 *kinesis.DescribeStreamInput) (*request.Request, *kinesis.DescribeStreamOutput)

func (*MockKinesisAPI) DescribeStreamWithContext

func (_m *MockKinesisAPI) DescribeStreamWithContext(_param0 aws.Context, _param1 *kinesis.DescribeStreamInput, _param2 ...request.Option) (*kinesis.DescribeStreamOutput, error)

func (*MockKinesisAPI) DisableEnhancedMonitoring

func (_m *MockKinesisAPI) DisableEnhancedMonitoring(_param0 *kinesis.DisableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)

func (*MockKinesisAPI) DisableEnhancedMonitoringRequest

func (_m *MockKinesisAPI) DisableEnhancedMonitoringRequest(_param0 *kinesis.DisableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)

func (*MockKinesisAPI) DisableEnhancedMonitoringWithContext

func (_m *MockKinesisAPI) DisableEnhancedMonitoringWithContext(_param0 aws.Context, _param1 *kinesis.DisableEnhancedMonitoringInput, _param2 ...request.Option) (*kinesis.EnhancedMonitoringOutput, error)

func (*MockKinesisAPI) EXPECT

func (_m *MockKinesisAPI) EXPECT() *_MockKinesisAPIRecorder

func (*MockKinesisAPI) EnableEnhancedMonitoring

func (*MockKinesisAPI) EnableEnhancedMonitoringRequest

func (_m *MockKinesisAPI) EnableEnhancedMonitoringRequest(_param0 *kinesis.EnableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)

func (*MockKinesisAPI) EnableEnhancedMonitoringWithContext

func (_m *MockKinesisAPI) EnableEnhancedMonitoringWithContext(_param0 aws.Context, _param1 *kinesis.EnableEnhancedMonitoringInput, _param2 ...request.Option) (*kinesis.EnhancedMonitoringOutput, error)

func (*MockKinesisAPI) GetRecords

func (_m *MockKinesisAPI) GetRecords(_param0 *kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error)

func (*MockKinesisAPI) GetRecordsRequest

func (_m *MockKinesisAPI) GetRecordsRequest(_param0 *kinesis.GetRecordsInput) (*request.Request, *kinesis.GetRecordsOutput)

func (*MockKinesisAPI) GetRecordsWithContext

func (_m *MockKinesisAPI) GetRecordsWithContext(_param0 aws.Context, _param1 *kinesis.GetRecordsInput, _param2 ...request.Option) (*kinesis.GetRecordsOutput, error)

func (*MockKinesisAPI) GetShardIterator

func (*MockKinesisAPI) GetShardIteratorRequest

func (_m *MockKinesisAPI) GetShardIteratorRequest(_param0 *kinesis.GetShardIteratorInput) (*request.Request, *kinesis.GetShardIteratorOutput)

func (*MockKinesisAPI) GetShardIteratorWithContext

func (_m *MockKinesisAPI) GetShardIteratorWithContext(_param0 aws.Context, _param1 *kinesis.GetShardIteratorInput, _param2 ...request.Option) (*kinesis.GetShardIteratorOutput, error)

func (*MockKinesisAPI) IncreaseStreamRetentionPeriodWithContext

func (_m *MockKinesisAPI) IncreaseStreamRetentionPeriodWithContext(_param0 aws.Context, _param1 *kinesis.IncreaseStreamRetentionPeriodInput, _param2 ...request.Option) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)

func (*MockKinesisAPI) ListStreams

func (_m *MockKinesisAPI) ListStreams(_param0 *kinesis.ListStreamsInput) (*kinesis.ListStreamsOutput, error)

func (*MockKinesisAPI) ListStreamsPages

func (_m *MockKinesisAPI) ListStreamsPages(_param0 *kinesis.ListStreamsInput, _param1 func(*kinesis.ListStreamsOutput, bool) bool) error

func (*MockKinesisAPI) ListStreamsPagesWithContext

func (_m *MockKinesisAPI) ListStreamsPagesWithContext(_param0 aws.Context, _param1 *kinesis.ListStreamsInput, _param2 func(*kinesis.ListStreamsOutput, bool) bool, _param3 ...request.Option) error

func (*MockKinesisAPI) ListStreamsRequest

func (_m *MockKinesisAPI) ListStreamsRequest(_param0 *kinesis.ListStreamsInput) (*request.Request, *kinesis.ListStreamsOutput)

func (*MockKinesisAPI) ListStreamsWithContext

func (_m *MockKinesisAPI) ListStreamsWithContext(_param0 aws.Context, _param1 *kinesis.ListStreamsInput, _param2 ...request.Option) (*kinesis.ListStreamsOutput, error)

func (*MockKinesisAPI) ListTagsForStream

func (*MockKinesisAPI) ListTagsForStreamRequest

func (_m *MockKinesisAPI) ListTagsForStreamRequest(_param0 *kinesis.ListTagsForStreamInput) (*request.Request, *kinesis.ListTagsForStreamOutput)

func (*MockKinesisAPI) ListTagsForStreamWithContext

func (_m *MockKinesisAPI) ListTagsForStreamWithContext(_param0 aws.Context, _param1 *kinesis.ListTagsForStreamInput, _param2 ...request.Option) (*kinesis.ListTagsForStreamOutput, error)

func (*MockKinesisAPI) MergeShards

func (_m *MockKinesisAPI) MergeShards(_param0 *kinesis.MergeShardsInput) (*kinesis.MergeShardsOutput, error)

func (*MockKinesisAPI) MergeShardsRequest

func (_m *MockKinesisAPI) MergeShardsRequest(_param0 *kinesis.MergeShardsInput) (*request.Request, *kinesis.MergeShardsOutput)

func (*MockKinesisAPI) MergeShardsWithContext

func (_m *MockKinesisAPI) MergeShardsWithContext(_param0 aws.Context, _param1 *kinesis.MergeShardsInput, _param2 ...request.Option) (*kinesis.MergeShardsOutput, error)

func (*MockKinesisAPI) PutRecord

func (_m *MockKinesisAPI) PutRecord(_param0 *kinesis.PutRecordInput) (*kinesis.PutRecordOutput, error)

func (*MockKinesisAPI) PutRecordRequest

func (_m *MockKinesisAPI) PutRecordRequest(_param0 *kinesis.PutRecordInput) (*request.Request, *kinesis.PutRecordOutput)

func (*MockKinesisAPI) PutRecordWithContext

func (_m *MockKinesisAPI) PutRecordWithContext(_param0 aws.Context, _param1 *kinesis.PutRecordInput, _param2 ...request.Option) (*kinesis.PutRecordOutput, error)

func (*MockKinesisAPI) PutRecords

func (_m *MockKinesisAPI) PutRecords(_param0 *kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error)

func (*MockKinesisAPI) PutRecordsRequest

func (_m *MockKinesisAPI) PutRecordsRequest(_param0 *kinesis.PutRecordsInput) (*request.Request, *kinesis.PutRecordsOutput)

func (*MockKinesisAPI) PutRecordsWithContext

func (_m *MockKinesisAPI) PutRecordsWithContext(_param0 aws.Context, _param1 *kinesis.PutRecordsInput, _param2 ...request.Option) (*kinesis.PutRecordsOutput, error)

func (*MockKinesisAPI) RemoveTagsFromStream

func (*MockKinesisAPI) RemoveTagsFromStreamRequest

func (_m *MockKinesisAPI) RemoveTagsFromStreamRequest(_param0 *kinesis.RemoveTagsFromStreamInput) (*request.Request, *kinesis.RemoveTagsFromStreamOutput)

func (*MockKinesisAPI) RemoveTagsFromStreamWithContext

func (_m *MockKinesisAPI) RemoveTagsFromStreamWithContext(_param0 aws.Context, _param1 *kinesis.RemoveTagsFromStreamInput, _param2 ...request.Option) (*kinesis.RemoveTagsFromStreamOutput, error)

func (*MockKinesisAPI) SplitShard

func (_m *MockKinesisAPI) SplitShard(_param0 *kinesis.SplitShardInput) (*kinesis.SplitShardOutput, error)

func (*MockKinesisAPI) SplitShardRequest

func (_m *MockKinesisAPI) SplitShardRequest(_param0 *kinesis.SplitShardInput) (*request.Request, *kinesis.SplitShardOutput)

func (*MockKinesisAPI) SplitShardWithContext

func (_m *MockKinesisAPI) SplitShardWithContext(_param0 aws.Context, _param1 *kinesis.SplitShardInput, _param2 ...request.Option) (*kinesis.SplitShardOutput, error)

func (*MockKinesisAPI) StartStreamEncryption

func (*MockKinesisAPI) StartStreamEncryptionRequest

func (*MockKinesisAPI) StartStreamEncryptionWithContext

func (_m *MockKinesisAPI) StartStreamEncryptionWithContext(_param0 aws.Context, _param1 *kinesis.StartStreamEncryptionInput, _param2 ...request.Option) (*kinesis.StartStreamEncryptionOutput, error)

func (*MockKinesisAPI) StopStreamEncryption

func (*MockKinesisAPI) StopStreamEncryptionRequest

func (_m *MockKinesisAPI) StopStreamEncryptionRequest(_param0 *kinesis.StopStreamEncryptionInput) (*request.Request, *kinesis.StopStreamEncryptionOutput)

func (*MockKinesisAPI) StopStreamEncryptionWithContext

func (_m *MockKinesisAPI) StopStreamEncryptionWithContext(_param0 aws.Context, _param1 *kinesis.StopStreamEncryptionInput, _param2 ...request.Option) (*kinesis.StopStreamEncryptionOutput, error)

func (*MockKinesisAPI) UpdateShardCount

func (*MockKinesisAPI) UpdateShardCountRequest

func (_m *MockKinesisAPI) UpdateShardCountRequest(_param0 *kinesis.UpdateShardCountInput) (*request.Request, *kinesis.UpdateShardCountOutput)

func (*MockKinesisAPI) UpdateShardCountWithContext

func (_m *MockKinesisAPI) UpdateShardCountWithContext(_param0 aws.Context, _param1 *kinesis.UpdateShardCountInput, _param2 ...request.Option) (*kinesis.UpdateShardCountOutput, error)

func (*MockKinesisAPI) WaitUntilStreamExists

func (_m *MockKinesisAPI) WaitUntilStreamExists(_param0 *kinesis.DescribeStreamInput) error

func (*MockKinesisAPI) WaitUntilStreamExistsWithContext

func (_m *MockKinesisAPI) WaitUntilStreamExistsWithContext(_param0 aws.Context, _param1 *kinesis.DescribeStreamInput, _param2 ...request.WaiterOption) error

func (*MockKinesisAPI) WaitUntilStreamNotExists

func (_m *MockKinesisAPI) WaitUntilStreamNotExists(_param0 *kinesis.DescribeStreamInput) error

func (*MockKinesisAPI) WaitUntilStreamNotExistsWithContext

func (_m *MockKinesisAPI) WaitUntilStreamNotExistsWithContext(_param0 aws.Context, _param1 *kinesis.DescribeStreamInput, _param2 ...request.WaiterOption) error

type MockProcessor

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

Mock of Processor interface

func NewMockProcessor

func NewMockProcessor(ctrl *gomock.Controller) *MockProcessor

func (*MockProcessor) EXPECT

func (_m *MockProcessor) EXPECT() *_MockProcessorRecorder

func (*MockProcessor) ProcessEvent

func (_m *MockProcessor) ProcessEvent(event string) error

type MockRoundTripper

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

Mock of RoundTripper interface

func NewMockRoundTripper

func NewMockRoundTripper(ctrl *gomock.Controller) *MockRoundTripper

func (*MockRoundTripper) EXPECT

func (_m *MockRoundTripper) EXPECT() *_MockRoundTripperRecorder

func (*MockRoundTripper) RoundTrip

func (_m *MockRoundTripper) RoundTrip(_param0 *http.Request) (*http.Response, error)

type MockSQSAPI

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

Mock of SQSAPI interface

func NewMockSQSAPI

func NewMockSQSAPI(ctrl *gomock.Controller) *MockSQSAPI

func (*MockSQSAPI) AddPermission

func (_m *MockSQSAPI) AddPermission(_param0 *sqs.AddPermissionInput) (*sqs.AddPermissionOutput, error)

func (*MockSQSAPI) AddPermissionRequest

func (_m *MockSQSAPI) AddPermissionRequest(_param0 *sqs.AddPermissionInput) (*request.Request, *sqs.AddPermissionOutput)

func (*MockSQSAPI) AddPermissionWithContext

func (_m *MockSQSAPI) AddPermissionWithContext(_param0 aws.Context, _param1 *sqs.AddPermissionInput, _param2 ...request.Option) (*sqs.AddPermissionOutput, error)

func (*MockSQSAPI) ChangeMessageVisibility

func (_m *MockSQSAPI) ChangeMessageVisibility(_param0 *sqs.ChangeMessageVisibilityInput) (*sqs.ChangeMessageVisibilityOutput, error)

func (*MockSQSAPI) ChangeMessageVisibilityBatch

func (_m *MockSQSAPI) ChangeMessageVisibilityBatch(_param0 *sqs.ChangeMessageVisibilityBatchInput) (*sqs.ChangeMessageVisibilityBatchOutput, error)

func (*MockSQSAPI) ChangeMessageVisibilityBatchRequest

func (_m *MockSQSAPI) ChangeMessageVisibilityBatchRequest(_param0 *sqs.ChangeMessageVisibilityBatchInput) (*request.Request, *sqs.ChangeMessageVisibilityBatchOutput)

func (*MockSQSAPI) ChangeMessageVisibilityBatchWithContext

func (_m *MockSQSAPI) ChangeMessageVisibilityBatchWithContext(_param0 aws.Context, _param1 *sqs.ChangeMessageVisibilityBatchInput, _param2 ...request.Option) (*sqs.ChangeMessageVisibilityBatchOutput, error)

func (*MockSQSAPI) ChangeMessageVisibilityRequest

func (_m *MockSQSAPI) ChangeMessageVisibilityRequest(_param0 *sqs.ChangeMessageVisibilityInput) (*request.Request, *sqs.ChangeMessageVisibilityOutput)

func (*MockSQSAPI) ChangeMessageVisibilityWithContext

func (_m *MockSQSAPI) ChangeMessageVisibilityWithContext(_param0 aws.Context, _param1 *sqs.ChangeMessageVisibilityInput, _param2 ...request.Option) (*sqs.ChangeMessageVisibilityOutput, error)

func (*MockSQSAPI) CreateQueue

func (_m *MockSQSAPI) CreateQueue(_param0 *sqs.CreateQueueInput) (*sqs.CreateQueueOutput, error)

func (*MockSQSAPI) CreateQueueRequest

func (_m *MockSQSAPI) CreateQueueRequest(_param0 *sqs.CreateQueueInput) (*request.Request, *sqs.CreateQueueOutput)

func (*MockSQSAPI) CreateQueueWithContext

func (_m *MockSQSAPI) CreateQueueWithContext(_param0 aws.Context, _param1 *sqs.CreateQueueInput, _param2 ...request.Option) (*sqs.CreateQueueOutput, error)

func (*MockSQSAPI) DeleteMessage

func (_m *MockSQSAPI) DeleteMessage(_param0 *sqs.DeleteMessageInput) (*sqs.DeleteMessageOutput, error)

func (*MockSQSAPI) DeleteMessageBatch

func (_m *MockSQSAPI) DeleteMessageBatch(_param0 *sqs.DeleteMessageBatchInput) (*sqs.DeleteMessageBatchOutput, error)

func (*MockSQSAPI) DeleteMessageBatchRequest

func (_m *MockSQSAPI) DeleteMessageBatchRequest(_param0 *sqs.DeleteMessageBatchInput) (*request.Request, *sqs.DeleteMessageBatchOutput)

func (*MockSQSAPI) DeleteMessageBatchWithContext

func (_m *MockSQSAPI) DeleteMessageBatchWithContext(_param0 aws.Context, _param1 *sqs.DeleteMessageBatchInput, _param2 ...request.Option) (*sqs.DeleteMessageBatchOutput, error)

func (*MockSQSAPI) DeleteMessageRequest

func (_m *MockSQSAPI) DeleteMessageRequest(_param0 *sqs.DeleteMessageInput) (*request.Request, *sqs.DeleteMessageOutput)

func (*MockSQSAPI) DeleteMessageWithContext

func (_m *MockSQSAPI) DeleteMessageWithContext(_param0 aws.Context, _param1 *sqs.DeleteMessageInput, _param2 ...request.Option) (*sqs.DeleteMessageOutput, error)

func (*MockSQSAPI) DeleteQueue

func (_m *MockSQSAPI) DeleteQueue(_param0 *sqs.DeleteQueueInput) (*sqs.DeleteQueueOutput, error)

func (*MockSQSAPI) DeleteQueueRequest

func (_m *MockSQSAPI) DeleteQueueRequest(_param0 *sqs.DeleteQueueInput) (*request.Request, *sqs.DeleteQueueOutput)

func (*MockSQSAPI) DeleteQueueWithContext

func (_m *MockSQSAPI) DeleteQueueWithContext(_param0 aws.Context, _param1 *sqs.DeleteQueueInput, _param2 ...request.Option) (*sqs.DeleteQueueOutput, error)

func (*MockSQSAPI) EXPECT

func (_m *MockSQSAPI) EXPECT() *_MockSQSAPIRecorder

func (*MockSQSAPI) GetQueueAttributes

func (_m *MockSQSAPI) GetQueueAttributes(_param0 *sqs.GetQueueAttributesInput) (*sqs.GetQueueAttributesOutput, error)

func (*MockSQSAPI) GetQueueAttributesRequest

func (_m *MockSQSAPI) GetQueueAttributesRequest(_param0 *sqs.GetQueueAttributesInput) (*request.Request, *sqs.GetQueueAttributesOutput)

func (*MockSQSAPI) GetQueueAttributesWithContext

func (_m *MockSQSAPI) GetQueueAttributesWithContext(_param0 aws.Context, _param1 *sqs.GetQueueAttributesInput, _param2 ...request.Option) (*sqs.GetQueueAttributesOutput, error)

func (*MockSQSAPI) GetQueueUrl

func (_m *MockSQSAPI) GetQueueUrl(_param0 *sqs.GetQueueUrlInput) (*sqs.GetQueueUrlOutput, error)

func (*MockSQSAPI) GetQueueUrlRequest

func (_m *MockSQSAPI) GetQueueUrlRequest(_param0 *sqs.GetQueueUrlInput) (*request.Request, *sqs.GetQueueUrlOutput)

func (*MockSQSAPI) GetQueueUrlWithContext

func (_m *MockSQSAPI) GetQueueUrlWithContext(_param0 aws.Context, _param1 *sqs.GetQueueUrlInput, _param2 ...request.Option) (*sqs.GetQueueUrlOutput, error)

func (*MockSQSAPI) ListDeadLetterSourceQueues

func (_m *MockSQSAPI) ListDeadLetterSourceQueues(_param0 *sqs.ListDeadLetterSourceQueuesInput) (*sqs.ListDeadLetterSourceQueuesOutput, error)

func (*MockSQSAPI) ListDeadLetterSourceQueuesRequest

func (_m *MockSQSAPI) ListDeadLetterSourceQueuesRequest(_param0 *sqs.ListDeadLetterSourceQueuesInput) (*request.Request, *sqs.ListDeadLetterSourceQueuesOutput)

func (*MockSQSAPI) ListDeadLetterSourceQueuesWithContext

func (_m *MockSQSAPI) ListDeadLetterSourceQueuesWithContext(_param0 aws.Context, _param1 *sqs.ListDeadLetterSourceQueuesInput, _param2 ...request.Option) (*sqs.ListDeadLetterSourceQueuesOutput, error)

func (*MockSQSAPI) ListQueues

func (_m *MockSQSAPI) ListQueues(_param0 *sqs.ListQueuesInput) (*sqs.ListQueuesOutput, error)

func (*MockSQSAPI) ListQueuesRequest

func (_m *MockSQSAPI) ListQueuesRequest(_param0 *sqs.ListQueuesInput) (*request.Request, *sqs.ListQueuesOutput)

func (*MockSQSAPI) ListQueuesWithContext

func (_m *MockSQSAPI) ListQueuesWithContext(_param0 aws.Context, _param1 *sqs.ListQueuesInput, _param2 ...request.Option) (*sqs.ListQueuesOutput, error)

func (*MockSQSAPI) PurgeQueue

func (_m *MockSQSAPI) PurgeQueue(_param0 *sqs.PurgeQueueInput) (*sqs.PurgeQueueOutput, error)

func (*MockSQSAPI) PurgeQueueRequest

func (_m *MockSQSAPI) PurgeQueueRequest(_param0 *sqs.PurgeQueueInput) (*request.Request, *sqs.PurgeQueueOutput)

func (*MockSQSAPI) PurgeQueueWithContext

func (_m *MockSQSAPI) PurgeQueueWithContext(_param0 aws.Context, _param1 *sqs.PurgeQueueInput, _param2 ...request.Option) (*sqs.PurgeQueueOutput, error)

func (*MockSQSAPI) ReceiveMessage

func (_m *MockSQSAPI) ReceiveMessage(_param0 *sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error)

func (*MockSQSAPI) ReceiveMessageRequest

func (_m *MockSQSAPI) ReceiveMessageRequest(_param0 *sqs.ReceiveMessageInput) (*request.Request, *sqs.ReceiveMessageOutput)

func (*MockSQSAPI) ReceiveMessageWithContext

func (_m *MockSQSAPI) ReceiveMessageWithContext(_param0 aws.Context, _param1 *sqs.ReceiveMessageInput, _param2 ...request.Option) (*sqs.ReceiveMessageOutput, error)

func (*MockSQSAPI) RemovePermission

func (_m *MockSQSAPI) RemovePermission(_param0 *sqs.RemovePermissionInput) (*sqs.RemovePermissionOutput, error)

func (*MockSQSAPI) RemovePermissionRequest

func (_m *MockSQSAPI) RemovePermissionRequest(_param0 *sqs.RemovePermissionInput) (*request.Request, *sqs.RemovePermissionOutput)

func (*MockSQSAPI) RemovePermissionWithContext

func (_m *MockSQSAPI) RemovePermissionWithContext(_param0 aws.Context, _param1 *sqs.RemovePermissionInput, _param2 ...request.Option) (*sqs.RemovePermissionOutput, error)

func (*MockSQSAPI) SendMessage

func (_m *MockSQSAPI) SendMessage(_param0 *sqs.SendMessageInput) (*sqs.SendMessageOutput, error)

func (*MockSQSAPI) SendMessageBatch

func (_m *MockSQSAPI) SendMessageBatch(_param0 *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)

func (*MockSQSAPI) SendMessageBatchRequest

func (_m *MockSQSAPI) SendMessageBatchRequest(_param0 *sqs.SendMessageBatchInput) (*request.Request, *sqs.SendMessageBatchOutput)

func (*MockSQSAPI) SendMessageBatchWithContext

func (_m *MockSQSAPI) SendMessageBatchWithContext(_param0 aws.Context, _param1 *sqs.SendMessageBatchInput, _param2 ...request.Option) (*sqs.SendMessageBatchOutput, error)

func (*MockSQSAPI) SendMessageRequest

func (_m *MockSQSAPI) SendMessageRequest(_param0 *sqs.SendMessageInput) (*request.Request, *sqs.SendMessageOutput)

func (*MockSQSAPI) SendMessageWithContext

func (_m *MockSQSAPI) SendMessageWithContext(_param0 aws.Context, _param1 *sqs.SendMessageInput, _param2 ...request.Option) (*sqs.SendMessageOutput, error)

func (*MockSQSAPI) SetQueueAttributes

func (_m *MockSQSAPI) SetQueueAttributes(_param0 *sqs.SetQueueAttributesInput) (*sqs.SetQueueAttributesOutput, error)

func (*MockSQSAPI) SetQueueAttributesRequest

func (_m *MockSQSAPI) SetQueueAttributesRequest(_param0 *sqs.SetQueueAttributesInput) (*request.Request, *sqs.SetQueueAttributesOutput)

func (*MockSQSAPI) SetQueueAttributesWithContext

func (_m *MockSQSAPI) SetQueueAttributesWithContext(_param0 aws.Context, _param1 *sqs.SetQueueAttributesInput, _param2 ...request.Option) (*sqs.SetQueueAttributesOutput, error)

type MockTaskLoader

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

Mock of TaskLoader interface

func NewMockTaskLoader

func NewMockTaskLoader(ctrl *gomock.Controller) *MockTaskLoader

func (*MockTaskLoader) EXPECT

func (_m *MockTaskLoader) EXPECT() *_MockTaskLoaderRecorder

func (*MockTaskLoader) LoadTasks

func (_m *MockTaskLoader) LoadTasks() error

type MockTaskStore

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

Mock of TaskStore interface

func NewMockTaskStore

func NewMockTaskStore(ctrl *gomock.Controller) *MockTaskStore

func (*MockTaskStore) AddTask

func (_m *MockTaskStore) AddTask(task string) error

func (*MockTaskStore) DeleteTask

func (_m *MockTaskStore) DeleteTask(cluster string, taskARN string) error

func (*MockTaskStore) EXPECT

func (_m *MockTaskStore) EXPECT() *_MockTaskStoreRecorder

func (*MockTaskStore) FilterTasks

func (_m *MockTaskStore) FilterTasks(filterMap map[string]string) ([]types.VersionedTask, error)

func (*MockTaskStore) GetTask

func (_m *MockTaskStore) GetTask(cluster string, taskARN string) (*types.VersionedTask, error)

func (*MockTaskStore) ListTasks

func (_m *MockTaskStore) ListTasks() ([]types.VersionedTask, error)

func (*MockTaskStore) StreamTasks

func (_m *MockTaskStore) StreamTasks(ctx context.Context, entityVersion string) (chan types.VersionedTask, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL