emr

package

Go to main page

Versions in this module

v1

v1.5.0

Aug 24, 2026

v1.4.0

Aug 19, 2026

v1.3.5

Aug 19, 2026

v1.3.4

Aug 18, 2026

v1.3.3

Aug 17, 2026

v1.3.2

Aug 16, 2026

v1.3.1

Aug 16, 2026

Changes in this version

+ type CloudWatchLogConfiguration struct

+ Enabled bool

+ EncryptionKeyArn string

+ LogGroupName string

+ LogStreamNamePrefix string

+ LogTypes map[string][]string

type Cluster

+ LogEncryptionKmsKeyID string

+ MonitoringConfiguration *MonitoringConfiguration

+ RepoUpgradeOnBoot string

+ RequestedAmiVersion string

+ RunningAmiVersion string

+ type KeyValue struct

+ Key string

+ Value string

type ListInstancesParams

+ InstanceFleetType string

+ type MonitoringConfiguration struct

+ CloudWatchLogConfiguration *CloudWatchLogConfiguration

+ S3LoggingConfiguration *S3LoggingConfiguration

+ type NotebookExecutionSummary struct

+ EditorID string

+ EndTime float64

+ ExecutionEngineID string

+ NotebookExecutionID string

+ NotebookExecutionName string

+ StartTime float64

+ Status string

type PersistentAppUI

+ CreatedAt time.Time

type RunJobFlowParams

+ AmiVersion string

+ LogEncryptionKmsKeyID string

+ MonitoringConfiguration *MonitoringConfiguration

+ RepoUpgradeOnBoot string

+ StepExecutionRoleArn string

+ type S3LoggingConfiguration struct

+ LogTypeUploadPolicy map[string]string

type Step

+ ExecutionRoleArn string

type StepHadoopJarStep

+ Properties map[string]string

+ type StepHadoopJarStepInput struct

+ Args []string

+ Jar string

+ MainClass string

+ Properties []KeyValue

type Studio

+ IdcUserAssignment string

v1.3.0

Aug 3, 2026

v1.2.0

Aug 3, 2026

Changes in this version

+ const SessionStateBusy

+ const SessionStateFailed

+ const SessionStateIdle

+ const SessionStateStarted

+ const SessionStateStarting

+ const SessionStateSubmitted

+ const SessionStateTerminated

+ const SessionStateTerminating

+ const StateRunning

type Cluster

+ AutoTerminate bool

+ InstanceCollectionType string

+ KerberosAttributes *KerberosAttributes

+ PlacementGroups []PlacementGroupConfig

type InMemoryBackend

+ func (b *InMemoryBackend) GetSession(ctx context.Context, clusterID, sessionID string) (*Session, error)

+ func (b *InMemoryBackend) GetSessionEndpoint(ctx context.Context, clusterID, sessionID string) (*SessionEndpointResult, error)

+ func (b *InMemoryBackend) ListSessions(ctx context.Context, clusterID string, states []string, marker string) ([]Session, string, error)

+ func (b *InMemoryBackend) StartSession(ctx context.Context, params StartSessionParams) (*Session, error)

+ func (b *InMemoryBackend) TaggedResources() []TaggedEntry

+ func (b *InMemoryBackend) TerminateSession(ctx context.Context, clusterID, sessionID string) (*Session, error)

+ type KerberosAttributes struct

+ ADDomainJoinPassword string

+ ADDomainJoinUser string

+ CrossRealmTrustPrincipalPassword string

+ KdcAdminPassword string

+ Realm string

+ type PlacementGroupConfig struct

+ InstanceRole string

+ PlacementStrategy string

type RunJobFlowInstances

+ InstanceFleets []InstanceFleetSpec

type RunJobFlowParams

+ AutoTerminationPolicy *AutoTerminationPolicy

+ JobFlowRole string

+ KerberosAttributes *KerberosAttributes

+ ManagedScalingPolicy *ManagedScalingPolicy

+ PlacementGroupConfigs []PlacementGroupConfig

+ type Session struct

+ ARN string

+ AccountID string

+ ClusterID string

+ CreatedAt float64

+ EndedAt float64

+ EngineConfigurations []Configuration

+ ExecutionRoleArn string

+ ID string

+ IdleSince float64

+ MonitoringConfiguration *SessionMonitoringConfiguration

+ Name string

+ ReleaseLabel string

+ ServerURL string

+ SessionIdleTimeoutInMinutes int64

+ StartedAt float64

+ State string

+ StateChangeReason string

+ Tags []Tag

+ UpdatedAt float64

+ type SessionCloudWatchLoggingConfiguration struct

+ Enabled bool

+ EncryptionKeyArn string

+ LogGroup string

+ LogStreamNamePrefix string

+ LogTypes map[string][]string

+ type SessionEndpointResult struct

+ AuthToken string

+ Credentials map[string]any

+ Endpoint string

+ Expiry time.Time

+ type SessionManagedLoggingConfiguration struct

+ Enabled bool

+ EncryptionKeyArn string

+ type SessionMonitoringConfiguration struct

+ CloudWatchLoggingConfiguration *SessionCloudWatchLoggingConfiguration

+ ManagedLoggingConfiguration *SessionManagedLoggingConfiguration

+ S3LoggingConfiguration *SessionS3LoggingConfiguration

+ type SessionS3LoggingConfiguration struct

+ Enabled bool

+ EncryptionKeyArn string

+ LogTypes map[string][]string

+ LogURI string

+ type StartSessionParams struct

+ ClusterID string

+ EngineConfigurations []Configuration

+ ExecutionRoleArn string

+ MonitoringConfiguration *SessionMonitoringConfiguration

+ Name string

+ SessionIdleTimeoutInMinutes int64

+ Tags []Tag

+ type TaggedEntry struct

+ ARN string

+ Tags map[string]string

v1.1.4

Jul 20, 2026

v1.1.3

Jul 20, 2026

v1.1.2

Jul 20, 2026

v1.1.1

Jul 20, 2026

v1.1.0

Jul 19, 2026

Changes in this version

+ const NotebookStatusFinished

+ const NotebookStatusRunning

+ const NotebookStatusStopped

+ const NotebookStatusStopping

+ const StateTerminated

+ const StateTerminatedWithErrors

+ const StateWaiting

+ const StepStateCancelled

+ const StepStateCompleted

+ const StepStatePending

+ var ErrAlreadyExists = awserr.New("ClientException", awserr.ErrAlreadyExists)

+ var ErrNilAppContext = errors.New("EMR provider: nil AppContext")

+ var ErrNotFound = awserr.New("ClientException", awserr.ErrNotFound)

+ var ErrValidation = awserr.New("ValidationException: required field is missing", awserr.ErrInvalidParameter)

+ type Application struct

+ Name string

+ Version string

+ type AutoScalingConstraints struct

+ MaxCapacity int

+ MinCapacity int

+ type AutoScalingPolicyDetail struct

+ Constraints AutoScalingConstraints

+ Rules []ScalingRule

+ Status map[string]string

+ type AutoScalingPolicySpec struct

+ Constraints AutoScalingConstraints

+ Rules []ScalingRule

+ type AutoTerminationPolicy struct

+ IdleTimeout int64

+ type BlockPublicAccessConfiguration struct

+ BlockPublicSecurityGroupRules bool

+ PermittedPublicSecurityGroupRuleRanges []PortRange

+ type BootstrapActionConfig struct

+ Name string

+ ScriptBootstrapAction BootstrapActionScript

+ type BootstrapActionScript struct

+ Args []string

+ Path string

+ type CancelStepsInfo struct

+ Reason string

+ Status string

+ StepID string

+ type CloudWatchAlarmDefinition struct

+ ComparisonOperator string

+ EvaluationPeriods int

+ MetricName string

+ Namespace string

+ Period int

+ Statistic string

+ Threshold float64

+ Unit string

+ type Cluster struct

+ ARN string

+ Applications []Application

+ AutoScalingRole string

+ Configurations []Configuration

+ CustomAmiID string

+ EbsRootVolumeIops int

+ EbsRootVolumeSize int

+ EbsRootVolumeThroughput int

+ Ec2InstanceAttributes *EC2InstanceAttributes

+ ID string

+ KeepJobFlowAliveWhenNoSteps bool

+ LogURI string

+ Name string

+ OSReleaseLabel string

+ ReleaseLabel string

+ ScaleDownBehavior string

+ SecurityConfiguration string

+ ServiceRole string

+ Status ClusterStatus

+ StepConcurrencyLevel int

+ Tags []Tag

+ TerminatedAt time.Time

+ TerminationProtected bool

+ UnhealthyNodeReplacement bool

+ VisibleToAllUsers bool

+ type ClusterInstance struct

+ Ec2InstanceID string

+ ID string

+ InstanceFleetID string

+ InstanceGroupID string

+ InstanceType string

+ Market string

+ PrivateDNSName string

+ PrivateIPAddress string

+ PublicDNSName string

+ Status ClusterInstanceStatus

+ type ClusterInstanceStatus struct

+ State string

+ type ClusterStatus struct

+ State string

+ StateChangeReason map[string]any

+ Timeline map[string]any

+ type ClusterSummary struct

+ ClusterArn string

+ ID string

+ Name string

+ ReleaseLabel string

+ Status ClusterStatus

+ type Command struct

+ Args []string

+ Name string

+ ScriptPath string

+ type ComputeLimits struct

+ MaximumCapacityUnits int

+ MaximumCoreCapacityUnits int

+ MaximumOnDemandCapacityUnits int

+ MinimumCapacityUnits int

+ UnitType string

+ type ConfigProvider interface

+ GetEMRSettings func() Settings

+ type Configuration struct

+ Classification string

+ Configurations []Configuration

+ Properties map[string]string

+ type EC2InstanceAttributes struct

+ AdditionalMasterSecurityGroups []string

+ AdditionalSlaveSecurityGroups []string

+ Ec2AvailabilityZone string

+ Ec2KeyName string

+ Ec2SubnetID string

+ EmrManagedMasterSecurityGroup string

+ EmrManagedSlaveSecurityGroup string

+ IamInstanceProfile string

+ RequestedEc2SubnetIDs []string

+ ServiceAccessSecurityGroup string

+ type Handler struct

+ Backend *InMemoryBackend

+ func NewHandler(backend *InMemoryBackend) *Handler

+ func (h *Handler) ChaosOperations() []string

+ func (h *Handler) ChaosRegions() []string

+ func (h *Handler) ChaosServiceName() string

+ func (h *Handler) ExtractOperation(c *echo.Context) string

+ func (h *Handler) ExtractResource(c *echo.Context) string

+ func (h *Handler) GetSupportedOperations() []string

+ func (h *Handler) Handler() echo.HandlerFunc

+ func (h *Handler) MatchPriority() int

+ func (h *Handler) Name() string

+ func (h *Handler) Reset()

+ func (h *Handler) Restore(ctx context.Context, data []byte) error

+ func (h *Handler) RouteMatcher() service.Matcher

+ func (h *Handler) Snapshot(ctx context.Context) []byte

+ func (h *Handler) StartWorker(ctx context.Context) error

+ func (h *Handler) WithJanitor(interval, terminatedTTL time.Duration, taskTimeout ...time.Duration) *Handler

+ type InMemoryBackend struct

+ func NewInMemoryBackend(accountID, region string) *InMemoryBackend

+ func (b *InMemoryBackend) AddClusterInternal(ctx context.Context, cluster *Cluster)

+ func (b *InMemoryBackend) AddInstanceFleet(ctx context.Context, clusterID string, spec InstanceFleetSpec) (*InstanceFleet, string, error)

+ func (b *InMemoryBackend) AddInstanceGroups(ctx context.Context, clusterID string, specs []InstanceGroupSpec) ([]string, string, error)

+ func (b *InMemoryBackend) AddJobFlowSteps(ctx context.Context, jobFlowID string, specs []StepSpec) ([]string, error)

+ func (b *InMemoryBackend) AddPersistentAppUIInternal(ctx context.Context, ui PersistentAppUI)

+ func (b *InMemoryBackend) AddSecurityConfigInternal(ctx context.Context, sc SecurityConfiguration)

+ func (b *InMemoryBackend) AddStudioInternal(ctx context.Context, studio Studio)

+ func (b *InMemoryBackend) AddTags(ctx context.Context, resourceID string, tags []Tag) error

+ func (b *InMemoryBackend) CancelSteps(ctx context.Context, clusterID string, stepIDs []string) ([]*CancelStepsInfo, error)

+ func (b *InMemoryBackend) CreatePersistentAppUI(ctx context.Context, targetResourceArn string) (*PersistentAppUI, error)

+ func (b *InMemoryBackend) CreateSecurityConfiguration(ctx context.Context, name, securityConfig string) (*SecurityConfiguration, error)

+ func (b *InMemoryBackend) CreateStudio(ctx context.Context, ...) (*Studio, error)

+ func (b *InMemoryBackend) CreateStudioSessionMapping(ctx context.Context, ...) error

+ func (b *InMemoryBackend) DeleteSecurityConfiguration(ctx context.Context, name string) error

+ func (b *InMemoryBackend) DeleteStudio(ctx context.Context, studioID string) error

+ func (b *InMemoryBackend) DeleteStudioSessionMapping(ctx context.Context, studioID, identityType, identityID, identityName string) error

+ func (b *InMemoryBackend) DescribeCluster(ctx context.Context, id string) (*Cluster, error)

+ func (b *InMemoryBackend) DescribeJobFlows(ctx context.Context, ids, states []string, ...) []JobFlow

+ func (b *InMemoryBackend) DescribeNotebookExecution(ctx context.Context, id string) (*NotebookExecution, error)

+ func (b *InMemoryBackend) DescribePersistentAppUI(ctx context.Context, id string) (*PersistentAppUI, error)

+ func (b *InMemoryBackend) DescribeReleaseLabel(_ context.Context, releaseLabel string) (*ReleaseLabel, error)

+ func (b *InMemoryBackend) DescribeSecurityConfiguration(ctx context.Context, name string) (*SecurityConfiguration, error)

+ func (b *InMemoryBackend) DescribeStep(ctx context.Context, clusterID, stepID string) (*Step, error)

+ func (b *InMemoryBackend) DescribeStudio(ctx context.Context, studioID string) (*Studio, error)

+ func (b *InMemoryBackend) GetAutoTerminationPolicy(ctx context.Context, clusterID string) (*AutoTerminationPolicy, error)

+ func (b *InMemoryBackend) GetBlockPublicAccessConfiguration(ctx context.Context) (BlockPublicAccessConfiguration, blockPublicAccessMeta)

+ func (b *InMemoryBackend) GetClusterSessionCredentials(ctx context.Context, clusterID, executionRoleArn string) (map[string]any, time.Time, error)

+ func (b *InMemoryBackend) GetManagedScalingPolicy(ctx context.Context, clusterID string) (*ManagedScalingPolicy, error)

+ func (b *InMemoryBackend) GetOnClusterPresignedURL(_ context.Context, clusterID, region string) (string, error)

+ func (b *InMemoryBackend) GetPresignedURL(id, region string) string

+ func (b *InMemoryBackend) GetStudioSessionMapping(ctx context.Context, studioID, identityType, identityID, identityName string) (*StudioSessionMapping, error)

+ func (b *InMemoryBackend) ListBootstrapActions(ctx context.Context, clusterID, marker string) ([]Command, string, error)

+ func (b *InMemoryBackend) ListClusters(ctx context.Context, params ListClustersParams) ([]ClusterSummary, string)

+ func (b *InMemoryBackend) ListInstanceFleets(ctx context.Context, clusterID string) ([]InstanceFleet, error)

+ func (b *InMemoryBackend) ListInstanceGroups(ctx context.Context, clusterID string) ([]InstanceGroup, error)

+ func (b *InMemoryBackend) ListInstances(ctx context.Context, clusterID string, params ListInstancesParams) ([]ClusterInstance, string)

+ func (b *InMemoryBackend) ListNotebookExecutions(ctx context.Context, params ListNotebookExecutionsParams) ([]NotebookExecution, string)

+ func (b *InMemoryBackend) ListReleaseLabels(_ context.Context, prefix, application, marker string) ([]string, string)

+ func (b *InMemoryBackend) ListSecurityConfigurations(ctx context.Context, marker string) ([]SecurityConfigSummary, string)

+ func (b *InMemoryBackend) ListSteps(ctx context.Context, clusterID string, stepStates []string, stepIDs []string, ...) ([]Step, string)

+ func (b *InMemoryBackend) ListStudioSessionMappings(ctx context.Context, studioID, identityType string) []StudioSessionMapping

+ func (b *InMemoryBackend) ListStudios(ctx context.Context, marker string) ([]StudioSummary, string)

+ func (b *InMemoryBackend) ListSupportedInstanceTypes(_ context.Context, releaseLabel, marker string) ([]SupportedInstanceType, string)

+ func (b *InMemoryBackend) ListTagsForResource(ctx context.Context, resourceID string) ([]Tag, error)

+ func (b *InMemoryBackend) ModifyCluster(ctx context.Context, clusterID string, stepConcurrencyLevel int) (int, error)

+ func (b *InMemoryBackend) ModifyInstanceFleet(ctx context.Context, clusterID string, mod InstanceFleetModification) error

+ func (b *InMemoryBackend) ModifyInstanceGroups(ctx context.Context, clusterID string, mods []InstanceGroupModification) error

+ func (b *InMemoryBackend) PutAutoScalingPolicy(ctx context.Context, clusterID, instanceGroupID string, ...) (*AutoScalingPolicyDetail, string, string, error)

+ func (b *InMemoryBackend) PutAutoTerminationPolicy(ctx context.Context, clusterID string, policy AutoTerminationPolicy) error

+ func (b *InMemoryBackend) PutBlockPublicAccessConfiguration(ctx context.Context, config BlockPublicAccessConfiguration) error

+ func (b *InMemoryBackend) PutManagedScalingPolicy(ctx context.Context, clusterID string, policy ManagedScalingPolicy) error

+ func (b *InMemoryBackend) Region() string

+ func (b *InMemoryBackend) RemoveAutoScalingPolicy(ctx context.Context, clusterID, instanceGroupID string) error

+ func (b *InMemoryBackend) RemoveAutoTerminationPolicy(ctx context.Context, clusterID string) error

+ func (b *InMemoryBackend) RemoveManagedScalingPolicy(ctx context.Context, clusterID string) error

+ func (b *InMemoryBackend) RemoveTags(ctx context.Context, resourceID string, tagKeys []string) error

+ func (b *InMemoryBackend) Reset()

+ func (b *InMemoryBackend) Restore(ctx context.Context, data []byte) error

+ func (b *InMemoryBackend) RunJobFlow(ctx context.Context, params RunJobFlowParams) (*Cluster, error)

+ func (b *InMemoryBackend) SetKeepJobFlowAliveWhenNoSteps(ctx context.Context, jobFlowIDs []string, keep bool) error

+ func (b *InMemoryBackend) SetTerminationProtection(ctx context.Context, jobFlowIDs []string, protect bool) error

+ func (b *InMemoryBackend) SetUnhealthyNodeReplacement(ctx context.Context, jobFlowIDs []string, replace bool) error

+ func (b *InMemoryBackend) SetVisibleToAllUsers(ctx context.Context, jobFlowIDs []string, visible bool) error

+ func (b *InMemoryBackend) Snapshot(ctx context.Context) []byte

+ func (b *InMemoryBackend) StartNotebookExecution(ctx context.Context, editorID, name, params, engineID string, tags []Tag) (*NotebookExecution, error)

+ func (b *InMemoryBackend) StopNotebookExecution(ctx context.Context, id string) error

+ func (b *InMemoryBackend) TerminateJobFlows(ctx context.Context, ids []string) error

+ func (b *InMemoryBackend) UpdateStudio(ctx context.Context, ...) error

+ func (b *InMemoryBackend) UpdateStudioSessionMapping(ctx context.Context, ...) error

+ type InstanceFleet struct

+ ID string

+ InstanceFleetType string

+ Name string

+ ProvisionedOnDemandCapacity int

+ ProvisionedSpotCapacity int

+ Status InstanceFleetStatus

+ TargetOnDemandCapacity int

+ TargetSpotCapacity int

+ type InstanceFleetModification struct

+ InstanceFleetID string

+ TargetOnDemandCapacity int

+ TargetSpotCapacity int

+ type InstanceFleetSpec struct

+ Configurations []Configuration

+ InstanceFleetType string

+ Name string

+ TargetOnDemandCapacity int

+ TargetSpotCapacity int

+ type InstanceFleetStatus struct

+ State string

+ type InstanceGroup struct

+ AutoScalingPolicy *AutoScalingPolicyDetail

+ BidPrice string

+ Configurations []Configuration

+ ID string

+ InstanceGroupType string

+ InstanceType string

+ Market string

+ Name string

+ RequestedInstanceCount int

+ RunningInstanceCount int

+ Status InstanceGroupStatus

+ type InstanceGroupModification struct

+ InstanceCount int

+ InstanceGroupID string

+ type InstanceGroupSpec struct

+ BidPrice string

+ Configurations []Configuration

+ InstanceCount int

+ InstanceRole string

+ InstanceType string

+ Market string

+ Name string

+ type InstanceGroupStatus struct

+ State string

+ type Janitor struct

+ Backend *InMemoryBackend

+ Interval time.Duration

+ TaskTimeout time.Duration

+ TerminatedTTL time.Duration

+ func NewJanitor(backend *InMemoryBackend, interval, terminatedTTL time.Duration) *Janitor

+ func (j *Janitor) Run(ctx context.Context)

+ func (j *Janitor) SweepOnce(ctx context.Context)

+ type JobFlow struct

+ ExecutionStatusDetail JobFlowExecutionStatusDetail

+ Instances JobFlowInstancesDetail

+ JobFlowID string

+ LogURI string

+ Name string

+ ReleaseLabel string

+ ServiceRole string

+ type JobFlowExecutionStatusDetail struct

+ CreationDateTime float64

+ EndDateTime float64

+ State string

+ StateChangeReason string

+ type JobFlowInstancesDetail struct

+ InstanceCount int

+ MasterInstanceType string

+ SlaveInstanceType string

+ type ListClustersParams struct

+ ClusterStates []string

+ CreatedAfter *time.Time

+ CreatedBefore *time.Time

+ Marker string

+ type ListInstancesParams struct

+ InstanceFleetID string

+ InstanceGroupID string

+ InstanceGroupTypes []string

+ InstanceStates []string

+ Marker string

+ type ListNotebookExecutionsParams struct

+ EditorID string

+ Marker string

+ Status string

+ type ManagedScalingPolicy struct

+ ComputeLimits ComputeLimits

+ type NotebookExecution struct

+ EditorID string

+ EndTime float64

+ ExecutionEngineID string

+ NotebookExecutionID string

+ NotebookExecutionName string

+ NotebookParams string

+ StartTime float64

+ Status string

+ Tags []Tag

+ type PersistentAppUI struct

+ ID string

+ RuntimeRoleEnabledCluster bool

+ TargetResourceArn string

+ type PortRange struct

+ MaxRange int

+ MinRange int

+ type Provider struct

+ func (p *Provider) Init(ctx *service.AppContext) (service.Registerable, error)

+ func (p *Provider) Name() string

+ type ReleaseLabel struct

+ Applications []ReleaseLabelApplication

+ ReleaseLabel string

+ type ReleaseLabelApplication struct

+ Name string

+ Version string

+ type RunJobFlowInstances struct

+ AdditionalMasterSecurityGroups []string

+ AdditionalSlaveSecurityGroups []string

+ Ec2KeyName string

+ Ec2SubnetID string

+ Ec2SubnetIDs []string

+ EmrManagedMasterSecurityGroup string

+ EmrManagedSlaveSecurityGroup string

+ IamInstanceProfile string

+ InstanceGroups []InstanceGroupSpec

+ KeepJobFlowAliveWhenNoSteps bool

+ ServiceAccessSecurityGroup string

+ TerminationProtected bool

+ type RunJobFlowParams struct

+ Applications []Application

+ AutoScalingRole string

+ BootstrapActions []BootstrapActionConfig

+ Configurations []Configuration

+ CustomAmiID string

+ EbsRootVolumeIops int

+ EbsRootVolumeSize int

+ EbsRootVolumeThroughput int

+ Instances RunJobFlowInstances

+ LogURI string

+ Name string

+ OSReleaseLabel string

+ ReleaseLabel string

+ ScaleDownBehavior string

+ SecurityConfiguration string

+ ServiceRole string

+ StepConcurrencyLevel int

+ Steps []StepSpec

+ Tags []Tag

+ VisibleToAllUsers bool

+ type ScalingAction struct

+ SimpleScalingPolicyConfiguration SimpleScalingPolicyConfiguration

+ type ScalingRule struct

+ Action ScalingAction

+ Description string

+ Name string

+ Trigger ScalingTrigger

+ type ScalingTrigger struct

+ CloudWatchAlarmDefinition CloudWatchAlarmDefinition

+ type SecurityConfigSummary struct

+ CreationDateTime float64

+ Name string

+ type SecurityConfiguration struct

+ CreationDateTime float64

+ Name string

+ SecurityConfig string

+ type Settings struct

+ JanitorInterval time.Duration

+ TerminatedTTL time.Duration

+ type SimpleScalingPolicyConfiguration struct

+ AdjustmentType string

+ CoolDown int

+ ScalingAdjustment int

+ type Step struct

+ ActionOnFailure string

+ HadoopJarStep StepHadoopJarStep

+ ID string

+ Name string

+ Status StepStatus

+ type StepHadoopJarStep struct

+ Args []string

+ Jar string

+ MainClass string

+ type StepSpec struct

+ ActionOnFailure string

+ HadoopJarStep StepHadoopJarStep

+ Name string

+ type StepStatus struct

+ State string

+ Timeline StepTimeline

+ type StepTimeline struct

+ CreationDateTime float64

+ EndDateTime float64

+ StartDateTime float64

+ type Studio struct

+ AuthMode string

+ CreationTime float64

+ DefaultS3Location string

+ Description string

+ EncryptionKeyArn string

+ EngineSecurityGroupID string

+ IdcInstanceArn string

+ IdpAuthURL string

+ IdpRelayStateParameterName string

+ Name string

+ ServiceRole string

+ StudioArn string

+ StudioID string

+ SubnetIDs []string

+ Tags []Tag

+ TrustedIdentityPropagationEnabled bool

+ URL string

+ UserRole string

+ VpcID string

+ WorkspaceSecurityGroupID string

+ type StudioSessionMapping struct

+ CreationTime float64

+ IdentityID string

+ IdentityName string

+ IdentityType string

+ LastModifiedTime float64

+ SessionPolicyArn string

+ StudioID string

+ type StudioSummary struct

+ AuthMode string

+ CreationTime float64

+ DefaultS3Location string

+ Description string

+ Name string

+ StudioArn string

+ StudioID string

+ URL string

+ VpcID string

+ type SupportedInstanceType struct

+ Architecture string

+ Is64BitsOnly bool

+ MemoryGB float64

+ NumberOfDisks int

+ Type string

+ VCPU int

+ type Tag struct

+ Key string

+ Value string

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