mocks

Mar 28, 2025

Changes in this version

type BatchServiceClient

+ func NewBatchServiceClient(t interface{ ... }) *BatchServiceClient

+ func (_m *BatchServiceClient) EXPECT() *BatchServiceClient_Expecter

+ type BatchServiceClient_DescribeJobsWithContext_Call struct

+ func (_c *BatchServiceClient_DescribeJobsWithContext_Call) Return(_a0 *batch.DescribeJobsOutput, _a1 error) *BatchServiceClient_DescribeJobsWithContext_Call

+ func (_c *BatchServiceClient_DescribeJobsWithContext_Call) Run(...) *BatchServiceClient_DescribeJobsWithContext_Call

+ func (_c *BatchServiceClient_DescribeJobsWithContext_Call) RunAndReturn(...) *BatchServiceClient_DescribeJobsWithContext_Call

+ type BatchServiceClient_Expecter struct

+ func (_e *BatchServiceClient_Expecter) DescribeJobsWithContext(ctx interface{}, input interface{}, opts ...interface{}) *BatchServiceClient_DescribeJobsWithContext_Call

+ func (_e *BatchServiceClient_Expecter) RegisterJobDefinitionWithContext(ctx interface{}, input interface{}, opts ...interface{}) *BatchServiceClient_RegisterJobDefinitionWithContext_Call

+ func (_e *BatchServiceClient_Expecter) SubmitJobWithContext(ctx interface{}, input interface{}, opts ...interface{}) *BatchServiceClient_SubmitJobWithContext_Call

+ func (_e *BatchServiceClient_Expecter) TerminateJobWithContext(ctx interface{}, input interface{}, opts ...interface{}) *BatchServiceClient_TerminateJobWithContext_Call

+ type BatchServiceClient_RegisterJobDefinitionWithContext_Call struct

+ func (_c *BatchServiceClient_RegisterJobDefinitionWithContext_Call) Return(_a0 *batch.RegisterJobDefinitionOutput, _a1 error) *BatchServiceClient_RegisterJobDefinitionWithContext_Call

+ func (_c *BatchServiceClient_RegisterJobDefinitionWithContext_Call) Run(run func(ctx context.Context, input *batch.RegisterJobDefinitionInput, ...)) *BatchServiceClient_RegisterJobDefinitionWithContext_Call

+ func (_c *BatchServiceClient_RegisterJobDefinitionWithContext_Call) RunAndReturn(...) *BatchServiceClient_RegisterJobDefinitionWithContext_Call

+ type BatchServiceClient_SubmitJobWithContext_Call struct

+ func (_c *BatchServiceClient_SubmitJobWithContext_Call) Return(_a0 *batch.SubmitJobOutput, _a1 error) *BatchServiceClient_SubmitJobWithContext_Call

+ func (_c *BatchServiceClient_SubmitJobWithContext_Call) Run(...) *BatchServiceClient_SubmitJobWithContext_Call

+ func (_c *BatchServiceClient_SubmitJobWithContext_Call) RunAndReturn(...) *BatchServiceClient_SubmitJobWithContext_Call

+ type BatchServiceClient_TerminateJobWithContext_Call struct

+ func (_c *BatchServiceClient_TerminateJobWithContext_Call) Return(_a0 *batch.TerminateJobOutput, _a1 error) *BatchServiceClient_TerminateJobWithContext_Call

+ func (_c *BatchServiceClient_TerminateJobWithContext_Call) Run(...) *BatchServiceClient_TerminateJobWithContext_Call

+ func (_c *BatchServiceClient_TerminateJobWithContext_Call) RunAndReturn(...) *BatchServiceClient_TerminateJobWithContext_Call

type Cache

+ func NewCache(t interface{ ... }) *Cache

+ func (_m *Cache) EXPECT() *Cache_Expecter

type CacheKey

+ func NewCacheKey(t interface{ ... }) *CacheKey

+ func (_m *CacheKey) EXPECT() *CacheKey_Expecter

+ type CacheKey_Expecter struct

+ func (_e *CacheKey_Expecter) String() *CacheKey_String_Call

+ type CacheKey_String_Call struct

+ func (_c *CacheKey_String_Call) Return(_a0 string) *CacheKey_String_Call

+ func (_c *CacheKey_String_Call) Run(run func()) *CacheKey_String_Call

+ func (_c *CacheKey_String_Call) RunAndReturn(run func() string) *CacheKey_String_Call

+ type Cache_Expecter struct

+ func (_e *Cache_Expecter) Get(key interface{}) *Cache_Get_Call

+ func (_e *Cache_Expecter) Put(key interface{}, _a1 interface{}) *Cache_Put_Call

+ type Cache_Get_Call struct

+ func (_c *Cache_Get_Call) Return(jobDefinition string, found bool) *Cache_Get_Call

+ func (_c *Cache_Get_Call) Run(run func(key definition.CacheKey)) *Cache_Get_Call

+ func (_c *Cache_Get_Call) RunAndReturn(run func(definition.CacheKey) (string, bool)) *Cache_Get_Call

+ type Cache_Put_Call struct

+ func (_c *Cache_Put_Call) Return(_a0 error) *Cache_Put_Call

+ func (_c *Cache_Put_Call) Run(run func(key definition.CacheKey, _a1 string)) *Cache_Put_Call

+ func (_c *Cache_Put_Call) RunAndReturn(run func(definition.CacheKey, string) error) *Cache_Put_Call

type Client

+ func NewClient(t interface{ ... }) *Client

+ func (_m *Client) EXPECT() *Client_Expecter

+ type Client_Expecter struct

+ func (_e *Client_Expecter) GetAccountID() *Client_GetAccountID_Call

+ func (_e *Client_Expecter) GetJobDetailsBatch(ctx interface{}, ids interface{}) *Client_GetJobDetailsBatch_Call

+ func (_e *Client_Expecter) GetRegion() *Client_GetRegion_Call

+ func (_e *Client_Expecter) RegisterJobDefinition(ctx interface{}, name interface{}, image interface{}, role interface{}, ...) *Client_RegisterJobDefinition_Call

+ func (_e *Client_Expecter) SubmitJob(ctx interface{}, input interface{}) *Client_SubmitJob_Call

+ func (_e *Client_Expecter) TerminateJob(ctx interface{}, jobID interface{}, reason interface{}) *Client_TerminateJob_Call

+ type Client_GetAccountID_Call struct

+ func (_c *Client_GetAccountID_Call) Return(_a0 string) *Client_GetAccountID_Call

+ func (_c *Client_GetAccountID_Call) Run(run func()) *Client_GetAccountID_Call

+ func (_c *Client_GetAccountID_Call) RunAndReturn(run func() string) *Client_GetAccountID_Call

+ type Client_GetJobDetailsBatch_Call struct

+ func (_c *Client_GetJobDetailsBatch_Call) Return(_a0 []*batch.JobDetail, _a1 error) *Client_GetJobDetailsBatch_Call

+ func (_c *Client_GetJobDetailsBatch_Call) Run(run func(ctx context.Context, ids []string)) *Client_GetJobDetailsBatch_Call

+ func (_c *Client_GetJobDetailsBatch_Call) RunAndReturn(run func(context.Context, []string) ([]*batch.JobDetail, error)) *Client_GetJobDetailsBatch_Call

+ type Client_GetRegion_Call struct

+ func (_c *Client_GetRegion_Call) Return(_a0 string) *Client_GetRegion_Call

+ func (_c *Client_GetRegion_Call) Run(run func()) *Client_GetRegion_Call

+ func (_c *Client_GetRegion_Call) RunAndReturn(run func() string) *Client_GetRegion_Call

+ type Client_RegisterJobDefinition_Call struct

+ func (_c *Client_RegisterJobDefinition_Call) Return(arn string, err error) *Client_RegisterJobDefinition_Call

+ func (_c *Client_RegisterJobDefinition_Call) Run(run func(ctx context.Context, name string, image string, role string, ...)) *Client_RegisterJobDefinition_Call

+ func (_c *Client_RegisterJobDefinition_Call) RunAndReturn(run func(context.Context, string, string, string, string) (string, error)) *Client_RegisterJobDefinition_Call

+ type Client_SubmitJob_Call struct

+ func (_c *Client_SubmitJob_Call) Return(jobID string, err error) *Client_SubmitJob_Call

+ func (_c *Client_SubmitJob_Call) Run(run func(ctx context.Context, input *batch.SubmitJobInput)) *Client_SubmitJob_Call

+ func (_c *Client_SubmitJob_Call) RunAndReturn(run func(context.Context, *batch.SubmitJobInput) (string, error)) *Client_SubmitJob_Call

+ type Client_TerminateJob_Call struct

+ func (_c *Client_TerminateJob_Call) Return(_a0 error) *Client_TerminateJob_Call

+ func (_c *Client_TerminateJob_Call) Run(run func(ctx context.Context, jobID string, reason string)) *Client_TerminateJob_Call

+ func (_c *Client_TerminateJob_Call) RunAndReturn(run func(context.Context, string, string) error) *Client_TerminateJob_Call

Sep 26, 2023

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)