Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + type BatchServiceClient struct + 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 struct + func (_m BatchServiceClient_DescribeJobsWithContext) Return(_a0 *batch.DescribeJobsOutput, _a1 error) *BatchServiceClient_DescribeJobsWithContext + type BatchServiceClient_RegisterJobDefinitionWithContext struct + func (_m BatchServiceClient_RegisterJobDefinitionWithContext) Return(_a0 *batch.RegisterJobDefinitionOutput, _a1 error) *BatchServiceClient_RegisterJobDefinitionWithContext + type BatchServiceClient_SubmitJobWithContext struct + func (_m BatchServiceClient_SubmitJobWithContext) Return(_a0 *batch.SubmitJobOutput, _a1 error) *BatchServiceClient_SubmitJobWithContext + type BatchServiceClient_TerminateJobWithContext struct + func (_m BatchServiceClient_TerminateJobWithContext) Return(_a0 *batch.TerminateJobOutput, _a1 error) *BatchServiceClient_TerminateJobWithContext + type Cache struct + 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 struct + func (_m *CacheKey) OnString() *CacheKey_String + func (_m *CacheKey) OnStringMatch(matchers ...interface{}) *CacheKey_String + func (_m *CacheKey) String() string + type CacheKey_String struct + func (_m CacheKey_String) Return(_a0 string) *CacheKey_String + type Cache_Get struct + func (_m Cache_Get) Return(jobDefinition string, found bool) *Cache_Get + type Cache_Put struct + func (_m Cache_Put) Return(_a0 error) *Cache_Put + type Client struct + 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 struct + func (_m Client_GetAccountID) Return(_a0 string) *Client_GetAccountID + type Client_GetJobDetailsBatch struct + func (_m Client_GetJobDetailsBatch) Return(_a0 []*batch.JobDetail, _a1 error) *Client_GetJobDetailsBatch + type Client_GetRegion struct + func (_m Client_GetRegion) Return(_a0 string) *Client_GetRegion + type Client_RegisterJobDefinition struct + func (_m Client_RegisterJobDefinition) Return(arn string, err error) *Client_RegisterJobDefinition + type Client_SubmitJob struct + func (_m Client_SubmitJob) Return(jobID string, err error) *Client_SubmitJob + type Client_TerminateJob struct + func (_m Client_TerminateJob) Return(_a0 error) *Client_TerminateJob + type MockAwsBatchClient struct + DescribeJobsWithContextCb func(ctx context.Context, input *batch.DescribeJobsInput, opts ...request.Option) (*batch.DescribeJobsOutput, error) + RegisterJobDefinitionWithContextCb func(ctx context.Context, input *batch.RegisterJobDefinitionInput, ...) (*batch.RegisterJobDefinitionOutput, error) + 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) + func NewMockAwsBatchClient() *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)