mocks

package
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 (_m *MockKinesisAPI) AddTagsToStream(_param0 *kinesis.AddTagsToStreamInput) (*kinesis.AddTagsToStreamOutput, error)

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 (_m *MockKinesisAPI) CreateStream(_param0 *kinesis.CreateStreamInput) (*kinesis.CreateStreamOutput, error)

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

func (_m *MockKinesisAPI) DecreaseStreamRetentionPeriod(_param0 *kinesis.DecreaseStreamRetentionPeriodInput) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)

func (*MockKinesisAPI) DecreaseStreamRetentionPeriodRequest 

func (_m *MockKinesisAPI) DecreaseStreamRetentionPeriodRequest(_param0 *kinesis.DecreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.DecreaseStreamRetentionPeriodOutput)

func (*MockKinesisAPI) DecreaseStreamRetentionPeriodWithContext 

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

func (*MockKinesisAPI) DeleteStream 

func (_m *MockKinesisAPI) DeleteStream(_param0 *kinesis.DeleteStreamInput) (*kinesis.DeleteStreamOutput, error)

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 (_m *MockKinesisAPI) DescribeLimits(_param0 *kinesis.DescribeLimitsInput) (*kinesis.DescribeLimitsOutput, error)

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 (_m *MockKinesisAPI) DescribeStream(_param0 *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)

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 (_m *MockKinesisAPI) EnableEnhancedMonitoring(_param0 *kinesis.EnableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)

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 (_m *MockKinesisAPI) GetShardIterator(_param0 *kinesis.GetShardIteratorInput) (*kinesis.GetShardIteratorOutput, error)

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

func (_m *MockKinesisAPI) IncreaseStreamRetentionPeriod(_param0 *kinesis.IncreaseStreamRetentionPeriodInput) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)

func (*MockKinesisAPI) IncreaseStreamRetentionPeriodRequest 

func (_m *MockKinesisAPI) IncreaseStreamRetentionPeriodRequest(_param0 *kinesis.IncreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.IncreaseStreamRetentionPeriodOutput)

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 (_m *MockKinesisAPI) ListTagsForStream(_param0 *kinesis.ListTagsForStreamInput) (*kinesis.ListTagsForStreamOutput, error)

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 (_m *MockKinesisAPI) RemoveTagsFromStream(_param0 *kinesis.RemoveTagsFromStreamInput) (*kinesis.RemoveTagsFromStreamOutput, error)

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 (_m *MockKinesisAPI) StartStreamEncryption(_param0 *kinesis.StartStreamEncryptionInput) (*kinesis.StartStreamEncryptionOutput, error)

func (*MockKinesisAPI) StartStreamEncryptionRequest 

func (_m *MockKinesisAPI) StartStreamEncryptionRequest(_param0 *kinesis.StartStreamEncryptionInput) (*request.Request, *kinesis.StartStreamEncryptionOutput)

func (*MockKinesisAPI) StartStreamEncryptionWithContext 

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

func (*MockKinesisAPI) StopStreamEncryption 

func (_m *MockKinesisAPI) StopStreamEncryption(_param0 *kinesis.StopStreamEncryptionInput) (*kinesis.StopStreamEncryptionOutput, error)

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 (_m *MockKinesisAPI) UpdateShardCount(_param0 *kinesis.UpdateShardCountInput) (*kinesis.UpdateShardCountOutput, error)

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)

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.