batch

Documentation

Index

• type AwsClient
• type BatchRepository
  • func NewBatchRepository(ctx context.Context, client AwsClient) *BatchRepository
  • func (r *BatchRepository) GetRegion() ptypes.AwsRegion
  • func (r *BatchRepository) ListComputeEnvironmentAll() ([]ComputeEnvironment, error)
  • func (r *BatchRepository) ListComputeEnvironmentByInput(query *batch.DescribeComputeEnvironmentsInput) ([]ComputeEnvironment, error)
  • func (r *BatchRepository) ListJobQueueAll() ([]JobQueue, error)
  • func (r *BatchRepository) ListJobQueueByInput(query *batch.DescribeJobQueuesInput) ([]JobQueue, error)
• type ComputeEnvironment
  • func NewComputeEnvironment(client AwsClient, cenv types.ComputeEnvironmentDetail) ComputeEnvironment
  • func (e ComputeEnvironment) GetName() string
  • func (e ComputeEnvironment) GetTagValue(tag string) string
  • func (e ComputeEnvironment) GetTags() map[string]string
• type ComputeEnvironmentList
• type JobQueue
  • func NewJobQueue(client AwsClient, jobQueue types.JobQueueDetail) JobQueue
  • func (e JobQueue) GetName() string
  • func (e JobQueue) GetTagValue(tag string) string
  • func (e JobQueue) GetTags() map[string]string
• type JobQueueList

Types

type AwsClient

type AwsClient interface {
	GetRegion() ptypes.AwsRegion
	GetAccountID() ptypes.AwsAccountID
	Batch() *batch.Client
}

type BatchRepository

type BatchRepository struct {
	// contains filtered or unexported fields
}

func NewBatchRepository

func NewBatchRepository(ctx context.Context, client AwsClient) *BatchRepository

func (*BatchRepository) GetRegion

func (r *BatchRepository) GetRegion() ptypes.AwsRegion

func (*BatchRepository) ListComputeEnvironmentAll

func (r *BatchRepository) ListComputeEnvironmentAll() ([]ComputeEnvironment, error)

cfg.ResourceTypeBatchComputeEnvironment

func (*BatchRepository) ListComputeEnvironmentByInput

func (r *BatchRepository) ListComputeEnvironmentByInput(query *batch.DescribeComputeEnvironmentsInput) ([]ComputeEnvironment, error)

func (*BatchRepository) ListJobQueueAll

func (r *BatchRepository) ListJobQueueAll() ([]JobQueue, error)

func (*BatchRepository) ListJobQueueByInput

func (r *BatchRepository) ListJobQueueByInput(query *batch.DescribeJobQueuesInput) ([]JobQueue, error)

type ComputeEnvironment

type ComputeEnvironment struct {
	service.AbstractResource
	types.ComputeEnvironmentDetail
	Tags map[string]string
}

func NewComputeEnvironment

func NewComputeEnvironment(client AwsClient, cenv types.ComputeEnvironmentDetail) ComputeEnvironment

func (ComputeEnvironment) GetName

func (e ComputeEnvironment) GetName() string

func (ComputeEnvironment) GetTagValue

func (e ComputeEnvironment) GetTagValue(tag string) string

func (ComputeEnvironment) GetTags

func (e ComputeEnvironment) GetTags() map[string]string

type ComputeEnvironmentList

type ComputeEnvironmentList struct {
	Items []ComputeEnvironment
}

type JobQueue

type JobQueue struct {
	service.AbstractResource
	types.JobQueueDetail
	Tags map[string]string
}

func NewJobQueue

func NewJobQueue(client AwsClient, jobQueue types.JobQueueDetail) JobQueue

func (JobQueue) GetName

func (e JobQueue) GetName() string

func (JobQueue) GetTagValue

func (e JobQueue) GetTagValue(tag string) string

func (JobQueue) GetTags

func (e JobQueue) GetTags() map[string]string

type JobQueueList

type JobQueueList struct {
	Items []JobQueue
}