datapipeline

package

Go to main page

Versions in this module

v1

v1.13.54

May 22, 2018

v1.13.9

Mar 6, 2018

v1.12.67

Jan 22, 2018

v1.10.51

Sep 22, 2017

v1.10.18

Jul 27, 2017

v1.9.0

Jun 19, 2017

Changes in this version

type DataPipeline

+ func (c *DataPipeline) ActivatePipelineWithContext(ctx aws.Context, input *ActivatePipelineInput, opts ...request.Option) (*ActivatePipelineOutput, error)

+ func (c *DataPipeline) AddTagsWithContext(ctx aws.Context, input *AddTagsInput, opts ...request.Option) (*AddTagsOutput, error)

+ func (c *DataPipeline) CreatePipelineWithContext(ctx aws.Context, input *CreatePipelineInput, opts ...request.Option) (*CreatePipelineOutput, error)

+ func (c *DataPipeline) DeactivatePipelineWithContext(ctx aws.Context, input *DeactivatePipelineInput, opts ...request.Option) (*DeactivatePipelineOutput, error)

+ func (c *DataPipeline) DeletePipelineWithContext(ctx aws.Context, input *DeletePipelineInput, opts ...request.Option) (*DeletePipelineOutput, error)

+ func (c *DataPipeline) DescribeObjectsPagesWithContext(ctx aws.Context, input *DescribeObjectsInput, ...) error

+ func (c *DataPipeline) DescribeObjectsWithContext(ctx aws.Context, input *DescribeObjectsInput, opts ...request.Option) (*DescribeObjectsOutput, error)

+ func (c *DataPipeline) DescribePipelinesWithContext(ctx aws.Context, input *DescribePipelinesInput, opts ...request.Option) (*DescribePipelinesOutput, error)

+ func (c *DataPipeline) EvaluateExpressionWithContext(ctx aws.Context, input *EvaluateExpressionInput, opts ...request.Option) (*EvaluateExpressionOutput, error)

+ func (c *DataPipeline) GetPipelineDefinitionWithContext(ctx aws.Context, input *GetPipelineDefinitionInput, opts ...request.Option) (*GetPipelineDefinitionOutput, error)

+ func (c *DataPipeline) ListPipelinesPagesWithContext(ctx aws.Context, input *ListPipelinesInput, ...) error

+ func (c *DataPipeline) ListPipelinesWithContext(ctx aws.Context, input *ListPipelinesInput, opts ...request.Option) (*ListPipelinesOutput, error)

+ func (c *DataPipeline) PollForTaskWithContext(ctx aws.Context, input *PollForTaskInput, opts ...request.Option) (*PollForTaskOutput, error)

+ func (c *DataPipeline) PutPipelineDefinitionWithContext(ctx aws.Context, input *PutPipelineDefinitionInput, opts ...request.Option) (*PutPipelineDefinitionOutput, error)

+ func (c *DataPipeline) QueryObjectsPagesWithContext(ctx aws.Context, input *QueryObjectsInput, ...) error

+ func (c *DataPipeline) QueryObjectsWithContext(ctx aws.Context, input *QueryObjectsInput, opts ...request.Option) (*QueryObjectsOutput, error)

+ func (c *DataPipeline) RemoveTagsWithContext(ctx aws.Context, input *RemoveTagsInput, opts ...request.Option) (*RemoveTagsOutput, error)

+ func (c *DataPipeline) ReportTaskProgressWithContext(ctx aws.Context, input *ReportTaskProgressInput, opts ...request.Option) (*ReportTaskProgressOutput, error)

+ func (c *DataPipeline) ReportTaskRunnerHeartbeatWithContext(ctx aws.Context, input *ReportTaskRunnerHeartbeatInput, opts ...request.Option) (*ReportTaskRunnerHeartbeatOutput, error)

+ func (c *DataPipeline) SetStatusWithContext(ctx aws.Context, input *SetStatusInput, opts ...request.Option) (*SetStatusOutput, error)

+ func (c *DataPipeline) SetTaskStatusWithContext(ctx aws.Context, input *SetTaskStatusInput, opts ...request.Option) (*SetTaskStatusOutput, error)

+ func (c *DataPipeline) ValidatePipelineDefinitionWithContext(ctx aws.Context, input *ValidatePipelineDefinitionInput, ...) (*ValidatePipelineDefinitionOutput, error)

v1.7.0

Feb 23, 2017

v1.6.20

Feb 10, 2017

Changes in this version

+ const ErrCodeInternalServiceError

+ const ErrCodeInvalidRequestException

+ const ErrCodePipelineDeletedException

+ const ErrCodePipelineNotFoundException

+ const ErrCodeTaskNotFoundException

v1.6.16

Jan 24, 2017

Changes in this version

+ const EndpointsID

type ActivatePipelineInput

+ func (s *ActivatePipelineInput) SetParameterValues(v []*ParameterValue) *ActivatePipelineInput

+ func (s *ActivatePipelineInput) SetPipelineId(v string) *ActivatePipelineInput

+ func (s *ActivatePipelineInput) SetStartTimestamp(v time.Time) *ActivatePipelineInput

type AddTagsInput

+ func (s *AddTagsInput) SetPipelineId(v string) *AddTagsInput

+ func (s *AddTagsInput) SetTags(v []*Tag) *AddTagsInput

type CreatePipelineInput

+ func (s *CreatePipelineInput) SetDescription(v string) *CreatePipelineInput

+ func (s *CreatePipelineInput) SetName(v string) *CreatePipelineInput

+ func (s *CreatePipelineInput) SetTags(v []*Tag) *CreatePipelineInput

+ func (s *CreatePipelineInput) SetUniqueId(v string) *CreatePipelineInput

type CreatePipelineOutput

+ func (s *CreatePipelineOutput) SetPipelineId(v string) *CreatePipelineOutput

type DeactivatePipelineInput

+ func (s *DeactivatePipelineInput) SetCancelActive(v bool) *DeactivatePipelineInput

+ func (s *DeactivatePipelineInput) SetPipelineId(v string) *DeactivatePipelineInput

type DeletePipelineInput

+ func (s *DeletePipelineInput) SetPipelineId(v string) *DeletePipelineInput

type DescribeObjectsInput

+ func (s *DescribeObjectsInput) SetEvaluateExpressions(v bool) *DescribeObjectsInput

+ func (s *DescribeObjectsInput) SetMarker(v string) *DescribeObjectsInput

+ func (s *DescribeObjectsInput) SetObjectIds(v []*string) *DescribeObjectsInput

+ func (s *DescribeObjectsInput) SetPipelineId(v string) *DescribeObjectsInput

type DescribeObjectsOutput

+ func (s *DescribeObjectsOutput) SetHasMoreResults(v bool) *DescribeObjectsOutput

+ func (s *DescribeObjectsOutput) SetMarker(v string) *DescribeObjectsOutput

+ func (s *DescribeObjectsOutput) SetPipelineObjects(v []*PipelineObject) *DescribeObjectsOutput

type DescribePipelinesInput

+ func (s *DescribePipelinesInput) SetPipelineIds(v []*string) *DescribePipelinesInput

type DescribePipelinesOutput

+ func (s *DescribePipelinesOutput) SetPipelineDescriptionList(v []*PipelineDescription) *DescribePipelinesOutput

type EvaluateExpressionInput

+ func (s *EvaluateExpressionInput) SetExpression(v string) *EvaluateExpressionInput

+ func (s *EvaluateExpressionInput) SetObjectId(v string) *EvaluateExpressionInput

+ func (s *EvaluateExpressionInput) SetPipelineId(v string) *EvaluateExpressionInput

type EvaluateExpressionOutput

+ func (s *EvaluateExpressionOutput) SetEvaluatedExpression(v string) *EvaluateExpressionOutput

type Field

+ func (s *Field) SetKey(v string) *Field

+ func (s *Field) SetRefValue(v string) *Field

+ func (s *Field) SetStringValue(v string) *Field

type GetPipelineDefinitionInput

+ func (s *GetPipelineDefinitionInput) SetPipelineId(v string) *GetPipelineDefinitionInput

+ func (s *GetPipelineDefinitionInput) SetVersion(v string) *GetPipelineDefinitionInput

type GetPipelineDefinitionOutput

+ func (s *GetPipelineDefinitionOutput) SetParameterObjects(v []*ParameterObject) *GetPipelineDefinitionOutput

+ func (s *GetPipelineDefinitionOutput) SetParameterValues(v []*ParameterValue) *GetPipelineDefinitionOutput

+ func (s *GetPipelineDefinitionOutput) SetPipelineObjects(v []*PipelineObject) *GetPipelineDefinitionOutput

type InstanceIdentity

+ func (s *InstanceIdentity) SetDocument(v string) *InstanceIdentity

+ func (s *InstanceIdentity) SetSignature(v string) *InstanceIdentity

type ListPipelinesInput

+ func (s *ListPipelinesInput) SetMarker(v string) *ListPipelinesInput

type ListPipelinesOutput

+ func (s *ListPipelinesOutput) SetHasMoreResults(v bool) *ListPipelinesOutput

+ func (s *ListPipelinesOutput) SetMarker(v string) *ListPipelinesOutput

+ func (s *ListPipelinesOutput) SetPipelineIdList(v []*PipelineIdName) *ListPipelinesOutput

type Operator

+ func (s *Operator) SetType(v string) *Operator

+ func (s *Operator) SetValues(v []*string) *Operator

type ParameterAttribute

+ func (s *ParameterAttribute) SetKey(v string) *ParameterAttribute

+ func (s *ParameterAttribute) SetStringValue(v string) *ParameterAttribute

type ParameterObject

+ func (s *ParameterObject) SetAttributes(v []*ParameterAttribute) *ParameterObject

+ func (s *ParameterObject) SetId(v string) *ParameterObject

type ParameterValue

+ func (s *ParameterValue) SetId(v string) *ParameterValue

+ func (s *ParameterValue) SetStringValue(v string) *ParameterValue

type PipelineDescription

+ func (s *PipelineDescription) SetDescription(v string) *PipelineDescription

+ func (s *PipelineDescription) SetFields(v []*Field) *PipelineDescription

+ func (s *PipelineDescription) SetName(v string) *PipelineDescription

+ func (s *PipelineDescription) SetPipelineId(v string) *PipelineDescription

+ func (s *PipelineDescription) SetTags(v []*Tag) *PipelineDescription

type PipelineIdName

+ func (s *PipelineIdName) SetId(v string) *PipelineIdName

+ func (s *PipelineIdName) SetName(v string) *PipelineIdName

type PipelineObject

+ func (s *PipelineObject) SetFields(v []*Field) *PipelineObject

+ func (s *PipelineObject) SetId(v string) *PipelineObject

+ func (s *PipelineObject) SetName(v string) *PipelineObject

type PollForTaskInput

+ func (s *PollForTaskInput) SetHostname(v string) *PollForTaskInput

+ func (s *PollForTaskInput) SetInstanceIdentity(v *InstanceIdentity) *PollForTaskInput

+ func (s *PollForTaskInput) SetWorkerGroup(v string) *PollForTaskInput

type PollForTaskOutput

+ func (s *PollForTaskOutput) SetTaskObject(v *TaskObject) *PollForTaskOutput

type PutPipelineDefinitionInput

+ func (s *PutPipelineDefinitionInput) SetParameterObjects(v []*ParameterObject) *PutPipelineDefinitionInput

+ func (s *PutPipelineDefinitionInput) SetParameterValues(v []*ParameterValue) *PutPipelineDefinitionInput

+ func (s *PutPipelineDefinitionInput) SetPipelineId(v string) *PutPipelineDefinitionInput

+ func (s *PutPipelineDefinitionInput) SetPipelineObjects(v []*PipelineObject) *PutPipelineDefinitionInput

type PutPipelineDefinitionOutput

+ func (s *PutPipelineDefinitionOutput) SetErrored(v bool) *PutPipelineDefinitionOutput

+ func (s *PutPipelineDefinitionOutput) SetValidationErrors(v []*ValidationError) *PutPipelineDefinitionOutput

+ func (s *PutPipelineDefinitionOutput) SetValidationWarnings(v []*ValidationWarning) *PutPipelineDefinitionOutput

type Query

+ func (s *Query) SetSelectors(v []*Selector) *Query

type QueryObjectsInput

+ func (s *QueryObjectsInput) SetLimit(v int64) *QueryObjectsInput

+ func (s *QueryObjectsInput) SetMarker(v string) *QueryObjectsInput

+ func (s *QueryObjectsInput) SetPipelineId(v string) *QueryObjectsInput

+ func (s *QueryObjectsInput) SetQuery(v *Query) *QueryObjectsInput

+ func (s *QueryObjectsInput) SetSphere(v string) *QueryObjectsInput

type QueryObjectsOutput

+ func (s *QueryObjectsOutput) SetHasMoreResults(v bool) *QueryObjectsOutput

+ func (s *QueryObjectsOutput) SetIds(v []*string) *QueryObjectsOutput

+ func (s *QueryObjectsOutput) SetMarker(v string) *QueryObjectsOutput

type RemoveTagsInput

+ func (s *RemoveTagsInput) SetPipelineId(v string) *RemoveTagsInput

+ func (s *RemoveTagsInput) SetTagKeys(v []*string) *RemoveTagsInput

type ReportTaskProgressInput

+ func (s *ReportTaskProgressInput) SetFields(v []*Field) *ReportTaskProgressInput

+ func (s *ReportTaskProgressInput) SetTaskId(v string) *ReportTaskProgressInput

type ReportTaskProgressOutput

+ func (s *ReportTaskProgressOutput) SetCanceled(v bool) *ReportTaskProgressOutput

type ReportTaskRunnerHeartbeatInput

+ func (s *ReportTaskRunnerHeartbeatInput) SetHostname(v string) *ReportTaskRunnerHeartbeatInput

+ func (s *ReportTaskRunnerHeartbeatInput) SetTaskrunnerId(v string) *ReportTaskRunnerHeartbeatInput

+ func (s *ReportTaskRunnerHeartbeatInput) SetWorkerGroup(v string) *ReportTaskRunnerHeartbeatInput

type ReportTaskRunnerHeartbeatOutput

+ func (s *ReportTaskRunnerHeartbeatOutput) SetTerminate(v bool) *ReportTaskRunnerHeartbeatOutput

type Selector

+ func (s *Selector) SetFieldName(v string) *Selector

+ func (s *Selector) SetOperator(v *Operator) *Selector

type SetStatusInput

+ func (s *SetStatusInput) SetObjectIds(v []*string) *SetStatusInput

+ func (s *SetStatusInput) SetPipelineId(v string) *SetStatusInput

+ func (s *SetStatusInput) SetStatus(v string) *SetStatusInput

type SetTaskStatusInput

+ func (s *SetTaskStatusInput) SetErrorId(v string) *SetTaskStatusInput

+ func (s *SetTaskStatusInput) SetErrorMessage(v string) *SetTaskStatusInput

+ func (s *SetTaskStatusInput) SetErrorStackTrace(v string) *SetTaskStatusInput

+ func (s *SetTaskStatusInput) SetTaskId(v string) *SetTaskStatusInput

+ func (s *SetTaskStatusInput) SetTaskStatus(v string) *SetTaskStatusInput

type Tag

+ func (s *Tag) SetKey(v string) *Tag

+ func (s *Tag) SetValue(v string) *Tag

type TaskObject

+ func (s *TaskObject) SetAttemptId(v string) *TaskObject

+ func (s *TaskObject) SetObjects(v map[string]*PipelineObject) *TaskObject

+ func (s *TaskObject) SetPipelineId(v string) *TaskObject

+ func (s *TaskObject) SetTaskId(v string) *TaskObject

type ValidatePipelineDefinitionInput

+ func (s *ValidatePipelineDefinitionInput) SetParameterObjects(v []*ParameterObject) *ValidatePipelineDefinitionInput

+ func (s *ValidatePipelineDefinitionInput) SetParameterValues(v []*ParameterValue) *ValidatePipelineDefinitionInput

+ func (s *ValidatePipelineDefinitionInput) SetPipelineId(v string) *ValidatePipelineDefinitionInput

+ func (s *ValidatePipelineDefinitionInput) SetPipelineObjects(v []*PipelineObject) *ValidatePipelineDefinitionInput

type ValidatePipelineDefinitionOutput

+ func (s *ValidatePipelineDefinitionOutput) SetErrored(v bool) *ValidatePipelineDefinitionOutput

+ func (s *ValidatePipelineDefinitionOutput) SetValidationErrors(v []*ValidationError) *ValidatePipelineDefinitionOutput

+ func (s *ValidatePipelineDefinitionOutput) SetValidationWarnings(v []*ValidationWarning) *ValidatePipelineDefinitionOutput

type ValidationError

+ func (s *ValidationError) SetErrors(v []*string) *ValidationError

+ func (s *ValidationError) SetId(v string) *ValidationError

type ValidationWarning

+ func (s *ValidationWarning) SetId(v string) *ValidationWarning

+ func (s *ValidationWarning) SetWarnings(v []*string) *ValidationWarning

v1.4.5

Aug 30, 2016

v1.3.0

Aug 2, 2016

Changes in this version

type ActivatePipelineInput

+ func (s *ActivatePipelineInput) Validate() error

type AddTagsInput

+ func (s *AddTagsInput) Validate() error

type CreatePipelineInput

+ func (s *CreatePipelineInput) Validate() error

type DeactivatePipelineInput

+ func (s *DeactivatePipelineInput) Validate() error

type DeletePipelineInput

+ func (s *DeletePipelineInput) Validate() error

type DescribeObjectsInput

+ func (s *DescribeObjectsInput) Validate() error

type DescribePipelinesInput

+ func (s *DescribePipelinesInput) Validate() error

type EvaluateExpressionInput

+ func (s *EvaluateExpressionInput) Validate() error

type Field

+ func (s *Field) Validate() error

type GetPipelineDefinitionInput

+ func (s *GetPipelineDefinitionInput) Validate() error

type ParameterAttribute

+ func (s *ParameterAttribute) Validate() error

type ParameterObject

+ func (s *ParameterObject) Validate() error

type ParameterValue

+ func (s *ParameterValue) Validate() error

type PipelineObject

+ func (s *PipelineObject) Validate() error

type PollForTaskInput

+ func (s *PollForTaskInput) Validate() error

type PutPipelineDefinitionInput

+ func (s *PutPipelineDefinitionInput) Validate() error

type QueryObjectsInput

+ func (s *QueryObjectsInput) Validate() error

type RemoveTagsInput

+ func (s *RemoveTagsInput) Validate() error

type ReportTaskProgressInput

+ func (s *ReportTaskProgressInput) Validate() error

type ReportTaskRunnerHeartbeatInput

+ func (s *ReportTaskRunnerHeartbeatInput) Validate() error

type SetStatusInput

+ func (s *SetStatusInput) Validate() error

type SetTaskStatusInput

+ func (s *SetTaskStatusInput) Validate() error

type Tag

+ func (s *Tag) Validate() error

type ValidatePipelineDefinitionInput

+ func (s *ValidatePipelineDefinitionInput) Validate() error

v1.1.19

Apr 19, 2016

v1.0.8

Jan 12, 2016

v1.0.2

Nov 24, 2015

Changes in this version

+ const OperatorTypeBetween

+ const OperatorTypeEq

+ const OperatorTypeGe

+ const OperatorTypeLe

+ const OperatorTypeRefEq

+ const ServiceName

+ const TaskStatusFailed

+ const TaskStatusFalse

+ const TaskStatusFinished

+ type ActivatePipelineInput struct

+ ParameterValues []*ParameterValue

+ PipelineId *string

+ StartTimestamp *time.Time

+ func (s ActivatePipelineInput) GoString() string

+ func (s ActivatePipelineInput) String() string

+ type ActivatePipelineOutput struct

+ func (s ActivatePipelineOutput) GoString() string

+ func (s ActivatePipelineOutput) String() string

+ type AddTagsInput struct

+ PipelineId *string

+ Tags []*Tag

+ func (s AddTagsInput) GoString() string

+ func (s AddTagsInput) String() string

+ type AddTagsOutput struct

+ func (s AddTagsOutput) GoString() string

+ func (s AddTagsOutput) String() string

+ type CreatePipelineInput struct

+ Description *string

+ Name *string

+ Tags []*Tag

+ UniqueId *string

+ func (s CreatePipelineInput) GoString() string

+ func (s CreatePipelineInput) String() string

+ type CreatePipelineOutput struct

+ PipelineId *string

+ func (s CreatePipelineOutput) GoString() string

+ func (s CreatePipelineOutput) String() string

+ type DataPipeline struct

+ func New(p client.ConfigProvider, cfgs ...*aws.Config) *DataPipeline

+ func (c *DataPipeline) ActivatePipeline(input *ActivatePipelineInput) (*ActivatePipelineOutput, error)

+ func (c *DataPipeline) ActivatePipelineRequest(input *ActivatePipelineInput) (req *request.Request, output *ActivatePipelineOutput)

+ func (c *DataPipeline) AddTags(input *AddTagsInput) (*AddTagsOutput, error)

+ func (c *DataPipeline) AddTagsRequest(input *AddTagsInput) (req *request.Request, output *AddTagsOutput)

+ func (c *DataPipeline) CreatePipeline(input *CreatePipelineInput) (*CreatePipelineOutput, error)

+ func (c *DataPipeline) CreatePipelineRequest(input *CreatePipelineInput) (req *request.Request, output *CreatePipelineOutput)

+ func (c *DataPipeline) DeactivatePipeline(input *DeactivatePipelineInput) (*DeactivatePipelineOutput, error)

+ func (c *DataPipeline) DeactivatePipelineRequest(input *DeactivatePipelineInput) (req *request.Request, output *DeactivatePipelineOutput)

+ func (c *DataPipeline) DeletePipeline(input *DeletePipelineInput) (*DeletePipelineOutput, error)

+ func (c *DataPipeline) DeletePipelineRequest(input *DeletePipelineInput) (req *request.Request, output *DeletePipelineOutput)

+ func (c *DataPipeline) DescribeObjects(input *DescribeObjectsInput) (*DescribeObjectsOutput, error)

+ func (c *DataPipeline) DescribeObjectsPages(input *DescribeObjectsInput, ...) error

+ func (c *DataPipeline) DescribeObjectsRequest(input *DescribeObjectsInput) (req *request.Request, output *DescribeObjectsOutput)

+ func (c *DataPipeline) DescribePipelines(input *DescribePipelinesInput) (*DescribePipelinesOutput, error)

+ func (c *DataPipeline) DescribePipelinesRequest(input *DescribePipelinesInput) (req *request.Request, output *DescribePipelinesOutput)

+ func (c *DataPipeline) EvaluateExpression(input *EvaluateExpressionInput) (*EvaluateExpressionOutput, error)

+ func (c *DataPipeline) EvaluateExpressionRequest(input *EvaluateExpressionInput) (req *request.Request, output *EvaluateExpressionOutput)

+ func (c *DataPipeline) GetPipelineDefinition(input *GetPipelineDefinitionInput) (*GetPipelineDefinitionOutput, error)

+ func (c *DataPipeline) GetPipelineDefinitionRequest(input *GetPipelineDefinitionInput) (req *request.Request, output *GetPipelineDefinitionOutput)

+ func (c *DataPipeline) ListPipelines(input *ListPipelinesInput) (*ListPipelinesOutput, error)

+ func (c *DataPipeline) ListPipelinesPages(input *ListPipelinesInput, ...) error

+ func (c *DataPipeline) ListPipelinesRequest(input *ListPipelinesInput) (req *request.Request, output *ListPipelinesOutput)

+ func (c *DataPipeline) PollForTask(input *PollForTaskInput) (*PollForTaskOutput, error)

+ func (c *DataPipeline) PollForTaskRequest(input *PollForTaskInput) (req *request.Request, output *PollForTaskOutput)

+ func (c *DataPipeline) PutPipelineDefinition(input *PutPipelineDefinitionInput) (*PutPipelineDefinitionOutput, error)

+ func (c *DataPipeline) PutPipelineDefinitionRequest(input *PutPipelineDefinitionInput) (req *request.Request, output *PutPipelineDefinitionOutput)

+ func (c *DataPipeline) QueryObjects(input *QueryObjectsInput) (*QueryObjectsOutput, error)

+ func (c *DataPipeline) QueryObjectsPages(input *QueryObjectsInput, ...) error

+ func (c *DataPipeline) QueryObjectsRequest(input *QueryObjectsInput) (req *request.Request, output *QueryObjectsOutput)

+ func (c *DataPipeline) RemoveTags(input *RemoveTagsInput) (*RemoveTagsOutput, error)

+ func (c *DataPipeline) RemoveTagsRequest(input *RemoveTagsInput) (req *request.Request, output *RemoveTagsOutput)

+ func (c *DataPipeline) ReportTaskProgress(input *ReportTaskProgressInput) (*ReportTaskProgressOutput, error)

+ func (c *DataPipeline) ReportTaskProgressRequest(input *ReportTaskProgressInput) (req *request.Request, output *ReportTaskProgressOutput)

+ func (c *DataPipeline) ReportTaskRunnerHeartbeat(input *ReportTaskRunnerHeartbeatInput) (*ReportTaskRunnerHeartbeatOutput, error)

+ func (c *DataPipeline) ReportTaskRunnerHeartbeatRequest(input *ReportTaskRunnerHeartbeatInput) (req *request.Request, output *ReportTaskRunnerHeartbeatOutput)

+ func (c *DataPipeline) SetStatus(input *SetStatusInput) (*SetStatusOutput, error)

+ func (c *DataPipeline) SetStatusRequest(input *SetStatusInput) (req *request.Request, output *SetStatusOutput)

+ func (c *DataPipeline) SetTaskStatus(input *SetTaskStatusInput) (*SetTaskStatusOutput, error)

+ func (c *DataPipeline) SetTaskStatusRequest(input *SetTaskStatusInput) (req *request.Request, output *SetTaskStatusOutput)

+ func (c *DataPipeline) ValidatePipelineDefinition(input *ValidatePipelineDefinitionInput) (*ValidatePipelineDefinitionOutput, error)

+ func (c *DataPipeline) ValidatePipelineDefinitionRequest(input *ValidatePipelineDefinitionInput) (req *request.Request, output *ValidatePipelineDefinitionOutput)

+ type DeactivatePipelineInput struct

+ CancelActive *bool

+ PipelineId *string

+ func (s DeactivatePipelineInput) GoString() string

+ func (s DeactivatePipelineInput) String() string

+ type DeactivatePipelineOutput struct

+ func (s DeactivatePipelineOutput) GoString() string

+ func (s DeactivatePipelineOutput) String() string

+ type DeletePipelineInput struct

+ PipelineId *string

+ func (s DeletePipelineInput) GoString() string

+ func (s DeletePipelineInput) String() string

+ type DeletePipelineOutput struct

+ func (s DeletePipelineOutput) GoString() string

+ func (s DeletePipelineOutput) String() string

+ type DescribeObjectsInput struct

+ EvaluateExpressions *bool

+ Marker *string

+ ObjectIds []*string

+ PipelineId *string

+ func (s DescribeObjectsInput) GoString() string

+ func (s DescribeObjectsInput) String() string

+ type DescribeObjectsOutput struct

+ HasMoreResults *bool

+ Marker *string

+ PipelineObjects []*PipelineObject

+ func (s DescribeObjectsOutput) GoString() string

+ func (s DescribeObjectsOutput) String() string

+ type DescribePipelinesInput struct

+ PipelineIds []*string

+ func (s DescribePipelinesInput) GoString() string

+ func (s DescribePipelinesInput) String() string

+ type DescribePipelinesOutput struct

+ PipelineDescriptionList []*PipelineDescription

+ func (s DescribePipelinesOutput) GoString() string

+ func (s DescribePipelinesOutput) String() string

+ type EvaluateExpressionInput struct

+ Expression *string

+ ObjectId *string

+ PipelineId *string

+ func (s EvaluateExpressionInput) GoString() string

+ func (s EvaluateExpressionInput) String() string

+ type EvaluateExpressionOutput struct

+ EvaluatedExpression *string

+ func (s EvaluateExpressionOutput) GoString() string

+ func (s EvaluateExpressionOutput) String() string

+ type Field struct

+ Key *string

+ RefValue *string

+ StringValue *string

+ func (s Field) GoString() string

+ func (s Field) String() string

+ type GetPipelineDefinitionInput struct

+ PipelineId *string

+ Version *string

+ func (s GetPipelineDefinitionInput) GoString() string

+ func (s GetPipelineDefinitionInput) String() string

+ type GetPipelineDefinitionOutput struct

+ ParameterObjects []*ParameterObject

+ ParameterValues []*ParameterValue

+ PipelineObjects []*PipelineObject

+ func (s GetPipelineDefinitionOutput) GoString() string

+ func (s GetPipelineDefinitionOutput) String() string

+ type InstanceIdentity struct

+ Document *string

+ Signature *string

+ func (s InstanceIdentity) GoString() string

+ func (s InstanceIdentity) String() string

+ type ListPipelinesInput struct

+ Marker *string

+ func (s ListPipelinesInput) GoString() string

+ func (s ListPipelinesInput) String() string

+ type ListPipelinesOutput struct

+ HasMoreResults *bool

+ Marker *string

+ PipelineIdList []*PipelineIdName

+ func (s ListPipelinesOutput) GoString() string

+ func (s ListPipelinesOutput) String() string

+ type Operator struct

+ Type *string

+ Values []*string

+ func (s Operator) GoString() string

+ func (s Operator) String() string

+ type ParameterAttribute struct

+ Key *string

+ StringValue *string

+ func (s ParameterAttribute) GoString() string

+ func (s ParameterAttribute) String() string

+ type ParameterObject struct

+ Attributes []*ParameterAttribute

+ Id *string

+ func (s ParameterObject) GoString() string

+ func (s ParameterObject) String() string

+ type ParameterValue struct

+ Id *string

+ StringValue *string

+ func (s ParameterValue) GoString() string

+ func (s ParameterValue) String() string

+ type PipelineDescription struct

+ Description *string

+ Fields []*Field

+ Name *string

+ PipelineId *string

+ Tags []*Tag

+ func (s PipelineDescription) GoString() string

+ func (s PipelineDescription) String() string

+ type PipelineIdName struct

+ Id *string

+ Name *string

+ func (s PipelineIdName) GoString() string

+ func (s PipelineIdName) String() string

+ type PipelineObject struct

+ Fields []*Field

+ Id *string

+ Name *string

+ func (s PipelineObject) GoString() string

+ func (s PipelineObject) String() string

+ type PollForTaskInput struct

+ Hostname *string

+ InstanceIdentity *InstanceIdentity

+ WorkerGroup *string

+ func (s PollForTaskInput) GoString() string

+ func (s PollForTaskInput) String() string

+ type PollForTaskOutput struct

+ TaskObject *TaskObject

+ func (s PollForTaskOutput) GoString() string

+ func (s PollForTaskOutput) String() string

+ type PutPipelineDefinitionInput struct

+ ParameterObjects []*ParameterObject

+ ParameterValues []*ParameterValue

+ PipelineId *string

+ PipelineObjects []*PipelineObject

+ func (s PutPipelineDefinitionInput) GoString() string

+ func (s PutPipelineDefinitionInput) String() string

+ type PutPipelineDefinitionOutput struct

+ Errored *bool

+ ValidationErrors []*ValidationError

+ ValidationWarnings []*ValidationWarning

+ func (s PutPipelineDefinitionOutput) GoString() string

+ func (s PutPipelineDefinitionOutput) String() string

+ type Query struct

+ Selectors []*Selector

+ func (s Query) GoString() string

+ func (s Query) String() string

+ type QueryObjectsInput struct

+ Limit *int64

+ Marker *string

+ PipelineId *string

+ Query *Query

+ Sphere *string

+ func (s QueryObjectsInput) GoString() string

+ func (s QueryObjectsInput) String() string

+ type QueryObjectsOutput struct

+ HasMoreResults *bool

+ Ids []*string

+ Marker *string

+ func (s QueryObjectsOutput) GoString() string

+ func (s QueryObjectsOutput) String() string

+ type RemoveTagsInput struct

+ PipelineId *string

+ TagKeys []*string

+ func (s RemoveTagsInput) GoString() string

+ func (s RemoveTagsInput) String() string

+ type RemoveTagsOutput struct

+ func (s RemoveTagsOutput) GoString() string

+ func (s RemoveTagsOutput) String() string

+ type ReportTaskProgressInput struct

+ Fields []*Field

+ TaskId *string

+ func (s ReportTaskProgressInput) GoString() string

+ func (s ReportTaskProgressInput) String() string

+ type ReportTaskProgressOutput struct

+ Canceled *bool

+ func (s ReportTaskProgressOutput) GoString() string

+ func (s ReportTaskProgressOutput) String() string

+ type ReportTaskRunnerHeartbeatInput struct

+ Hostname *string

+ TaskrunnerId *string

+ WorkerGroup *string

+ func (s ReportTaskRunnerHeartbeatInput) GoString() string

+ func (s ReportTaskRunnerHeartbeatInput) String() string

+ type ReportTaskRunnerHeartbeatOutput struct

+ Terminate *bool

+ func (s ReportTaskRunnerHeartbeatOutput) GoString() string

+ func (s ReportTaskRunnerHeartbeatOutput) String() string

+ type Selector struct

+ FieldName *string

+ Operator *Operator

+ func (s Selector) GoString() string

+ func (s Selector) String() string

+ type SetStatusInput struct

+ ObjectIds []*string

+ PipelineId *string

+ Status *string

+ func (s SetStatusInput) GoString() string

+ func (s SetStatusInput) String() string

+ type SetStatusOutput struct

+ func (s SetStatusOutput) GoString() string

+ func (s SetStatusOutput) String() string

+ type SetTaskStatusInput struct

+ ErrorId *string

+ ErrorMessage *string

+ ErrorStackTrace *string

+ TaskId *string

+ TaskStatus *string

+ func (s SetTaskStatusInput) GoString() string

+ func (s SetTaskStatusInput) String() string

+ type SetTaskStatusOutput struct

+ func (s SetTaskStatusOutput) GoString() string

+ func (s SetTaskStatusOutput) String() string

+ type Tag struct

+ Key *string

+ Value *string

+ func (s Tag) GoString() string

+ func (s Tag) String() string

+ type TaskObject struct

+ AttemptId *string

+ Objects map[string]*PipelineObject

+ PipelineId *string

+ TaskId *string

+ func (s TaskObject) GoString() string

+ func (s TaskObject) String() string

+ type ValidatePipelineDefinitionInput struct

+ ParameterObjects []*ParameterObject

+ ParameterValues []*ParameterValue

+ PipelineId *string

+ PipelineObjects []*PipelineObject

+ func (s ValidatePipelineDefinitionInput) GoString() string

+ func (s ValidatePipelineDefinitionInput) String() string

+ type ValidatePipelineDefinitionOutput struct

+ Errored *bool

+ ValidationErrors []*ValidationError

+ ValidationWarnings []*ValidationWarning

+ func (s ValidatePipelineDefinitionOutput) GoString() string

+ func (s ValidatePipelineDefinitionOutput) String() string

+ type ValidationError struct

+ Errors []*string

+ Id *string

+ func (s ValidationError) GoString() string

+ func (s ValidationError) String() string

+ type ValidationWarning struct

+ Id *string

+ Warnings []*string

+ func (s ValidationWarning) GoString() string

+ func (s ValidationWarning) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL