datapipelinestub

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Jan 31, 2022 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 ActivatePipelineFuture 

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

func (*ActivatePipelineFuture) Get 

func (r *ActivatePipelineFuture) Get(ctx workflow.Context) (*datapipeline.ActivatePipelineOutput, error)

type AddTagsFuture 

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

func (*AddTagsFuture) Get 

func (r *AddTagsFuture) Get(ctx workflow.Context) (*datapipeline.AddTagsOutput, error)

type Client 

type Client interface {
	ActivatePipeline(ctx workflow.Context, input *datapipeline.ActivatePipelineInput) (*datapipeline.ActivatePipelineOutput, error)
	ActivatePipelineAsync(ctx workflow.Context, input *datapipeline.ActivatePipelineInput) *ActivatePipelineFuture

	AddTags(ctx workflow.Context, input *datapipeline.AddTagsInput) (*datapipeline.AddTagsOutput, error)
	AddTagsAsync(ctx workflow.Context, input *datapipeline.AddTagsInput) *AddTagsFuture

	CreatePipeline(ctx workflow.Context, input *datapipeline.CreatePipelineInput) (*datapipeline.CreatePipelineOutput, error)
	CreatePipelineAsync(ctx workflow.Context, input *datapipeline.CreatePipelineInput) *CreatePipelineFuture

	DeactivatePipeline(ctx workflow.Context, input *datapipeline.DeactivatePipelineInput) (*datapipeline.DeactivatePipelineOutput, error)
	DeactivatePipelineAsync(ctx workflow.Context, input *datapipeline.DeactivatePipelineInput) *DeactivatePipelineFuture

	DeletePipeline(ctx workflow.Context, input *datapipeline.DeletePipelineInput) (*datapipeline.DeletePipelineOutput, error)
	DeletePipelineAsync(ctx workflow.Context, input *datapipeline.DeletePipelineInput) *DeletePipelineFuture

	DescribeObjects(ctx workflow.Context, input *datapipeline.DescribeObjectsInput) (*datapipeline.DescribeObjectsOutput, error)
	DescribeObjectsAsync(ctx workflow.Context, input *datapipeline.DescribeObjectsInput) *DescribeObjectsFuture

	DescribePipelines(ctx workflow.Context, input *datapipeline.DescribePipelinesInput) (*datapipeline.DescribePipelinesOutput, error)
	DescribePipelinesAsync(ctx workflow.Context, input *datapipeline.DescribePipelinesInput) *DescribePipelinesFuture

	EvaluateExpression(ctx workflow.Context, input *datapipeline.EvaluateExpressionInput) (*datapipeline.EvaluateExpressionOutput, error)
	EvaluateExpressionAsync(ctx workflow.Context, input *datapipeline.EvaluateExpressionInput) *EvaluateExpressionFuture

	GetPipelineDefinition(ctx workflow.Context, input *datapipeline.GetPipelineDefinitionInput) (*datapipeline.GetPipelineDefinitionOutput, error)
	GetPipelineDefinitionAsync(ctx workflow.Context, input *datapipeline.GetPipelineDefinitionInput) *GetPipelineDefinitionFuture

	ListPipelines(ctx workflow.Context, input *datapipeline.ListPipelinesInput) (*datapipeline.ListPipelinesOutput, error)
	ListPipelinesAsync(ctx workflow.Context, input *datapipeline.ListPipelinesInput) *ListPipelinesFuture

	PollForTask(ctx workflow.Context, input *datapipeline.PollForTaskInput) (*datapipeline.PollForTaskOutput, error)
	PollForTaskAsync(ctx workflow.Context, input *datapipeline.PollForTaskInput) *PollForTaskFuture

	PutPipelineDefinition(ctx workflow.Context, input *datapipeline.PutPipelineDefinitionInput) (*datapipeline.PutPipelineDefinitionOutput, error)
	PutPipelineDefinitionAsync(ctx workflow.Context, input *datapipeline.PutPipelineDefinitionInput) *PutPipelineDefinitionFuture

	QueryObjects(ctx workflow.Context, input *datapipeline.QueryObjectsInput) (*datapipeline.QueryObjectsOutput, error)
	QueryObjectsAsync(ctx workflow.Context, input *datapipeline.QueryObjectsInput) *QueryObjectsFuture

	RemoveTags(ctx workflow.Context, input *datapipeline.RemoveTagsInput) (*datapipeline.RemoveTagsOutput, error)
	RemoveTagsAsync(ctx workflow.Context, input *datapipeline.RemoveTagsInput) *RemoveTagsFuture

	ReportTaskProgress(ctx workflow.Context, input *datapipeline.ReportTaskProgressInput) (*datapipeline.ReportTaskProgressOutput, error)
	ReportTaskProgressAsync(ctx workflow.Context, input *datapipeline.ReportTaskProgressInput) *ReportTaskProgressFuture

	ReportTaskRunnerHeartbeat(ctx workflow.Context, input *datapipeline.ReportTaskRunnerHeartbeatInput) (*datapipeline.ReportTaskRunnerHeartbeatOutput, error)
	ReportTaskRunnerHeartbeatAsync(ctx workflow.Context, input *datapipeline.ReportTaskRunnerHeartbeatInput) *ReportTaskRunnerHeartbeatFuture

	SetStatus(ctx workflow.Context, input *datapipeline.SetStatusInput) (*datapipeline.SetStatusOutput, error)
	SetStatusAsync(ctx workflow.Context, input *datapipeline.SetStatusInput) *SetStatusFuture

	SetTaskStatus(ctx workflow.Context, input *datapipeline.SetTaskStatusInput) (*datapipeline.SetTaskStatusOutput, error)
	SetTaskStatusAsync(ctx workflow.Context, input *datapipeline.SetTaskStatusInput) *SetTaskStatusFuture

	ValidatePipelineDefinition(ctx workflow.Context, input *datapipeline.ValidatePipelineDefinitionInput) (*datapipeline.ValidatePipelineDefinitionOutput, error)
	ValidatePipelineDefinitionAsync(ctx workflow.Context, input *datapipeline.ValidatePipelineDefinitionInput) *ValidatePipelineDefinitionFuture
}

func NewClient 

func NewClient() Client

type CreatePipelineFuture 

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

func (*CreatePipelineFuture) Get 

func (r *CreatePipelineFuture) Get(ctx workflow.Context) (*datapipeline.CreatePipelineOutput, error)

type DeactivatePipelineFuture 

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

func (*DeactivatePipelineFuture) Get 

func (r *DeactivatePipelineFuture) Get(ctx workflow.Context) (*datapipeline.DeactivatePipelineOutput, error)

type DeletePipelineFuture 

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

func (*DeletePipelineFuture) Get 

func (r *DeletePipelineFuture) Get(ctx workflow.Context) (*datapipeline.DeletePipelineOutput, error)

type DescribeObjectsFuture 

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

func (*DescribeObjectsFuture) Get 

func (r *DescribeObjectsFuture) Get(ctx workflow.Context) (*datapipeline.DescribeObjectsOutput, error)

type DescribePipelinesFuture 

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

func (*DescribePipelinesFuture) Get 

func (r *DescribePipelinesFuture) Get(ctx workflow.Context) (*datapipeline.DescribePipelinesOutput, error)

type EvaluateExpressionFuture 

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

func (*EvaluateExpressionFuture) Get 

func (r *EvaluateExpressionFuture) Get(ctx workflow.Context) (*datapipeline.EvaluateExpressionOutput, error)

type GetPipelineDefinitionFuture 

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

func (*GetPipelineDefinitionFuture) Get 

func (r *GetPipelineDefinitionFuture) Get(ctx workflow.Context) (*datapipeline.GetPipelineDefinitionOutput, error)

type ListPipelinesFuture 

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

func (*ListPipelinesFuture) Get 

func (r *ListPipelinesFuture) Get(ctx workflow.Context) (*datapipeline.ListPipelinesOutput, error)

type PollForTaskFuture 

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

func (*PollForTaskFuture) Get 

func (r *PollForTaskFuture) Get(ctx workflow.Context) (*datapipeline.PollForTaskOutput, error)

type PutPipelineDefinitionFuture 

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

func (*PutPipelineDefinitionFuture) Get 

func (r *PutPipelineDefinitionFuture) Get(ctx workflow.Context) (*datapipeline.PutPipelineDefinitionOutput, error)

type QueryObjectsFuture 

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

func (*QueryObjectsFuture) Get 

func (r *QueryObjectsFuture) Get(ctx workflow.Context) (*datapipeline.QueryObjectsOutput, error)

type RemoveTagsFuture 

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

func (*RemoveTagsFuture) Get 

func (r *RemoveTagsFuture) Get(ctx workflow.Context) (*datapipeline.RemoveTagsOutput, error)

type ReportTaskProgressFuture 

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

func (*ReportTaskProgressFuture) Get 

func (r *ReportTaskProgressFuture) Get(ctx workflow.Context) (*datapipeline.ReportTaskProgressOutput, error)

type ReportTaskRunnerHeartbeatFuture 

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

func (*ReportTaskRunnerHeartbeatFuture) Get 

func (r *ReportTaskRunnerHeartbeatFuture) Get(ctx workflow.Context) (*datapipeline.ReportTaskRunnerHeartbeatOutput, error)

type SetStatusFuture 

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

func (*SetStatusFuture) Get 

func (r *SetStatusFuture) Get(ctx workflow.Context) (*datapipeline.SetStatusOutput, error)

type SetTaskStatusFuture 

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

func (*SetTaskStatusFuture) Get 

func (r *SetTaskStatusFuture) Get(ctx workflow.Context) (*datapipeline.SetTaskStatusOutput, error)

type ValidatePipelineDefinitionFuture 

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

func (*ValidatePipelineDefinitionFuture) Get 

func (r *ValidatePipelineDefinitionFuture) Get(ctx workflow.Context) (*datapipeline.ValidatePipelineDefinitionOutput, 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.