emr

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 ActionOnFailure

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

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

type AddInstanceFleetRequest

+ Copy func(*AddInstanceFleetInput) AddInstanceFleetRequest

type AddInstanceGroupsRequest

+ Copy func(*AddInstanceGroupsInput) AddInstanceGroupsRequest

type AddJobFlowStepsRequest

+ Copy func(*AddJobFlowStepsInput) AddJobFlowStepsRequest

type AddTagsRequest

+ Copy func(*AddTagsInput) AddTagsRequest

type AdjustmentType

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

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

type AutoScalingPolicyState

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

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

type AutoScalingPolicyStateChangeReasonCode

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

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

type CancelStepsRequest

+ Copy func(*CancelStepsInput) CancelStepsRequest

type CancelStepsRequestStatus

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

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

type ClusterState

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

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

type ClusterStateChangeReasonCode

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

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

type ComparisonOperator

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

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

type CreateSecurityConfigurationRequest

+ Copy func(*CreateSecurityConfigurationInput) CreateSecurityConfigurationRequest

type DeleteSecurityConfigurationRequest

+ Copy func(*DeleteSecurityConfigurationInput) DeleteSecurityConfigurationRequest

type DescribeClusterRequest

+ Copy func(*DescribeClusterInput) DescribeClusterRequest

type DescribeJobFlowsRequest

+ Copy func(*DescribeJobFlowsInput) DescribeJobFlowsRequest

type DescribeSecurityConfigurationRequest

+ Copy func(*DescribeSecurityConfigurationInput) DescribeSecurityConfigurationRequest

type DescribeStepRequest

+ Copy func(*DescribeStepInput) DescribeStepRequest

type InstanceCollectionType

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

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

type InstanceFleetState

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

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

type InstanceFleetStateChangeReasonCode

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

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

type InstanceFleetType

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

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

type InstanceGroupState

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

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

type InstanceGroupStateChangeReasonCode

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

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

type InstanceGroupType

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

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

type InstanceRoleType

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

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

type InstanceState

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

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

type InstanceStateChangeReasonCode

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

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

type JobFlowExecutionState

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

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

+ type ListBootstrapActionsPager struct

+ func (p *ListBootstrapActionsPager) CurrentPage() *ListBootstrapActionsOutput

type ListBootstrapActionsRequest

+ Copy func(*ListBootstrapActionsInput) ListBootstrapActionsRequest

+ func (p *ListBootstrapActionsRequest) Paginate(opts ...aws.Option) ListBootstrapActionsPager

+ type ListClustersPager struct

+ func (p *ListClustersPager) CurrentPage() *ListClustersOutput

type ListClustersRequest

+ Copy func(*ListClustersInput) ListClustersRequest

+ func (p *ListClustersRequest) Paginate(opts ...aws.Option) ListClustersPager

+ type ListInstanceFleetsPager struct

+ func (p *ListInstanceFleetsPager) CurrentPage() *ListInstanceFleetsOutput

type ListInstanceFleetsRequest

+ Copy func(*ListInstanceFleetsInput) ListInstanceFleetsRequest

+ func (p *ListInstanceFleetsRequest) Paginate(opts ...aws.Option) ListInstanceFleetsPager

+ type ListInstanceGroupsPager struct

+ func (p *ListInstanceGroupsPager) CurrentPage() *ListInstanceGroupsOutput

type ListInstanceGroupsRequest

+ Copy func(*ListInstanceGroupsInput) ListInstanceGroupsRequest

+ func (p *ListInstanceGroupsRequest) Paginate(opts ...aws.Option) ListInstanceGroupsPager

+ type ListInstancesPager struct

+ func (p *ListInstancesPager) CurrentPage() *ListInstancesOutput

type ListInstancesRequest

+ Copy func(*ListInstancesInput) ListInstancesRequest

+ func (p *ListInstancesRequest) Paginate(opts ...aws.Option) ListInstancesPager

type ListSecurityConfigurationsRequest

+ Copy func(*ListSecurityConfigurationsInput) ListSecurityConfigurationsRequest

+ type ListStepsPager struct

+ func (p *ListStepsPager) CurrentPage() *ListStepsOutput

type ListStepsRequest

+ Copy func(*ListStepsInput) ListStepsRequest

+ func (p *ListStepsRequest) Paginate(opts ...aws.Option) ListStepsPager

type MarketType

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

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

type ModifyInstanceFleetRequest

+ Copy func(*ModifyInstanceFleetInput) ModifyInstanceFleetRequest

type ModifyInstanceGroupsRequest

+ Copy func(*ModifyInstanceGroupsInput) ModifyInstanceGroupsRequest

type PutAutoScalingPolicyRequest

+ Copy func(*PutAutoScalingPolicyInput) PutAutoScalingPolicyRequest

type RemoveAutoScalingPolicyRequest

+ Copy func(*RemoveAutoScalingPolicyInput) RemoveAutoScalingPolicyRequest

type RemoveTagsRequest

+ Copy func(*RemoveTagsInput) RemoveTagsRequest

type RepoUpgradeOnBoot

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

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

type RunJobFlowRequest

+ Copy func(*RunJobFlowInput) RunJobFlowRequest

type ScaleDownBehavior

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

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

type SetTerminationProtectionRequest

+ Copy func(*SetTerminationProtectionInput) SetTerminationProtectionRequest

type SetVisibleToAllUsersRequest

+ Copy func(*SetVisibleToAllUsersInput) SetVisibleToAllUsersRequest

type SpotProvisioningTimeoutAction

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

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

type Statistic

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

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

type StepExecutionState

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

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

type StepState

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

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

type StepStateChangeReasonCode

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

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

type TerminateJobFlowsRequest

+ Copy func(*TerminateJobFlowsInput) TerminateJobFlowsRequest

type Unit

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

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

v0.2.0

Jan 15, 2018

Changes in this version

type Cluster

+ KerberosAttributes *KerberosAttributes

+ func (s *Cluster) SetKerberosAttributes(v *KerberosAttributes) *Cluster

+ type KerberosAttributes struct

+ ADDomainJoinPassword *string

+ ADDomainJoinUser *string

+ CrossRealmTrustPrincipalPassword *string

+ KdcAdminPassword *string

+ Realm *string

+ func (s *KerberosAttributes) SetADDomainJoinPassword(v string) *KerberosAttributes

+ func (s *KerberosAttributes) SetADDomainJoinUser(v string) *KerberosAttributes

+ func (s *KerberosAttributes) SetCrossRealmTrustPrincipalPassword(v string) *KerberosAttributes

+ func (s *KerberosAttributes) SetKdcAdminPassword(v string) *KerberosAttributes

+ func (s *KerberosAttributes) SetRealm(v string) *KerberosAttributes

+ func (s *KerberosAttributes) Validate() error

+ func (s KerberosAttributes) GoString() string

+ func (s KerberosAttributes) String() string

type RunJobFlowInput

+ KerberosAttributes *KerberosAttributes

+ func (s *RunJobFlowInput) SetKerberosAttributes(v *KerberosAttributes) *RunJobFlowInput

v0.1.0

Dec 21, 2017

Changes in this version

+ const EndpointsID

+ const ErrCodeInternalServerError

+ const ErrCodeInternalServerException

+ const ErrCodeInvalidRequestException

+ const ServiceName

+ type ActionOnFailure string

+ const ActionOnFailureCancelAndWait

+ const ActionOnFailureContinue

+ const ActionOnFailureTerminateCluster

+ const ActionOnFailureTerminateJobFlow

+ type AddInstanceFleetInput struct

+ ClusterId *string

+ InstanceFleet *InstanceFleetConfig

+ func (s *AddInstanceFleetInput) SetClusterId(v string) *AddInstanceFleetInput

+ func (s *AddInstanceFleetInput) SetInstanceFleet(v *InstanceFleetConfig) *AddInstanceFleetInput

+ func (s *AddInstanceFleetInput) Validate() error

+ func (s AddInstanceFleetInput) GoString() string

+ func (s AddInstanceFleetInput) String() string

+ type AddInstanceFleetOutput struct

+ ClusterId *string

+ InstanceFleetId *string

+ func (s *AddInstanceFleetOutput) SetClusterId(v string) *AddInstanceFleetOutput

+ func (s *AddInstanceFleetOutput) SetInstanceFleetId(v string) *AddInstanceFleetOutput

+ func (s AddInstanceFleetOutput) GoString() string

+ func (s AddInstanceFleetOutput) SDKResponseMetadata() aws.Response

+ func (s AddInstanceFleetOutput) String() string

+ type AddInstanceFleetRequest struct

+ Input *AddInstanceFleetInput

+ func (r AddInstanceFleetRequest) Send() (*AddInstanceFleetOutput, error)

+ type AddInstanceGroupsInput struct

+ InstanceGroups []InstanceGroupConfig

+ JobFlowId *string

+ func (s *AddInstanceGroupsInput) SetInstanceGroups(v []InstanceGroupConfig) *AddInstanceGroupsInput

+ func (s *AddInstanceGroupsInput) SetJobFlowId(v string) *AddInstanceGroupsInput

+ func (s *AddInstanceGroupsInput) Validate() error

+ func (s AddInstanceGroupsInput) GoString() string

+ func (s AddInstanceGroupsInput) String() string

+ type AddInstanceGroupsOutput struct

+ InstanceGroupIds []string

+ JobFlowId *string

+ func (s *AddInstanceGroupsOutput) SetInstanceGroupIds(v []string) *AddInstanceGroupsOutput

+ func (s *AddInstanceGroupsOutput) SetJobFlowId(v string) *AddInstanceGroupsOutput

+ func (s AddInstanceGroupsOutput) GoString() string

+ func (s AddInstanceGroupsOutput) SDKResponseMetadata() aws.Response

+ func (s AddInstanceGroupsOutput) String() string

+ type AddInstanceGroupsRequest struct

+ Input *AddInstanceGroupsInput

+ func (r AddInstanceGroupsRequest) Send() (*AddInstanceGroupsOutput, error)

+ type AddJobFlowStepsInput struct

+ JobFlowId *string

+ Steps []StepConfig

+ func (s *AddJobFlowStepsInput) SetJobFlowId(v string) *AddJobFlowStepsInput

+ func (s *AddJobFlowStepsInput) SetSteps(v []StepConfig) *AddJobFlowStepsInput

+ func (s *AddJobFlowStepsInput) Validate() error

+ func (s AddJobFlowStepsInput) GoString() string

+ func (s AddJobFlowStepsInput) String() string

+ type AddJobFlowStepsOutput struct

+ StepIds []string

+ func (s *AddJobFlowStepsOutput) SetStepIds(v []string) *AddJobFlowStepsOutput

+ func (s AddJobFlowStepsOutput) GoString() string

+ func (s AddJobFlowStepsOutput) SDKResponseMetadata() aws.Response

+ func (s AddJobFlowStepsOutput) String() string

+ type AddJobFlowStepsRequest struct

+ Input *AddJobFlowStepsInput

+ func (r AddJobFlowStepsRequest) Send() (*AddJobFlowStepsOutput, error)

+ type AddTagsInput struct

+ ResourceId *string

+ Tags []Tag

+ func (s *AddTagsInput) SetResourceId(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 AdjustmentType string

+ const AdjustmentTypeChangeInCapacity

+ const AdjustmentTypeExactCapacity

+ const AdjustmentTypePercentChangeInCapacity

+ type Application struct

+ AdditionalInfo map[string]string

+ Args []string

+ Name *string

+ Version *string

+ func (s *Application) SetAdditionalInfo(v map[string]string) *Application

+ func (s *Application) SetArgs(v []string) *Application

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

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

+ func (s Application) GoString() string

+ func (s Application) String() string

+ type AutoScalingPolicy struct

+ Constraints *ScalingConstraints

+ Rules []ScalingRule

+ func (s *AutoScalingPolicy) SetConstraints(v *ScalingConstraints) *AutoScalingPolicy

+ func (s *AutoScalingPolicy) SetRules(v []ScalingRule) *AutoScalingPolicy

+ func (s *AutoScalingPolicy) Validate() error

+ func (s AutoScalingPolicy) GoString() string

+ func (s AutoScalingPolicy) String() string

+ type AutoScalingPolicyDescription struct

+ Constraints *ScalingConstraints

+ Rules []ScalingRule

+ Status *AutoScalingPolicyStatus

+ func (s *AutoScalingPolicyDescription) SetConstraints(v *ScalingConstraints) *AutoScalingPolicyDescription

+ func (s *AutoScalingPolicyDescription) SetRules(v []ScalingRule) *AutoScalingPolicyDescription

+ func (s *AutoScalingPolicyDescription) SetStatus(v *AutoScalingPolicyStatus) *AutoScalingPolicyDescription

+ func (s AutoScalingPolicyDescription) GoString() string

+ func (s AutoScalingPolicyDescription) String() string

+ type AutoScalingPolicyState string

+ const AutoScalingPolicyStateAttached

+ const AutoScalingPolicyStateAttaching

+ const AutoScalingPolicyStateDetached

+ const AutoScalingPolicyStateDetaching

+ const AutoScalingPolicyStateFailed

+ const AutoScalingPolicyStatePending

+ type AutoScalingPolicyStateChangeReason struct

+ Code AutoScalingPolicyStateChangeReasonCode

+ Message *string

+ func (s *AutoScalingPolicyStateChangeReason) SetCode(v AutoScalingPolicyStateChangeReasonCode) *AutoScalingPolicyStateChangeReason

+ func (s *AutoScalingPolicyStateChangeReason) SetMessage(v string) *AutoScalingPolicyStateChangeReason

+ func (s AutoScalingPolicyStateChangeReason) GoString() string

+ func (s AutoScalingPolicyStateChangeReason) String() string

+ type AutoScalingPolicyStateChangeReasonCode string

+ const AutoScalingPolicyStateChangeReasonCodeCleanupFailure

+ const AutoScalingPolicyStateChangeReasonCodeProvisionFailure

+ const AutoScalingPolicyStateChangeReasonCodeUserRequest

+ type AutoScalingPolicyStatus struct

+ State AutoScalingPolicyState

+ StateChangeReason *AutoScalingPolicyStateChangeReason

+ func (s *AutoScalingPolicyStatus) SetState(v AutoScalingPolicyState) *AutoScalingPolicyStatus

+ func (s *AutoScalingPolicyStatus) SetStateChangeReason(v *AutoScalingPolicyStateChangeReason) *AutoScalingPolicyStatus

+ func (s AutoScalingPolicyStatus) GoString() string

+ func (s AutoScalingPolicyStatus) String() string

+ type BootstrapActionConfig struct

+ Name *string

+ ScriptBootstrapAction *ScriptBootstrapActionConfig

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

+ func (s *BootstrapActionConfig) SetScriptBootstrapAction(v *ScriptBootstrapActionConfig) *BootstrapActionConfig

+ func (s *BootstrapActionConfig) Validate() error

+ func (s BootstrapActionConfig) GoString() string

+ func (s BootstrapActionConfig) String() string

+ type BootstrapActionDetail struct

+ BootstrapActionConfig *BootstrapActionConfig

+ func (s *BootstrapActionDetail) SetBootstrapActionConfig(v *BootstrapActionConfig) *BootstrapActionDetail

+ func (s BootstrapActionDetail) GoString() string

+ func (s BootstrapActionDetail) String() string

+ type CancelStepsInfo struct

+ Reason *string

+ Status CancelStepsRequestStatus

+ StepId *string

+ func (s *CancelStepsInfo) SetReason(v string) *CancelStepsInfo

+ func (s *CancelStepsInfo) SetStatus(v CancelStepsRequestStatus) *CancelStepsInfo

+ func (s *CancelStepsInfo) SetStepId(v string) *CancelStepsInfo

+ func (s CancelStepsInfo) GoString() string

+ func (s CancelStepsInfo) String() string

+ type CancelStepsInput struct

+ ClusterId *string

+ StepIds []string

+ func (s *CancelStepsInput) SetClusterId(v string) *CancelStepsInput

+ func (s *CancelStepsInput) SetStepIds(v []string) *CancelStepsInput

+ func (s CancelStepsInput) GoString() string

+ func (s CancelStepsInput) String() string

+ type CancelStepsOutput struct

+ CancelStepsInfoList []CancelStepsInfo

+ func (s *CancelStepsOutput) SetCancelStepsInfoList(v []CancelStepsInfo) *CancelStepsOutput

+ func (s CancelStepsOutput) GoString() string

+ func (s CancelStepsOutput) SDKResponseMetadata() aws.Response

+ func (s CancelStepsOutput) String() string

+ type CancelStepsRequest struct

+ Input *CancelStepsInput

+ func (r CancelStepsRequest) Send() (*CancelStepsOutput, error)

+ type CancelStepsRequestStatus string

+ const CancelStepsRequestStatusFailed

+ const CancelStepsRequestStatusSubmitted

+ type CloudWatchAlarmDefinition struct

+ ComparisonOperator ComparisonOperator

+ Dimensions []MetricDimension

+ EvaluationPeriods *int64

+ MetricName *string

+ Namespace *string

+ Period *int64

+ Statistic Statistic

+ Threshold *float64

+ Unit Unit

+ func (s *CloudWatchAlarmDefinition) SetComparisonOperator(v ComparisonOperator) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) SetDimensions(v []MetricDimension) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) SetEvaluationPeriods(v int64) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) SetMetricName(v string) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) SetNamespace(v string) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) SetPeriod(v int64) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) SetStatistic(v Statistic) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) SetThreshold(v float64) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) SetUnit(v Unit) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) Validate() error

+ func (s CloudWatchAlarmDefinition) GoString() string

+ func (s CloudWatchAlarmDefinition) String() string

+ type Cluster struct

+ Applications []Application

+ AutoScalingRole *string

+ AutoTerminate *bool

+ Configurations []Configuration

+ CustomAmiId *string

+ EbsRootVolumeSize *int64

+ Ec2InstanceAttributes *Ec2InstanceAttributes

+ Id *string

+ InstanceCollectionType InstanceCollectionType

+ LogUri *string

+ MasterPublicDnsName *string

+ Name *string

+ NormalizedInstanceHours *int64

+ ReleaseLabel *string

+ RepoUpgradeOnBoot RepoUpgradeOnBoot

+ RequestedAmiVersion *string

+ RunningAmiVersion *string

+ ScaleDownBehavior ScaleDownBehavior

+ SecurityConfiguration *string

+ ServiceRole *string

+ Status *ClusterStatus

+ Tags []Tag

+ TerminationProtected *bool

+ VisibleToAllUsers *bool

+ func (s *Cluster) SetApplications(v []Application) *Cluster

+ func (s *Cluster) SetAutoScalingRole(v string) *Cluster

+ func (s *Cluster) SetAutoTerminate(v bool) *Cluster

+ func (s *Cluster) SetConfigurations(v []Configuration) *Cluster

+ func (s *Cluster) SetCustomAmiId(v string) *Cluster

+ func (s *Cluster) SetEbsRootVolumeSize(v int64) *Cluster

+ func (s *Cluster) SetEc2InstanceAttributes(v *Ec2InstanceAttributes) *Cluster

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

+ func (s *Cluster) SetInstanceCollectionType(v InstanceCollectionType) *Cluster

+ func (s *Cluster) SetLogUri(v string) *Cluster

+ func (s *Cluster) SetMasterPublicDnsName(v string) *Cluster

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

+ func (s *Cluster) SetNormalizedInstanceHours(v int64) *Cluster

+ func (s *Cluster) SetReleaseLabel(v string) *Cluster

+ func (s *Cluster) SetRepoUpgradeOnBoot(v RepoUpgradeOnBoot) *Cluster

+ func (s *Cluster) SetRequestedAmiVersion(v string) *Cluster

+ func (s *Cluster) SetRunningAmiVersion(v string) *Cluster

+ func (s *Cluster) SetScaleDownBehavior(v ScaleDownBehavior) *Cluster

+ func (s *Cluster) SetSecurityConfiguration(v string) *Cluster

+ func (s *Cluster) SetServiceRole(v string) *Cluster

+ func (s *Cluster) SetStatus(v *ClusterStatus) *Cluster

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

+ func (s *Cluster) SetTerminationProtected(v bool) *Cluster

+ func (s *Cluster) SetVisibleToAllUsers(v bool) *Cluster

+ func (s Cluster) GoString() string

+ func (s Cluster) String() string

+ type ClusterState string

+ const ClusterStateBootstrapping

+ const ClusterStateRunning

+ const ClusterStateStarting

+ const ClusterStateTerminated

+ const ClusterStateTerminatedWithErrors

+ const ClusterStateTerminating

+ const ClusterStateWaiting

+ type ClusterStateChangeReason struct

+ Code ClusterStateChangeReasonCode

+ Message *string

+ func (s *ClusterStateChangeReason) SetCode(v ClusterStateChangeReasonCode) *ClusterStateChangeReason

+ func (s *ClusterStateChangeReason) SetMessage(v string) *ClusterStateChangeReason

+ func (s ClusterStateChangeReason) GoString() string

+ func (s ClusterStateChangeReason) String() string

+ type ClusterStateChangeReasonCode string

+ const ClusterStateChangeReasonCodeAllStepsCompleted

+ const ClusterStateChangeReasonCodeBootstrapFailure

+ const ClusterStateChangeReasonCodeInstanceFailure

+ const ClusterStateChangeReasonCodeInstanceFleetTimeout

+ const ClusterStateChangeReasonCodeInternalError

+ const ClusterStateChangeReasonCodeStepFailure

+ const ClusterStateChangeReasonCodeUserRequest

+ const ClusterStateChangeReasonCodeValidationError

+ type ClusterStatus struct

+ State ClusterState

+ StateChangeReason *ClusterStateChangeReason

+ Timeline *ClusterTimeline

+ func (s *ClusterStatus) SetState(v ClusterState) *ClusterStatus

+ func (s *ClusterStatus) SetStateChangeReason(v *ClusterStateChangeReason) *ClusterStatus

+ func (s *ClusterStatus) SetTimeline(v *ClusterTimeline) *ClusterStatus

+ func (s ClusterStatus) GoString() string

+ func (s ClusterStatus) String() string

+ type ClusterSummary struct

+ Id *string

+ Name *string

+ NormalizedInstanceHours *int64

+ Status *ClusterStatus

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

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

+ func (s *ClusterSummary) SetNormalizedInstanceHours(v int64) *ClusterSummary

+ func (s *ClusterSummary) SetStatus(v *ClusterStatus) *ClusterSummary

+ func (s ClusterSummary) GoString() string

+ func (s ClusterSummary) String() string

+ type ClusterTimeline struct

+ CreationDateTime *time.Time

+ EndDateTime *time.Time

+ ReadyDateTime *time.Time

+ func (s *ClusterTimeline) SetCreationDateTime(v time.Time) *ClusterTimeline

+ func (s *ClusterTimeline) SetEndDateTime(v time.Time) *ClusterTimeline

+ func (s *ClusterTimeline) SetReadyDateTime(v time.Time) *ClusterTimeline

+ func (s ClusterTimeline) GoString() string

+ func (s ClusterTimeline) String() string

+ type Command struct

+ Args []string

+ Name *string

+ ScriptPath *string

+ func (s *Command) SetArgs(v []string) *Command

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

+ func (s *Command) SetScriptPath(v string) *Command

+ func (s Command) GoString() string

+ func (s Command) String() string

+ type ComparisonOperator string

+ const ComparisonOperatorGreaterThan

+ const ComparisonOperatorGreaterThanOrEqual

+ const ComparisonOperatorLessThan

+ const ComparisonOperatorLessThanOrEqual

+ type Configuration struct

+ Classification *string

+ Configurations []Configuration

+ Properties map[string]string

+ func (s *Configuration) SetClassification(v string) *Configuration

+ func (s *Configuration) SetConfigurations(v []Configuration) *Configuration

+ func (s *Configuration) SetProperties(v map[string]string) *Configuration

+ func (s Configuration) GoString() string

+ func (s Configuration) String() string

+ type CreateSecurityConfigurationInput struct

+ Name *string

+ SecurityConfiguration *string

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

+ func (s *CreateSecurityConfigurationInput) SetSecurityConfiguration(v string) *CreateSecurityConfigurationInput

+ func (s *CreateSecurityConfigurationInput) Validate() error

+ func (s CreateSecurityConfigurationInput) GoString() string

+ func (s CreateSecurityConfigurationInput) String() string

+ type CreateSecurityConfigurationOutput struct

+ CreationDateTime *time.Time

+ Name *string

+ func (s *CreateSecurityConfigurationOutput) SetCreationDateTime(v time.Time) *CreateSecurityConfigurationOutput

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

+ func (s CreateSecurityConfigurationOutput) GoString() string

+ func (s CreateSecurityConfigurationOutput) SDKResponseMetadata() aws.Response

+ func (s CreateSecurityConfigurationOutput) String() string

+ type CreateSecurityConfigurationRequest struct

+ Input *CreateSecurityConfigurationInput

+ func (r CreateSecurityConfigurationRequest) Send() (*CreateSecurityConfigurationOutput, error)

+ type DeleteSecurityConfigurationInput struct

+ Name *string

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

+ func (s *DeleteSecurityConfigurationInput) Validate() error

+ func (s DeleteSecurityConfigurationInput) GoString() string

+ func (s DeleteSecurityConfigurationInput) String() string

+ type DeleteSecurityConfigurationOutput struct

+ func (s DeleteSecurityConfigurationOutput) GoString() string

+ func (s DeleteSecurityConfigurationOutput) SDKResponseMetadata() aws.Response

+ func (s DeleteSecurityConfigurationOutput) String() string

+ type DeleteSecurityConfigurationRequest struct

+ Input *DeleteSecurityConfigurationInput

+ func (r DeleteSecurityConfigurationRequest) Send() (*DeleteSecurityConfigurationOutput, error)

+ type DescribeClusterInput struct

+ ClusterId *string

+ func (s *DescribeClusterInput) SetClusterId(v string) *DescribeClusterInput

+ func (s *DescribeClusterInput) Validate() error

+ func (s DescribeClusterInput) GoString() string

+ func (s DescribeClusterInput) String() string

+ type DescribeClusterOutput struct

+ Cluster *Cluster

+ func (s *DescribeClusterOutput) SetCluster(v *Cluster) *DescribeClusterOutput

+ func (s DescribeClusterOutput) GoString() string

+ func (s DescribeClusterOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeClusterOutput) String() string

+ type DescribeClusterRequest struct

+ Input *DescribeClusterInput

+ func (r DescribeClusterRequest) Send() (*DescribeClusterOutput, error)

+ type DescribeJobFlowsInput struct

+ CreatedAfter *time.Time

+ CreatedBefore *time.Time

+ JobFlowIds []string

+ JobFlowStates []JobFlowExecutionState

+ func (s *DescribeJobFlowsInput) SetCreatedAfter(v time.Time) *DescribeJobFlowsInput

+ func (s *DescribeJobFlowsInput) SetCreatedBefore(v time.Time) *DescribeJobFlowsInput

+ func (s *DescribeJobFlowsInput) SetJobFlowIds(v []string) *DescribeJobFlowsInput

+ func (s *DescribeJobFlowsInput) SetJobFlowStates(v []JobFlowExecutionState) *DescribeJobFlowsInput

+ func (s DescribeJobFlowsInput) GoString() string

+ func (s DescribeJobFlowsInput) String() string

+ type DescribeJobFlowsOutput struct

+ JobFlows []JobFlowDetail

+ func (s *DescribeJobFlowsOutput) SetJobFlows(v []JobFlowDetail) *DescribeJobFlowsOutput

+ func (s DescribeJobFlowsOutput) GoString() string

+ func (s DescribeJobFlowsOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeJobFlowsOutput) String() string

+ type DescribeJobFlowsRequest struct

+ Input *DescribeJobFlowsInput

+ func (r DescribeJobFlowsRequest) Send() (*DescribeJobFlowsOutput, error)

+ type DescribeSecurityConfigurationInput struct

+ Name *string

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

+ func (s *DescribeSecurityConfigurationInput) Validate() error

+ func (s DescribeSecurityConfigurationInput) GoString() string

+ func (s DescribeSecurityConfigurationInput) String() string

+ type DescribeSecurityConfigurationOutput struct

+ CreationDateTime *time.Time

+ Name *string

+ SecurityConfiguration *string

+ func (s *DescribeSecurityConfigurationOutput) SetCreationDateTime(v time.Time) *DescribeSecurityConfigurationOutput

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

+ func (s *DescribeSecurityConfigurationOutput) SetSecurityConfiguration(v string) *DescribeSecurityConfigurationOutput

+ func (s DescribeSecurityConfigurationOutput) GoString() string

+ func (s DescribeSecurityConfigurationOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeSecurityConfigurationOutput) String() string

+ type DescribeSecurityConfigurationRequest struct

+ Input *DescribeSecurityConfigurationInput

+ func (r DescribeSecurityConfigurationRequest) Send() (*DescribeSecurityConfigurationOutput, error)

+ type DescribeStepInput struct

+ ClusterId *string

+ StepId *string

+ func (s *DescribeStepInput) SetClusterId(v string) *DescribeStepInput

+ func (s *DescribeStepInput) SetStepId(v string) *DescribeStepInput

+ func (s *DescribeStepInput) Validate() error

+ func (s DescribeStepInput) GoString() string

+ func (s DescribeStepInput) String() string

+ type DescribeStepOutput struct

+ Step *Step

+ func (s *DescribeStepOutput) SetStep(v *Step) *DescribeStepOutput

+ func (s DescribeStepOutput) GoString() string

+ func (s DescribeStepOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeStepOutput) String() string

+ type DescribeStepRequest struct

+ Input *DescribeStepInput

+ func (r DescribeStepRequest) Send() (*DescribeStepOutput, error)

+ type EMR struct

+ func New(config aws.Config) *EMR

+ func (c *EMR) AddInstanceFleetRequest(input *AddInstanceFleetInput) AddInstanceFleetRequest

+ func (c *EMR) AddInstanceGroupsRequest(input *AddInstanceGroupsInput) AddInstanceGroupsRequest

+ func (c *EMR) AddJobFlowStepsRequest(input *AddJobFlowStepsInput) AddJobFlowStepsRequest

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

+ func (c *EMR) CancelStepsRequest(input *CancelStepsInput) CancelStepsRequest

+ func (c *EMR) CreateSecurityConfigurationRequest(input *CreateSecurityConfigurationInput) CreateSecurityConfigurationRequest

+ func (c *EMR) DeleteSecurityConfigurationRequest(input *DeleteSecurityConfigurationInput) DeleteSecurityConfigurationRequest

+ func (c *EMR) DescribeClusterRequest(input *DescribeClusterInput) DescribeClusterRequest

+ func (c *EMR) DescribeJobFlowsRequest(input *DescribeJobFlowsInput) DescribeJobFlowsRequest

+ func (c *EMR) DescribeSecurityConfigurationRequest(input *DescribeSecurityConfigurationInput) DescribeSecurityConfigurationRequest

+ func (c *EMR) DescribeStepRequest(input *DescribeStepInput) DescribeStepRequest

+ func (c *EMR) ListBootstrapActionsPages(input *ListBootstrapActionsInput, ...) error

+ func (c *EMR) ListBootstrapActionsPagesWithContext(ctx aws.Context, input *ListBootstrapActionsInput, ...) error

+ func (c *EMR) ListBootstrapActionsRequest(input *ListBootstrapActionsInput) ListBootstrapActionsRequest

+ func (c *EMR) ListClustersPages(input *ListClustersInput, fn func(*ListClustersOutput, bool) bool) error

+ func (c *EMR) ListClustersPagesWithContext(ctx aws.Context, input *ListClustersInput, ...) error

+ func (c *EMR) ListClustersRequest(input *ListClustersInput) ListClustersRequest

+ func (c *EMR) ListInstanceFleetsPages(input *ListInstanceFleetsInput, fn func(*ListInstanceFleetsOutput, bool) bool) error

+ func (c *EMR) ListInstanceFleetsPagesWithContext(ctx aws.Context, input *ListInstanceFleetsInput, ...) error

+ func (c *EMR) ListInstanceFleetsRequest(input *ListInstanceFleetsInput) ListInstanceFleetsRequest

+ func (c *EMR) ListInstanceGroupsPages(input *ListInstanceGroupsInput, fn func(*ListInstanceGroupsOutput, bool) bool) error

+ func (c *EMR) ListInstanceGroupsPagesWithContext(ctx aws.Context, input *ListInstanceGroupsInput, ...) error

+ func (c *EMR) ListInstanceGroupsRequest(input *ListInstanceGroupsInput) ListInstanceGroupsRequest

+ func (c *EMR) ListInstancesPages(input *ListInstancesInput, fn func(*ListInstancesOutput, bool) bool) error

+ func (c *EMR) ListInstancesPagesWithContext(ctx aws.Context, input *ListInstancesInput, ...) error

+ func (c *EMR) ListInstancesRequest(input *ListInstancesInput) ListInstancesRequest

+ func (c *EMR) ListSecurityConfigurationsRequest(input *ListSecurityConfigurationsInput) ListSecurityConfigurationsRequest

+ func (c *EMR) ListStepsPages(input *ListStepsInput, fn func(*ListStepsOutput, bool) bool) error

+ func (c *EMR) ListStepsPagesWithContext(ctx aws.Context, input *ListStepsInput, fn func(*ListStepsOutput, bool) bool, ...) error

+ func (c *EMR) ListStepsRequest(input *ListStepsInput) ListStepsRequest

+ func (c *EMR) ModifyInstanceFleetRequest(input *ModifyInstanceFleetInput) ModifyInstanceFleetRequest

+ func (c *EMR) ModifyInstanceGroupsRequest(input *ModifyInstanceGroupsInput) ModifyInstanceGroupsRequest

+ func (c *EMR) PutAutoScalingPolicyRequest(input *PutAutoScalingPolicyInput) PutAutoScalingPolicyRequest

+ func (c *EMR) RemoveAutoScalingPolicyRequest(input *RemoveAutoScalingPolicyInput) RemoveAutoScalingPolicyRequest

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

+ func (c *EMR) RunJobFlowRequest(input *RunJobFlowInput) RunJobFlowRequest

+ func (c *EMR) SetTerminationProtectionRequest(input *SetTerminationProtectionInput) SetTerminationProtectionRequest

+ func (c *EMR) SetVisibleToAllUsersRequest(input *SetVisibleToAllUsersInput) SetVisibleToAllUsersRequest

+ func (c *EMR) TerminateJobFlowsRequest(input *TerminateJobFlowsInput) TerminateJobFlowsRequest

+ func (c *EMR) WaitUntilClusterRunning(input *DescribeClusterInput) error

+ func (c *EMR) WaitUntilClusterRunningWithContext(ctx aws.Context, input *DescribeClusterInput, opts ...aws.WaiterOption) error

+ func (c *EMR) WaitUntilClusterTerminated(input *DescribeClusterInput) error

+ func (c *EMR) WaitUntilClusterTerminatedWithContext(ctx aws.Context, input *DescribeClusterInput, opts ...aws.WaiterOption) error

+ func (c *EMR) WaitUntilStepComplete(input *DescribeStepInput) error

+ func (c *EMR) WaitUntilStepCompleteWithContext(ctx aws.Context, input *DescribeStepInput, opts ...aws.WaiterOption) error

+ type EbsBlockDevice struct

+ Device *string

+ VolumeSpecification *VolumeSpecification

+ func (s *EbsBlockDevice) SetDevice(v string) *EbsBlockDevice

+ func (s *EbsBlockDevice) SetVolumeSpecification(v *VolumeSpecification) *EbsBlockDevice

+ func (s EbsBlockDevice) GoString() string

+ func (s EbsBlockDevice) String() string

+ type EbsBlockDeviceConfig struct

+ VolumeSpecification *VolumeSpecification

+ VolumesPerInstance *int64

+ func (s *EbsBlockDeviceConfig) SetVolumeSpecification(v *VolumeSpecification) *EbsBlockDeviceConfig

+ func (s *EbsBlockDeviceConfig) SetVolumesPerInstance(v int64) *EbsBlockDeviceConfig

+ func (s *EbsBlockDeviceConfig) Validate() error

+ func (s EbsBlockDeviceConfig) GoString() string

+ func (s EbsBlockDeviceConfig) String() string

+ type EbsConfiguration struct

+ EbsBlockDeviceConfigs []EbsBlockDeviceConfig

+ EbsOptimized *bool

+ func (s *EbsConfiguration) SetEbsBlockDeviceConfigs(v []EbsBlockDeviceConfig) *EbsConfiguration

+ func (s *EbsConfiguration) SetEbsOptimized(v bool) *EbsConfiguration

+ func (s *EbsConfiguration) Validate() error

+ func (s EbsConfiguration) GoString() string

+ func (s EbsConfiguration) String() string

+ type EbsVolume struct

+ Device *string

+ VolumeId *string

+ func (s *EbsVolume) SetDevice(v string) *EbsVolume

+ func (s *EbsVolume) SetVolumeId(v string) *EbsVolume

+ func (s EbsVolume) GoString() string

+ func (s EbsVolume) String() string

+ type Ec2InstanceAttributes struct

+ AdditionalMasterSecurityGroups []string

+ AdditionalSlaveSecurityGroups []string

+ Ec2AvailabilityZone *string

+ Ec2KeyName *string

+ Ec2SubnetId *string

+ EmrManagedMasterSecurityGroup *string

+ EmrManagedSlaveSecurityGroup *string

+ IamInstanceProfile *string

+ RequestedEc2AvailabilityZones []string

+ RequestedEc2SubnetIds []string

+ ServiceAccessSecurityGroup *string

+ func (s *Ec2InstanceAttributes) SetAdditionalMasterSecurityGroups(v []string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetAdditionalSlaveSecurityGroups(v []string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetEc2AvailabilityZone(v string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetEc2KeyName(v string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetEc2SubnetId(v string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetEmrManagedMasterSecurityGroup(v string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetEmrManagedSlaveSecurityGroup(v string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetIamInstanceProfile(v string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetRequestedEc2AvailabilityZones(v []string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetRequestedEc2SubnetIds(v []string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetServiceAccessSecurityGroup(v string) *Ec2InstanceAttributes

+ func (s Ec2InstanceAttributes) GoString() string

+ func (s Ec2InstanceAttributes) String() string

+ type FailureDetails struct

+ LogFile *string

+ Message *string

+ Reason *string

+ func (s *FailureDetails) SetLogFile(v string) *FailureDetails

+ func (s *FailureDetails) SetMessage(v string) *FailureDetails

+ func (s *FailureDetails) SetReason(v string) *FailureDetails

+ func (s FailureDetails) GoString() string

+ func (s FailureDetails) String() string

+ type HadoopJarStepConfig struct

+ Args []string

+ Jar *string

+ MainClass *string

+ Properties []KeyValue

+ func (s *HadoopJarStepConfig) SetArgs(v []string) *HadoopJarStepConfig

+ func (s *HadoopJarStepConfig) SetJar(v string) *HadoopJarStepConfig

+ func (s *HadoopJarStepConfig) SetMainClass(v string) *HadoopJarStepConfig

+ func (s *HadoopJarStepConfig) SetProperties(v []KeyValue) *HadoopJarStepConfig

+ func (s *HadoopJarStepConfig) Validate() error

+ func (s HadoopJarStepConfig) GoString() string

+ func (s HadoopJarStepConfig) String() string

+ type HadoopStepConfig struct

+ Args []string

+ Jar *string

+ MainClass *string

+ Properties map[string]string

+ func (s *HadoopStepConfig) SetArgs(v []string) *HadoopStepConfig

+ func (s *HadoopStepConfig) SetJar(v string) *HadoopStepConfig

+ func (s *HadoopStepConfig) SetMainClass(v string) *HadoopStepConfig

+ func (s *HadoopStepConfig) SetProperties(v map[string]string) *HadoopStepConfig

+ func (s HadoopStepConfig) GoString() string

+ func (s HadoopStepConfig) String() string

+ type Instance struct

+ EbsVolumes []EbsVolume

+ Ec2InstanceId *string

+ Id *string

+ InstanceFleetId *string

+ InstanceGroupId *string

+ InstanceType *string

+ Market MarketType

+ PrivateDnsName *string

+ PrivateIpAddress *string

+ PublicDnsName *string

+ PublicIpAddress *string

+ Status *InstanceStatus

+ func (s *Instance) SetEbsVolumes(v []EbsVolume) *Instance

+ func (s *Instance) SetEc2InstanceId(v string) *Instance

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

+ func (s *Instance) SetInstanceFleetId(v string) *Instance

+ func (s *Instance) SetInstanceGroupId(v string) *Instance

+ func (s *Instance) SetInstanceType(v string) *Instance

+ func (s *Instance) SetMarket(v MarketType) *Instance

+ func (s *Instance) SetPrivateDnsName(v string) *Instance

+ func (s *Instance) SetPrivateIpAddress(v string) *Instance

+ func (s *Instance) SetPublicDnsName(v string) *Instance

+ func (s *Instance) SetPublicIpAddress(v string) *Instance

+ func (s *Instance) SetStatus(v *InstanceStatus) *Instance

+ func (s Instance) GoString() string

+ func (s Instance) String() string

+ type InstanceCollectionType string

+ const InstanceCollectionTypeInstanceFleet

+ const InstanceCollectionTypeInstanceGroup

+ type InstanceFleet struct

+ Id *string

+ InstanceFleetType InstanceFleetType

+ InstanceTypeSpecifications []InstanceTypeSpecification

+ LaunchSpecifications *InstanceFleetProvisioningSpecifications

+ Name *string

+ ProvisionedOnDemandCapacity *int64

+ ProvisionedSpotCapacity *int64

+ Status *InstanceFleetStatus

+ TargetOnDemandCapacity *int64

+ TargetSpotCapacity *int64

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

+ func (s *InstanceFleet) SetInstanceFleetType(v InstanceFleetType) *InstanceFleet

+ func (s *InstanceFleet) SetInstanceTypeSpecifications(v []InstanceTypeSpecification) *InstanceFleet

+ func (s *InstanceFleet) SetLaunchSpecifications(v *InstanceFleetProvisioningSpecifications) *InstanceFleet

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

+ func (s *InstanceFleet) SetProvisionedOnDemandCapacity(v int64) *InstanceFleet

+ func (s *InstanceFleet) SetProvisionedSpotCapacity(v int64) *InstanceFleet

+ func (s *InstanceFleet) SetStatus(v *InstanceFleetStatus) *InstanceFleet

+ func (s *InstanceFleet) SetTargetOnDemandCapacity(v int64) *InstanceFleet

+ func (s *InstanceFleet) SetTargetSpotCapacity(v int64) *InstanceFleet

+ func (s InstanceFleet) GoString() string

+ func (s InstanceFleet) String() string

+ type InstanceFleetConfig struct

+ InstanceFleetType InstanceFleetType

+ InstanceTypeConfigs []InstanceTypeConfig

+ LaunchSpecifications *InstanceFleetProvisioningSpecifications

+ Name *string

+ TargetOnDemandCapacity *int64

+ TargetSpotCapacity *int64

+ func (s *InstanceFleetConfig) SetInstanceFleetType(v InstanceFleetType) *InstanceFleetConfig

+ func (s *InstanceFleetConfig) SetInstanceTypeConfigs(v []InstanceTypeConfig) *InstanceFleetConfig

+ func (s *InstanceFleetConfig) SetLaunchSpecifications(v *InstanceFleetProvisioningSpecifications) *InstanceFleetConfig

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

+ func (s *InstanceFleetConfig) SetTargetOnDemandCapacity(v int64) *InstanceFleetConfig

+ func (s *InstanceFleetConfig) SetTargetSpotCapacity(v int64) *InstanceFleetConfig

+ func (s *InstanceFleetConfig) Validate() error

+ func (s InstanceFleetConfig) GoString() string

+ func (s InstanceFleetConfig) String() string

+ type InstanceFleetModifyConfig struct

+ InstanceFleetId *string

+ TargetOnDemandCapacity *int64

+ TargetSpotCapacity *int64

+ func (s *InstanceFleetModifyConfig) SetInstanceFleetId(v string) *InstanceFleetModifyConfig

+ func (s *InstanceFleetModifyConfig) SetTargetOnDemandCapacity(v int64) *InstanceFleetModifyConfig

+ func (s *InstanceFleetModifyConfig) SetTargetSpotCapacity(v int64) *InstanceFleetModifyConfig

+ func (s *InstanceFleetModifyConfig) Validate() error

+ func (s InstanceFleetModifyConfig) GoString() string

+ func (s InstanceFleetModifyConfig) String() string

+ type InstanceFleetProvisioningSpecifications struct

+ SpotSpecification *SpotProvisioningSpecification

+ func (s *InstanceFleetProvisioningSpecifications) SetSpotSpecification(v *SpotProvisioningSpecification) *InstanceFleetProvisioningSpecifications

+ func (s *InstanceFleetProvisioningSpecifications) Validate() error

+ func (s InstanceFleetProvisioningSpecifications) GoString() string

+ func (s InstanceFleetProvisioningSpecifications) String() string

+ type InstanceFleetState string

+ const InstanceFleetStateBootstrapping

+ const InstanceFleetStateProvisioning

+ const InstanceFleetStateResizing

+ const InstanceFleetStateRunning

+ const InstanceFleetStateSuspended

+ const InstanceFleetStateTerminated

+ const InstanceFleetStateTerminating

+ type InstanceFleetStateChangeReason struct

+ Code InstanceFleetStateChangeReasonCode

+ Message *string

+ func (s *InstanceFleetStateChangeReason) SetCode(v InstanceFleetStateChangeReasonCode) *InstanceFleetStateChangeReason

+ func (s *InstanceFleetStateChangeReason) SetMessage(v string) *InstanceFleetStateChangeReason

+ func (s InstanceFleetStateChangeReason) GoString() string

+ func (s InstanceFleetStateChangeReason) String() string

+ type InstanceFleetStateChangeReasonCode string

+ const InstanceFleetStateChangeReasonCodeClusterTerminated

+ const InstanceFleetStateChangeReasonCodeInstanceFailure

+ const InstanceFleetStateChangeReasonCodeInternalError

+ const InstanceFleetStateChangeReasonCodeValidationError

+ type InstanceFleetStatus struct

+ State InstanceFleetState

+ StateChangeReason *InstanceFleetStateChangeReason

+ Timeline *InstanceFleetTimeline

+ func (s *InstanceFleetStatus) SetState(v InstanceFleetState) *InstanceFleetStatus

+ func (s *InstanceFleetStatus) SetStateChangeReason(v *InstanceFleetStateChangeReason) *InstanceFleetStatus

+ func (s *InstanceFleetStatus) SetTimeline(v *InstanceFleetTimeline) *InstanceFleetStatus

+ func (s InstanceFleetStatus) GoString() string

+ func (s InstanceFleetStatus) String() string

+ type InstanceFleetTimeline struct

+ CreationDateTime *time.Time

+ EndDateTime *time.Time

+ ReadyDateTime *time.Time

+ func (s *InstanceFleetTimeline) SetCreationDateTime(v time.Time) *InstanceFleetTimeline

+ func (s *InstanceFleetTimeline) SetEndDateTime(v time.Time) *InstanceFleetTimeline

+ func (s *InstanceFleetTimeline) SetReadyDateTime(v time.Time) *InstanceFleetTimeline

+ func (s InstanceFleetTimeline) GoString() string

+ func (s InstanceFleetTimeline) String() string

+ type InstanceFleetType string

+ const InstanceFleetTypeCore

+ const InstanceFleetTypeMaster

+ const InstanceFleetTypeTask

+ type InstanceGroup struct

+ AutoScalingPolicy *AutoScalingPolicyDescription

+ BidPrice *string

+ Configurations []Configuration

+ EbsBlockDevices []EbsBlockDevice

+ EbsOptimized *bool

+ Id *string

+ InstanceGroupType InstanceGroupType

+ InstanceType *string

+ Market MarketType

+ Name *string

+ RequestedInstanceCount *int64

+ RunningInstanceCount *int64

+ ShrinkPolicy *ShrinkPolicy

+ Status *InstanceGroupStatus

+ func (s *InstanceGroup) SetAutoScalingPolicy(v *AutoScalingPolicyDescription) *InstanceGroup

+ func (s *InstanceGroup) SetBidPrice(v string) *InstanceGroup

+ func (s *InstanceGroup) SetConfigurations(v []Configuration) *InstanceGroup

+ func (s *InstanceGroup) SetEbsBlockDevices(v []EbsBlockDevice) *InstanceGroup

+ func (s *InstanceGroup) SetEbsOptimized(v bool) *InstanceGroup

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

+ func (s *InstanceGroup) SetInstanceGroupType(v InstanceGroupType) *InstanceGroup

+ func (s *InstanceGroup) SetInstanceType(v string) *InstanceGroup

+ func (s *InstanceGroup) SetMarket(v MarketType) *InstanceGroup

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

+ func (s *InstanceGroup) SetRequestedInstanceCount(v int64) *InstanceGroup

+ func (s *InstanceGroup) SetRunningInstanceCount(v int64) *InstanceGroup

+ func (s *InstanceGroup) SetShrinkPolicy(v *ShrinkPolicy) *InstanceGroup

+ func (s *InstanceGroup) SetStatus(v *InstanceGroupStatus) *InstanceGroup

+ func (s InstanceGroup) GoString() string

+ func (s InstanceGroup) String() string

+ type InstanceGroupConfig struct

+ AutoScalingPolicy *AutoScalingPolicy

+ BidPrice *string

+ Configurations []Configuration

+ EbsConfiguration *EbsConfiguration

+ InstanceCount *int64

+ InstanceRole InstanceRoleType

+ InstanceType *string

+ Market MarketType

+ Name *string

+ func (s *InstanceGroupConfig) SetAutoScalingPolicy(v *AutoScalingPolicy) *InstanceGroupConfig

+ func (s *InstanceGroupConfig) SetBidPrice(v string) *InstanceGroupConfig

+ func (s *InstanceGroupConfig) SetConfigurations(v []Configuration) *InstanceGroupConfig

+ func (s *InstanceGroupConfig) SetEbsConfiguration(v *EbsConfiguration) *InstanceGroupConfig

+ func (s *InstanceGroupConfig) SetInstanceCount(v int64) *InstanceGroupConfig

+ func (s *InstanceGroupConfig) SetInstanceRole(v InstanceRoleType) *InstanceGroupConfig

+ func (s *InstanceGroupConfig) SetInstanceType(v string) *InstanceGroupConfig

+ func (s *InstanceGroupConfig) SetMarket(v MarketType) *InstanceGroupConfig

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

+ func (s *InstanceGroupConfig) Validate() error

+ func (s InstanceGroupConfig) GoString() string

+ func (s InstanceGroupConfig) String() string

+ type InstanceGroupDetail struct

+ BidPrice *string

+ CreationDateTime *time.Time

+ EndDateTime *time.Time

+ InstanceGroupId *string

+ InstanceRequestCount *int64

+ InstanceRole InstanceRoleType

+ InstanceRunningCount *int64

+ InstanceType *string

+ LastStateChangeReason *string

+ Market MarketType

+ Name *string

+ ReadyDateTime *time.Time

+ StartDateTime *time.Time

+ State InstanceGroupState

+ func (s *InstanceGroupDetail) SetBidPrice(v string) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetCreationDateTime(v time.Time) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetEndDateTime(v time.Time) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetInstanceGroupId(v string) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetInstanceRequestCount(v int64) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetInstanceRole(v InstanceRoleType) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetInstanceRunningCount(v int64) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetInstanceType(v string) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetLastStateChangeReason(v string) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetMarket(v MarketType) *InstanceGroupDetail

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

+ func (s *InstanceGroupDetail) SetReadyDateTime(v time.Time) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetStartDateTime(v time.Time) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetState(v InstanceGroupState) *InstanceGroupDetail

+ func (s InstanceGroupDetail) GoString() string

+ func (s InstanceGroupDetail) String() string

+ type InstanceGroupModifyConfig struct

+ EC2InstanceIdsToTerminate []string

+ InstanceCount *int64

+ InstanceGroupId *string

+ ShrinkPolicy *ShrinkPolicy

+ func (s *InstanceGroupModifyConfig) SetEC2InstanceIdsToTerminate(v []string) *InstanceGroupModifyConfig

+ func (s *InstanceGroupModifyConfig) SetInstanceCount(v int64) *InstanceGroupModifyConfig

+ func (s *InstanceGroupModifyConfig) SetInstanceGroupId(v string) *InstanceGroupModifyConfig

+ func (s *InstanceGroupModifyConfig) SetShrinkPolicy(v *ShrinkPolicy) *InstanceGroupModifyConfig

+ func (s *InstanceGroupModifyConfig) Validate() error

+ func (s InstanceGroupModifyConfig) GoString() string

+ func (s InstanceGroupModifyConfig) String() string

+ type InstanceGroupState string

+ const InstanceGroupStateArrested

+ const InstanceGroupStateBootstrapping

+ const InstanceGroupStateEnded

+ const InstanceGroupStateProvisioning

+ const InstanceGroupStateResizing

+ const InstanceGroupStateRunning

+ const InstanceGroupStateShuttingDown

+ const InstanceGroupStateSuspended

+ const InstanceGroupStateTerminated

+ const InstanceGroupStateTerminating

+ type InstanceGroupStateChangeReason struct

+ Code InstanceGroupStateChangeReasonCode

+ Message *string

+ func (s *InstanceGroupStateChangeReason) SetCode(v InstanceGroupStateChangeReasonCode) *InstanceGroupStateChangeReason

+ func (s *InstanceGroupStateChangeReason) SetMessage(v string) *InstanceGroupStateChangeReason

+ func (s InstanceGroupStateChangeReason) GoString() string

+ func (s InstanceGroupStateChangeReason) String() string

+ type InstanceGroupStateChangeReasonCode string

+ const InstanceGroupStateChangeReasonCodeClusterTerminated

+ const InstanceGroupStateChangeReasonCodeInstanceFailure

+ const InstanceGroupStateChangeReasonCodeInternalError

+ const InstanceGroupStateChangeReasonCodeValidationError

+ type InstanceGroupStatus struct

+ State InstanceGroupState

+ StateChangeReason *InstanceGroupStateChangeReason

+ Timeline *InstanceGroupTimeline

+ func (s *InstanceGroupStatus) SetState(v InstanceGroupState) *InstanceGroupStatus

+ func (s *InstanceGroupStatus) SetStateChangeReason(v *InstanceGroupStateChangeReason) *InstanceGroupStatus

+ func (s *InstanceGroupStatus) SetTimeline(v *InstanceGroupTimeline) *InstanceGroupStatus

+ func (s InstanceGroupStatus) GoString() string

+ func (s InstanceGroupStatus) String() string

+ type InstanceGroupTimeline struct

+ CreationDateTime *time.Time

+ EndDateTime *time.Time

+ ReadyDateTime *time.Time

+ func (s *InstanceGroupTimeline) SetCreationDateTime(v time.Time) *InstanceGroupTimeline

+ func (s *InstanceGroupTimeline) SetEndDateTime(v time.Time) *InstanceGroupTimeline

+ func (s *InstanceGroupTimeline) SetReadyDateTime(v time.Time) *InstanceGroupTimeline

+ func (s InstanceGroupTimeline) GoString() string

+ func (s InstanceGroupTimeline) String() string

+ type InstanceGroupType string

+ const InstanceGroupTypeCore

+ const InstanceGroupTypeMaster

+ const InstanceGroupTypeTask

+ type InstanceResizePolicy struct

+ InstanceTerminationTimeout *int64

+ InstancesToProtect []string

+ InstancesToTerminate []string

+ func (s *InstanceResizePolicy) SetInstanceTerminationTimeout(v int64) *InstanceResizePolicy

+ func (s *InstanceResizePolicy) SetInstancesToProtect(v []string) *InstanceResizePolicy

+ func (s *InstanceResizePolicy) SetInstancesToTerminate(v []string) *InstanceResizePolicy

+ func (s InstanceResizePolicy) GoString() string

+ func (s InstanceResizePolicy) String() string

+ type InstanceRoleType string

+ const InstanceRoleTypeCore

+ const InstanceRoleTypeMaster

+ const InstanceRoleTypeTask

+ type InstanceState string

+ const InstanceStateAwaitingFulfillment

+ const InstanceStateBootstrapping

+ const InstanceStateProvisioning

+ const InstanceStateRunning

+ const InstanceStateTerminated

+ type InstanceStateChangeReason struct

+ Code InstanceStateChangeReasonCode

+ Message *string

+ func (s *InstanceStateChangeReason) SetCode(v InstanceStateChangeReasonCode) *InstanceStateChangeReason

+ func (s *InstanceStateChangeReason) SetMessage(v string) *InstanceStateChangeReason

+ func (s InstanceStateChangeReason) GoString() string

+ func (s InstanceStateChangeReason) String() string

+ type InstanceStateChangeReasonCode string

+ const InstanceStateChangeReasonCodeBootstrapFailure

+ const InstanceStateChangeReasonCodeClusterTerminated

+ const InstanceStateChangeReasonCodeInstanceFailure

+ const InstanceStateChangeReasonCodeInternalError

+ const InstanceStateChangeReasonCodeValidationError

+ type InstanceStatus struct

+ State InstanceState

+ StateChangeReason *InstanceStateChangeReason

+ Timeline *InstanceTimeline

+ func (s *InstanceStatus) SetState(v InstanceState) *InstanceStatus

+ func (s *InstanceStatus) SetStateChangeReason(v *InstanceStateChangeReason) *InstanceStatus

+ func (s *InstanceStatus) SetTimeline(v *InstanceTimeline) *InstanceStatus

+ func (s InstanceStatus) GoString() string

+ func (s InstanceStatus) String() string

+ type InstanceTimeline struct

+ CreationDateTime *time.Time

+ EndDateTime *time.Time

+ ReadyDateTime *time.Time

+ func (s *InstanceTimeline) SetCreationDateTime(v time.Time) *InstanceTimeline

+ func (s *InstanceTimeline) SetEndDateTime(v time.Time) *InstanceTimeline

+ func (s *InstanceTimeline) SetReadyDateTime(v time.Time) *InstanceTimeline

+ func (s InstanceTimeline) GoString() string

+ func (s InstanceTimeline) String() string

+ type InstanceTypeConfig struct

+ BidPrice *string

+ BidPriceAsPercentageOfOnDemandPrice *float64

+ Configurations []Configuration

+ EbsConfiguration *EbsConfiguration

+ InstanceType *string

+ WeightedCapacity *int64

+ func (s *InstanceTypeConfig) SetBidPrice(v string) *InstanceTypeConfig

+ func (s *InstanceTypeConfig) SetBidPriceAsPercentageOfOnDemandPrice(v float64) *InstanceTypeConfig

+ func (s *InstanceTypeConfig) SetConfigurations(v []Configuration) *InstanceTypeConfig

+ func (s *InstanceTypeConfig) SetEbsConfiguration(v *EbsConfiguration) *InstanceTypeConfig

+ func (s *InstanceTypeConfig) SetInstanceType(v string) *InstanceTypeConfig

+ func (s *InstanceTypeConfig) SetWeightedCapacity(v int64) *InstanceTypeConfig

+ func (s *InstanceTypeConfig) Validate() error

+ func (s InstanceTypeConfig) GoString() string

+ func (s InstanceTypeConfig) String() string

+ type InstanceTypeSpecification struct

+ BidPrice *string

+ BidPriceAsPercentageOfOnDemandPrice *float64

+ Configurations []Configuration

+ EbsBlockDevices []EbsBlockDevice

+ EbsOptimized *bool

+ InstanceType *string

+ WeightedCapacity *int64

+ func (s *InstanceTypeSpecification) SetBidPrice(v string) *InstanceTypeSpecification

+ func (s *InstanceTypeSpecification) SetBidPriceAsPercentageOfOnDemandPrice(v float64) *InstanceTypeSpecification

+ func (s *InstanceTypeSpecification) SetConfigurations(v []Configuration) *InstanceTypeSpecification

+ func (s *InstanceTypeSpecification) SetEbsBlockDevices(v []EbsBlockDevice) *InstanceTypeSpecification

+ func (s *InstanceTypeSpecification) SetEbsOptimized(v bool) *InstanceTypeSpecification

+ func (s *InstanceTypeSpecification) SetInstanceType(v string) *InstanceTypeSpecification

+ func (s *InstanceTypeSpecification) SetWeightedCapacity(v int64) *InstanceTypeSpecification

+ func (s InstanceTypeSpecification) GoString() string

+ func (s InstanceTypeSpecification) String() string

+ type JobFlowDetail struct

+ AmiVersion *string

+ AutoScalingRole *string

+ BootstrapActions []BootstrapActionDetail

+ ExecutionStatusDetail *JobFlowExecutionStatusDetail

+ Instances *JobFlowInstancesDetail

+ JobFlowId *string

+ JobFlowRole *string

+ LogUri *string

+ Name *string

+ ScaleDownBehavior ScaleDownBehavior

+ ServiceRole *string

+ Steps []StepDetail

+ SupportedProducts []string

+ VisibleToAllUsers *bool

+ func (s *JobFlowDetail) SetAmiVersion(v string) *JobFlowDetail

+ func (s *JobFlowDetail) SetAutoScalingRole(v string) *JobFlowDetail

+ func (s *JobFlowDetail) SetBootstrapActions(v []BootstrapActionDetail) *JobFlowDetail

+ func (s *JobFlowDetail) SetExecutionStatusDetail(v *JobFlowExecutionStatusDetail) *JobFlowDetail

+ func (s *JobFlowDetail) SetInstances(v *JobFlowInstancesDetail) *JobFlowDetail

+ func (s *JobFlowDetail) SetJobFlowId(v string) *JobFlowDetail

+ func (s *JobFlowDetail) SetJobFlowRole(v string) *JobFlowDetail

+ func (s *JobFlowDetail) SetLogUri(v string) *JobFlowDetail

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

+ func (s *JobFlowDetail) SetScaleDownBehavior(v ScaleDownBehavior) *JobFlowDetail

+ func (s *JobFlowDetail) SetServiceRole(v string) *JobFlowDetail

+ func (s *JobFlowDetail) SetSteps(v []StepDetail) *JobFlowDetail

+ func (s *JobFlowDetail) SetSupportedProducts(v []string) *JobFlowDetail

+ func (s *JobFlowDetail) SetVisibleToAllUsers(v bool) *JobFlowDetail

+ func (s JobFlowDetail) GoString() string

+ func (s JobFlowDetail) String() string

+ type JobFlowExecutionState string

+ const JobFlowExecutionStateBootstrapping

+ const JobFlowExecutionStateCompleted

+ const JobFlowExecutionStateFailed

+ const JobFlowExecutionStateRunning

+ const JobFlowExecutionStateShuttingDown

+ const JobFlowExecutionStateStarting

+ const JobFlowExecutionStateTerminated

+ const JobFlowExecutionStateWaiting

+ type JobFlowExecutionStatusDetail struct

+ CreationDateTime *time.Time

+ EndDateTime *time.Time

+ LastStateChangeReason *string

+ ReadyDateTime *time.Time

+ StartDateTime *time.Time

+ State JobFlowExecutionState

+ func (s *JobFlowExecutionStatusDetail) SetCreationDateTime(v time.Time) *JobFlowExecutionStatusDetail

+ func (s *JobFlowExecutionStatusDetail) SetEndDateTime(v time.Time) *JobFlowExecutionStatusDetail

+ func (s *JobFlowExecutionStatusDetail) SetLastStateChangeReason(v string) *JobFlowExecutionStatusDetail

+ func (s *JobFlowExecutionStatusDetail) SetReadyDateTime(v time.Time) *JobFlowExecutionStatusDetail

+ func (s *JobFlowExecutionStatusDetail) SetStartDateTime(v time.Time) *JobFlowExecutionStatusDetail

+ func (s *JobFlowExecutionStatusDetail) SetState(v JobFlowExecutionState) *JobFlowExecutionStatusDetail

+ func (s JobFlowExecutionStatusDetail) GoString() string

+ func (s JobFlowExecutionStatusDetail) String() string

+ type JobFlowInstancesConfig struct

+ AdditionalMasterSecurityGroups []string

+ AdditionalSlaveSecurityGroups []string

+ Ec2KeyName *string

+ Ec2SubnetId *string

+ Ec2SubnetIds []string

+ EmrManagedMasterSecurityGroup *string

+ EmrManagedSlaveSecurityGroup *string

+ HadoopVersion *string

+ InstanceCount *int64

+ InstanceFleets []InstanceFleetConfig

+ InstanceGroups []InstanceGroupConfig

+ KeepJobFlowAliveWhenNoSteps *bool

+ MasterInstanceType *string

+ Placement *PlacementType

+ ServiceAccessSecurityGroup *string

+ SlaveInstanceType *string

+ TerminationProtected *bool

+ func (s *JobFlowInstancesConfig) SetAdditionalMasterSecurityGroups(v []string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetAdditionalSlaveSecurityGroups(v []string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetEc2KeyName(v string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetEc2SubnetId(v string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetEc2SubnetIds(v []string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetEmrManagedMasterSecurityGroup(v string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetEmrManagedSlaveSecurityGroup(v string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetHadoopVersion(v string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetInstanceCount(v int64) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetInstanceFleets(v []InstanceFleetConfig) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetInstanceGroups(v []InstanceGroupConfig) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetKeepJobFlowAliveWhenNoSteps(v bool) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetMasterInstanceType(v string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetPlacement(v *PlacementType) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetServiceAccessSecurityGroup(v string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetSlaveInstanceType(v string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetTerminationProtected(v bool) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) Validate() error

+ func (s JobFlowInstancesConfig) GoString() string

+ func (s JobFlowInstancesConfig) String() string

+ type JobFlowInstancesDetail struct

+ Ec2KeyName *string

+ Ec2SubnetId *string

+ HadoopVersion *string

+ InstanceCount *int64

+ InstanceGroups []InstanceGroupDetail

+ KeepJobFlowAliveWhenNoSteps *bool

+ MasterInstanceId *string

+ MasterInstanceType *string

+ MasterPublicDnsName *string

+ NormalizedInstanceHours *int64

+ Placement *PlacementType

+ SlaveInstanceType *string

+ TerminationProtected *bool

+ func (s *JobFlowInstancesDetail) SetEc2KeyName(v string) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetEc2SubnetId(v string) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetHadoopVersion(v string) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetInstanceCount(v int64) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetInstanceGroups(v []InstanceGroupDetail) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetKeepJobFlowAliveWhenNoSteps(v bool) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetMasterInstanceId(v string) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetMasterInstanceType(v string) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetMasterPublicDnsName(v string) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetNormalizedInstanceHours(v int64) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetPlacement(v *PlacementType) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetSlaveInstanceType(v string) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetTerminationProtected(v bool) *JobFlowInstancesDetail

+ func (s JobFlowInstancesDetail) GoString() string

+ func (s JobFlowInstancesDetail) String() string

+ type KeyValue struct

+ Key *string

+ Value *string

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

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

+ func (s KeyValue) GoString() string

+ func (s KeyValue) String() string

+ type ListBootstrapActionsInput struct

+ ClusterId *string

+ Marker *string

+ func (s *ListBootstrapActionsInput) SetClusterId(v string) *ListBootstrapActionsInput

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

+ func (s *ListBootstrapActionsInput) Validate() error

+ func (s ListBootstrapActionsInput) GoString() string

+ func (s ListBootstrapActionsInput) String() string

+ type ListBootstrapActionsOutput struct

+ BootstrapActions []Command

+ Marker *string

+ func (s *ListBootstrapActionsOutput) SetBootstrapActions(v []Command) *ListBootstrapActionsOutput

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

+ func (s ListBootstrapActionsOutput) GoString() string

+ func (s ListBootstrapActionsOutput) SDKResponseMetadata() aws.Response

+ func (s ListBootstrapActionsOutput) String() string

+ type ListBootstrapActionsRequest struct

+ Input *ListBootstrapActionsInput

+ func (r ListBootstrapActionsRequest) Send() (*ListBootstrapActionsOutput, error)

+ type ListClustersInput struct

+ ClusterStates []ClusterState

+ CreatedAfter *time.Time

+ CreatedBefore *time.Time

+ Marker *string

+ func (s *ListClustersInput) SetClusterStates(v []ClusterState) *ListClustersInput

+ func (s *ListClustersInput) SetCreatedAfter(v time.Time) *ListClustersInput

+ func (s *ListClustersInput) SetCreatedBefore(v time.Time) *ListClustersInput

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

+ func (s ListClustersInput) GoString() string

+ func (s ListClustersInput) String() string

+ type ListClustersOutput struct

+ Clusters []ClusterSummary

+ Marker *string

+ func (s *ListClustersOutput) SetClusters(v []ClusterSummary) *ListClustersOutput

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

+ func (s ListClustersOutput) GoString() string

+ func (s ListClustersOutput) SDKResponseMetadata() aws.Response

+ func (s ListClustersOutput) String() string

+ type ListClustersRequest struct

+ Input *ListClustersInput

+ func (r ListClustersRequest) Send() (*ListClustersOutput, error)

+ type ListInstanceFleetsInput struct

+ ClusterId *string

+ Marker *string

+ func (s *ListInstanceFleetsInput) SetClusterId(v string) *ListInstanceFleetsInput

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

+ func (s *ListInstanceFleetsInput) Validate() error

+ func (s ListInstanceFleetsInput) GoString() string

+ func (s ListInstanceFleetsInput) String() string

+ type ListInstanceFleetsOutput struct

+ InstanceFleets []InstanceFleet

+ Marker *string

+ func (s *ListInstanceFleetsOutput) SetInstanceFleets(v []InstanceFleet) *ListInstanceFleetsOutput

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

+ func (s ListInstanceFleetsOutput) GoString() string

+ func (s ListInstanceFleetsOutput) SDKResponseMetadata() aws.Response

+ func (s ListInstanceFleetsOutput) String() string

+ type ListInstanceFleetsRequest struct

+ Input *ListInstanceFleetsInput

+ func (r ListInstanceFleetsRequest) Send() (*ListInstanceFleetsOutput, error)

+ type ListInstanceGroupsInput struct

+ ClusterId *string

+ Marker *string

+ func (s *ListInstanceGroupsInput) SetClusterId(v string) *ListInstanceGroupsInput

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

+ func (s *ListInstanceGroupsInput) Validate() error

+ func (s ListInstanceGroupsInput) GoString() string

+ func (s ListInstanceGroupsInput) String() string

+ type ListInstanceGroupsOutput struct

+ InstanceGroups []InstanceGroup

+ Marker *string

+ func (s *ListInstanceGroupsOutput) SetInstanceGroups(v []InstanceGroup) *ListInstanceGroupsOutput

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

+ func (s ListInstanceGroupsOutput) GoString() string

+ func (s ListInstanceGroupsOutput) SDKResponseMetadata() aws.Response

+ func (s ListInstanceGroupsOutput) String() string

+ type ListInstanceGroupsRequest struct

+ Input *ListInstanceGroupsInput

+ func (r ListInstanceGroupsRequest) Send() (*ListInstanceGroupsOutput, error)

+ type ListInstancesInput struct

+ ClusterId *string

+ InstanceFleetId *string

+ InstanceFleetType InstanceFleetType

+ InstanceGroupId *string

+ InstanceGroupTypes []InstanceGroupType

+ InstanceStates []InstanceState

+ Marker *string

+ func (s *ListInstancesInput) SetClusterId(v string) *ListInstancesInput

+ func (s *ListInstancesInput) SetInstanceFleetId(v string) *ListInstancesInput

+ func (s *ListInstancesInput) SetInstanceFleetType(v InstanceFleetType) *ListInstancesInput

+ func (s *ListInstancesInput) SetInstanceGroupId(v string) *ListInstancesInput

+ func (s *ListInstancesInput) SetInstanceGroupTypes(v []InstanceGroupType) *ListInstancesInput

+ func (s *ListInstancesInput) SetInstanceStates(v []InstanceState) *ListInstancesInput

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

+ func (s *ListInstancesInput) Validate() error

+ func (s ListInstancesInput) GoString() string

+ func (s ListInstancesInput) String() string

+ type ListInstancesOutput struct

+ Instances []Instance

+ Marker *string

+ func (s *ListInstancesOutput) SetInstances(v []Instance) *ListInstancesOutput

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

+ func (s ListInstancesOutput) GoString() string

+ func (s ListInstancesOutput) SDKResponseMetadata() aws.Response

+ func (s ListInstancesOutput) String() string

+ type ListInstancesRequest struct

+ Input *ListInstancesInput

+ func (r ListInstancesRequest) Send() (*ListInstancesOutput, error)

+ type ListSecurityConfigurationsInput struct

+ Marker *string

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

+ func (s ListSecurityConfigurationsInput) GoString() string

+ func (s ListSecurityConfigurationsInput) String() string

+ type ListSecurityConfigurationsOutput struct

+ Marker *string

+ SecurityConfigurations []SecurityConfigurationSummary

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

+ func (s *ListSecurityConfigurationsOutput) SetSecurityConfigurations(v []SecurityConfigurationSummary) *ListSecurityConfigurationsOutput

+ func (s ListSecurityConfigurationsOutput) GoString() string

+ func (s ListSecurityConfigurationsOutput) SDKResponseMetadata() aws.Response

+ func (s ListSecurityConfigurationsOutput) String() string

+ type ListSecurityConfigurationsRequest struct

+ Input *ListSecurityConfigurationsInput

+ func (r ListSecurityConfigurationsRequest) Send() (*ListSecurityConfigurationsOutput, error)

+ type ListStepsInput struct

+ ClusterId *string

+ Marker *string

+ StepIds []string

+ StepStates []StepState

+ func (s *ListStepsInput) SetClusterId(v string) *ListStepsInput

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

+ func (s *ListStepsInput) SetStepIds(v []string) *ListStepsInput

+ func (s *ListStepsInput) SetStepStates(v []StepState) *ListStepsInput

+ func (s *ListStepsInput) Validate() error

+ func (s ListStepsInput) GoString() string

+ func (s ListStepsInput) String() string

+ type ListStepsOutput struct

+ Marker *string

+ Steps []StepSummary

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

+ func (s *ListStepsOutput) SetSteps(v []StepSummary) *ListStepsOutput

+ func (s ListStepsOutput) GoString() string

+ func (s ListStepsOutput) SDKResponseMetadata() aws.Response

+ func (s ListStepsOutput) String() string

+ type ListStepsRequest struct

+ Input *ListStepsInput

+ func (r ListStepsRequest) Send() (*ListStepsOutput, error)

+ type MarketType string

+ const MarketTypeOnDemand

+ const MarketTypeSpot

+ type MetricDimension struct

+ Key *string

+ Value *string

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

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

+ func (s MetricDimension) GoString() string

+ func (s MetricDimension) String() string

+ type ModifyInstanceFleetInput struct

+ ClusterId *string

+ InstanceFleet *InstanceFleetModifyConfig

+ func (s *ModifyInstanceFleetInput) SetClusterId(v string) *ModifyInstanceFleetInput

+ func (s *ModifyInstanceFleetInput) SetInstanceFleet(v *InstanceFleetModifyConfig) *ModifyInstanceFleetInput

+ func (s *ModifyInstanceFleetInput) Validate() error

+ func (s ModifyInstanceFleetInput) GoString() string

+ func (s ModifyInstanceFleetInput) String() string

+ type ModifyInstanceFleetOutput struct

+ func (s ModifyInstanceFleetOutput) GoString() string

+ func (s ModifyInstanceFleetOutput) SDKResponseMetadata() aws.Response

+ func (s ModifyInstanceFleetOutput) String() string

+ type ModifyInstanceFleetRequest struct

+ Input *ModifyInstanceFleetInput

+ func (r ModifyInstanceFleetRequest) Send() (*ModifyInstanceFleetOutput, error)

+ type ModifyInstanceGroupsInput struct

+ ClusterId *string

+ InstanceGroups []InstanceGroupModifyConfig

+ func (s *ModifyInstanceGroupsInput) SetClusterId(v string) *ModifyInstanceGroupsInput

+ func (s *ModifyInstanceGroupsInput) SetInstanceGroups(v []InstanceGroupModifyConfig) *ModifyInstanceGroupsInput

+ func (s *ModifyInstanceGroupsInput) Validate() error

+ func (s ModifyInstanceGroupsInput) GoString() string

+ func (s ModifyInstanceGroupsInput) String() string

+ type ModifyInstanceGroupsOutput struct

+ func (s ModifyInstanceGroupsOutput) GoString() string

+ func (s ModifyInstanceGroupsOutput) SDKResponseMetadata() aws.Response

+ func (s ModifyInstanceGroupsOutput) String() string

+ type ModifyInstanceGroupsRequest struct

+ Input *ModifyInstanceGroupsInput

+ func (r ModifyInstanceGroupsRequest) Send() (*ModifyInstanceGroupsOutput, error)

+ type PlacementType struct

+ AvailabilityZone *string

+ AvailabilityZones []string

+ func (s *PlacementType) SetAvailabilityZone(v string) *PlacementType

+ func (s *PlacementType) SetAvailabilityZones(v []string) *PlacementType

+ func (s PlacementType) GoString() string

+ func (s PlacementType) String() string

+ type PutAutoScalingPolicyInput struct

+ AutoScalingPolicy *AutoScalingPolicy

+ ClusterId *string

+ InstanceGroupId *string

+ func (s *PutAutoScalingPolicyInput) SetAutoScalingPolicy(v *AutoScalingPolicy) *PutAutoScalingPolicyInput

+ func (s *PutAutoScalingPolicyInput) SetClusterId(v string) *PutAutoScalingPolicyInput

+ func (s *PutAutoScalingPolicyInput) SetInstanceGroupId(v string) *PutAutoScalingPolicyInput

+ func (s *PutAutoScalingPolicyInput) Validate() error

+ func (s PutAutoScalingPolicyInput) GoString() string

+ func (s PutAutoScalingPolicyInput) String() string

+ type PutAutoScalingPolicyOutput struct

+ AutoScalingPolicy *AutoScalingPolicyDescription

+ ClusterId *string

+ InstanceGroupId *string

+ func (s *PutAutoScalingPolicyOutput) SetAutoScalingPolicy(v *AutoScalingPolicyDescription) *PutAutoScalingPolicyOutput

+ func (s *PutAutoScalingPolicyOutput) SetClusterId(v string) *PutAutoScalingPolicyOutput

+ func (s *PutAutoScalingPolicyOutput) SetInstanceGroupId(v string) *PutAutoScalingPolicyOutput

+ func (s PutAutoScalingPolicyOutput) GoString() string

+ func (s PutAutoScalingPolicyOutput) SDKResponseMetadata() aws.Response

+ func (s PutAutoScalingPolicyOutput) String() string

+ type PutAutoScalingPolicyRequest struct

+ Input *PutAutoScalingPolicyInput

+ func (r PutAutoScalingPolicyRequest) Send() (*PutAutoScalingPolicyOutput, error)

+ type RemoveAutoScalingPolicyInput struct

+ ClusterId *string

+ InstanceGroupId *string

+ func (s *RemoveAutoScalingPolicyInput) SetClusterId(v string) *RemoveAutoScalingPolicyInput

+ func (s *RemoveAutoScalingPolicyInput) SetInstanceGroupId(v string) *RemoveAutoScalingPolicyInput

+ func (s *RemoveAutoScalingPolicyInput) Validate() error

+ func (s RemoveAutoScalingPolicyInput) GoString() string

+ func (s RemoveAutoScalingPolicyInput) String() string

+ type RemoveAutoScalingPolicyOutput struct

+ func (s RemoveAutoScalingPolicyOutput) GoString() string

+ func (s RemoveAutoScalingPolicyOutput) SDKResponseMetadata() aws.Response

+ func (s RemoveAutoScalingPolicyOutput) String() string

+ type RemoveAutoScalingPolicyRequest struct

+ Input *RemoveAutoScalingPolicyInput

+ func (r RemoveAutoScalingPolicyRequest) Send() (*RemoveAutoScalingPolicyOutput, error)

+ type RemoveTagsInput struct

+ ResourceId *string

+ TagKeys []string

+ func (s *RemoveTagsInput) SetResourceId(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 RepoUpgradeOnBoot string

+ const RepoUpgradeOnBootNone

+ const RepoUpgradeOnBootSecurity

+ type RunJobFlowInput struct

+ AdditionalInfo *string

+ AmiVersion *string

+ Applications []Application

+ AutoScalingRole *string

+ BootstrapActions []BootstrapActionConfig

+ Configurations []Configuration

+ CustomAmiId *string

+ EbsRootVolumeSize *int64

+ Instances *JobFlowInstancesConfig

+ JobFlowRole *string

+ LogUri *string

+ Name *string

+ NewSupportedProducts []SupportedProductConfig

+ ReleaseLabel *string

+ RepoUpgradeOnBoot RepoUpgradeOnBoot

+ ScaleDownBehavior ScaleDownBehavior

+ SecurityConfiguration *string

+ ServiceRole *string

+ Steps []StepConfig

+ SupportedProducts []string

+ Tags []Tag

+ VisibleToAllUsers *bool

+ func (s *RunJobFlowInput) SetAdditionalInfo(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetAmiVersion(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetApplications(v []Application) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetAutoScalingRole(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetBootstrapActions(v []BootstrapActionConfig) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetConfigurations(v []Configuration) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetCustomAmiId(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetEbsRootVolumeSize(v int64) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetInstances(v *JobFlowInstancesConfig) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetJobFlowRole(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetLogUri(v string) *RunJobFlowInput

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

+ func (s *RunJobFlowInput) SetNewSupportedProducts(v []SupportedProductConfig) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetReleaseLabel(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetRepoUpgradeOnBoot(v RepoUpgradeOnBoot) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetScaleDownBehavior(v ScaleDownBehavior) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetSecurityConfiguration(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetServiceRole(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetSteps(v []StepConfig) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetSupportedProducts(v []string) *RunJobFlowInput

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

+ func (s *RunJobFlowInput) SetVisibleToAllUsers(v bool) *RunJobFlowInput

+ func (s *RunJobFlowInput) Validate() error

+ func (s RunJobFlowInput) GoString() string

+ func (s RunJobFlowInput) String() string

+ type RunJobFlowOutput struct

+ JobFlowId *string

+ func (s *RunJobFlowOutput) SetJobFlowId(v string) *RunJobFlowOutput

+ func (s RunJobFlowOutput) GoString() string

+ func (s RunJobFlowOutput) SDKResponseMetadata() aws.Response

+ func (s RunJobFlowOutput) String() string

+ type RunJobFlowRequest struct

+ Input *RunJobFlowInput

+ func (r RunJobFlowRequest) Send() (*RunJobFlowOutput, error)

+ type ScaleDownBehavior string

+ const ScaleDownBehaviorTerminateAtInstanceHour

+ const ScaleDownBehaviorTerminateAtTaskCompletion

+ type ScalingAction struct

+ Market MarketType

+ SimpleScalingPolicyConfiguration *SimpleScalingPolicyConfiguration

+ func (s *ScalingAction) SetMarket(v MarketType) *ScalingAction

+ func (s *ScalingAction) SetSimpleScalingPolicyConfiguration(v *SimpleScalingPolicyConfiguration) *ScalingAction

+ func (s *ScalingAction) Validate() error

+ func (s ScalingAction) GoString() string

+ func (s ScalingAction) String() string

+ type ScalingConstraints struct

+ MaxCapacity *int64

+ MinCapacity *int64

+ func (s *ScalingConstraints) SetMaxCapacity(v int64) *ScalingConstraints

+ func (s *ScalingConstraints) SetMinCapacity(v int64) *ScalingConstraints

+ func (s *ScalingConstraints) Validate() error

+ func (s ScalingConstraints) GoString() string

+ func (s ScalingConstraints) String() string

+ type ScalingRule struct

+ Action *ScalingAction

+ Description *string

+ Name *string

+ Trigger *ScalingTrigger

+ func (s *ScalingRule) SetAction(v *ScalingAction) *ScalingRule

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

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

+ func (s *ScalingRule) SetTrigger(v *ScalingTrigger) *ScalingRule

+ func (s *ScalingRule) Validate() error

+ func (s ScalingRule) GoString() string

+ func (s ScalingRule) String() string

+ type ScalingTrigger struct

+ CloudWatchAlarmDefinition *CloudWatchAlarmDefinition

+ func (s *ScalingTrigger) SetCloudWatchAlarmDefinition(v *CloudWatchAlarmDefinition) *ScalingTrigger

+ func (s *ScalingTrigger) Validate() error

+ func (s ScalingTrigger) GoString() string

+ func (s ScalingTrigger) String() string

+ type ScriptBootstrapActionConfig struct

+ Args []string

+ Path *string

+ func (s *ScriptBootstrapActionConfig) SetArgs(v []string) *ScriptBootstrapActionConfig

+ func (s *ScriptBootstrapActionConfig) SetPath(v string) *ScriptBootstrapActionConfig

+ func (s *ScriptBootstrapActionConfig) Validate() error

+ func (s ScriptBootstrapActionConfig) GoString() string

+ func (s ScriptBootstrapActionConfig) String() string

+ type SecurityConfigurationSummary struct

+ CreationDateTime *time.Time

+ Name *string

+ func (s *SecurityConfigurationSummary) SetCreationDateTime(v time.Time) *SecurityConfigurationSummary

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

+ func (s SecurityConfigurationSummary) GoString() string

+ func (s SecurityConfigurationSummary) String() string

+ type SetTerminationProtectionInput struct

+ JobFlowIds []string

+ TerminationProtected *bool

+ func (s *SetTerminationProtectionInput) SetJobFlowIds(v []string) *SetTerminationProtectionInput

+ func (s *SetTerminationProtectionInput) SetTerminationProtected(v bool) *SetTerminationProtectionInput

+ func (s *SetTerminationProtectionInput) Validate() error

+ func (s SetTerminationProtectionInput) GoString() string

+ func (s SetTerminationProtectionInput) String() string

+ type SetTerminationProtectionOutput struct

+ func (s SetTerminationProtectionOutput) GoString() string

+ func (s SetTerminationProtectionOutput) SDKResponseMetadata() aws.Response

+ func (s SetTerminationProtectionOutput) String() string

+ type SetTerminationProtectionRequest struct

+ Input *SetTerminationProtectionInput

+ func (r SetTerminationProtectionRequest) Send() (*SetTerminationProtectionOutput, error)

+ type SetVisibleToAllUsersInput struct

+ JobFlowIds []string

+ VisibleToAllUsers *bool

+ func (s *SetVisibleToAllUsersInput) SetJobFlowIds(v []string) *SetVisibleToAllUsersInput

+ func (s *SetVisibleToAllUsersInput) SetVisibleToAllUsers(v bool) *SetVisibleToAllUsersInput

+ func (s *SetVisibleToAllUsersInput) Validate() error

+ func (s SetVisibleToAllUsersInput) GoString() string

+ func (s SetVisibleToAllUsersInput) String() string

+ type SetVisibleToAllUsersOutput struct

+ func (s SetVisibleToAllUsersOutput) GoString() string

+ func (s SetVisibleToAllUsersOutput) SDKResponseMetadata() aws.Response

+ func (s SetVisibleToAllUsersOutput) String() string

+ type SetVisibleToAllUsersRequest struct

+ Input *SetVisibleToAllUsersInput

+ func (r SetVisibleToAllUsersRequest) Send() (*SetVisibleToAllUsersOutput, error)

+ type ShrinkPolicy struct

+ DecommissionTimeout *int64

+ InstanceResizePolicy *InstanceResizePolicy

+ func (s *ShrinkPolicy) SetDecommissionTimeout(v int64) *ShrinkPolicy

+ func (s *ShrinkPolicy) SetInstanceResizePolicy(v *InstanceResizePolicy) *ShrinkPolicy

+ func (s ShrinkPolicy) GoString() string

+ func (s ShrinkPolicy) String() string

+ type SimpleScalingPolicyConfiguration struct

+ AdjustmentType AdjustmentType

+ CoolDown *int64

+ ScalingAdjustment *int64

+ func (s *SimpleScalingPolicyConfiguration) SetAdjustmentType(v AdjustmentType) *SimpleScalingPolicyConfiguration

+ func (s *SimpleScalingPolicyConfiguration) SetCoolDown(v int64) *SimpleScalingPolicyConfiguration

+ func (s *SimpleScalingPolicyConfiguration) SetScalingAdjustment(v int64) *SimpleScalingPolicyConfiguration

+ func (s *SimpleScalingPolicyConfiguration) Validate() error

+ func (s SimpleScalingPolicyConfiguration) GoString() string

+ func (s SimpleScalingPolicyConfiguration) String() string

+ type SpotProvisioningSpecification struct

+ BlockDurationMinutes *int64

+ TimeoutAction SpotProvisioningTimeoutAction

+ TimeoutDurationMinutes *int64

+ func (s *SpotProvisioningSpecification) SetBlockDurationMinutes(v int64) *SpotProvisioningSpecification

+ func (s *SpotProvisioningSpecification) SetTimeoutAction(v SpotProvisioningTimeoutAction) *SpotProvisioningSpecification

+ func (s *SpotProvisioningSpecification) SetTimeoutDurationMinutes(v int64) *SpotProvisioningSpecification

+ func (s *SpotProvisioningSpecification) Validate() error

+ func (s SpotProvisioningSpecification) GoString() string

+ func (s SpotProvisioningSpecification) String() string

+ type SpotProvisioningTimeoutAction string

+ const SpotProvisioningTimeoutActionSwitchToOnDemand

+ const SpotProvisioningTimeoutActionTerminateCluster

+ type Statistic string

+ const StatisticAverage

+ const StatisticMaximum

+ const StatisticMinimum

+ const StatisticSampleCount

+ const StatisticSum

+ type Step struct

+ ActionOnFailure ActionOnFailure

+ Config *HadoopStepConfig

+ Id *string

+ Name *string

+ Status *StepStatus

+ func (s *Step) SetActionOnFailure(v ActionOnFailure) *Step

+ func (s *Step) SetConfig(v *HadoopStepConfig) *Step

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

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

+ func (s *Step) SetStatus(v *StepStatus) *Step

+ func (s Step) GoString() string

+ func (s Step) String() string

+ type StepConfig struct

+ ActionOnFailure ActionOnFailure

+ HadoopJarStep *HadoopJarStepConfig

+ Name *string

+ func (s *StepConfig) SetActionOnFailure(v ActionOnFailure) *StepConfig

+ func (s *StepConfig) SetHadoopJarStep(v *HadoopJarStepConfig) *StepConfig

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

+ func (s *StepConfig) Validate() error

+ func (s StepConfig) GoString() string

+ func (s StepConfig) String() string

+ type StepDetail struct

+ ExecutionStatusDetail *StepExecutionStatusDetail

+ StepConfig *StepConfig

+ func (s *StepDetail) SetExecutionStatusDetail(v *StepExecutionStatusDetail) *StepDetail

+ func (s *StepDetail) SetStepConfig(v *StepConfig) *StepDetail

+ func (s StepDetail) GoString() string

+ func (s StepDetail) String() string

+ type StepExecutionState string

+ const StepExecutionStateCancelled

+ const StepExecutionStateCompleted

+ const StepExecutionStateContinue

+ const StepExecutionStateFailed

+ const StepExecutionStateInterrupted

+ const StepExecutionStatePending

+ const StepExecutionStateRunning

+ type StepExecutionStatusDetail struct

+ CreationDateTime *time.Time

+ EndDateTime *time.Time

+ LastStateChangeReason *string

+ StartDateTime *time.Time

+ State StepExecutionState

+ func (s *StepExecutionStatusDetail) SetCreationDateTime(v time.Time) *StepExecutionStatusDetail

+ func (s *StepExecutionStatusDetail) SetEndDateTime(v time.Time) *StepExecutionStatusDetail

+ func (s *StepExecutionStatusDetail) SetLastStateChangeReason(v string) *StepExecutionStatusDetail

+ func (s *StepExecutionStatusDetail) SetStartDateTime(v time.Time) *StepExecutionStatusDetail

+ func (s *StepExecutionStatusDetail) SetState(v StepExecutionState) *StepExecutionStatusDetail

+ func (s StepExecutionStatusDetail) GoString() string

+ func (s StepExecutionStatusDetail) String() string

+ type StepState string

+ const StepStateCancelPending

+ const StepStateCancelled

+ const StepStateCompleted

+ const StepStateFailed

+ const StepStateInterrupted

+ const StepStatePending

+ const StepStateRunning

+ type StepStateChangeReason struct

+ Code StepStateChangeReasonCode

+ Message *string

+ func (s *StepStateChangeReason) SetCode(v StepStateChangeReasonCode) *StepStateChangeReason

+ func (s *StepStateChangeReason) SetMessage(v string) *StepStateChangeReason

+ func (s StepStateChangeReason) GoString() string

+ func (s StepStateChangeReason) String() string

+ type StepStateChangeReasonCode string

+ const StepStateChangeReasonCodeNone

+ type StepStatus struct

+ FailureDetails *FailureDetails

+ State StepState

+ StateChangeReason *StepStateChangeReason

+ Timeline *StepTimeline

+ func (s *StepStatus) SetFailureDetails(v *FailureDetails) *StepStatus

+ func (s *StepStatus) SetState(v StepState) *StepStatus

+ func (s *StepStatus) SetStateChangeReason(v *StepStateChangeReason) *StepStatus

+ func (s *StepStatus) SetTimeline(v *StepTimeline) *StepStatus

+ func (s StepStatus) GoString() string

+ func (s StepStatus) String() string

+ type StepSummary struct

+ ActionOnFailure ActionOnFailure

+ Config *HadoopStepConfig

+ Id *string

+ Name *string

+ Status *StepStatus

+ func (s *StepSummary) SetActionOnFailure(v ActionOnFailure) *StepSummary

+ func (s *StepSummary) SetConfig(v *HadoopStepConfig) *StepSummary

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

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

+ func (s *StepSummary) SetStatus(v *StepStatus) *StepSummary

+ func (s StepSummary) GoString() string

+ func (s StepSummary) String() string

+ type StepTimeline struct

+ CreationDateTime *time.Time

+ EndDateTime *time.Time

+ StartDateTime *time.Time

+ func (s *StepTimeline) SetCreationDateTime(v time.Time) *StepTimeline

+ func (s *StepTimeline) SetEndDateTime(v time.Time) *StepTimeline

+ func (s *StepTimeline) SetStartDateTime(v time.Time) *StepTimeline

+ func (s StepTimeline) GoString() string

+ func (s StepTimeline) String() string

+ type SupportedProductConfig struct

+ Args []string

+ Name *string

+ func (s *SupportedProductConfig) SetArgs(v []string) *SupportedProductConfig

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

+ func (s SupportedProductConfig) GoString() string

+ func (s SupportedProductConfig) 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) GoString() string

+ func (s Tag) String() string

+ type TerminateJobFlowsInput struct

+ JobFlowIds []string

+ func (s *TerminateJobFlowsInput) SetJobFlowIds(v []string) *TerminateJobFlowsInput

+ func (s *TerminateJobFlowsInput) Validate() error

+ func (s TerminateJobFlowsInput) GoString() string

+ func (s TerminateJobFlowsInput) String() string

+ type TerminateJobFlowsOutput struct

+ func (s TerminateJobFlowsOutput) GoString() string

+ func (s TerminateJobFlowsOutput) SDKResponseMetadata() aws.Response

+ func (s TerminateJobFlowsOutput) String() string

+ type TerminateJobFlowsRequest struct

+ Input *TerminateJobFlowsInput

+ func (r TerminateJobFlowsRequest) Send() (*TerminateJobFlowsOutput, error)

+ type Unit string

+ const UnitBits

+ const UnitBitsPerSecond

+ const UnitBytes

+ const UnitBytesPerSecond

+ const UnitCount

+ const UnitCountPerSecond

+ const UnitGigaBits

+ const UnitGigaBitsPerSecond

+ const UnitGigaBytes

+ const UnitGigaBytesPerSecond

+ const UnitKiloBits

+ const UnitKiloBitsPerSecond

+ const UnitKiloBytes

+ const UnitKiloBytesPerSecond

+ const UnitMegaBits

+ const UnitMegaBitsPerSecond

+ const UnitMegaBytes

+ const UnitMegaBytesPerSecond

+ const UnitMicroSeconds

+ const UnitMilliSeconds

+ const UnitNone

+ const UnitPercent

+ const UnitSeconds

+ const UnitTeraBits

+ const UnitTeraBitsPerSecond

+ const UnitTeraBytes

+ const UnitTeraBytesPerSecond

+ type VolumeSpecification struct

+ Iops *int64

+ SizeInGB *int64

+ VolumeType *string

+ func (s *VolumeSpecification) SetIops(v int64) *VolumeSpecification

+ func (s *VolumeSpecification) SetSizeInGB(v int64) *VolumeSpecification

+ func (s *VolumeSpecification) SetVolumeType(v string) *VolumeSpecification

+ func (s *VolumeSpecification) Validate() error

+ func (s VolumeSpecification) GoString() string

+ func (s VolumeSpecification) String() string

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