Versions in this module Expand all Collapse all v0 v0.6.0 Jun 3, 2015 Changes in this version + type ActivatePipelineInput struct + ParameterValues []*ParameterValue + PipelineID *string + StartTimestamp *time.Time + type ActivatePipelineOutput struct + type AddTagsInput struct + PipelineID *string + Tags []*Tag + type AddTagsOutput struct + type CreatePipelineInput struct + Description *string + Name *string + Tags []*Tag + UniqueID *string + type CreatePipelineOutput struct + PipelineID *string + type DataPipeline struct + func New(config *aws.Config) *DataPipeline + func (c *DataPipeline) ActivatePipeline(input *ActivatePipelineInput) (*ActivatePipelineOutput, error) + func (c *DataPipeline) ActivatePipelineRequest(input *ActivatePipelineInput) (req *aws.Request, output *ActivatePipelineOutput) + func (c *DataPipeline) AddTags(input *AddTagsInput) (*AddTagsOutput, error) + func (c *DataPipeline) AddTagsRequest(input *AddTagsInput) (req *aws.Request, output *AddTagsOutput) + func (c *DataPipeline) CreatePipeline(input *CreatePipelineInput) (*CreatePipelineOutput, error) + func (c *DataPipeline) CreatePipelineRequest(input *CreatePipelineInput) (req *aws.Request, output *CreatePipelineOutput) + func (c *DataPipeline) DeactivatePipeline(input *DeactivatePipelineInput) (*DeactivatePipelineOutput, error) + func (c *DataPipeline) DeactivatePipelineRequest(input *DeactivatePipelineInput) (req *aws.Request, output *DeactivatePipelineOutput) + func (c *DataPipeline) DeletePipeline(input *DeletePipelineInput) (*DeletePipelineOutput, error) + func (c *DataPipeline) DeletePipelineRequest(input *DeletePipelineInput) (req *aws.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 *aws.Request, output *DescribeObjectsOutput) + func (c *DataPipeline) DescribePipelines(input *DescribePipelinesInput) (*DescribePipelinesOutput, error) + func (c *DataPipeline) DescribePipelinesRequest(input *DescribePipelinesInput) (req *aws.Request, output *DescribePipelinesOutput) + func (c *DataPipeline) EvaluateExpression(input *EvaluateExpressionInput) (*EvaluateExpressionOutput, error) + func (c *DataPipeline) EvaluateExpressionRequest(input *EvaluateExpressionInput) (req *aws.Request, output *EvaluateExpressionOutput) + func (c *DataPipeline) GetPipelineDefinition(input *GetPipelineDefinitionInput) (*GetPipelineDefinitionOutput, error) + func (c *DataPipeline) GetPipelineDefinitionRequest(input *GetPipelineDefinitionInput) (req *aws.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 *aws.Request, output *ListPipelinesOutput) + func (c *DataPipeline) PollForTask(input *PollForTaskInput) (*PollForTaskOutput, error) + func (c *DataPipeline) PollForTaskRequest(input *PollForTaskInput) (req *aws.Request, output *PollForTaskOutput) + func (c *DataPipeline) PutPipelineDefinition(input *PutPipelineDefinitionInput) (*PutPipelineDefinitionOutput, error) + func (c *DataPipeline) PutPipelineDefinitionRequest(input *PutPipelineDefinitionInput) (req *aws.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 *aws.Request, output *QueryObjectsOutput) + func (c *DataPipeline) RemoveTags(input *RemoveTagsInput) (*RemoveTagsOutput, error) + func (c *DataPipeline) RemoveTagsRequest(input *RemoveTagsInput) (req *aws.Request, output *RemoveTagsOutput) + func (c *DataPipeline) ReportTaskProgress(input *ReportTaskProgressInput) (*ReportTaskProgressOutput, error) + func (c *DataPipeline) ReportTaskProgressRequest(input *ReportTaskProgressInput) (req *aws.Request, output *ReportTaskProgressOutput) + func (c *DataPipeline) ReportTaskRunnerHeartbeat(input *ReportTaskRunnerHeartbeatInput) (*ReportTaskRunnerHeartbeatOutput, error) + func (c *DataPipeline) ReportTaskRunnerHeartbeatRequest(input *ReportTaskRunnerHeartbeatInput) (req *aws.Request, output *ReportTaskRunnerHeartbeatOutput) + func (c *DataPipeline) SetStatus(input *SetStatusInput) (*SetStatusOutput, error) + func (c *DataPipeline) SetStatusRequest(input *SetStatusInput) (req *aws.Request, output *SetStatusOutput) + func (c *DataPipeline) SetTaskStatus(input *SetTaskStatusInput) (*SetTaskStatusOutput, error) + func (c *DataPipeline) SetTaskStatusRequest(input *SetTaskStatusInput) (req *aws.Request, output *SetTaskStatusOutput) + func (c *DataPipeline) ValidatePipelineDefinition(input *ValidatePipelineDefinitionInput) (*ValidatePipelineDefinitionOutput, error) + func (c *DataPipeline) ValidatePipelineDefinitionRequest(input *ValidatePipelineDefinitionInput) (req *aws.Request, output *ValidatePipelineDefinitionOutput) + type DeactivatePipelineInput struct + CancelActive *bool + PipelineID *string + type DeactivatePipelineOutput struct + type DeletePipelineInput struct + PipelineID *string + type DeletePipelineOutput struct + type DescribeObjectsInput struct + EvaluateExpressions *bool + Marker *string + ObjectIDs []*string + PipelineID *string + type DescribeObjectsOutput struct + HasMoreResults *bool + Marker *string + PipelineObjects []*PipelineObject + type DescribePipelinesInput struct + PipelineIDs []*string + type DescribePipelinesOutput struct + PipelineDescriptionList []*PipelineDescription + type EvaluateExpressionInput struct + Expression *string + ObjectID *string + PipelineID *string + type EvaluateExpressionOutput struct + EvaluatedExpression *string + type Field struct + Key *string + RefValue *string + StringValue *string + type GetPipelineDefinitionInput struct + PipelineID *string + Version *string + type GetPipelineDefinitionOutput struct + ParameterObjects []*ParameterObject + ParameterValues []*ParameterValue + PipelineObjects []*PipelineObject + type InstanceIdentity struct + Document *string + Signature *string + type ListPipelinesInput struct + Marker *string + type ListPipelinesOutput struct + HasMoreResults *bool + Marker *string + PipelineIDList []*PipelineIDName + type Operator struct + Type *string + Values []*string + type ParameterAttribute struct + Key *string + StringValue *string + type ParameterObject struct + Attributes []*ParameterAttribute + ID *string + type ParameterValue struct + ID *string + StringValue *string + type PipelineDescription struct + Description *string + Fields []*Field + Name *string + PipelineID *string + Tags []*Tag + type PipelineIDName struct + ID *string + Name *string + type PipelineObject struct + Fields []*Field + ID *string + Name *string + type PollForTaskInput struct + Hostname *string + InstanceIdentity *InstanceIdentity + WorkerGroup *string + type PollForTaskOutput struct + TaskObject *TaskObject + type PutPipelineDefinitionInput struct + ParameterObjects []*ParameterObject + ParameterValues []*ParameterValue + PipelineID *string + PipelineObjects []*PipelineObject + type PutPipelineDefinitionOutput struct + Errored *bool + ValidationErrors []*ValidationError + ValidationWarnings []*ValidationWarning + type Query struct + Selectors []*Selector + type QueryObjectsInput struct + Limit *int64 + Marker *string + PipelineID *string + Query *Query + Sphere *string + type QueryObjectsOutput struct + HasMoreResults *bool + IDs []*string + Marker *string + type RemoveTagsInput struct + PipelineID *string + TagKeys []*string + type RemoveTagsOutput struct + type ReportTaskProgressInput struct + Fields []*Field + TaskID *string + type ReportTaskProgressOutput struct + Canceled *bool + type ReportTaskRunnerHeartbeatInput struct + Hostname *string + TaskRunnerID *string + WorkerGroup *string + type ReportTaskRunnerHeartbeatOutput struct + Terminate *bool + type Selector struct + FieldName *string + Operator *Operator + type SetStatusInput struct + ObjectIDs []*string + PipelineID *string + Status *string + type SetStatusOutput struct + type SetTaskStatusInput struct + ErrorID *string + ErrorMessage *string + ErrorStackTrace *string + TaskID *string + TaskStatus *string + type SetTaskStatusOutput struct + type Tag struct + Key *string + Value *string + type TaskObject struct + AttemptID *string + Objects map[string]*PipelineObject + PipelineID *string + TaskID *string + type ValidatePipelineDefinitionInput struct + ParameterObjects []*ParameterObject + ParameterValues []*ParameterValue + PipelineID *string + PipelineObjects []*PipelineObject + type ValidatePipelineDefinitionOutput struct + Errored *bool + ValidationErrors []*ValidationError + ValidationWarnings []*ValidationWarning + type ValidationError struct + Errors []*string + ID *string + type ValidationWarning struct + ID *string + Warnings []*string