Versions in this module Expand all Collapse all v1 v1.0.1 Jul 4, 2024 v1.0.0 Jul 4, 2024 Changes in this version + const EndpointsID + const ErrCodeInternalServiceError + const ErrCodeInvalidRequestException + const ErrCodePipelineDeletedException + const ErrCodePipelineNotFoundException + const ErrCodeTaskNotFoundException + const OperatorTypeBetween + const OperatorTypeEq + const OperatorTypeGe + const OperatorTypeLe + const OperatorTypeRefEq + const ServiceID + const ServiceName + const TaskStatusFailed + const TaskStatusFalse + const TaskStatusFinished + func OperatorType_Values() []string + func TaskStatus_Values() []string + type ActivatePipelineInput struct + ParameterValues []*ParameterValue + PipelineId *string + StartTimestamp *time.Time + func (s *ActivatePipelineInput) SetParameterValues(v []*ParameterValue) *ActivatePipelineInput + func (s *ActivatePipelineInput) SetPipelineId(v string) *ActivatePipelineInput + func (s *ActivatePipelineInput) SetStartTimestamp(v time.Time) *ActivatePipelineInput + func (s *ActivatePipelineInput) Validate() error + 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) SetPipelineId(v string) *AddTagsInput + func (s *AddTagsInput) SetTags(v []*Tag) *AddTagsInput + func (s *AddTagsInput) Validate() error + 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) 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 + func (s *CreatePipelineInput) Validate() error + func (s CreatePipelineInput) GoString() string + func (s CreatePipelineInput) String() string + type CreatePipelineOutput struct + PipelineId *string + func (s *CreatePipelineOutput) SetPipelineId(v string) *CreatePipelineOutput + 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) ActivatePipelineWithContext(ctx aws.Context, input *ActivatePipelineInput, opts ...request.Option) (*ActivatePipelineOutput, error) + func (c *DataPipeline) AddTags(input *AddTagsInput) (*AddTagsOutput, error) + func (c *DataPipeline) AddTagsRequest(input *AddTagsInput) (req *request.Request, output *AddTagsOutput) + func (c *DataPipeline) AddTagsWithContext(ctx aws.Context, input *AddTagsInput, opts ...request.Option) (*AddTagsOutput, error) + func (c *DataPipeline) CreatePipeline(input *CreatePipelineInput) (*CreatePipelineOutput, error) + func (c *DataPipeline) CreatePipelineRequest(input *CreatePipelineInput) (req *request.Request, output *CreatePipelineOutput) + func (c *DataPipeline) CreatePipelineWithContext(ctx aws.Context, input *CreatePipelineInput, opts ...request.Option) (*CreatePipelineOutput, error) + func (c *DataPipeline) DeactivatePipeline(input *DeactivatePipelineInput) (*DeactivatePipelineOutput, error) + func (c *DataPipeline) DeactivatePipelineRequest(input *DeactivatePipelineInput) (req *request.Request, output *DeactivatePipelineOutput) + func (c *DataPipeline) DeactivatePipelineWithContext(ctx aws.Context, input *DeactivatePipelineInput, opts ...request.Option) (*DeactivatePipelineOutput, error) + func (c *DataPipeline) DeletePipeline(input *DeletePipelineInput) (*DeletePipelineOutput, error) + func (c *DataPipeline) DeletePipelineRequest(input *DeletePipelineInput) (req *request.Request, output *DeletePipelineOutput) + func (c *DataPipeline) DeletePipelineWithContext(ctx aws.Context, input *DeletePipelineInput, opts ...request.Option) (*DeletePipelineOutput, error) + func (c *DataPipeline) DescribeObjects(input *DescribeObjectsInput) (*DescribeObjectsOutput, error) + func (c *DataPipeline) DescribeObjectsPages(input *DescribeObjectsInput, fn func(*DescribeObjectsOutput, bool) bool) error + func (c *DataPipeline) DescribeObjectsPagesWithContext(ctx aws.Context, input *DescribeObjectsInput, ...) error + func (c *DataPipeline) DescribeObjectsRequest(input *DescribeObjectsInput) (req *request.Request, output *DescribeObjectsOutput) + func (c *DataPipeline) DescribeObjectsWithContext(ctx aws.Context, input *DescribeObjectsInput, opts ...request.Option) (*DescribeObjectsOutput, error) + func (c *DataPipeline) DescribePipelines(input *DescribePipelinesInput) (*DescribePipelinesOutput, error) + func (c *DataPipeline) DescribePipelinesRequest(input *DescribePipelinesInput) (req *request.Request, output *DescribePipelinesOutput) + func (c *DataPipeline) DescribePipelinesWithContext(ctx aws.Context, input *DescribePipelinesInput, opts ...request.Option) (*DescribePipelinesOutput, error) + func (c *DataPipeline) EvaluateExpression(input *EvaluateExpressionInput) (*EvaluateExpressionOutput, error) + func (c *DataPipeline) EvaluateExpressionRequest(input *EvaluateExpressionInput) (req *request.Request, output *EvaluateExpressionOutput) + func (c *DataPipeline) EvaluateExpressionWithContext(ctx aws.Context, input *EvaluateExpressionInput, opts ...request.Option) (*EvaluateExpressionOutput, error) + func (c *DataPipeline) GetPipelineDefinition(input *GetPipelineDefinitionInput) (*GetPipelineDefinitionOutput, error) + func (c *DataPipeline) GetPipelineDefinitionRequest(input *GetPipelineDefinitionInput) (req *request.Request, output *GetPipelineDefinitionOutput) + func (c *DataPipeline) GetPipelineDefinitionWithContext(ctx aws.Context, input *GetPipelineDefinitionInput, opts ...request.Option) (*GetPipelineDefinitionOutput, error) + func (c *DataPipeline) ListPipelines(input *ListPipelinesInput) (*ListPipelinesOutput, error) + func (c *DataPipeline) ListPipelinesPages(input *ListPipelinesInput, fn func(*ListPipelinesOutput, bool) bool) error + func (c *DataPipeline) ListPipelinesPagesWithContext(ctx aws.Context, input *ListPipelinesInput, ...) error + func (c *DataPipeline) ListPipelinesRequest(input *ListPipelinesInput) (req *request.Request, output *ListPipelinesOutput) + func (c *DataPipeline) ListPipelinesWithContext(ctx aws.Context, input *ListPipelinesInput, opts ...request.Option) (*ListPipelinesOutput, error) + func (c *DataPipeline) PollForTask(input *PollForTaskInput) (*PollForTaskOutput, error) + func (c *DataPipeline) PollForTaskRequest(input *PollForTaskInput) (req *request.Request, output *PollForTaskOutput) + func (c *DataPipeline) PollForTaskWithContext(ctx aws.Context, input *PollForTaskInput, opts ...request.Option) (*PollForTaskOutput, error) + func (c *DataPipeline) PutPipelineDefinition(input *PutPipelineDefinitionInput) (*PutPipelineDefinitionOutput, error) + func (c *DataPipeline) PutPipelineDefinitionRequest(input *PutPipelineDefinitionInput) (req *request.Request, output *PutPipelineDefinitionOutput) + func (c *DataPipeline) PutPipelineDefinitionWithContext(ctx aws.Context, input *PutPipelineDefinitionInput, opts ...request.Option) (*PutPipelineDefinitionOutput, error) + func (c *DataPipeline) QueryObjects(input *QueryObjectsInput) (*QueryObjectsOutput, error) + func (c *DataPipeline) QueryObjectsPages(input *QueryObjectsInput, fn func(*QueryObjectsOutput, bool) bool) error + func (c *DataPipeline) QueryObjectsPagesWithContext(ctx aws.Context, input *QueryObjectsInput, ...) error + func (c *DataPipeline) QueryObjectsRequest(input *QueryObjectsInput) (req *request.Request, output *QueryObjectsOutput) + func (c *DataPipeline) QueryObjectsWithContext(ctx aws.Context, input *QueryObjectsInput, opts ...request.Option) (*QueryObjectsOutput, error) + func (c *DataPipeline) RemoveTags(input *RemoveTagsInput) (*RemoveTagsOutput, error) + func (c *DataPipeline) RemoveTagsRequest(input *RemoveTagsInput) (req *request.Request, output *RemoveTagsOutput) + func (c *DataPipeline) RemoveTagsWithContext(ctx aws.Context, input *RemoveTagsInput, opts ...request.Option) (*RemoveTagsOutput, error) + func (c *DataPipeline) ReportTaskProgress(input *ReportTaskProgressInput) (*ReportTaskProgressOutput, error) + func (c *DataPipeline) ReportTaskProgressRequest(input *ReportTaskProgressInput) (req *request.Request, output *ReportTaskProgressOutput) + func (c *DataPipeline) ReportTaskProgressWithContext(ctx aws.Context, input *ReportTaskProgressInput, opts ...request.Option) (*ReportTaskProgressOutput, error) + func (c *DataPipeline) ReportTaskRunnerHeartbeat(input *ReportTaskRunnerHeartbeatInput) (*ReportTaskRunnerHeartbeatOutput, error) + func (c *DataPipeline) ReportTaskRunnerHeartbeatRequest(input *ReportTaskRunnerHeartbeatInput) (req *request.Request, output *ReportTaskRunnerHeartbeatOutput) + func (c *DataPipeline) ReportTaskRunnerHeartbeatWithContext(ctx aws.Context, input *ReportTaskRunnerHeartbeatInput, opts ...request.Option) (*ReportTaskRunnerHeartbeatOutput, error) + func (c *DataPipeline) SetStatus(input *SetStatusInput) (*SetStatusOutput, error) + func (c *DataPipeline) SetStatusRequest(input *SetStatusInput) (req *request.Request, output *SetStatusOutput) + func (c *DataPipeline) SetStatusWithContext(ctx aws.Context, input *SetStatusInput, opts ...request.Option) (*SetStatusOutput, error) + func (c *DataPipeline) SetTaskStatus(input *SetTaskStatusInput) (*SetTaskStatusOutput, error) + func (c *DataPipeline) SetTaskStatusRequest(input *SetTaskStatusInput) (req *request.Request, output *SetTaskStatusOutput) + func (c *DataPipeline) SetTaskStatusWithContext(ctx aws.Context, input *SetTaskStatusInput, opts ...request.Option) (*SetTaskStatusOutput, error) + func (c *DataPipeline) ValidatePipelineDefinition(input *ValidatePipelineDefinitionInput) (*ValidatePipelineDefinitionOutput, error) + func (c *DataPipeline) ValidatePipelineDefinitionRequest(input *ValidatePipelineDefinitionInput) (req *request.Request, output *ValidatePipelineDefinitionOutput) + func (c *DataPipeline) ValidatePipelineDefinitionWithContext(ctx aws.Context, input *ValidatePipelineDefinitionInput, ...) (*ValidatePipelineDefinitionOutput, error) + type DeactivatePipelineInput struct + CancelActive *bool + PipelineId *string + func (s *DeactivatePipelineInput) SetCancelActive(v bool) *DeactivatePipelineInput + func (s *DeactivatePipelineInput) SetPipelineId(v string) *DeactivatePipelineInput + func (s *DeactivatePipelineInput) Validate() error + 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) SetPipelineId(v string) *DeletePipelineInput + func (s *DeletePipelineInput) Validate() error + 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) 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 + func (s *DescribeObjectsInput) Validate() error + func (s DescribeObjectsInput) GoString() string + func (s DescribeObjectsInput) String() string + type DescribeObjectsOutput struct + HasMoreResults *bool + Marker *string + PipelineObjects []*PipelineObject + func (s *DescribeObjectsOutput) SetHasMoreResults(v bool) *DescribeObjectsOutput + func (s *DescribeObjectsOutput) SetMarker(v string) *DescribeObjectsOutput + func (s *DescribeObjectsOutput) SetPipelineObjects(v []*PipelineObject) *DescribeObjectsOutput + func (s DescribeObjectsOutput) GoString() string + func (s DescribeObjectsOutput) String() string + type DescribePipelinesInput struct + PipelineIds []*string + func (s *DescribePipelinesInput) SetPipelineIds(v []*string) *DescribePipelinesInput + func (s *DescribePipelinesInput) Validate() error + func (s DescribePipelinesInput) GoString() string + func (s DescribePipelinesInput) String() string + type DescribePipelinesOutput struct + PipelineDescriptionList []*PipelineDescription + func (s *DescribePipelinesOutput) SetPipelineDescriptionList(v []*PipelineDescription) *DescribePipelinesOutput + func (s DescribePipelinesOutput) GoString() string + func (s DescribePipelinesOutput) String() string + type EvaluateExpressionInput struct + Expression *string + ObjectId *string + PipelineId *string + func (s *EvaluateExpressionInput) SetExpression(v string) *EvaluateExpressionInput + func (s *EvaluateExpressionInput) SetObjectId(v string) *EvaluateExpressionInput + func (s *EvaluateExpressionInput) SetPipelineId(v string) *EvaluateExpressionInput + func (s *EvaluateExpressionInput) Validate() error + func (s EvaluateExpressionInput) GoString() string + func (s EvaluateExpressionInput) String() string + type EvaluateExpressionOutput struct + EvaluatedExpression *string + func (s *EvaluateExpressionOutput) SetEvaluatedExpression(v string) *EvaluateExpressionOutput + func (s EvaluateExpressionOutput) GoString() string + func (s EvaluateExpressionOutput) String() string + type Field struct + Key *string + RefValue *string + StringValue *string + func (s *Field) SetKey(v string) *Field + func (s *Field) SetRefValue(v string) *Field + func (s *Field) SetStringValue(v string) *Field + func (s *Field) Validate() error + func (s Field) GoString() string + func (s Field) String() string + type GetPipelineDefinitionInput struct + PipelineId *string + Version *string + func (s *GetPipelineDefinitionInput) SetPipelineId(v string) *GetPipelineDefinitionInput + func (s *GetPipelineDefinitionInput) SetVersion(v string) *GetPipelineDefinitionInput + func (s *GetPipelineDefinitionInput) Validate() error + func (s GetPipelineDefinitionInput) GoString() string + func (s GetPipelineDefinitionInput) String() string + type GetPipelineDefinitionOutput struct + ParameterObjects []*ParameterObject + ParameterValues []*ParameterValue + PipelineObjects []*PipelineObject + func (s *GetPipelineDefinitionOutput) SetParameterObjects(v []*ParameterObject) *GetPipelineDefinitionOutput + func (s *GetPipelineDefinitionOutput) SetParameterValues(v []*ParameterValue) *GetPipelineDefinitionOutput + func (s *GetPipelineDefinitionOutput) SetPipelineObjects(v []*PipelineObject) *GetPipelineDefinitionOutput + func (s GetPipelineDefinitionOutput) GoString() string + func (s GetPipelineDefinitionOutput) String() string + type InstanceIdentity struct + Document *string + Signature *string + func (s *InstanceIdentity) SetDocument(v string) *InstanceIdentity + func (s *InstanceIdentity) SetSignature(v string) *InstanceIdentity + func (s InstanceIdentity) GoString() string + func (s InstanceIdentity) String() string + type InternalServiceError struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *InternalServiceError) Code() string + func (s *InternalServiceError) Error() string + func (s *InternalServiceError) Message() string + func (s *InternalServiceError) OrigErr() error + func (s *InternalServiceError) RequestID() string + func (s *InternalServiceError) StatusCode() int + func (s InternalServiceError) GoString() string + func (s InternalServiceError) String() string + type InvalidRequestException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *InvalidRequestException) Code() string + func (s *InvalidRequestException) Error() string + func (s *InvalidRequestException) Message() string + func (s *InvalidRequestException) OrigErr() error + func (s *InvalidRequestException) RequestID() string + func (s *InvalidRequestException) StatusCode() int + func (s InvalidRequestException) GoString() string + func (s InvalidRequestException) String() string + type ListPipelinesInput struct + Marker *string + func (s *ListPipelinesInput) SetMarker(v string) *ListPipelinesInput + func (s ListPipelinesInput) GoString() string + func (s ListPipelinesInput) String() string + type ListPipelinesOutput struct + HasMoreResults *bool + Marker *string + PipelineIdList []*PipelineIdName + func (s *ListPipelinesOutput) SetHasMoreResults(v bool) *ListPipelinesOutput + func (s *ListPipelinesOutput) SetMarker(v string) *ListPipelinesOutput + func (s *ListPipelinesOutput) SetPipelineIdList(v []*PipelineIdName) *ListPipelinesOutput + func (s ListPipelinesOutput) GoString() string + func (s ListPipelinesOutput) String() string + type Operator struct + Type *string + Values []*string + func (s *Operator) SetType(v string) *Operator + func (s *Operator) SetValues(v []*string) *Operator + func (s Operator) GoString() string + func (s Operator) String() string + type ParameterAttribute struct + Key *string + StringValue *string + func (s *ParameterAttribute) SetKey(v string) *ParameterAttribute + func (s *ParameterAttribute) SetStringValue(v string) *ParameterAttribute + func (s *ParameterAttribute) Validate() error + func (s ParameterAttribute) GoString() string + func (s ParameterAttribute) String() string + type ParameterObject struct + Attributes []*ParameterAttribute + Id *string + func (s *ParameterObject) SetAttributes(v []*ParameterAttribute) *ParameterObject + func (s *ParameterObject) SetId(v string) *ParameterObject + func (s *ParameterObject) Validate() error + func (s ParameterObject) GoString() string + func (s ParameterObject) String() string + type ParameterValue struct + Id *string + StringValue *string + func (s *ParameterValue) SetId(v string) *ParameterValue + func (s *ParameterValue) SetStringValue(v string) *ParameterValue + func (s *ParameterValue) Validate() error + func (s ParameterValue) GoString() string + func (s ParameterValue) String() string + type PipelineDeletedException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *PipelineDeletedException) Code() string + func (s *PipelineDeletedException) Error() string + func (s *PipelineDeletedException) Message() string + func (s *PipelineDeletedException) OrigErr() error + func (s *PipelineDeletedException) RequestID() string + func (s *PipelineDeletedException) StatusCode() int + func (s PipelineDeletedException) GoString() string + func (s PipelineDeletedException) String() string + type PipelineDescription struct + Description *string + Fields []*Field + Name *string + PipelineId *string + Tags []*Tag + 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 + func (s PipelineDescription) GoString() string + func (s PipelineDescription) String() string + type PipelineIdName struct + Id *string + Name *string + func (s *PipelineIdName) SetId(v string) *PipelineIdName + func (s *PipelineIdName) SetName(v string) *PipelineIdName + func (s PipelineIdName) GoString() string + func (s PipelineIdName) String() string + type PipelineNotFoundException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *PipelineNotFoundException) Code() string + func (s *PipelineNotFoundException) Error() string + func (s *PipelineNotFoundException) Message() string + func (s *PipelineNotFoundException) OrigErr() error + func (s *PipelineNotFoundException) RequestID() string + func (s *PipelineNotFoundException) StatusCode() int + func (s PipelineNotFoundException) GoString() string + func (s PipelineNotFoundException) String() string + type PipelineObject struct + Fields []*Field + Id *string + Name *string + func (s *PipelineObject) SetFields(v []*Field) *PipelineObject + func (s *PipelineObject) SetId(v string) *PipelineObject + func (s *PipelineObject) SetName(v string) *PipelineObject + func (s *PipelineObject) Validate() error + func (s PipelineObject) GoString() string + func (s PipelineObject) String() string + type PollForTaskInput struct + Hostname *string + InstanceIdentity *InstanceIdentity + WorkerGroup *string + func (s *PollForTaskInput) SetHostname(v string) *PollForTaskInput + func (s *PollForTaskInput) SetInstanceIdentity(v *InstanceIdentity) *PollForTaskInput + func (s *PollForTaskInput) SetWorkerGroup(v string) *PollForTaskInput + func (s *PollForTaskInput) Validate() error + func (s PollForTaskInput) GoString() string + func (s PollForTaskInput) String() string + type PollForTaskOutput struct + TaskObject *TaskObject + func (s *PollForTaskOutput) SetTaskObject(v *TaskObject) *PollForTaskOutput + func (s PollForTaskOutput) GoString() string + func (s PollForTaskOutput) String() string + type PutPipelineDefinitionInput struct + ParameterObjects []*ParameterObject + ParameterValues []*ParameterValue + PipelineId *string + PipelineObjects []*PipelineObject + 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 + func (s *PutPipelineDefinitionInput) Validate() error + func (s PutPipelineDefinitionInput) GoString() string + func (s PutPipelineDefinitionInput) String() string + type PutPipelineDefinitionOutput struct + Errored *bool + ValidationErrors []*ValidationError + ValidationWarnings []*ValidationWarning + func (s *PutPipelineDefinitionOutput) SetErrored(v bool) *PutPipelineDefinitionOutput + func (s *PutPipelineDefinitionOutput) SetValidationErrors(v []*ValidationError) *PutPipelineDefinitionOutput + func (s *PutPipelineDefinitionOutput) SetValidationWarnings(v []*ValidationWarning) *PutPipelineDefinitionOutput + func (s PutPipelineDefinitionOutput) GoString() string + func (s PutPipelineDefinitionOutput) String() string + type Query struct + Selectors []*Selector + func (s *Query) SetSelectors(v []*Selector) *Query + 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) 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 + func (s *QueryObjectsInput) Validate() error + func (s QueryObjectsInput) GoString() string + func (s QueryObjectsInput) String() string + type QueryObjectsOutput struct + HasMoreResults *bool + Ids []*string + Marker *string + func (s *QueryObjectsOutput) SetHasMoreResults(v bool) *QueryObjectsOutput + func (s *QueryObjectsOutput) SetIds(v []*string) *QueryObjectsOutput + func (s *QueryObjectsOutput) SetMarker(v string) *QueryObjectsOutput + func (s QueryObjectsOutput) GoString() string + func (s QueryObjectsOutput) String() string + type RemoveTagsInput struct + PipelineId *string + TagKeys []*string + func (s *RemoveTagsInput) SetPipelineId(v string) *RemoveTagsInput + func (s *RemoveTagsInput) SetTagKeys(v []*string) *RemoveTagsInput + func (s *RemoveTagsInput) Validate() error + 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) SetFields(v []*Field) *ReportTaskProgressInput + func (s *ReportTaskProgressInput) SetTaskId(v string) *ReportTaskProgressInput + func (s *ReportTaskProgressInput) Validate() error + func (s ReportTaskProgressInput) GoString() string + func (s ReportTaskProgressInput) String() string + type ReportTaskProgressOutput struct + Canceled *bool + func (s *ReportTaskProgressOutput) SetCanceled(v bool) *ReportTaskProgressOutput + func (s ReportTaskProgressOutput) GoString() string + func (s ReportTaskProgressOutput) String() string + type ReportTaskRunnerHeartbeatInput struct + Hostname *string + TaskrunnerId *string + WorkerGroup *string + func (s *ReportTaskRunnerHeartbeatInput) SetHostname(v string) *ReportTaskRunnerHeartbeatInput + func (s *ReportTaskRunnerHeartbeatInput) SetTaskrunnerId(v string) *ReportTaskRunnerHeartbeatInput + func (s *ReportTaskRunnerHeartbeatInput) SetWorkerGroup(v string) *ReportTaskRunnerHeartbeatInput + func (s *ReportTaskRunnerHeartbeatInput) Validate() error + func (s ReportTaskRunnerHeartbeatInput) GoString() string + func (s ReportTaskRunnerHeartbeatInput) String() string + type ReportTaskRunnerHeartbeatOutput struct + Terminate *bool + func (s *ReportTaskRunnerHeartbeatOutput) SetTerminate(v bool) *ReportTaskRunnerHeartbeatOutput + func (s ReportTaskRunnerHeartbeatOutput) GoString() string + func (s ReportTaskRunnerHeartbeatOutput) String() string + type Selector struct + FieldName *string + Operator *Operator + func (s *Selector) SetFieldName(v string) *Selector + func (s *Selector) SetOperator(v *Operator) *Selector + func (s Selector) GoString() string + func (s Selector) String() string + type SetStatusInput struct + ObjectIds []*string + PipelineId *string + Status *string + func (s *SetStatusInput) SetObjectIds(v []*string) *SetStatusInput + func (s *SetStatusInput) SetPipelineId(v string) *SetStatusInput + func (s *SetStatusInput) SetStatus(v string) *SetStatusInput + func (s *SetStatusInput) Validate() error + 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) 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 + func (s *SetTaskStatusInput) Validate() error + 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) SetKey(v string) *Tag + func (s *Tag) SetValue(v string) *Tag + func (s *Tag) Validate() error + func (s Tag) GoString() string + func (s Tag) String() string + type TaskNotFoundException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *TaskNotFoundException) Code() string + func (s *TaskNotFoundException) Error() string + func (s *TaskNotFoundException) Message() string + func (s *TaskNotFoundException) OrigErr() error + func (s *TaskNotFoundException) RequestID() string + func (s *TaskNotFoundException) StatusCode() int + func (s TaskNotFoundException) GoString() string + func (s TaskNotFoundException) String() string + type TaskObject struct + AttemptId *string + Objects map[string]*PipelineObject + PipelineId *string + TaskId *string + 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 + func (s TaskObject) GoString() string + func (s TaskObject) String() string + type ValidatePipelineDefinitionInput struct + ParameterObjects []*ParameterObject + ParameterValues []*ParameterValue + PipelineId *string + PipelineObjects []*PipelineObject + 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 + func (s *ValidatePipelineDefinitionInput) Validate() error + func (s ValidatePipelineDefinitionInput) GoString() string + func (s ValidatePipelineDefinitionInput) String() string + type ValidatePipelineDefinitionOutput struct + Errored *bool + ValidationErrors []*ValidationError + ValidationWarnings []*ValidationWarning + func (s *ValidatePipelineDefinitionOutput) SetErrored(v bool) *ValidatePipelineDefinitionOutput + func (s *ValidatePipelineDefinitionOutput) SetValidationErrors(v []*ValidationError) *ValidatePipelineDefinitionOutput + func (s *ValidatePipelineDefinitionOutput) SetValidationWarnings(v []*ValidationWarning) *ValidatePipelineDefinitionOutput + func (s ValidatePipelineDefinitionOutput) GoString() string + func (s ValidatePipelineDefinitionOutput) String() string + type ValidationError struct + Errors []*string + Id *string + func (s *ValidationError) SetErrors(v []*string) *ValidationError + func (s *ValidationError) SetId(v string) *ValidationError + func (s ValidationError) GoString() string + func (s ValidationError) String() string + type ValidationWarning struct + Id *string + Warnings []*string + func (s *ValidationWarning) SetId(v string) *ValidationWarning + func (s *ValidationWarning) SetWarnings(v []*string) *ValidationWarning + func (s ValidationWarning) GoString() string + func (s ValidationWarning) String() string