Documentation ¶
Index ¶
- type BatchServiceClient
- func (_m *BatchServiceClient) DescribeJobsWithContext(ctx context.Context, input *batch.DescribeJobsInput, opts ...request.Option) (*batch.DescribeJobsOutput, error)
- func (_m *BatchServiceClient) OnDescribeJobsWithContext(ctx context.Context, input *batch.DescribeJobsInput, opts ...request.Option) *BatchServiceClient_DescribeJobsWithContext
- func (_m *BatchServiceClient) OnDescribeJobsWithContextMatch(matchers ...interface{}) *BatchServiceClient_DescribeJobsWithContext
- func (_m *BatchServiceClient) OnRegisterJobDefinitionWithContext(ctx context.Context, input *batch.RegisterJobDefinitionInput, ...) *BatchServiceClient_RegisterJobDefinitionWithContext
- func (_m *BatchServiceClient) OnRegisterJobDefinitionWithContextMatch(matchers ...interface{}) *BatchServiceClient_RegisterJobDefinitionWithContext
- func (_m *BatchServiceClient) OnSubmitJobWithContext(ctx context.Context, input *batch.SubmitJobInput, opts ...request.Option) *BatchServiceClient_SubmitJobWithContext
- func (_m *BatchServiceClient) OnSubmitJobWithContextMatch(matchers ...interface{}) *BatchServiceClient_SubmitJobWithContext
- func (_m *BatchServiceClient) OnTerminateJobWithContext(ctx context.Context, input *batch.TerminateJobInput, opts ...request.Option) *BatchServiceClient_TerminateJobWithContext
- func (_m *BatchServiceClient) OnTerminateJobWithContextMatch(matchers ...interface{}) *BatchServiceClient_TerminateJobWithContext
- func (_m *BatchServiceClient) RegisterJobDefinitionWithContext(ctx context.Context, input *batch.RegisterJobDefinitionInput, ...) (*batch.RegisterJobDefinitionOutput, error)
- func (_m *BatchServiceClient) SubmitJobWithContext(ctx context.Context, input *batch.SubmitJobInput, opts ...request.Option) (*batch.SubmitJobOutput, error)
- func (_m *BatchServiceClient) TerminateJobWithContext(ctx context.Context, input *batch.TerminateJobInput, opts ...request.Option) (*batch.TerminateJobOutput, error)
- type BatchServiceClient_DescribeJobsWithContext
- type BatchServiceClient_RegisterJobDefinitionWithContext
- type BatchServiceClient_SubmitJobWithContext
- type BatchServiceClient_TerminateJobWithContext
- type Cache
- func (_m *Cache) Get(key definition.CacheKey) (string, bool)
- func (_m *Cache) OnGet(key definition.CacheKey) *Cache_Get
- func (_m *Cache) OnGetMatch(matchers ...interface{}) *Cache_Get
- func (_m *Cache) OnPut(key definition.CacheKey, _a1 string) *Cache_Put
- func (_m *Cache) OnPutMatch(matchers ...interface{}) *Cache_Put
- func (_m *Cache) Put(key definition.CacheKey, _a1 string) error
- type CacheKey
- type CacheKey_String
- type Cache_Get
- type Cache_Put
- type Client
- func (_m *Client) GetAccountID() string
- func (_m *Client) GetJobDetailsBatch(ctx context.Context, ids []string) ([]*batch.JobDetail, error)
- func (_m *Client) GetRegion() string
- func (_m *Client) OnGetAccountID() *Client_GetAccountID
- func (_m *Client) OnGetAccountIDMatch(matchers ...interface{}) *Client_GetAccountID
- func (_m *Client) OnGetJobDetailsBatch(ctx context.Context, ids []string) *Client_GetJobDetailsBatch
- func (_m *Client) OnGetJobDetailsBatchMatch(matchers ...interface{}) *Client_GetJobDetailsBatch
- func (_m *Client) OnGetRegion() *Client_GetRegion
- func (_m *Client) OnGetRegionMatch(matchers ...interface{}) *Client_GetRegion
- func (_m *Client) OnRegisterJobDefinition(ctx context.Context, name string, image string, role string) *Client_RegisterJobDefinition
- func (_m *Client) OnRegisterJobDefinitionMatch(matchers ...interface{}) *Client_RegisterJobDefinition
- func (_m *Client) OnSubmitJob(ctx context.Context, input *batch.SubmitJobInput) *Client_SubmitJob
- func (_m *Client) OnSubmitJobMatch(matchers ...interface{}) *Client_SubmitJob
- func (_m *Client) OnTerminateJob(ctx context.Context, jobID string, reason string) *Client_TerminateJob
- func (_m *Client) OnTerminateJobMatch(matchers ...interface{}) *Client_TerminateJob
- func (_m *Client) RegisterJobDefinition(ctx context.Context, name string, image string, role string) (string, error)
- func (_m *Client) SubmitJob(ctx context.Context, input *batch.SubmitJobInput) (string, error)
- func (_m *Client) TerminateJob(ctx context.Context, jobID string, reason string) error
- type Client_GetAccountID
- type Client_GetJobDetailsBatch
- type Client_GetRegion
- type Client_RegisterJobDefinition
- type Client_SubmitJob
- type Client_TerminateJob
- type MockAwsBatchClient
- func (m *MockAwsBatchClient) DescribeJobsWithContext(ctx aws.Context, input *batch.DescribeJobsInput, opts ...request.Option) (*batch.DescribeJobsOutput, error)
- func (m *MockAwsBatchClient) RegisterJobDefinitionWithContext(ctx aws.Context, input *batch.RegisterJobDefinitionInput, ...) (*batch.RegisterJobDefinitionOutput, error)
- func (m *MockAwsBatchClient) SubmitJobWithContext(ctx aws.Context, input *batch.SubmitJobInput, opts ...request.Option) (*batch.SubmitJobOutput, error)
- func (m *MockAwsBatchClient) TerminateJobWithContext(ctx aws.Context, input *batch.TerminateJobInput, opts ...request.Option) (*batch.TerminateJobOutput, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BatchServiceClient ¶
BatchServiceClient is an autogenerated mock type for the BatchServiceClient type
func (*BatchServiceClient) DescribeJobsWithContext ¶
func (_m *BatchServiceClient) DescribeJobsWithContext(ctx context.Context, input *batch.DescribeJobsInput, opts ...request.Option) (*batch.DescribeJobsOutput, error)
DescribeJobsWithContext provides a mock function with given fields: ctx, input, opts
func (*BatchServiceClient) OnDescribeJobsWithContext ¶
func (_m *BatchServiceClient) OnDescribeJobsWithContext(ctx context.Context, input *batch.DescribeJobsInput, opts ...request.Option) *BatchServiceClient_DescribeJobsWithContext
func (*BatchServiceClient) OnDescribeJobsWithContextMatch ¶
func (_m *BatchServiceClient) OnDescribeJobsWithContextMatch(matchers ...interface{}) *BatchServiceClient_DescribeJobsWithContext
func (*BatchServiceClient) OnRegisterJobDefinitionWithContext ¶
func (_m *BatchServiceClient) OnRegisterJobDefinitionWithContext(ctx context.Context, input *batch.RegisterJobDefinitionInput, opts ...request.Option) *BatchServiceClient_RegisterJobDefinitionWithContext
func (*BatchServiceClient) OnRegisterJobDefinitionWithContextMatch ¶
func (_m *BatchServiceClient) OnRegisterJobDefinitionWithContextMatch(matchers ...interface{}) *BatchServiceClient_RegisterJobDefinitionWithContext
func (*BatchServiceClient) OnSubmitJobWithContext ¶
func (_m *BatchServiceClient) OnSubmitJobWithContext(ctx context.Context, input *batch.SubmitJobInput, opts ...request.Option) *BatchServiceClient_SubmitJobWithContext
func (*BatchServiceClient) OnSubmitJobWithContextMatch ¶
func (_m *BatchServiceClient) OnSubmitJobWithContextMatch(matchers ...interface{}) *BatchServiceClient_SubmitJobWithContext
func (*BatchServiceClient) OnTerminateJobWithContext ¶
func (_m *BatchServiceClient) OnTerminateJobWithContext(ctx context.Context, input *batch.TerminateJobInput, opts ...request.Option) *BatchServiceClient_TerminateJobWithContext
func (*BatchServiceClient) OnTerminateJobWithContextMatch ¶
func (_m *BatchServiceClient) OnTerminateJobWithContextMatch(matchers ...interface{}) *BatchServiceClient_TerminateJobWithContext
func (*BatchServiceClient) RegisterJobDefinitionWithContext ¶
func (_m *BatchServiceClient) RegisterJobDefinitionWithContext(ctx context.Context, input *batch.RegisterJobDefinitionInput, opts ...request.Option) (*batch.RegisterJobDefinitionOutput, error)
RegisterJobDefinitionWithContext provides a mock function with given fields: ctx, input, opts
func (*BatchServiceClient) SubmitJobWithContext ¶
func (_m *BatchServiceClient) SubmitJobWithContext(ctx context.Context, input *batch.SubmitJobInput, opts ...request.Option) (*batch.SubmitJobOutput, error)
SubmitJobWithContext provides a mock function with given fields: ctx, input, opts
func (*BatchServiceClient) TerminateJobWithContext ¶
func (_m *BatchServiceClient) TerminateJobWithContext(ctx context.Context, input *batch.TerminateJobInput, opts ...request.Option) (*batch.TerminateJobOutput, error)
TerminateJobWithContext provides a mock function with given fields: ctx, input, opts
type BatchServiceClient_DescribeJobsWithContext ¶
func (BatchServiceClient_DescribeJobsWithContext) Return ¶
func (_m BatchServiceClient_DescribeJobsWithContext) Return(_a0 *batch.DescribeJobsOutput, _a1 error) *BatchServiceClient_DescribeJobsWithContext
type BatchServiceClient_RegisterJobDefinitionWithContext ¶
type BatchServiceClient_SubmitJobWithContext ¶
func (BatchServiceClient_SubmitJobWithContext) Return ¶
func (_m BatchServiceClient_SubmitJobWithContext) Return(_a0 *batch.SubmitJobOutput, _a1 error) *BatchServiceClient_SubmitJobWithContext
type BatchServiceClient_TerminateJobWithContext ¶
func (BatchServiceClient_TerminateJobWithContext) Return ¶
func (_m BatchServiceClient_TerminateJobWithContext) Return(_a0 *batch.TerminateJobOutput, _a1 error) *BatchServiceClient_TerminateJobWithContext
type Cache ¶
Cache is an autogenerated mock type for the Cache type
func (*Cache) Get ¶
func (_m *Cache) Get(key definition.CacheKey) (string, bool)
Get provides a mock function with given fields: key
func (*Cache) OnGetMatch ¶
func (*Cache) OnPutMatch ¶
type CacheKey ¶
CacheKey is an autogenerated mock type for the CacheKey type
func (*CacheKey) OnString ¶
func (_m *CacheKey) OnString() *CacheKey_String
func (*CacheKey) OnStringMatch ¶
func (_m *CacheKey) OnStringMatch(matchers ...interface{}) *CacheKey_String
type CacheKey_String ¶
func (CacheKey_String) Return ¶
func (_m CacheKey_String) Return(_a0 string) *CacheKey_String
type Client ¶
Client is an autogenerated mock type for the Client type
func (*Client) GetAccountID ¶
GetAccountID provides a mock function with given fields:
func (*Client) GetJobDetailsBatch ¶
GetJobDetailsBatch provides a mock function with given fields: ctx, ids
func (*Client) OnGetAccountID ¶
func (_m *Client) OnGetAccountID() *Client_GetAccountID
func (*Client) OnGetAccountIDMatch ¶
func (_m *Client) OnGetAccountIDMatch(matchers ...interface{}) *Client_GetAccountID
func (*Client) OnGetJobDetailsBatch ¶
func (_m *Client) OnGetJobDetailsBatch(ctx context.Context, ids []string) *Client_GetJobDetailsBatch
func (*Client) OnGetJobDetailsBatchMatch ¶
func (_m *Client) OnGetJobDetailsBatchMatch(matchers ...interface{}) *Client_GetJobDetailsBatch
func (*Client) OnGetRegion ¶
func (_m *Client) OnGetRegion() *Client_GetRegion
func (*Client) OnGetRegionMatch ¶
func (_m *Client) OnGetRegionMatch(matchers ...interface{}) *Client_GetRegion
func (*Client) OnRegisterJobDefinition ¶
func (*Client) OnRegisterJobDefinitionMatch ¶
func (_m *Client) OnRegisterJobDefinitionMatch(matchers ...interface{}) *Client_RegisterJobDefinition
func (*Client) OnSubmitJob ¶
func (_m *Client) OnSubmitJob(ctx context.Context, input *batch.SubmitJobInput) *Client_SubmitJob
func (*Client) OnSubmitJobMatch ¶
func (_m *Client) OnSubmitJobMatch(matchers ...interface{}) *Client_SubmitJob
func (*Client) OnTerminateJob ¶
func (*Client) OnTerminateJobMatch ¶
func (_m *Client) OnTerminateJobMatch(matchers ...interface{}) *Client_TerminateJob
func (*Client) RegisterJobDefinition ¶
func (_m *Client) RegisterJobDefinition(ctx context.Context, name string, image string, role string) (string, error)
RegisterJobDefinition provides a mock function with given fields: ctx, name, image, role
type Client_GetAccountID ¶
func (Client_GetAccountID) Return ¶
func (_m Client_GetAccountID) Return(_a0 string) *Client_GetAccountID
type Client_GetJobDetailsBatch ¶
func (Client_GetJobDetailsBatch) Return ¶
func (_m Client_GetJobDetailsBatch) Return(_a0 []*batch.JobDetail, _a1 error) *Client_GetJobDetailsBatch
type Client_GetRegion ¶
func (Client_GetRegion) Return ¶
func (_m Client_GetRegion) Return(_a0 string) *Client_GetRegion
type Client_RegisterJobDefinition ¶
func (Client_RegisterJobDefinition) Return ¶
func (_m Client_RegisterJobDefinition) Return(arn string, err error) *Client_RegisterJobDefinition
type Client_SubmitJob ¶
func (Client_SubmitJob) Return ¶
func (_m Client_SubmitJob) Return(jobID string, err error) *Client_SubmitJob
type Client_TerminateJob ¶
func (Client_TerminateJob) Return ¶
func (_m Client_TerminateJob) Return(_a0 error) *Client_TerminateJob
type MockAwsBatchClient ¶
type MockAwsBatchClient struct { SubmitJobWithContextCb func(ctx context.Context, input *batch.SubmitJobInput, opts ...request.Option) (*batch.SubmitJobOutput, error) TerminateJobWithContextCb func(ctx context.Context, input *batch.TerminateJobInput, opts ...request.Option) (*batch.TerminateJobOutput, error) DescribeJobsWithContextCb func(ctx context.Context, input *batch.DescribeJobsInput, opts ...request.Option) (*batch.DescribeJobsOutput, error) RegisterJobDefinitionWithContextCb func(ctx context.Context, input *batch.RegisterJobDefinitionInput, opts ...request.Option) (*batch.RegisterJobDefinitionOutput, error) // contains filtered or unexported fields }
func NewMockAwsBatchClient ¶
func NewMockAwsBatchClient() *MockAwsBatchClient
Creates a new client with overridable behavior for certain APIs. The default implementation will progress submitted jobs until completion every time GetJobDetails is called.
func (*MockAwsBatchClient) DescribeJobsWithContext ¶
func (m *MockAwsBatchClient) DescribeJobsWithContext(ctx aws.Context, input *batch.DescribeJobsInput, opts ...request.Option) (*batch.DescribeJobsOutput, error)
func (*MockAwsBatchClient) RegisterJobDefinitionWithContext ¶
func (m *MockAwsBatchClient) RegisterJobDefinitionWithContext(ctx aws.Context, input *batch.RegisterJobDefinitionInput, opts ...request.Option) (*batch.RegisterJobDefinitionOutput, error)
func (*MockAwsBatchClient) SubmitJobWithContext ¶
func (m *MockAwsBatchClient) SubmitJobWithContext(ctx aws.Context, input *batch.SubmitJobInput, opts ...request.Option) ( *batch.SubmitJobOutput, error)
func (*MockAwsBatchClient) TerminateJobWithContext ¶
func (m *MockAwsBatchClient) TerminateJobWithContext(ctx aws.Context, input *batch.TerminateJobInput, opts ...request.Option) (*batch.TerminateJobOutput, error)