mrscaler

package
v1.102.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 29, 2021 License: Apache-2.0 Imports: 9 Imported by: 27

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var InstanceGroupTypeName = map[InstanceGroupType]string{
	InstanceGroupTypeMaster: "master",
	InstanceGroupTypeCore:   "core",
	InstanceGroupTypeTask:   "task",
}
View Source 
var InstanceGroupTypeValue = map[string]InstanceGroupType{
	"master": InstanceGroupTypeMaster,
	"core":   InstanceGroupTypeCore,
	"task":   InstanceGroupTypeTask,
}

Functions

This section is empty.

Types

type Action 

type Action struct {
	Type              *string `json:"type,omitempty"`
	Adjustment        *string `json:"adjustment,omitempty"`
	MinTargetCapacity *string `json:"minTargetCapacity,omitempty"`
	MaxTargetCapacity *string `json:"maxTargetCapacity,omitempty"`
	Target            *string `json:"target,omitempty"`
	Minimum           *string `json:"minimum,omitempty"`
	Maximum           *string `json:"maximum,omitempty"`
	// contains filtered or unexported fields
}

func (Action) MarshalJSON 

func (o Action) MarshalJSON() ([]byte, error)

func (*Action) SetAdjustment 

func (o *Action) SetAdjustment(v *string) *Action

func (*Action) SetMaxTargetCapacity 

func (o *Action) SetMaxTargetCapacity(v *string) *Action

func (*Action) SetMaximum 

func (o *Action) SetMaximum(v *string) *Action

func (*Action) SetMinTargetCapacity 

func (o *Action) SetMinTargetCapacity(v *string) *Action

func (*Action) SetMinimum 

func (o *Action) SetMinimum(v *string) *Action

func (*Action) SetTarget 

func (o *Action) SetTarget(v *string) *Action

func (*Action) SetType 

func (o *Action) SetType(v *string) *Action

type Application 

type Application struct {
	Args    []string `json:"args,omitempty"`
	Name    *string  `json:"name,omitempty"`
	Version *string  `json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (Application) MarshalJSON 

func (o Application) MarshalJSON() ([]byte, error)

func (*Application) SetArgs 

func (o *Application) SetArgs(v []string) *Application

SetArgs sets the list of args to use with the application

func (*Application) SetName 

func (o *Application) SetName(v *string) *Application

SetName sets the name of the application

func (*Application) SetVersion 

func (o *Application) SetVersion(v *string) *Application

SetVersion sets the application version

type AvailabilityZone 

type AvailabilityZone struct {
	Name     *string `json:"name,omitempty"`
	SubnetID *string `json:"subnetId,omitempty"`
	// contains filtered or unexported fields
}

func (AvailabilityZone) MarshalJSON 

func (o AvailabilityZone) MarshalJSON() ([]byte, error)

func (*AvailabilityZone) SetName 

func (o *AvailabilityZone) SetName(v *string) *AvailabilityZone

func (*AvailabilityZone) SetSubnetId 

func (o *AvailabilityZone) SetSubnetId(v *string) *AvailabilityZone

type BlockDeviceConfig 

type BlockDeviceConfig struct {
	VolumesPerInstance  *int                 `json:"volumesPerInstance,omitempty"`
	VolumeSpecification *VolumeSpecification `json:"volumeSpecification,omitempty"`
	// contains filtered or unexported fields
}

func (BlockDeviceConfig) MarshalJSON 

func (o BlockDeviceConfig) MarshalJSON() ([]byte, error)

region BlockDeviceConfig

func (*BlockDeviceConfig) SetVolumeSpecification 

func (o *BlockDeviceConfig) SetVolumeSpecification(v *VolumeSpecification) *BlockDeviceConfig

func (*BlockDeviceConfig) SetVolumesPerInstance 

func (o *BlockDeviceConfig) SetVolumesPerInstance(v *int) *BlockDeviceConfig

type BootstrapActions 

type BootstrapActions struct {
	File *S3File `json:"file,omitempty"`
	// contains filtered or unexported fields
}

func (BootstrapActions) MarshalJSON 

func (o BootstrapActions) MarshalJSON() ([]byte, error)

func (*BootstrapActions) SetFile 

func (o *BootstrapActions) SetFile(v *S3File) *BootstrapActions

type Cloning 

type Cloning struct {
	OriginClusterID *string `json:"originClusterId,omitempty"`
	Retries         *int    `json:"numberOfRetries,omitempty"`
	// contains filtered or unexported fields
}

func (Cloning) MarshalJSON 

func (o Cloning) MarshalJSON() ([]byte, error)

func (*Cloning) SetOriginClusterId 

func (o *Cloning) SetOriginClusterId(v *string) *Cloning

func (*Cloning) SetRetries 

func (o *Cloning) SetRetries(v *int) *Cloning

SetRetries sets the number of retries to attempt when cloning a scaler

type Cluster 

type Cluster struct {
	LogURI                      *string `json:"logUri,omitempty"`
	AdditionalInfo              *string `json:"additionalInfo,omitempty"`
	JobFlowRole                 *string `json:"jobFlowRole,omitempty"`
	SecurityConfiguration       *string `json:"securityConfiguration,omitempty"`
	ServiceRole                 *string `json:"serviceRole,omitempty"`
	VisibleToAllUsers           *bool   `json:"visibleToAllUsers,omitempty"`
	TerminationProtected        *bool   `json:"terminationProtected,omitempty"`
	KeepJobFlowAliveWhenNoSteps *bool   `json:"keepJobFlowAliveWhenNoSteps,omitempty"`
	// contains filtered or unexported fields
}

func (Cluster) MarshalJSON 

func (o Cluster) MarshalJSON() ([]byte, error)

func (*Cluster) SetAdditionalInfo 

func (o *Cluster) SetAdditionalInfo(v *string) *Cluster

SetAdditionalInfo sets the additional info field used by third party integrations when creating a new mrscaler

func (*Cluster) SetJobFlowRole 

func (o *Cluster) SetJobFlowRole(v *string) *Cluster

SetJobFlowRole sets the IAM role that will be adopted by the launched EC2 instances

func (*Cluster) SetKeepJobFlowAliveWhenNoSteps 

func (o *Cluster) SetKeepJobFlowAliveWhenNoSteps(v *bool) *Cluster

SetKeepJobFlowAliveWhenNoSteps sets KeepJobFlowAliveWhenNoSteps

func (*Cluster) SetLogURI 

func (o *Cluster) SetLogURI(v *string) *Cluster

SetLogURI sets the log uri when creating a new cluster

func (*Cluster) SetSecurityConfiguration 

func (o *Cluster) SetSecurityConfiguration(v *string) *Cluster

SetSecurityConfiguration sets the name of the security configuration to be applied to the cluster

func (*Cluster) SetServiceRole 

func (o *Cluster) SetServiceRole(v *string) *Cluster

SetServiceRole sets the IAM role that the EMR will assume to access AWS resources on your behalf

func (*Cluster) SetTerminationProtected 

func (o *Cluster) SetTerminationProtected(v *bool) *Cluster

SetTerminationProtected sets whether the EC2 instances in the cluster are protected from terminating API calls

func (*Cluster) SetVisibleToAllUsers 

func (o *Cluster) SetVisibleToAllUsers(v *bool) *Cluster

SetVisibleToAllUsers sets a flag indicating if the cluster is visibile to all IAM users

type Compute 

type Compute struct {
	AvailabilityZones               []*AvailabilityZone `json:"availabilityZones,omitempty"`
	Tags                            []*Tag              `json:"tags,omitempty"`
	InstanceGroups                  *InstanceGroups     `json:"instanceGroups,omitempty"`
	Configurations                  *Configurations     `json:"configurations,omitempty"`
	EBSRootVolumeSize               *int                `json:"ebsRootVolumeSize,omitempty"`
	ManagedPrimarySecurityGroup     *string             `json:"emrManagedMasterSecurityGroup,omitempty"`
	ManagedReplicaSecurityGroup     *string             `json:"emrManagedSlaveSecurityGroup,omitempty"`
	ServiceAccessSecurityGroup      *string             `json:"serviceAccessSecurityGroup,omitempty"`
	AdditionalPrimarySecurityGroups []string            `json:"additionalMasterSecurityGroups,omitempty"`
	AdditionalReplicaSecurityGroups []string            `json:"additionalSlaveSecurityGroups,omitempty"`
	CustomAMIID                     *string             `json:"customAmiId,omitempty"`
	RepoUpgradeOnBoot               *string             `json:"repoUpgradeOnBoot,omitempty"`
	EC2KeyName                      *string             `json:"ec2KeyName,omitempty"`
	Applications                    []*Application      `json:"applications,omitempty"`
	BootstrapActions                *BootstrapActions   `json:"bootstrapActions,omitempty"`
	Steps                           *Steps              `json:"steps,omitempty"`
	InstanceWeights                 []*InstanceWeight   `json:"instanceWeights,omitempty"`
	// contains filtered or unexported fields
}

func (Compute) MarshalJSON 

func (o Compute) MarshalJSON() ([]byte, error)

func (*Compute) SetAdditionalPrimarySecurityGroups 

func (o *Compute) SetAdditionalPrimarySecurityGroups(v []string) *Compute

SetAdditionalPrimarySecurityGroups sets a list of additional primary security groups

func (*Compute) SetAdditionalReplicaSecurityGroups 

func (o *Compute) SetAdditionalReplicaSecurityGroups(v []string) *Compute

SetAdditionalReplicaSecurityGroups sets a list of additional Replica security groups

func (*Compute) SetApplications 

func (o *Compute) SetApplications(v []*Application) *Compute

SetApplications sets the applications object

func (*Compute) SetAvailabilityZones 

func (o *Compute) SetAvailabilityZones(v []*AvailabilityZone) *Compute

func (*Compute) SetBootstrapActions 

func (o *Compute) SetBootstrapActions(v *BootstrapActions) *Compute

SetBootstrapActions sets the path for a bootstrap actions file stored in AWS S3

func (*Compute) SetConfigurations 

func (o *Compute) SetConfigurations(v *Configurations) *Compute

func (*Compute) SetCustomAMIID 

func (o *Compute) SetCustomAMIID(v *string) *Compute

SetCustomAMIID sets the custom AMI ID

func (*Compute) SetEBSRootVolumeSize 

func (o *Compute) SetEBSRootVolumeSize(v *int) *Compute

SetEBSRootVolumeSize sets the ebs root volume size when creating a new scaler

func (*Compute) SetEC2KeyName 

func (o *Compute) SetEC2KeyName(v *string) *Compute

SetEC2KeyName sets the EC2 key name

func (*Compute) SetInstanceGroups 

func (o *Compute) SetInstanceGroups(v *InstanceGroups) *Compute

func (*Compute) SetInstanceWeights 

func (o *Compute) SetInstanceWeights(v []*InstanceWeight) *Compute

SetInstanceWeights sets a list if instance weights by type

func (*Compute) SetManagedPrimarySecurityGroup 

func (o *Compute) SetManagedPrimarySecurityGroup(v *string) *Compute

SetManagedPrimarySecurityGroup sets the managed primary security group when creating a new scaler

func (*Compute) SetManagedReplicaSecurityGroup 

func (o *Compute) SetManagedReplicaSecurityGroup(v *string) *Compute

SetManagedReplicaSecurityGroup sets the managed replica security group when creating a new scaler

func (*Compute) SetRepoUpgradeOnBoot 

func (o *Compute) SetRepoUpgradeOnBoot(v *string) *Compute

func (*Compute) SetServiceAccessSecurityGroup 

func (o *Compute) SetServiceAccessSecurityGroup(v *string) *Compute

SetServiceAccessSecurityGroup sets the service security group when creating a new scaler

func (*Compute) SetSteps 

func (o *Compute) SetSteps(v *Steps) *Compute

SetSteps sets the path for a steps file stored in AWS S3

func (*Compute) SetTags 

func (o *Compute) SetTags(v []*Tag) *Compute

type Configurations 

type Configurations struct {
	File *S3File `json:"file,omitempty"`
	// contains filtered or unexported fields
}

func (Configurations) MarshalJSON 

func (o Configurations) MarshalJSON() ([]byte, error)

func (*Configurations) SetFile 

func (o *Configurations) SetFile(v *S3File) *Configurations

type CreateNew 

type CreateNew struct {
	ReleaseLabel *string `json:"releaseLabel,omitempty"`
	Retries      *int    `json:"numberOfRetries,omitempty"`
	// contains filtered or unexported fields
}

func (CreateNew) MarshalJSON 

func (o CreateNew) MarshalJSON() ([]byte, error)

func (*CreateNew) SetReleaseLabel 

func (o *CreateNew) SetReleaseLabel(v *string) *CreateNew

SetReleaseLabel sets the release label for a new scaler

func (*CreateNew) SetRetries 

func (o *CreateNew) SetRetries(v *int) *CreateNew

SetRetries sets the number of retries to attempt when creating a new scaler

type CreateScalerInput 

type CreateScalerInput struct {
	Scaler *Scaler `json:"mrScaler,omitempty"`
}

type CreateScalerOutput 

type CreateScalerOutput struct {
	Scaler *Scaler `json:"mrScaler,omitempty"`
}

type DeleteScalerInput 

type DeleteScalerInput struct {
	ScalerID *string `json:"mrScalerId,omitempty"`
}

type DeleteScalerOutput 

type DeleteScalerOutput struct{}

type Dimension 

type Dimension struct {
	Name  *string `json:"name,omitempty"`
	Value *string `json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (Dimension) MarshalJSON 

func (o Dimension) MarshalJSON() ([]byte, error)

func (*Dimension) SetName 

func (o *Dimension) SetName(v *string) *Dimension

func (*Dimension) SetValue 

func (o *Dimension) SetValue(v *string) *Dimension

type EBSConfiguration 

type EBSConfiguration struct {
	Optimized          *bool                `json:"ebsOptimized,omitempty"`
	BlockDeviceConfigs []*BlockDeviceConfig `json:"ebsBlockDeviceConfigs,omitempty"`
	// contains filtered or unexported fields
}

func (EBSConfiguration) MarshalJSON 

func (o EBSConfiguration) MarshalJSON() ([]byte, error)

region EBSConfiguration

func (*EBSConfiguration) SetBlockDeviceConfigs 

func (o *EBSConfiguration) SetBlockDeviceConfigs(v []*BlockDeviceConfig) *EBSConfiguration

func (*EBSConfiguration) SetOptimized 

func (o *EBSConfiguration) SetOptimized(v *bool) *EBSConfiguration

type InstanceGroup 

type InstanceGroup struct {
	InstanceTypes    []string               `json:"instanceTypes,omitempty"`
	Target           *int                   `json:"target,omitempty"`
	Capacity         *InstanceGroupCapacity `json:"capacity,omitempty"`
	LifeCycle        *string                `json:"lifeCycle,omitempty"`
	EBSConfiguration *EBSConfiguration      `json:"ebsConfiguration,omitempty"`
	// contains filtered or unexported fields
}

func (InstanceGroup) MarshalJSON 

func (o InstanceGroup) MarshalJSON() ([]byte, error)

func (*InstanceGroup) SetCapacity 

func (o *InstanceGroup) SetCapacity(v *InstanceGroupCapacity) *InstanceGroup

func (*InstanceGroup) SetEBSConfiguration 

func (o *InstanceGroup) SetEBSConfiguration(v *EBSConfiguration) *InstanceGroup

func (*InstanceGroup) SetInstanceTypes 

func (o *InstanceGroup) SetInstanceTypes(v []string) *InstanceGroup

func (*InstanceGroup) SetLifeCycle 

func (o *InstanceGroup) SetLifeCycle(v *string) *InstanceGroup

func (*InstanceGroup) SetTarget 

func (o *InstanceGroup) SetTarget(v *int) *InstanceGroup

type InstanceGroupCapacity 

type InstanceGroupCapacity struct {
	Target  *int    `json:"target,omitempty"`
	Minimum *int    `json:"minimum,omitempty"`
	Maximum *int    `json:"maximum,omitempty"`
	Unit    *string `json:"unit,omitempty"`
	// contains filtered or unexported fields
}

func (InstanceGroupCapacity) MarshalJSON 

func (o InstanceGroupCapacity) MarshalJSON() ([]byte, error)

region InstanceGroupCapacity

func (*InstanceGroupCapacity) SetMaximum 

func (o *InstanceGroupCapacity) SetMaximum(v *int) *InstanceGroupCapacity

func (*InstanceGroupCapacity) SetMinimum 

func (o *InstanceGroupCapacity) SetMinimum(v *int) *InstanceGroupCapacity

func (*InstanceGroupCapacity) SetTarget 

func (o *InstanceGroupCapacity) SetTarget(v *int) *InstanceGroupCapacity

func (*InstanceGroupCapacity) SetUnit added in v1.48.0 

func (o *InstanceGroupCapacity) SetUnit(v *string) *InstanceGroupCapacity

type InstanceGroupType 

type InstanceGroupType int

A InstanceGroupType represents the type of an instance group. 

const (
	// InstanceGroupTypeMaster represents the master instance group type.
	InstanceGroupTypeMaster InstanceGroupType = iota

	// InstanceGroupTypeCore represents the core instance group type.
	InstanceGroupTypeCore

	// InstanceGroupTypeTask represents the task instance group type.
	InstanceGroupTypeTask
)

func (InstanceGroupType) String 

func (p InstanceGroupType) String() string

type InstanceGroups 

type InstanceGroups struct {
	MasterGroup *InstanceGroup `json:"masterGroup,omitempty"`
	CoreGroup   *InstanceGroup `json:"coreGroup,omitempty"`
	TaskGroup   *InstanceGroup `json:"taskGroup,omitempty"`
	// contains filtered or unexported fields
}

func (InstanceGroups) MarshalJSON 

func (o InstanceGroups) MarshalJSON() ([]byte, error)

func (*InstanceGroups) SetCoreGroup 

func (o *InstanceGroups) SetCoreGroup(v *InstanceGroup) *InstanceGroups

func (*InstanceGroups) SetMasterGroup 

func (o *InstanceGroups) SetMasterGroup(v *InstanceGroup) *InstanceGroups

func (*InstanceGroups) SetTaskGroup 

func (o *InstanceGroups) SetTaskGroup(v *InstanceGroup) *InstanceGroups

type InstanceWeight 

type InstanceWeight struct {
	InstanceType     *string `json:"instanceType,omitempty"`
	WeightedCapacity *int    `json:"weightedCapacity,omitempty"`
	// contains filtered or unexported fields
}

func (InstanceWeight) MarshalJSON 

func (o InstanceWeight) MarshalJSON() ([]byte, error)

func (*InstanceWeight) SetInstanceType 

func (o *InstanceWeight) SetInstanceType(v *string) *InstanceWeight

func (*InstanceWeight) SetWeightedCapacity 

func (o *InstanceWeight) SetWeightedCapacity(v *int) *InstanceWeight

type ListScalersInput 

type ListScalersInput struct{}

type ListScalersOutput 

type ListScalersOutput struct {
	Scalers []*Scaler `json:"mrScalers,omitempty"`
}

type ProvisioningTimeout 

type ProvisioningTimeout struct {
	Timeout       *int    `json:"timeout,omitempty"`
	TimeoutAction *string `json:"timeoutAction,omitempty"`
	// contains filtered or unexported fields
}

func (ProvisioningTimeout) MarshalJSON 

func (o ProvisioningTimeout) MarshalJSON() ([]byte, error)

func (*ProvisioningTimeout) SetTimeout 

func (o *ProvisioningTimeout) SetTimeout(v *int) *ProvisioningTimeout

SetTimeout sets the amount of time in seconds to wait for a scaler to be provisioned

func (*ProvisioningTimeout) SetTimeoutAction 

func (o *ProvisioningTimeout) SetTimeoutAction(v *string) *ProvisioningTimeout

SetTimeoutAction sets the action to take on timeout

type ReadScalerInput 

type ReadScalerInput struct {
	ScalerID *string `json:"mrScalerId,omitempty"`
}

type ReadScalerOutput 

type ReadScalerOutput struct {
	Scaler *Scaler `json:"mrScaler,omitempty"`
}

type S3File 

type S3File struct {
	Bucket *string `json:"bucket,omitempty"`
	Key    *string `json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (S3File) MarshalJSON 

func (o S3File) MarshalJSON() ([]byte, error)

region S3File

func (*S3File) SetBucket 

func (o *S3File) SetBucket(v *string) *S3File

func (*S3File) SetKey 

func (o *S3File) SetKey(v *string) *S3File

type Scaler 

type Scaler struct {
	ID                  *string              `json:"id,omitempty"`
	Name                *string              `json:"name,omitempty"`
	Description         *string              `json:"description,omitempty"`
	Region              *string              `json:"region,omitempty"`
	Strategy            *Strategy            `json:"strategy,omitempty"`
	Compute             *Compute             `json:"compute,omitempty"`
	Cluster             *Cluster             `json:"cluster,omitempty"`
	Scaling             *Scaling             `json:"scaling,omitempty"`
	CoreScaling         *Scaling             `json:"coreScaling,omitempty"`
	Scheduling          *Scheduling          `json:"scheduling,omitempty"`
	TerminationPolicies []*TerminationPolicy `json:"terminationPolicies,omitempty"`
	// contains filtered or unexported fields
}

func (Scaler) MarshalJSON 

func (o Scaler) MarshalJSON() ([]byte, error)

func (*Scaler) SetCluster 

func (o *Scaler) SetCluster(v *Cluster) *Scaler

SetCluster sets the Cluster object used when creating a new Scaler

func (*Scaler) SetCompute 

func (o *Scaler) SetCompute(v *Compute) *Scaler

func (*Scaler) SetCoreScaling 

func (o *Scaler) SetCoreScaling(v *Scaling) *Scaler

func (*Scaler) SetDescription 

func (o *Scaler) SetDescription(v *string) *Scaler

func (*Scaler) SetId 

func (o *Scaler) SetId(v *string) *Scaler

func (*Scaler) SetName 

func (o *Scaler) SetName(v *string) *Scaler

func (*Scaler) SetRegion 

func (o *Scaler) SetRegion(v *string) *Scaler

func (*Scaler) SetScaling 

func (o *Scaler) SetScaling(v *Scaling) *Scaler

func (*Scaler) SetStrategy 

func (o *Scaler) SetStrategy(v *Strategy) *Scaler

func (*Scaler) SetTerminationPolicies added in v1.45.0 

func (o *Scaler) SetTerminationPolicies(v []*TerminationPolicy) *Scaler

type ScalerCluster 

type ScalerCluster struct {
	ScalerClusterId *string `json:"id,omitempty"`
}

type ScalerClusterStatusInput 

type ScalerClusterStatusInput struct {
	ScalerID *string `json:"mrScalerId,omitempty"`
}

type ScalerClusterStatusOutput 

type ScalerClusterStatusOutput struct {
	ScalerClusterId *string `json:"id,omitempty"`
}

type Scaling 

type Scaling struct {
	Up   []*ScalingPolicy `json:"up,omitempty"`
	Down []*ScalingPolicy `json:"down,omitempty"`
	// contains filtered or unexported fields
}

func (Scaling) MarshalJSON 

func (o Scaling) MarshalJSON() ([]byte, error)

func (*Scaling) SetDown 

func (o *Scaling) SetDown(v []*ScalingPolicy) *Scaling

func (*Scaling) SetUp 

func (o *Scaling) SetUp(v []*ScalingPolicy) *Scaling

type ScalingPolicy 

type ScalingPolicy struct {
	PolicyName        *string      `json:"policyName,omitempty"`
	Namespace         *string      `json:"namespace,omitempty"`
	MetricName        *string      `json:"metricName,omitempty"`
	Dimensions        []*Dimension `json:"dimensions,omitempty"`
	Statistic         *string      `json:"statistic,omitempty"`
	Unit              *string      `json:"unit,omitempty"`
	Threshold         *float64     `json:"threshold,omitempty"`
	Period            *int         `json:"period,omitempty"`
	EvaluationPeriods *int         `json:"evaluationPeriods,omitempty"`
	Cooldown          *int         `json:"cooldown,omitempty"`
	Action            *Action      `json:"action,omitempty"`
	Operator          *string      `json:"operator,omitempty"`
	// contains filtered or unexported fields
}

func (ScalingPolicy) MarshalJSON 

func (o ScalingPolicy) MarshalJSON() ([]byte, error)

func (*ScalingPolicy) SetAction 

func (o *ScalingPolicy) SetAction(v *Action) *ScalingPolicy

func (*ScalingPolicy) SetCooldown 

func (o *ScalingPolicy) SetCooldown(v *int) *ScalingPolicy

func (*ScalingPolicy) SetDimensions 

func (o *ScalingPolicy) SetDimensions(v []*Dimension) *ScalingPolicy

func (*ScalingPolicy) SetEvaluationPeriods 

func (o *ScalingPolicy) SetEvaluationPeriods(v *int) *ScalingPolicy

func (*ScalingPolicy) SetMetricName 

func (o *ScalingPolicy) SetMetricName(v *string) *ScalingPolicy

func (*ScalingPolicy) SetNamespace 

func (o *ScalingPolicy) SetNamespace(v *string) *ScalingPolicy

func (*ScalingPolicy) SetOperator 

func (o *ScalingPolicy) SetOperator(v *string) *ScalingPolicy

func (*ScalingPolicy) SetPeriod 

func (o *ScalingPolicy) SetPeriod(v *int) *ScalingPolicy

func (*ScalingPolicy) SetPolicyName 

func (o *ScalingPolicy) SetPolicyName(v *string) *ScalingPolicy

func (*ScalingPolicy) SetStatistic 

func (o *ScalingPolicy) SetStatistic(v *string) *ScalingPolicy

func (*ScalingPolicy) SetThreshold 

func (o *ScalingPolicy) SetThreshold(v *float64) *ScalingPolicy

func (*ScalingPolicy) SetUnit 

func (o *ScalingPolicy) SetUnit(v *string) *ScalingPolicy

type Scheduling 

type Scheduling struct {
	Tasks []*Task `json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (Scheduling) MarshalJSON 

func (o Scheduling) MarshalJSON() ([]byte, error)

func (*Scheduling) SetTasks 

func (o *Scheduling) SetTasks(v []*Task) *Scheduling

type Service 

type Service interface {
	List(context.Context, *ListScalersInput) (*ListScalersOutput, error)
	Create(context.Context, *CreateScalerInput) (*CreateScalerOutput, error)
	Read(context.Context, *ReadScalerInput) (*ReadScalerOutput, error)
	ReadScalerCluster(context.Context, *ScalerClusterStatusInput) (*ScalerClusterStatusOutput, error)
	Update(context.Context, *UpdateScalerInput) (*UpdateScalerOutput, error)
	Delete(context.Context, *DeleteScalerInput) (*DeleteScalerOutput, error)
}

Service provides the API operation methods for making requests to endpoints of the Spotinst API. See this package's package overview docs for details on the service.

type ServiceOp 

type ServiceOp struct {
	Client *client.Client
}

func New 

func New(sess *session.Session, cfgs ...*spotinst.Config) *ServiceOp

func (*ServiceOp) Create 

func (s *ServiceOp) Create(ctx context.Context, input *CreateScalerInput) (*CreateScalerOutput, error)

func (*ServiceOp) Delete 

func (s *ServiceOp) Delete(ctx context.Context, input *DeleteScalerInput) (*DeleteScalerOutput, error)

func (*ServiceOp) List 

func (s *ServiceOp) List(ctx context.Context, input *ListScalersInput) (*ListScalersOutput, error)

func (*ServiceOp) Read 

func (s *ServiceOp) Read(ctx context.Context, input *ReadScalerInput) (*ReadScalerOutput, error)

func (*ServiceOp) ReadScalerCluster 

func (s *ServiceOp) ReadScalerCluster(ctx context.Context, input *ScalerClusterStatusInput) (*ScalerClusterStatusOutput, error)

func (*ServiceOp) Update 

func (s *ServiceOp) Update(ctx context.Context, input *UpdateScalerInput) (*UpdateScalerOutput, error)

type Statement added in v1.45.0 

type Statement struct {
	Namespace         *string  `json:"namespace,omitempty"`
	MetricName        *string  `json:"metricName,omitempty"`
	Statistic         *string  `json:"statistic,omitempty"`
	Unit              *string  `json:"unit,omitempty"`
	Threshold         *float64 `json:"threshold,omitempty"`
	Period            *int     `json:"period,omitempty"`
	EvaluationPeriods *int     `json:"evaluationPeriods,omitempty"`
	Operator          *string  `json:"operator,omitempty"`
	// contains filtered or unexported fields
}

func (Statement) MarshalJSON added in v1.45.0 

func (o Statement) MarshalJSON() ([]byte, error)

func (*Statement) SetEvaluationPeriods added in v1.45.0 

func (o *Statement) SetEvaluationPeriods(v *int) *Statement

func (*Statement) SetMetricName added in v1.45.0 

func (o *Statement) SetMetricName(v *string) *Statement

func (*Statement) SetNamespace added in v1.45.0 

func (o *Statement) SetNamespace(v *string) *Statement

func (*Statement) SetOperator added in v1.45.0 

func (o *Statement) SetOperator(v *string) *Statement

func (*Statement) SetPeriod added in v1.45.0 

func (o *Statement) SetPeriod(v *int) *Statement

func (*Statement) SetStatistic added in v1.45.0 

func (o *Statement) SetStatistic(v *string) *Statement

func (*Statement) SetThreshold added in v1.45.0 

func (o *Statement) SetThreshold(v *float64) *Statement

func (*Statement) SetUnit added in v1.45.0 

func (o *Statement) SetUnit(v *string) *Statement

type Steps 

type Steps struct {
	File *S3File `json:"file,omitempty"`
	// contains filtered or unexported fields
}

func (Steps) MarshalJSON 

func (o Steps) MarshalJSON() ([]byte, error)

func (*Steps) SetFile 

func (o *Steps) SetFile(v *S3File) *Steps

type Strategy 

type Strategy struct {
	Cloning             *Cloning             `json:"cloning,omitempty"`
	Wrapping            *Wrapping            `json:"wrapping,omitempty"`
	CreateNew           *CreateNew           `json:"new,omitempty"`
	ProvisioningTimeout *ProvisioningTimeout `json:"provisioningTimeout,omitempty"`
	// contains filtered or unexported fields
}

func (Strategy) MarshalJSON 

func (o Strategy) MarshalJSON() ([]byte, error)

func (*Strategy) SetCloning 

func (o *Strategy) SetCloning(v *Cloning) *Strategy

func (*Strategy) SetCreateNew 

func (o *Strategy) SetCreateNew(v *CreateNew) *Strategy

SetCreateNew sets a new mrscaler object

func (*Strategy) SetProvisioningTimeout 

func (o *Strategy) SetProvisioningTimeout(v *ProvisioningTimeout) *Strategy

SetProvisioningTimeout sets the timeout when creating or cloning a scaler

func (*Strategy) SetWrapping 

func (o *Strategy) SetWrapping(v *Wrapping) *Strategy

type Tag 

type Tag struct {
	Key   *string `json:"tagKey,omitempty"`
	Value *string `json:"tagValue,omitempty"`
	// contains filtered or unexported fields
}

func (Tag) MarshalJSON 

func (o Tag) MarshalJSON() ([]byte, error)

func (*Tag) SetKey 

func (o *Tag) SetKey(v *string) *Tag

func (*Tag) SetValue 

func (o *Tag) SetValue(v *string) *Tag

type Task 

type Task struct {
	IsEnabled         *bool   `json:"isEnabled,omitempty"`
	Type              *string `json:"taskType,omitempty"`
	InstanceGroupType *string `json:"instanceGroupType,omitempty"`
	CronExpression    *string `json:"cronExpression,omitempty"`
	TargetCapacity    *int    `json:"targetCapacity,omitempty"`
	MinCapacity       *int    `json:"minCapacity,omitempty"`
	MaxCapacity       *int    `json:"maxCapacity,omitempty"`
	// contains filtered or unexported fields
}

func (Task) MarshalJSON 

func (o Task) MarshalJSON() ([]byte, error)

func (*Task) SetCronExpression 

func (o *Task) SetCronExpression(v *string) *Task

func (*Task) SetInstanceGroupType 

func (o *Task) SetInstanceGroupType(v *string) *Task

SetInstanceGroupType sets the instance group to apply the scheduled task to.

func (*Task) SetIsEnabled 

func (o *Task) SetIsEnabled(v *bool) *Task

func (*Task) SetMaxCapacity 

func (o *Task) SetMaxCapacity(v *int) *Task

func (*Task) SetMinCapacity 

func (o *Task) SetMinCapacity(v *int) *Task

func (*Task) SetTargetCapacity 

func (o *Task) SetTargetCapacity(v *int) *Task

func (*Task) SetType 

func (o *Task) SetType(v *string) *Task

type TerminationPolicy added in v1.45.0 

type TerminationPolicy struct {
	Statements []*Statement `json:"statements,omitempty"`
	// contains filtered or unexported fields
}

func (TerminationPolicy) MarshalJSON added in v1.45.0 

func (o TerminationPolicy) MarshalJSON() ([]byte, error)

func (*TerminationPolicy) SetStatements added in v1.45.0 

func (o *TerminationPolicy) SetStatements(v []*Statement) *TerminationPolicy

type UpdateScalerInput 

type UpdateScalerInput struct {
	Scaler *Scaler `json:"mrScaler,omitempty"`
}

type UpdateScalerOutput 

type UpdateScalerOutput struct {
	Scaler *Scaler `json:"mrScaler,omitempty"`
}

type VolumeSpecification 

type VolumeSpecification struct {
	VolumeType *string `json:"volumeType,omitempty"`
	SizeInGB   *int    `json:"sizeInGB,omitempty"`
	IOPS       *int    `json:"iops,omitempty"`
	// contains filtered or unexported fields
}

func (VolumeSpecification) MarshalJSON 

func (o VolumeSpecification) MarshalJSON() ([]byte, error)

region VolumeSpecification

func (*VolumeSpecification) SetIOPS 

func (o *VolumeSpecification) SetIOPS(v *int) *VolumeSpecification

func (*VolumeSpecification) SetSizeInGB 

func (o *VolumeSpecification) SetSizeInGB(v *int) *VolumeSpecification

func (*VolumeSpecification) SetVolumeType 

func (o *VolumeSpecification) SetVolumeType(v *string) *VolumeSpecification

type Wrapping 

type Wrapping struct {
	SourceClusterID *string `json:"sourceClusterId,omitempty"`
	// contains filtered or unexported fields
}

func (Wrapping) MarshalJSON 

func (o Wrapping) MarshalJSON() ([]byte, error)

func (*Wrapping) SetSourceClusterId 

func (o *Wrapping) SetSourceClusterId(v *string) *Wrapping

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.