datapipeline

package

Go to main page

Versions in this module

v0

v0.4.0

May 26, 2018

v0.3.0

Mar 8, 2018

Changes in this version

type ActivatePipelineRequest

+ Copy func(*ActivatePipelineInput) ActivatePipelineRequest

type AddTagsRequest

+ Copy func(*AddTagsInput) AddTagsRequest

type CreatePipelineRequest

+ Copy func(*CreatePipelineInput) CreatePipelineRequest

type DeactivatePipelineRequest

+ Copy func(*DeactivatePipelineInput) DeactivatePipelineRequest

type DeletePipelineRequest

+ Copy func(*DeletePipelineInput) DeletePipelineRequest

+ type DescribeObjectsPager struct

+ func (p *DescribeObjectsPager) CurrentPage() *DescribeObjectsOutput

type DescribeObjectsRequest

+ Copy func(*DescribeObjectsInput) DescribeObjectsRequest

+ func (p *DescribeObjectsRequest) Paginate(opts ...aws.Option) DescribeObjectsPager

type DescribePipelinesRequest

+ Copy func(*DescribePipelinesInput) DescribePipelinesRequest

type EvaluateExpressionRequest

+ Copy func(*EvaluateExpressionInput) EvaluateExpressionRequest

type GetPipelineDefinitionRequest

+ Copy func(*GetPipelineDefinitionInput) GetPipelineDefinitionRequest

+ type ListPipelinesPager struct

+ func (p *ListPipelinesPager) CurrentPage() *ListPipelinesOutput

type ListPipelinesRequest

+ Copy func(*ListPipelinesInput) ListPipelinesRequest

+ func (p *ListPipelinesRequest) Paginate(opts ...aws.Option) ListPipelinesPager

type OperatorType

+ func (enum OperatorType) MarshalValue() (string, error)

+ func (enum OperatorType) MarshalValueBuf(b []byte) ([]byte, error)

type PollForTaskRequest

+ Copy func(*PollForTaskInput) PollForTaskRequest

type PutPipelineDefinitionRequest

+ Copy func(*PutPipelineDefinitionInput) PutPipelineDefinitionRequest

+ type QueryObjectsPager struct

+ func (p *QueryObjectsPager) CurrentPage() *QueryObjectsOutput

type QueryObjectsRequest

+ Copy func(*QueryObjectsInput) QueryObjectsRequest

+ func (p *QueryObjectsRequest) Paginate(opts ...aws.Option) QueryObjectsPager

type RemoveTagsRequest

+ Copy func(*RemoveTagsInput) RemoveTagsRequest

type ReportTaskProgressRequest

+ Copy func(*ReportTaskProgressInput) ReportTaskProgressRequest

type ReportTaskRunnerHeartbeatRequest

+ Copy func(*ReportTaskRunnerHeartbeatInput) ReportTaskRunnerHeartbeatRequest

type SetStatusRequest

+ Copy func(*SetStatusInput) SetStatusRequest

type SetTaskStatusRequest

+ Copy func(*SetTaskStatusInput) SetTaskStatusRequest

type TaskStatus

+ func (enum TaskStatus) MarshalValue() (string, error)

+ func (enum TaskStatus) MarshalValueBuf(b []byte) ([]byte, error)

type ValidatePipelineDefinitionRequest

+ Copy func(*ValidatePipelineDefinitionInput) ValidatePipelineDefinitionRequest

v0.2.0

Jan 15, 2018

v0.1.0

Dec 21, 2017

Changes in this version

+ const EndpointsID

+ const ErrCodeInternalServiceError

+ const ErrCodeInvalidRequestException

+ const ErrCodePipelineDeletedException

+ const ErrCodePipelineNotFoundException

+ const ErrCodeTaskNotFoundException

+ const ServiceName

+ 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) SDKResponseMetadata() aws.Response

+ func (s ActivatePipelineOutput) String() string

+ type ActivatePipelineRequest struct

+ Input *ActivatePipelineInput

+ func (r ActivatePipelineRequest) Send() (*ActivatePipelineOutput, error)

+ 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) SDKResponseMetadata() aws.Response

+ func (s AddTagsOutput) String() string

+ type AddTagsRequest struct

+ Input *AddTagsInput

+ func (r AddTagsRequest) Send() (*AddTagsOutput, error)

+ 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) SDKResponseMetadata() aws.Response

+ func (s CreatePipelineOutput) String() string

+ type CreatePipelineRequest struct

+ Input *CreatePipelineInput

+ func (r CreatePipelineRequest) Send() (*CreatePipelineOutput, error)

+ type DataPipeline struct

+ func New(config aws.Config) *DataPipeline

+ func (c *DataPipeline) ActivatePipelineRequest(input *ActivatePipelineInput) ActivatePipelineRequest

+ func (c *DataPipeline) AddTagsRequest(input *AddTagsInput) AddTagsRequest

+ func (c *DataPipeline) CreatePipelineRequest(input *CreatePipelineInput) CreatePipelineRequest

+ func (c *DataPipeline) DeactivatePipelineRequest(input *DeactivatePipelineInput) DeactivatePipelineRequest

+ func (c *DataPipeline) DeletePipelineRequest(input *DeletePipelineInput) DeletePipelineRequest

+ 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) DescribeObjectsRequest

+ func (c *DataPipeline) DescribePipelinesRequest(input *DescribePipelinesInput) DescribePipelinesRequest

+ func (c *DataPipeline) EvaluateExpressionRequest(input *EvaluateExpressionInput) EvaluateExpressionRequest

+ func (c *DataPipeline) GetPipelineDefinitionRequest(input *GetPipelineDefinitionInput) GetPipelineDefinitionRequest

+ 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) ListPipelinesRequest

+ func (c *DataPipeline) PollForTaskRequest(input *PollForTaskInput) PollForTaskRequest

+ func (c *DataPipeline) PutPipelineDefinitionRequest(input *PutPipelineDefinitionInput) PutPipelineDefinitionRequest

+ 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) QueryObjectsRequest

+ func (c *DataPipeline) RemoveTagsRequest(input *RemoveTagsInput) RemoveTagsRequest

+ func (c *DataPipeline) ReportTaskProgressRequest(input *ReportTaskProgressInput) ReportTaskProgressRequest

+ func (c *DataPipeline) ReportTaskRunnerHeartbeatRequest(input *ReportTaskRunnerHeartbeatInput) ReportTaskRunnerHeartbeatRequest

+ func (c *DataPipeline) SetStatusRequest(input *SetStatusInput) SetStatusRequest

+ func (c *DataPipeline) SetTaskStatusRequest(input *SetTaskStatusInput) SetTaskStatusRequest

+ func (c *DataPipeline) ValidatePipelineDefinitionRequest(input *ValidatePipelineDefinitionInput) ValidatePipelineDefinitionRequest

+ 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) SDKResponseMetadata() aws.Response

+ func (s DeactivatePipelineOutput) String() string

+ type DeactivatePipelineRequest struct

+ Input *DeactivatePipelineInput

+ func (r DeactivatePipelineRequest) Send() (*DeactivatePipelineOutput, error)

+ 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) SDKResponseMetadata() aws.Response

+ func (s DeletePipelineOutput) String() string

+ type DeletePipelineRequest struct

+ Input *DeletePipelineInput

+ func (r DeletePipelineRequest) Send() (*DeletePipelineOutput, error)

+ 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) SDKResponseMetadata() aws.Response

+ func (s DescribeObjectsOutput) String() string

+ type DescribeObjectsRequest struct

+ Input *DescribeObjectsInput

+ func (r DescribeObjectsRequest) Send() (*DescribeObjectsOutput, error)

+ 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) SDKResponseMetadata() aws.Response

+ func (s DescribePipelinesOutput) String() string

+ type DescribePipelinesRequest struct

+ Input *DescribePipelinesInput

+ func (r DescribePipelinesRequest) Send() (*DescribePipelinesOutput, error)

+ 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) SDKResponseMetadata() aws.Response

+ func (s EvaluateExpressionOutput) String() string

+ type EvaluateExpressionRequest struct

+ Input *EvaluateExpressionInput

+ func (r EvaluateExpressionRequest) Send() (*EvaluateExpressionOutput, error)

+ 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) SDKResponseMetadata() aws.Response

+ func (s GetPipelineDefinitionOutput) String() string

+ type GetPipelineDefinitionRequest struct

+ Input *GetPipelineDefinitionInput

+ func (r GetPipelineDefinitionRequest) Send() (*GetPipelineDefinitionOutput, error)

+ 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 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) SDKResponseMetadata() aws.Response

+ func (s ListPipelinesOutput) String() string

+ type ListPipelinesRequest struct

+ Input *ListPipelinesInput

+ func (r ListPipelinesRequest) Send() (*ListPipelinesOutput, error)

+ type Operator struct

+ Type OperatorType

+ Values []string

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

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

+ func (s Operator) GoString() string

+ func (s Operator) String() string

+ type OperatorType string

+ const OperatorTypeBetween

+ const OperatorTypeEq

+ const OperatorTypeGe

+ const OperatorTypeLe

+ const OperatorTypeRefEq

+ 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 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 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) SDKResponseMetadata() aws.Response

+ func (s PollForTaskOutput) String() string

+ type PollForTaskRequest struct

+ Input *PollForTaskInput

+ func (r PollForTaskRequest) Send() (*PollForTaskOutput, error)

+ 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) SDKResponseMetadata() aws.Response

+ func (s PutPipelineDefinitionOutput) String() string

+ type PutPipelineDefinitionRequest struct

+ Input *PutPipelineDefinitionInput

+ func (r PutPipelineDefinitionRequest) Send() (*PutPipelineDefinitionOutput, error)

+ 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) SDKResponseMetadata() aws.Response

+ func (s QueryObjectsOutput) String() string

+ type QueryObjectsRequest struct

+ Input *QueryObjectsInput

+ func (r QueryObjectsRequest) Send() (*QueryObjectsOutput, error)

+ 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) SDKResponseMetadata() aws.Response

+ func (s RemoveTagsOutput) String() string

+ type RemoveTagsRequest struct

+ Input *RemoveTagsInput

+ func (r RemoveTagsRequest) Send() (*RemoveTagsOutput, error)

+ 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) SDKResponseMetadata() aws.Response

+ func (s ReportTaskProgressOutput) String() string

+ type ReportTaskProgressRequest struct

+ Input *ReportTaskProgressInput

+ func (r ReportTaskProgressRequest) Send() (*ReportTaskProgressOutput, error)

+ 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) SDKResponseMetadata() aws.Response

+ func (s ReportTaskRunnerHeartbeatOutput) String() string

+ type ReportTaskRunnerHeartbeatRequest struct

+ Input *ReportTaskRunnerHeartbeatInput

+ func (r ReportTaskRunnerHeartbeatRequest) Send() (*ReportTaskRunnerHeartbeatOutput, error)

+ 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) SDKResponseMetadata() aws.Response

+ func (s SetStatusOutput) String() string

+ type SetStatusRequest struct

+ Input *SetStatusInput

+ func (r SetStatusRequest) Send() (*SetStatusOutput, error)

+ type SetTaskStatusInput struct

+ ErrorId *string

+ ErrorMessage *string

+ ErrorStackTrace *string

+ TaskId *string

+ TaskStatus TaskStatus

+ 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 TaskStatus) *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) SDKResponseMetadata() aws.Response

+ func (s SetTaskStatusOutput) String() string

+ type SetTaskStatusRequest struct

+ Input *SetTaskStatusInput

+ func (r SetTaskStatusRequest) Send() (*SetTaskStatusOutput, error)

+ 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 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 TaskStatus string

+ const TaskStatusFailed

+ const TaskStatusFalse

+ const TaskStatusFinished

+ 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) SDKResponseMetadata() aws.Response

+ func (s ValidatePipelineDefinitionOutput) String() string

+ type ValidatePipelineDefinitionRequest struct

+ Input *ValidatePipelineDefinitionInput

+ func (r ValidatePipelineDefinitionRequest) Send() (*ValidatePipelineDefinitionOutput, error)

+ 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

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