batchstub

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 8, 2021 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CancelJobFuture 

type CancelJobFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*CancelJobFuture) Get 

func (r *CancelJobFuture) Get(ctx workflow.Context) (*batch.CancelJobOutput, error)

type Client 

type Client interface {
	CancelJob(ctx workflow.Context, input *batch.CancelJobInput) (*batch.CancelJobOutput, error)
	CancelJobAsync(ctx workflow.Context, input *batch.CancelJobInput) *CancelJobFuture

	CreateComputeEnvironment(ctx workflow.Context, input *batch.CreateComputeEnvironmentInput) (*batch.CreateComputeEnvironmentOutput, error)
	CreateComputeEnvironmentAsync(ctx workflow.Context, input *batch.CreateComputeEnvironmentInput) *CreateComputeEnvironmentFuture

	CreateJobQueue(ctx workflow.Context, input *batch.CreateJobQueueInput) (*batch.CreateJobQueueOutput, error)
	CreateJobQueueAsync(ctx workflow.Context, input *batch.CreateJobQueueInput) *CreateJobQueueFuture

	DeleteComputeEnvironment(ctx workflow.Context, input *batch.DeleteComputeEnvironmentInput) (*batch.DeleteComputeEnvironmentOutput, error)
	DeleteComputeEnvironmentAsync(ctx workflow.Context, input *batch.DeleteComputeEnvironmentInput) *DeleteComputeEnvironmentFuture

	DeleteJobQueue(ctx workflow.Context, input *batch.DeleteJobQueueInput) (*batch.DeleteJobQueueOutput, error)
	DeleteJobQueueAsync(ctx workflow.Context, input *batch.DeleteJobQueueInput) *DeleteJobQueueFuture

	DeregisterJobDefinition(ctx workflow.Context, input *batch.DeregisterJobDefinitionInput) (*batch.DeregisterJobDefinitionOutput, error)
	DeregisterJobDefinitionAsync(ctx workflow.Context, input *batch.DeregisterJobDefinitionInput) *DeregisterJobDefinitionFuture

	DescribeComputeEnvironments(ctx workflow.Context, input *batch.DescribeComputeEnvironmentsInput) (*batch.DescribeComputeEnvironmentsOutput, error)
	DescribeComputeEnvironmentsAsync(ctx workflow.Context, input *batch.DescribeComputeEnvironmentsInput) *DescribeComputeEnvironmentsFuture

	DescribeJobDefinitions(ctx workflow.Context, input *batch.DescribeJobDefinitionsInput) (*batch.DescribeJobDefinitionsOutput, error)
	DescribeJobDefinitionsAsync(ctx workflow.Context, input *batch.DescribeJobDefinitionsInput) *DescribeJobDefinitionsFuture

	DescribeJobQueues(ctx workflow.Context, input *batch.DescribeJobQueuesInput) (*batch.DescribeJobQueuesOutput, error)
	DescribeJobQueuesAsync(ctx workflow.Context, input *batch.DescribeJobQueuesInput) *DescribeJobQueuesFuture

	DescribeJobs(ctx workflow.Context, input *batch.DescribeJobsInput) (*batch.DescribeJobsOutput, error)
	DescribeJobsAsync(ctx workflow.Context, input *batch.DescribeJobsInput) *DescribeJobsFuture

	ListJobs(ctx workflow.Context, input *batch.ListJobsInput) (*batch.ListJobsOutput, error)
	ListJobsAsync(ctx workflow.Context, input *batch.ListJobsInput) *ListJobsFuture

	ListTagsForResource(ctx workflow.Context, input *batch.ListTagsForResourceInput) (*batch.ListTagsForResourceOutput, error)
	ListTagsForResourceAsync(ctx workflow.Context, input *batch.ListTagsForResourceInput) *ListTagsForResourceFuture

	RegisterJobDefinition(ctx workflow.Context, input *batch.RegisterJobDefinitionInput) (*batch.RegisterJobDefinitionOutput, error)
	RegisterJobDefinitionAsync(ctx workflow.Context, input *batch.RegisterJobDefinitionInput) *RegisterJobDefinitionFuture

	SubmitJob(ctx workflow.Context, input *batch.SubmitJobInput) (*batch.SubmitJobOutput, error)
	SubmitJobAsync(ctx workflow.Context, input *batch.SubmitJobInput) *SubmitJobFuture

	TagResource(ctx workflow.Context, input *batch.TagResourceInput) (*batch.TagResourceOutput, error)
	TagResourceAsync(ctx workflow.Context, input *batch.TagResourceInput) *TagResourceFuture

	TerminateJob(ctx workflow.Context, input *batch.TerminateJobInput) (*batch.TerminateJobOutput, error)
	TerminateJobAsync(ctx workflow.Context, input *batch.TerminateJobInput) *TerminateJobFuture

	UntagResource(ctx workflow.Context, input *batch.UntagResourceInput) (*batch.UntagResourceOutput, error)
	UntagResourceAsync(ctx workflow.Context, input *batch.UntagResourceInput) *UntagResourceFuture

	UpdateComputeEnvironment(ctx workflow.Context, input *batch.UpdateComputeEnvironmentInput) (*batch.UpdateComputeEnvironmentOutput, error)
	UpdateComputeEnvironmentAsync(ctx workflow.Context, input *batch.UpdateComputeEnvironmentInput) *UpdateComputeEnvironmentFuture

	UpdateJobQueue(ctx workflow.Context, input *batch.UpdateJobQueueInput) (*batch.UpdateJobQueueOutput, error)
	UpdateJobQueueAsync(ctx workflow.Context, input *batch.UpdateJobQueueInput) *UpdateJobQueueFuture
}

func NewClient 

func NewClient() Client

type CreateComputeEnvironmentFuture 

type CreateComputeEnvironmentFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*CreateComputeEnvironmentFuture) Get 

func (r *CreateComputeEnvironmentFuture) Get(ctx workflow.Context) (*batch.CreateComputeEnvironmentOutput, error)

type CreateJobQueueFuture 

type CreateJobQueueFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*CreateJobQueueFuture) Get 

func (r *CreateJobQueueFuture) Get(ctx workflow.Context) (*batch.CreateJobQueueOutput, error)

type DeleteComputeEnvironmentFuture 

type DeleteComputeEnvironmentFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DeleteComputeEnvironmentFuture) Get 

func (r *DeleteComputeEnvironmentFuture) Get(ctx workflow.Context) (*batch.DeleteComputeEnvironmentOutput, error)

type DeleteJobQueueFuture 

type DeleteJobQueueFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DeleteJobQueueFuture) Get 

func (r *DeleteJobQueueFuture) Get(ctx workflow.Context) (*batch.DeleteJobQueueOutput, error)

type DeregisterJobDefinitionFuture 

type DeregisterJobDefinitionFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DeregisterJobDefinitionFuture) Get 

func (r *DeregisterJobDefinitionFuture) Get(ctx workflow.Context) (*batch.DeregisterJobDefinitionOutput, error)

type DescribeComputeEnvironmentsFuture 

type DescribeComputeEnvironmentsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DescribeComputeEnvironmentsFuture) Get 

func (r *DescribeComputeEnvironmentsFuture) Get(ctx workflow.Context) (*batch.DescribeComputeEnvironmentsOutput, error)

type DescribeJobDefinitionsFuture 

type DescribeJobDefinitionsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DescribeJobDefinitionsFuture) Get 

func (r *DescribeJobDefinitionsFuture) Get(ctx workflow.Context) (*batch.DescribeJobDefinitionsOutput, error)

type DescribeJobQueuesFuture 

type DescribeJobQueuesFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DescribeJobQueuesFuture) Get 

func (r *DescribeJobQueuesFuture) Get(ctx workflow.Context) (*batch.DescribeJobQueuesOutput, error)

type DescribeJobsFuture 

type DescribeJobsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DescribeJobsFuture) Get 

func (r *DescribeJobsFuture) Get(ctx workflow.Context) (*batch.DescribeJobsOutput, error)

type ListJobsFuture 

type ListJobsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListJobsFuture) Get 

func (r *ListJobsFuture) Get(ctx workflow.Context) (*batch.ListJobsOutput, error)

type ListTagsForResourceFuture 

type ListTagsForResourceFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListTagsForResourceFuture) Get 

func (r *ListTagsForResourceFuture) Get(ctx workflow.Context) (*batch.ListTagsForResourceOutput, error)

type RegisterJobDefinitionFuture 

type RegisterJobDefinitionFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*RegisterJobDefinitionFuture) Get 

func (r *RegisterJobDefinitionFuture) Get(ctx workflow.Context) (*batch.RegisterJobDefinitionOutput, error)

type SubmitJobFuture 

type SubmitJobFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*SubmitJobFuture) Get 

func (r *SubmitJobFuture) Get(ctx workflow.Context) (*batch.SubmitJobOutput, error)

type TagResourceFuture 

type TagResourceFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*TagResourceFuture) Get 

func (r *TagResourceFuture) Get(ctx workflow.Context) (*batch.TagResourceOutput, error)

type TerminateJobFuture 

type TerminateJobFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*TerminateJobFuture) Get 

func (r *TerminateJobFuture) Get(ctx workflow.Context) (*batch.TerminateJobOutput, error)

type UntagResourceFuture 

type UntagResourceFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*UntagResourceFuture) Get 

func (r *UntagResourceFuture) Get(ctx workflow.Context) (*batch.UntagResourceOutput, error)

type UpdateComputeEnvironmentFuture 

type UpdateComputeEnvironmentFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*UpdateComputeEnvironmentFuture) Get 

func (r *UpdateComputeEnvironmentFuture) Get(ctx workflow.Context) (*batch.UpdateComputeEnvironmentOutput, error)

type UpdateJobQueueFuture 

type UpdateJobQueueFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*UpdateJobQueueFuture) Get 

func (r *UpdateJobQueueFuture) Get(ctx workflow.Context) (*batch.UpdateJobQueueOutput, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.