iotjobsdataplanestub

Documentation

Index

• type Client
  • func NewClient() Client
• type DescribeJobExecutionFuture
  • func (r *DescribeJobExecutionFuture) Get(ctx workflow.Context) (*iotjobsdataplane.DescribeJobExecutionOutput, error)
• type GetPendingJobExecutionsFuture
  • func (r *GetPendingJobExecutionsFuture) Get(ctx workflow.Context) (*iotjobsdataplane.GetPendingJobExecutionsOutput, error)
• type StartNextPendingJobExecutionFuture
  • func (r *StartNextPendingJobExecutionFuture) Get(ctx workflow.Context) (*iotjobsdataplane.StartNextPendingJobExecutionOutput, error)
• type UpdateJobExecutionFuture
  • func (r *UpdateJobExecutionFuture) Get(ctx workflow.Context) (*iotjobsdataplane.UpdateJobExecutionOutput, error)

Types

type Client

type Client interface {
	DescribeJobExecution(ctx workflow.Context, input *iotjobsdataplane.DescribeJobExecutionInput) (*iotjobsdataplane.DescribeJobExecutionOutput, error)
	DescribeJobExecutionAsync(ctx workflow.Context, input *iotjobsdataplane.DescribeJobExecutionInput) *DescribeJobExecutionFuture

	GetPendingJobExecutions(ctx workflow.Context, input *iotjobsdataplane.GetPendingJobExecutionsInput) (*iotjobsdataplane.GetPendingJobExecutionsOutput, error)
	GetPendingJobExecutionsAsync(ctx workflow.Context, input *iotjobsdataplane.GetPendingJobExecutionsInput) *GetPendingJobExecutionsFuture

	StartNextPendingJobExecution(ctx workflow.Context, input *iotjobsdataplane.StartNextPendingJobExecutionInput) (*iotjobsdataplane.StartNextPendingJobExecutionOutput, error)
	StartNextPendingJobExecutionAsync(ctx workflow.Context, input *iotjobsdataplane.StartNextPendingJobExecutionInput) *StartNextPendingJobExecutionFuture

	UpdateJobExecution(ctx workflow.Context, input *iotjobsdataplane.UpdateJobExecutionInput) (*iotjobsdataplane.UpdateJobExecutionOutput, error)
	UpdateJobExecutionAsync(ctx workflow.Context, input *iotjobsdataplane.UpdateJobExecutionInput) *UpdateJobExecutionFuture
}

func NewClient

func NewClient() Client

type DescribeJobExecutionFuture

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

func (*DescribeJobExecutionFuture) Get

func (r *DescribeJobExecutionFuture) Get(ctx workflow.Context) (*iotjobsdataplane.DescribeJobExecutionOutput, error)

type GetPendingJobExecutionsFuture

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

func (*GetPendingJobExecutionsFuture) Get

func (r *GetPendingJobExecutionsFuture) Get(ctx workflow.Context) (*iotjobsdataplane.GetPendingJobExecutionsOutput, error)

type StartNextPendingJobExecutionFuture

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

func (*StartNextPendingJobExecutionFuture) Get

func (r *StartNextPendingJobExecutionFuture) Get(ctx workflow.Context) (*iotjobsdataplane.StartNextPendingJobExecutionOutput, error)

type UpdateJobExecutionFuture

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

func (*UpdateJobExecutionFuture) Get

func (r *UpdateJobExecutionFuture) Get(ctx workflow.Context) (*iotjobsdataplane.UpdateJobExecutionOutput, error)