Documentation ¶
Index ¶
- type MockContainerInstanceLoader
- type MockContainerInstanceStore
- func (_m *MockContainerInstanceStore) AddContainerInstance(instance string) error
- func (_m *MockContainerInstanceStore) DeleteContainerInstance(cluster string, instanceARN string) error
- func (_m *MockContainerInstanceStore) EXPECT() *_MockContainerInstanceStoreRecorder
- func (_m *MockContainerInstanceStore) FilterContainerInstances(filterMap map[string]string) ([]types.VersionedContainerInstance, error)
- func (_m *MockContainerInstanceStore) GetContainerInstance(cluster string, instanceARN string) (*types.VersionedContainerInstance, error)
- func (_m *MockContainerInstanceStore) ListContainerInstances() ([]types.VersionedContainerInstance, error)
- func (_m *MockContainerInstanceStore) StreamContainerInstances(ctx context.Context, entityVersion string) (chan types.VersionedContainerInstance, error)
- type MockDataStore
- func (_m *MockDataStore) Add(_param0 string, _param1 string) error
- func (_m *MockDataStore) Delete(_param0 string) (int64, error)
- func (_m *MockDataStore) EXPECT() *_MockDataStoreRecorder
- func (_m *MockDataStore) Get(_param0 string) (map[string]types.Entity, error)
- func (_m *MockDataStore) GetV3Client() *clientv3.Client
- func (_m *MockDataStore) GetWithPrefix(_param0 string) (map[string]types.Entity, error)
- func (_m *MockDataStore) NewSTMRepeatable(_param0 context.Context, _param1 *clientv3.Client, ...) (*clientv3.TxnResponse, error)
- func (_m *MockDataStore) StreamWithPrefix(_param0 context.Context, _param1 string, _param2 string) (chan map[string]types.Entity, error)
- type MockECSAPI
- func (_m *MockECSAPI) CreateCluster(_param0 *ecs.CreateClusterInput) (*ecs.CreateClusterOutput, error)
- func (_m *MockECSAPI) CreateClusterRequest(_param0 *ecs.CreateClusterInput) (*request.Request, *ecs.CreateClusterOutput)
- func (_m *MockECSAPI) CreateService(_param0 *ecs.CreateServiceInput) (*ecs.CreateServiceOutput, error)
- func (_m *MockECSAPI) CreateServiceRequest(_param0 *ecs.CreateServiceInput) (*request.Request, *ecs.CreateServiceOutput)
- func (_m *MockECSAPI) DeleteAttributes(_param0 *ecs.DeleteAttributesInput) (*ecs.DeleteAttributesOutput, error)
- func (_m *MockECSAPI) DeleteAttributesRequest(_param0 *ecs.DeleteAttributesInput) (*request.Request, *ecs.DeleteAttributesOutput)
- func (_m *MockECSAPI) DeleteCluster(_param0 *ecs.DeleteClusterInput) (*ecs.DeleteClusterOutput, error)
- func (_m *MockECSAPI) DeleteClusterRequest(_param0 *ecs.DeleteClusterInput) (*request.Request, *ecs.DeleteClusterOutput)
- func (_m *MockECSAPI) DeleteService(_param0 *ecs.DeleteServiceInput) (*ecs.DeleteServiceOutput, error)
- func (_m *MockECSAPI) DeleteServiceRequest(_param0 *ecs.DeleteServiceInput) (*request.Request, *ecs.DeleteServiceOutput)
- func (_m *MockECSAPI) DeregisterContainerInstance(_param0 *ecs.DeregisterContainerInstanceInput) (*ecs.DeregisterContainerInstanceOutput, error)
- func (_m *MockECSAPI) DeregisterContainerInstanceRequest(_param0 *ecs.DeregisterContainerInstanceInput) (*request.Request, *ecs.DeregisterContainerInstanceOutput)
- func (_m *MockECSAPI) DeregisterTaskDefinition(_param0 *ecs.DeregisterTaskDefinitionInput) (*ecs.DeregisterTaskDefinitionOutput, error)
- func (_m *MockECSAPI) DeregisterTaskDefinitionRequest(_param0 *ecs.DeregisterTaskDefinitionInput) (*request.Request, *ecs.DeregisterTaskDefinitionOutput)
- func (_m *MockECSAPI) DescribeClusters(_param0 *ecs.DescribeClustersInput) (*ecs.DescribeClustersOutput, error)
- func (_m *MockECSAPI) DescribeClustersRequest(_param0 *ecs.DescribeClustersInput) (*request.Request, *ecs.DescribeClustersOutput)
- func (_m *MockECSAPI) DescribeContainerInstances(_param0 *ecs.DescribeContainerInstancesInput) (*ecs.DescribeContainerInstancesOutput, error)
- func (_m *MockECSAPI) DescribeContainerInstancesRequest(_param0 *ecs.DescribeContainerInstancesInput) (*request.Request, *ecs.DescribeContainerInstancesOutput)
- func (_m *MockECSAPI) DescribeServices(_param0 *ecs.DescribeServicesInput) (*ecs.DescribeServicesOutput, error)
- func (_m *MockECSAPI) DescribeServicesRequest(_param0 *ecs.DescribeServicesInput) (*request.Request, *ecs.DescribeServicesOutput)
- func (_m *MockECSAPI) DescribeTaskDefinition(_param0 *ecs.DescribeTaskDefinitionInput) (*ecs.DescribeTaskDefinitionOutput, error)
- func (_m *MockECSAPI) DescribeTaskDefinitionRequest(_param0 *ecs.DescribeTaskDefinitionInput) (*request.Request, *ecs.DescribeTaskDefinitionOutput)
- func (_m *MockECSAPI) DescribeTasks(_param0 *ecs.DescribeTasksInput) (*ecs.DescribeTasksOutput, error)
- func (_m *MockECSAPI) DescribeTasksRequest(_param0 *ecs.DescribeTasksInput) (*request.Request, *ecs.DescribeTasksOutput)
- func (_m *MockECSAPI) DiscoverPollEndpoint(_param0 *ecs.DiscoverPollEndpointInput) (*ecs.DiscoverPollEndpointOutput, error)
- func (_m *MockECSAPI) DiscoverPollEndpointRequest(_param0 *ecs.DiscoverPollEndpointInput) (*request.Request, *ecs.DiscoverPollEndpointOutput)
- func (_m *MockECSAPI) EXPECT() *_MockECSAPIRecorder
- func (_m *MockECSAPI) ListAttributes(_param0 *ecs.ListAttributesInput) (*ecs.ListAttributesOutput, error)
- func (_m *MockECSAPI) ListAttributesRequest(_param0 *ecs.ListAttributesInput) (*request.Request, *ecs.ListAttributesOutput)
- func (_m *MockECSAPI) ListClusters(_param0 *ecs.ListClustersInput) (*ecs.ListClustersOutput, error)
- func (_m *MockECSAPI) ListClustersPages(_param0 *ecs.ListClustersInput, ...) error
- func (_m *MockECSAPI) ListClustersRequest(_param0 *ecs.ListClustersInput) (*request.Request, *ecs.ListClustersOutput)
- func (_m *MockECSAPI) ListContainerInstances(_param0 *ecs.ListContainerInstancesInput) (*ecs.ListContainerInstancesOutput, error)
- func (_m *MockECSAPI) ListContainerInstancesPages(_param0 *ecs.ListContainerInstancesInput, ...) error
- func (_m *MockECSAPI) ListContainerInstancesRequest(_param0 *ecs.ListContainerInstancesInput) (*request.Request, *ecs.ListContainerInstancesOutput)
- func (_m *MockECSAPI) ListServices(_param0 *ecs.ListServicesInput) (*ecs.ListServicesOutput, error)
- func (_m *MockECSAPI) ListServicesPages(_param0 *ecs.ListServicesInput, ...) error
- func (_m *MockECSAPI) ListServicesRequest(_param0 *ecs.ListServicesInput) (*request.Request, *ecs.ListServicesOutput)
- func (_m *MockECSAPI) ListTaskDefinitionFamilies(_param0 *ecs.ListTaskDefinitionFamiliesInput) (*ecs.ListTaskDefinitionFamiliesOutput, error)
- func (_m *MockECSAPI) ListTaskDefinitionFamiliesPages(_param0 *ecs.ListTaskDefinitionFamiliesInput, ...) error
- func (_m *MockECSAPI) ListTaskDefinitionFamiliesRequest(_param0 *ecs.ListTaskDefinitionFamiliesInput) (*request.Request, *ecs.ListTaskDefinitionFamiliesOutput)
- func (_m *MockECSAPI) ListTaskDefinitions(_param0 *ecs.ListTaskDefinitionsInput) (*ecs.ListTaskDefinitionsOutput, error)
- func (_m *MockECSAPI) ListTaskDefinitionsPages(_param0 *ecs.ListTaskDefinitionsInput, ...) error
- func (_m *MockECSAPI) ListTaskDefinitionsRequest(_param0 *ecs.ListTaskDefinitionsInput) (*request.Request, *ecs.ListTaskDefinitionsOutput)
- func (_m *MockECSAPI) ListTasks(_param0 *ecs.ListTasksInput) (*ecs.ListTasksOutput, error)
- func (_m *MockECSAPI) ListTasksPages(_param0 *ecs.ListTasksInput, _param1 func(*ecs.ListTasksOutput, bool) bool) error
- func (_m *MockECSAPI) ListTasksRequest(_param0 *ecs.ListTasksInput) (*request.Request, *ecs.ListTasksOutput)
- func (_m *MockECSAPI) PutAttributes(_param0 *ecs.PutAttributesInput) (*ecs.PutAttributesOutput, error)
- func (_m *MockECSAPI) PutAttributesRequest(_param0 *ecs.PutAttributesInput) (*request.Request, *ecs.PutAttributesOutput)
- func (_m *MockECSAPI) RegisterContainerInstance(_param0 *ecs.RegisterContainerInstanceInput) (*ecs.RegisterContainerInstanceOutput, error)
- func (_m *MockECSAPI) RegisterContainerInstanceRequest(_param0 *ecs.RegisterContainerInstanceInput) (*request.Request, *ecs.RegisterContainerInstanceOutput)
- func (_m *MockECSAPI) RegisterTaskDefinition(_param0 *ecs.RegisterTaskDefinitionInput) (*ecs.RegisterTaskDefinitionOutput, error)
- func (_m *MockECSAPI) RegisterTaskDefinitionRequest(_param0 *ecs.RegisterTaskDefinitionInput) (*request.Request, *ecs.RegisterTaskDefinitionOutput)
- func (_m *MockECSAPI) RunTask(_param0 *ecs.RunTaskInput) (*ecs.RunTaskOutput, error)
- func (_m *MockECSAPI) RunTaskRequest(_param0 *ecs.RunTaskInput) (*request.Request, *ecs.RunTaskOutput)
- func (_m *MockECSAPI) StartTask(_param0 *ecs.StartTaskInput) (*ecs.StartTaskOutput, error)
- func (_m *MockECSAPI) StartTaskRequest(_param0 *ecs.StartTaskInput) (*request.Request, *ecs.StartTaskOutput)
- func (_m *MockECSAPI) StopTask(_param0 *ecs.StopTaskInput) (*ecs.StopTaskOutput, error)
- func (_m *MockECSAPI) StopTaskRequest(_param0 *ecs.StopTaskInput) (*request.Request, *ecs.StopTaskOutput)
- func (_m *MockECSAPI) SubmitContainerStateChange(_param0 *ecs.SubmitContainerStateChangeInput) (*ecs.SubmitContainerStateChangeOutput, error)
- func (_m *MockECSAPI) SubmitContainerStateChangeRequest(_param0 *ecs.SubmitContainerStateChangeInput) (*request.Request, *ecs.SubmitContainerStateChangeOutput)
- func (_m *MockECSAPI) SubmitTaskStateChange(_param0 *ecs.SubmitTaskStateChangeInput) (*ecs.SubmitTaskStateChangeOutput, error)
- func (_m *MockECSAPI) SubmitTaskStateChangeRequest(_param0 *ecs.SubmitTaskStateChangeInput) (*request.Request, *ecs.SubmitTaskStateChangeOutput)
- func (_m *MockECSAPI) UpdateContainerAgent(_param0 *ecs.UpdateContainerAgentInput) (*ecs.UpdateContainerAgentOutput, error)
- func (_m *MockECSAPI) UpdateContainerAgentRequest(_param0 *ecs.UpdateContainerAgentInput) (*request.Request, *ecs.UpdateContainerAgentOutput)
- func (_m *MockECSAPI) UpdateContainerInstancesState(_param0 *ecs.UpdateContainerInstancesStateInput) (*ecs.UpdateContainerInstancesStateOutput, error)
- func (_m *MockECSAPI) UpdateContainerInstancesStateRequest(_param0 *ecs.UpdateContainerInstancesStateInput) (*request.Request, *ecs.UpdateContainerInstancesStateOutput)
- func (_m *MockECSAPI) UpdateService(_param0 *ecs.UpdateServiceInput) (*ecs.UpdateServiceOutput, error)
- func (_m *MockECSAPI) UpdateServiceRequest(_param0 *ecs.UpdateServiceInput) (*request.Request, *ecs.UpdateServiceOutput)
- func (_m *MockECSAPI) WaitUntilServicesInactive(_param0 *ecs.DescribeServicesInput) error
- func (_m *MockECSAPI) WaitUntilServicesStable(_param0 *ecs.DescribeServicesInput) error
- func (_m *MockECSAPI) WaitUntilTasksRunning(_param0 *ecs.DescribeTasksInput) error
- func (_m *MockECSAPI) WaitUntilTasksStopped(_param0 *ecs.DescribeTasksInput) error
- type MockECSWrapper
- func (_m *MockECSWrapper) DescribeContainerInstances(_param0 *string, _param1 []*string) ([]types.ContainerInstance, []string, error)
- func (_m *MockECSWrapper) DescribeTasks(_param0 *string, _param1 []*string) ([]types.Task, []string, error)
- func (_m *MockECSWrapper) EXPECT() *_MockECSWrapperRecorder
- func (_m *MockECSWrapper) ListAllClusters() ([]*string, error)
- func (_m *MockECSWrapper) ListAllContainerInstances(_param0 *string) ([]*string, error)
- func (_m *MockECSWrapper) ListTasksWithDesiredStatus(_param0 *string, _param1 *string) ([]*string, error)
- type MockEtcdInterface
- func (_m *MockEtcdInterface) Close() error
- func (_m *MockEtcdInterface) Delete(_param0 context.Context, _param1 string, _param2 ...clientv3.OpOption) (*clientv3.DeleteResponse, error)
- func (_m *MockEtcdInterface) EXPECT() *_MockEtcdInterfaceRecorder
- func (_m *MockEtcdInterface) Get(_param0 context.Context, _param1 string, _param2 ...clientv3.OpOption) (*clientv3.GetResponse, error)
- func (_m *MockEtcdInterface) Put(_param0 context.Context, _param1 string, _param2 string, ...) (*clientv3.PutResponse, error)
- func (_m *MockEtcdInterface) Watch(_param0 context.Context, _param1 string, _param2 ...clientv3.OpOption) clientv3.WatchChan
- type MockEtcdTXStore
- type MockKinesisAPI
- func (_m *MockKinesisAPI) AddTagsToStream(_param0 *kinesis.AddTagsToStreamInput) (*kinesis.AddTagsToStreamOutput, error)
- func (_m *MockKinesisAPI) AddTagsToStreamRequest(_param0 *kinesis.AddTagsToStreamInput) (*request.Request, *kinesis.AddTagsToStreamOutput)
- func (_m *MockKinesisAPI) CreateStream(_param0 *kinesis.CreateStreamInput) (*kinesis.CreateStreamOutput, error)
- func (_m *MockKinesisAPI) CreateStreamRequest(_param0 *kinesis.CreateStreamInput) (*request.Request, *kinesis.CreateStreamOutput)
- func (_m *MockKinesisAPI) DecreaseStreamRetentionPeriod(_param0 *kinesis.DecreaseStreamRetentionPeriodInput) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)
- func (_m *MockKinesisAPI) DecreaseStreamRetentionPeriodRequest(_param0 *kinesis.DecreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.DecreaseStreamRetentionPeriodOutput)
- func (_m *MockKinesisAPI) DeleteStream(_param0 *kinesis.DeleteStreamInput) (*kinesis.DeleteStreamOutput, error)
- func (_m *MockKinesisAPI) DeleteStreamRequest(_param0 *kinesis.DeleteStreamInput) (*request.Request, *kinesis.DeleteStreamOutput)
- func (_m *MockKinesisAPI) DescribeLimits(_param0 *kinesis.DescribeLimitsInput) (*kinesis.DescribeLimitsOutput, error)
- func (_m *MockKinesisAPI) DescribeLimitsRequest(_param0 *kinesis.DescribeLimitsInput) (*request.Request, *kinesis.DescribeLimitsOutput)
- func (_m *MockKinesisAPI) DescribeStream(_param0 *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)
- func (_m *MockKinesisAPI) DescribeStreamPages(_param0 *kinesis.DescribeStreamInput, ...) error
- func (_m *MockKinesisAPI) DescribeStreamRequest(_param0 *kinesis.DescribeStreamInput) (*request.Request, *kinesis.DescribeStreamOutput)
- func (_m *MockKinesisAPI) DisableEnhancedMonitoring(_param0 *kinesis.DisableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)
- func (_m *MockKinesisAPI) DisableEnhancedMonitoringRequest(_param0 *kinesis.DisableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)
- func (_m *MockKinesisAPI) EXPECT() *_MockKinesisAPIRecorder
- func (_m *MockKinesisAPI) EnableEnhancedMonitoring(_param0 *kinesis.EnableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)
- func (_m *MockKinesisAPI) EnableEnhancedMonitoringRequest(_param0 *kinesis.EnableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)
- func (_m *MockKinesisAPI) GetRecords(_param0 *kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error)
- func (_m *MockKinesisAPI) GetRecordsRequest(_param0 *kinesis.GetRecordsInput) (*request.Request, *kinesis.GetRecordsOutput)
- func (_m *MockKinesisAPI) GetShardIterator(_param0 *kinesis.GetShardIteratorInput) (*kinesis.GetShardIteratorOutput, error)
- func (_m *MockKinesisAPI) GetShardIteratorRequest(_param0 *kinesis.GetShardIteratorInput) (*request.Request, *kinesis.GetShardIteratorOutput)
- func (_m *MockKinesisAPI) IncreaseStreamRetentionPeriod(_param0 *kinesis.IncreaseStreamRetentionPeriodInput) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)
- func (_m *MockKinesisAPI) IncreaseStreamRetentionPeriodRequest(_param0 *kinesis.IncreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.IncreaseStreamRetentionPeriodOutput)
- func (_m *MockKinesisAPI) ListStreams(_param0 *kinesis.ListStreamsInput) (*kinesis.ListStreamsOutput, error)
- func (_m *MockKinesisAPI) ListStreamsPages(_param0 *kinesis.ListStreamsInput, ...) error
- func (_m *MockKinesisAPI) ListStreamsRequest(_param0 *kinesis.ListStreamsInput) (*request.Request, *kinesis.ListStreamsOutput)
- func (_m *MockKinesisAPI) ListTagsForStream(_param0 *kinesis.ListTagsForStreamInput) (*kinesis.ListTagsForStreamOutput, error)
- func (_m *MockKinesisAPI) ListTagsForStreamRequest(_param0 *kinesis.ListTagsForStreamInput) (*request.Request, *kinesis.ListTagsForStreamOutput)
- func (_m *MockKinesisAPI) MergeShards(_param0 *kinesis.MergeShardsInput) (*kinesis.MergeShardsOutput, error)
- func (_m *MockKinesisAPI) MergeShardsRequest(_param0 *kinesis.MergeShardsInput) (*request.Request, *kinesis.MergeShardsOutput)
- func (_m *MockKinesisAPI) PutRecord(_param0 *kinesis.PutRecordInput) (*kinesis.PutRecordOutput, error)
- func (_m *MockKinesisAPI) PutRecordRequest(_param0 *kinesis.PutRecordInput) (*request.Request, *kinesis.PutRecordOutput)
- func (_m *MockKinesisAPI) PutRecords(_param0 *kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error)
- func (_m *MockKinesisAPI) PutRecordsRequest(_param0 *kinesis.PutRecordsInput) (*request.Request, *kinesis.PutRecordsOutput)
- func (_m *MockKinesisAPI) RemoveTagsFromStream(_param0 *kinesis.RemoveTagsFromStreamInput) (*kinesis.RemoveTagsFromStreamOutput, error)
- func (_m *MockKinesisAPI) RemoveTagsFromStreamRequest(_param0 *kinesis.RemoveTagsFromStreamInput) (*request.Request, *kinesis.RemoveTagsFromStreamOutput)
- func (_m *MockKinesisAPI) SplitShard(_param0 *kinesis.SplitShardInput) (*kinesis.SplitShardOutput, error)
- func (_m *MockKinesisAPI) SplitShardRequest(_param0 *kinesis.SplitShardInput) (*request.Request, *kinesis.SplitShardOutput)
- func (_m *MockKinesisAPI) UpdateShardCount(_param0 *kinesis.UpdateShardCountInput) (*kinesis.UpdateShardCountOutput, error)
- func (_m *MockKinesisAPI) UpdateShardCountRequest(_param0 *kinesis.UpdateShardCountInput) (*request.Request, *kinesis.UpdateShardCountOutput)
- func (_m *MockKinesisAPI) WaitUntilStreamExists(_param0 *kinesis.DescribeStreamInput) error
- type MockProcessor
- type MockRoundTripper
- type MockSQSAPI
- func (_m *MockSQSAPI) AddPermission(_param0 *sqs.AddPermissionInput) (*sqs.AddPermissionOutput, error)
- func (_m *MockSQSAPI) AddPermissionRequest(_param0 *sqs.AddPermissionInput) (*request.Request, *sqs.AddPermissionOutput)
- func (_m *MockSQSAPI) ChangeMessageVisibility(_param0 *sqs.ChangeMessageVisibilityInput) (*sqs.ChangeMessageVisibilityOutput, error)
- func (_m *MockSQSAPI) ChangeMessageVisibilityBatch(_param0 *sqs.ChangeMessageVisibilityBatchInput) (*sqs.ChangeMessageVisibilityBatchOutput, error)
- func (_m *MockSQSAPI) ChangeMessageVisibilityBatchRequest(_param0 *sqs.ChangeMessageVisibilityBatchInput) (*request.Request, *sqs.ChangeMessageVisibilityBatchOutput)
- func (_m *MockSQSAPI) ChangeMessageVisibilityRequest(_param0 *sqs.ChangeMessageVisibilityInput) (*request.Request, *sqs.ChangeMessageVisibilityOutput)
- func (_m *MockSQSAPI) CreateQueue(_param0 *sqs.CreateQueueInput) (*sqs.CreateQueueOutput, error)
- func (_m *MockSQSAPI) CreateQueueRequest(_param0 *sqs.CreateQueueInput) (*request.Request, *sqs.CreateQueueOutput)
- func (_m *MockSQSAPI) DeleteMessage(_param0 *sqs.DeleteMessageInput) (*sqs.DeleteMessageOutput, error)
- func (_m *MockSQSAPI) DeleteMessageBatch(_param0 *sqs.DeleteMessageBatchInput) (*sqs.DeleteMessageBatchOutput, error)
- func (_m *MockSQSAPI) DeleteMessageBatchRequest(_param0 *sqs.DeleteMessageBatchInput) (*request.Request, *sqs.DeleteMessageBatchOutput)
- func (_m *MockSQSAPI) DeleteMessageRequest(_param0 *sqs.DeleteMessageInput) (*request.Request, *sqs.DeleteMessageOutput)
- func (_m *MockSQSAPI) DeleteQueue(_param0 *sqs.DeleteQueueInput) (*sqs.DeleteQueueOutput, error)
- func (_m *MockSQSAPI) DeleteQueueRequest(_param0 *sqs.DeleteQueueInput) (*request.Request, *sqs.DeleteQueueOutput)
- func (_m *MockSQSAPI) EXPECT() *_MockSQSAPIRecorder
- func (_m *MockSQSAPI) GetQueueAttributes(_param0 *sqs.GetQueueAttributesInput) (*sqs.GetQueueAttributesOutput, error)
- func (_m *MockSQSAPI) GetQueueAttributesRequest(_param0 *sqs.GetQueueAttributesInput) (*request.Request, *sqs.GetQueueAttributesOutput)
- func (_m *MockSQSAPI) GetQueueUrl(_param0 *sqs.GetQueueUrlInput) (*sqs.GetQueueUrlOutput, error)
- func (_m *MockSQSAPI) GetQueueUrlRequest(_param0 *sqs.GetQueueUrlInput) (*request.Request, *sqs.GetQueueUrlOutput)
- func (_m *MockSQSAPI) ListDeadLetterSourceQueues(_param0 *sqs.ListDeadLetterSourceQueuesInput) (*sqs.ListDeadLetterSourceQueuesOutput, error)
- func (_m *MockSQSAPI) ListDeadLetterSourceQueuesRequest(_param0 *sqs.ListDeadLetterSourceQueuesInput) (*request.Request, *sqs.ListDeadLetterSourceQueuesOutput)
- func (_m *MockSQSAPI) ListQueues(_param0 *sqs.ListQueuesInput) (*sqs.ListQueuesOutput, error)
- func (_m *MockSQSAPI) ListQueuesRequest(_param0 *sqs.ListQueuesInput) (*request.Request, *sqs.ListQueuesOutput)
- func (_m *MockSQSAPI) PurgeQueue(_param0 *sqs.PurgeQueueInput) (*sqs.PurgeQueueOutput, error)
- func (_m *MockSQSAPI) PurgeQueueRequest(_param0 *sqs.PurgeQueueInput) (*request.Request, *sqs.PurgeQueueOutput)
- func (_m *MockSQSAPI) ReceiveMessage(_param0 *sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error)
- func (_m *MockSQSAPI) ReceiveMessageRequest(_param0 *sqs.ReceiveMessageInput) (*request.Request, *sqs.ReceiveMessageOutput)
- func (_m *MockSQSAPI) RemovePermission(_param0 *sqs.RemovePermissionInput) (*sqs.RemovePermissionOutput, error)
- func (_m *MockSQSAPI) RemovePermissionRequest(_param0 *sqs.RemovePermissionInput) (*request.Request, *sqs.RemovePermissionOutput)
- func (_m *MockSQSAPI) SendMessage(_param0 *sqs.SendMessageInput) (*sqs.SendMessageOutput, error)
- func (_m *MockSQSAPI) SendMessageBatch(_param0 *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)
- func (_m *MockSQSAPI) SendMessageBatchRequest(_param0 *sqs.SendMessageBatchInput) (*request.Request, *sqs.SendMessageBatchOutput)
- func (_m *MockSQSAPI) SendMessageRequest(_param0 *sqs.SendMessageInput) (*request.Request, *sqs.SendMessageOutput)
- func (_m *MockSQSAPI) SetQueueAttributes(_param0 *sqs.SetQueueAttributesInput) (*sqs.SetQueueAttributesOutput, error)
- func (_m *MockSQSAPI) SetQueueAttributesRequest(_param0 *sqs.SetQueueAttributesInput) (*request.Request, *sqs.SetQueueAttributesOutput)
- type MockTaskLoader
- type MockTaskStore
- func (_m *MockTaskStore) AddTask(task string) error
- func (_m *MockTaskStore) DeleteTask(cluster string, taskARN string) error
- func (_m *MockTaskStore) EXPECT() *_MockTaskStoreRecorder
- func (_m *MockTaskStore) FilterTasks(filterMap map[string]string) ([]types.VersionedTask, error)
- func (_m *MockTaskStore) GetTask(cluster string, taskARN string) (*types.VersionedTask, error)
- func (_m *MockTaskStore) ListTasks() ([]types.VersionedTask, error)
- func (_m *MockTaskStore) StreamTasks(ctx context.Context, entityVersion string) (chan types.VersionedTask, error)
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) EXPECT ¶
func (_m *MockDataStore) EXPECT() *_MockDataStoreRecorder
func (*MockDataStore) GetV3Client ¶
func (_m *MockDataStore) GetV3Client() *clientv3.Client
func (*MockDataStore) GetWithPrefix ¶
func (*MockDataStore) NewSTMRepeatable ¶
func (_m *MockDataStore) NewSTMRepeatable(_param0 context.Context, _param1 *clientv3.Client, _param2 func(concurrency.STM) error) (*clientv3.TxnResponse, 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) 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) DeleteAttributes ¶ added in v0.2.1
func (_m *MockECSAPI) DeleteAttributes(_param0 *ecs.DeleteAttributesInput) (*ecs.DeleteAttributesOutput, error)
func (*MockECSAPI) DeleteAttributesRequest ¶ added in v0.2.1
func (_m *MockECSAPI) DeleteAttributesRequest(_param0 *ecs.DeleteAttributesInput) (*request.Request, *ecs.DeleteAttributesOutput)
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) 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) 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) 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) 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) 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) 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) 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) 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) 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) EXPECT ¶
func (_m *MockECSAPI) EXPECT() *_MockECSAPIRecorder
func (*MockECSAPI) ListAttributes ¶ added in v0.2.1
func (_m *MockECSAPI) ListAttributes(_param0 *ecs.ListAttributesInput) (*ecs.ListAttributesOutput, error)
func (*MockECSAPI) ListAttributesRequest ¶ added in v0.2.1
func (_m *MockECSAPI) ListAttributesRequest(_param0 *ecs.ListAttributesInput) (*request.Request, *ecs.ListAttributesOutput)
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) ListClustersRequest ¶
func (_m *MockECSAPI) ListClustersRequest(_param0 *ecs.ListClustersInput) (*request.Request, *ecs.ListClustersOutput)
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) ListContainerInstancesRequest ¶
func (_m *MockECSAPI) ListContainerInstancesRequest(_param0 *ecs.ListContainerInstancesInput) (*request.Request, *ecs.ListContainerInstancesOutput)
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) ListServicesRequest ¶
func (_m *MockECSAPI) ListServicesRequest(_param0 *ecs.ListServicesInput) (*request.Request, *ecs.ListServicesOutput)
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) ListTaskDefinitionFamiliesRequest ¶
func (_m *MockECSAPI) ListTaskDefinitionFamiliesRequest(_param0 *ecs.ListTaskDefinitionFamiliesInput) (*request.Request, *ecs.ListTaskDefinitionFamiliesOutput)
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) ListTaskDefinitionsRequest ¶
func (_m *MockECSAPI) ListTaskDefinitionsRequest(_param0 *ecs.ListTaskDefinitionsInput) (*request.Request, *ecs.ListTaskDefinitionsOutput)
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) ListTasksRequest ¶
func (_m *MockECSAPI) ListTasksRequest(_param0 *ecs.ListTasksInput) (*request.Request, *ecs.ListTasksOutput)
func (*MockECSAPI) PutAttributes ¶ added in v0.2.1
func (_m *MockECSAPI) PutAttributes(_param0 *ecs.PutAttributesInput) (*ecs.PutAttributesOutput, error)
func (*MockECSAPI) PutAttributesRequest ¶ added in v0.2.1
func (_m *MockECSAPI) PutAttributesRequest(_param0 *ecs.PutAttributesInput) (*request.Request, *ecs.PutAttributesOutput)
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) 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) 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) 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) 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) 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) 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) 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) UpdateContainerInstancesState ¶ added in v0.2.1
func (_m *MockECSAPI) UpdateContainerInstancesState(_param0 *ecs.UpdateContainerInstancesStateInput) (*ecs.UpdateContainerInstancesStateOutput, error)
func (*MockECSAPI) UpdateContainerInstancesStateRequest ¶ added in v0.2.1
func (_m *MockECSAPI) UpdateContainerInstancesStateRequest(_param0 *ecs.UpdateContainerInstancesStateInput) (*request.Request, *ecs.UpdateContainerInstancesStateOutput)
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) WaitUntilServicesInactive ¶
func (_m *MockECSAPI) WaitUntilServicesInactive(_param0 *ecs.DescribeServicesInput) error
func (*MockECSAPI) WaitUntilServicesStable ¶
func (_m *MockECSAPI) WaitUntilServicesStable(_param0 *ecs.DescribeServicesInput) error
func (*MockECSAPI) WaitUntilTasksRunning ¶
func (_m *MockECSAPI) WaitUntilTasksRunning(_param0 *ecs.DescribeTasksInput) error
func (*MockECSAPI) WaitUntilTasksStopped ¶
func (_m *MockECSAPI) WaitUntilTasksStopped(_param0 *ecs.DescribeTasksInput) 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 (*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 ¶ added in v0.2.1
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)
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 ¶ added in v0.2.0
type MockKinesisAPI struct {
// contains filtered or unexported fields
}
Mock of KinesisAPI interface
func NewMockKinesisAPI ¶ added in v0.2.0
func NewMockKinesisAPI(ctrl *gomock.Controller) *MockKinesisAPI
func (*MockKinesisAPI) AddTagsToStream ¶ added in v0.2.0
func (_m *MockKinesisAPI) AddTagsToStream(_param0 *kinesis.AddTagsToStreamInput) (*kinesis.AddTagsToStreamOutput, error)
func (*MockKinesisAPI) AddTagsToStreamRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) AddTagsToStreamRequest(_param0 *kinesis.AddTagsToStreamInput) (*request.Request, *kinesis.AddTagsToStreamOutput)
func (*MockKinesisAPI) CreateStream ¶ added in v0.2.0
func (_m *MockKinesisAPI) CreateStream(_param0 *kinesis.CreateStreamInput) (*kinesis.CreateStreamOutput, error)
func (*MockKinesisAPI) CreateStreamRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) CreateStreamRequest(_param0 *kinesis.CreateStreamInput) (*request.Request, *kinesis.CreateStreamOutput)
func (*MockKinesisAPI) DecreaseStreamRetentionPeriod ¶ added in v0.2.0
func (_m *MockKinesisAPI) DecreaseStreamRetentionPeriod(_param0 *kinesis.DecreaseStreamRetentionPeriodInput) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)
func (*MockKinesisAPI) DecreaseStreamRetentionPeriodRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) DecreaseStreamRetentionPeriodRequest(_param0 *kinesis.DecreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.DecreaseStreamRetentionPeriodOutput)
func (*MockKinesisAPI) DeleteStream ¶ added in v0.2.0
func (_m *MockKinesisAPI) DeleteStream(_param0 *kinesis.DeleteStreamInput) (*kinesis.DeleteStreamOutput, error)
func (*MockKinesisAPI) DeleteStreamRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) DeleteStreamRequest(_param0 *kinesis.DeleteStreamInput) (*request.Request, *kinesis.DeleteStreamOutput)
func (*MockKinesisAPI) DescribeLimits ¶ added in v0.2.1
func (_m *MockKinesisAPI) DescribeLimits(_param0 *kinesis.DescribeLimitsInput) (*kinesis.DescribeLimitsOutput, error)
func (*MockKinesisAPI) DescribeLimitsRequest ¶ added in v0.2.1
func (_m *MockKinesisAPI) DescribeLimitsRequest(_param0 *kinesis.DescribeLimitsInput) (*request.Request, *kinesis.DescribeLimitsOutput)
func (*MockKinesisAPI) DescribeStream ¶ added in v0.2.0
func (_m *MockKinesisAPI) DescribeStream(_param0 *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)
func (*MockKinesisAPI) DescribeStreamPages ¶ added in v0.2.0
func (_m *MockKinesisAPI) DescribeStreamPages(_param0 *kinesis.DescribeStreamInput, _param1 func(*kinesis.DescribeStreamOutput, bool) bool) error
func (*MockKinesisAPI) DescribeStreamRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) DescribeStreamRequest(_param0 *kinesis.DescribeStreamInput) (*request.Request, *kinesis.DescribeStreamOutput)
func (*MockKinesisAPI) DisableEnhancedMonitoring ¶ added in v0.2.0
func (_m *MockKinesisAPI) DisableEnhancedMonitoring(_param0 *kinesis.DisableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)
func (*MockKinesisAPI) DisableEnhancedMonitoringRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) DisableEnhancedMonitoringRequest(_param0 *kinesis.DisableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)
func (*MockKinesisAPI) EXPECT ¶ added in v0.2.0
func (_m *MockKinesisAPI) EXPECT() *_MockKinesisAPIRecorder
func (*MockKinesisAPI) EnableEnhancedMonitoring ¶ added in v0.2.0
func (_m *MockKinesisAPI) EnableEnhancedMonitoring(_param0 *kinesis.EnableEnhancedMonitoringInput) (*kinesis.EnhancedMonitoringOutput, error)
func (*MockKinesisAPI) EnableEnhancedMonitoringRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) EnableEnhancedMonitoringRequest(_param0 *kinesis.EnableEnhancedMonitoringInput) (*request.Request, *kinesis.EnhancedMonitoringOutput)
func (*MockKinesisAPI) GetRecords ¶ added in v0.2.0
func (_m *MockKinesisAPI) GetRecords(_param0 *kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error)
func (*MockKinesisAPI) GetRecordsRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) GetRecordsRequest(_param0 *kinesis.GetRecordsInput) (*request.Request, *kinesis.GetRecordsOutput)
func (*MockKinesisAPI) GetShardIterator ¶ added in v0.2.0
func (_m *MockKinesisAPI) GetShardIterator(_param0 *kinesis.GetShardIteratorInput) (*kinesis.GetShardIteratorOutput, error)
func (*MockKinesisAPI) GetShardIteratorRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) GetShardIteratorRequest(_param0 *kinesis.GetShardIteratorInput) (*request.Request, *kinesis.GetShardIteratorOutput)
func (*MockKinesisAPI) IncreaseStreamRetentionPeriod ¶ added in v0.2.0
func (_m *MockKinesisAPI) IncreaseStreamRetentionPeriod(_param0 *kinesis.IncreaseStreamRetentionPeriodInput) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)
func (*MockKinesisAPI) IncreaseStreamRetentionPeriodRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) IncreaseStreamRetentionPeriodRequest(_param0 *kinesis.IncreaseStreamRetentionPeriodInput) (*request.Request, *kinesis.IncreaseStreamRetentionPeriodOutput)
func (*MockKinesisAPI) ListStreams ¶ added in v0.2.0
func (_m *MockKinesisAPI) ListStreams(_param0 *kinesis.ListStreamsInput) (*kinesis.ListStreamsOutput, error)
func (*MockKinesisAPI) ListStreamsPages ¶ added in v0.2.0
func (_m *MockKinesisAPI) ListStreamsPages(_param0 *kinesis.ListStreamsInput, _param1 func(*kinesis.ListStreamsOutput, bool) bool) error
func (*MockKinesisAPI) ListStreamsRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) ListStreamsRequest(_param0 *kinesis.ListStreamsInput) (*request.Request, *kinesis.ListStreamsOutput)
func (*MockKinesisAPI) ListTagsForStream ¶ added in v0.2.0
func (_m *MockKinesisAPI) ListTagsForStream(_param0 *kinesis.ListTagsForStreamInput) (*kinesis.ListTagsForStreamOutput, error)
func (*MockKinesisAPI) ListTagsForStreamRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) ListTagsForStreamRequest(_param0 *kinesis.ListTagsForStreamInput) (*request.Request, *kinesis.ListTagsForStreamOutput)
func (*MockKinesisAPI) MergeShards ¶ added in v0.2.0
func (_m *MockKinesisAPI) MergeShards(_param0 *kinesis.MergeShardsInput) (*kinesis.MergeShardsOutput, error)
func (*MockKinesisAPI) MergeShardsRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) MergeShardsRequest(_param0 *kinesis.MergeShardsInput) (*request.Request, *kinesis.MergeShardsOutput)
func (*MockKinesisAPI) PutRecord ¶ added in v0.2.0
func (_m *MockKinesisAPI) PutRecord(_param0 *kinesis.PutRecordInput) (*kinesis.PutRecordOutput, error)
func (*MockKinesisAPI) PutRecordRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) PutRecordRequest(_param0 *kinesis.PutRecordInput) (*request.Request, *kinesis.PutRecordOutput)
func (*MockKinesisAPI) PutRecords ¶ added in v0.2.0
func (_m *MockKinesisAPI) PutRecords(_param0 *kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error)
func (*MockKinesisAPI) PutRecordsRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) PutRecordsRequest(_param0 *kinesis.PutRecordsInput) (*request.Request, *kinesis.PutRecordsOutput)
func (*MockKinesisAPI) RemoveTagsFromStream ¶ added in v0.2.0
func (_m *MockKinesisAPI) RemoveTagsFromStream(_param0 *kinesis.RemoveTagsFromStreamInput) (*kinesis.RemoveTagsFromStreamOutput, error)
func (*MockKinesisAPI) RemoveTagsFromStreamRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) RemoveTagsFromStreamRequest(_param0 *kinesis.RemoveTagsFromStreamInput) (*request.Request, *kinesis.RemoveTagsFromStreamOutput)
func (*MockKinesisAPI) SplitShard ¶ added in v0.2.0
func (_m *MockKinesisAPI) SplitShard(_param0 *kinesis.SplitShardInput) (*kinesis.SplitShardOutput, error)
func (*MockKinesisAPI) SplitShardRequest ¶ added in v0.2.0
func (_m *MockKinesisAPI) SplitShardRequest(_param0 *kinesis.SplitShardInput) (*request.Request, *kinesis.SplitShardOutput)
func (*MockKinesisAPI) UpdateShardCount ¶ added in v0.2.1
func (_m *MockKinesisAPI) UpdateShardCount(_param0 *kinesis.UpdateShardCountInput) (*kinesis.UpdateShardCountOutput, error)
func (*MockKinesisAPI) UpdateShardCountRequest ¶ added in v0.2.1
func (_m *MockKinesisAPI) UpdateShardCountRequest(_param0 *kinesis.UpdateShardCountInput) (*request.Request, *kinesis.UpdateShardCountOutput)
func (*MockKinesisAPI) WaitUntilStreamExists ¶ added in v0.2.0
func (_m *MockKinesisAPI) WaitUntilStreamExists(_param0 *kinesis.DescribeStreamInput) 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
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) 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) ChangeMessageVisibilityRequest ¶
func (_m *MockSQSAPI) ChangeMessageVisibilityRequest(_param0 *sqs.ChangeMessageVisibilityInput) (*request.Request, *sqs.ChangeMessageVisibilityOutput)
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) 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) DeleteMessageRequest ¶
func (_m *MockSQSAPI) DeleteMessageRequest(_param0 *sqs.DeleteMessageInput) (*request.Request, *sqs.DeleteMessageOutput)
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) 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) 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) 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) 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) 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) 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) 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) 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) SendMessageRequest ¶
func (_m *MockSQSAPI) SendMessageRequest(_param0 *sqs.SendMessageInput) (*request.Request, *sqs.SendMessageOutput)
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)
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)
Click to show internal directories.
Click to hide internal directories.