spot

package

Go to main page

Versions in this module

v0

v0.35.0

Oct 11, 2023

v0.34.0

Sep 27, 2023

v0.33.0

Sep 14, 2023

Changes in this version

type OceanClusterOptions

+ ResourceTagSpecificationVolumes bool

v0.32.0

Jul 24, 2023

Changes in this version

type OceanClusterOptions

+ SpreadNodesBy string

v0.31.0

May 2, 2023

v0.30.0

Apr 26, 2023

v0.29.0

Mar 15, 2023

Changes in this version

type OceanClusterOptions

+ AvailabilityVsCost string

v0.28.0

Mar 2, 2023

v0.27.0

Feb 7, 2023

Changes in this version

+ type OceanSparkCluster struct

+ Obj interface{}

+ OceanClusterID string

+ State string

+ type OceanSparkClustersSorter struct

+ Clusters []*OceanSparkCluster

+ func (s *OceanSparkClustersSorter) Len() int

+ func (s *OceanSparkClustersSorter) Less(i, j int) bool

+ func (s *OceanSparkClustersSorter) Swap(i, j int)

+ type OceanSparkInterface interface

+ CreateCluster func(ctx context.Context, oceanClusterID string) (*OceanSparkCluster, error)

+ DeleteCluster func(ctx context.Context, clusterID string) error

+ GetCluster func(ctx context.Context, clusterID string) (*OceanSparkCluster, error)

+ ListClusters func(ctx context.Context, controllerClusterID string, state string) ([]*OceanSparkCluster, error)

type ServicesInterface

+ OceanSpark func() (OceanSparkInterface, error)

v0.26.0

Oct 13, 2022

Changes in this version

type OceanRolloutOptions

+ RespectPDB bool

v0.25.0

Jan 12, 2022

v0.24.0

Dec 21, 2021

v0.23.0

Dec 14, 2021

Changes in this version

type OceanClusterOptions

+ LoadBalancerARNs []string

+ LoadBalancerNames []string

v0.22.0

Dec 13, 2021

v0.21.0

Dec 9, 2021

v0.20.1

Oct 26, 2021

v0.20.0

Apr 28, 2021

v0.19.0

Mar 13, 2021

Changes in this version

+ type ResourceDoesNotExistError struct

+ func (e ResourceDoesNotExistError) Error() string

+ func (e ResourceDoesNotExistError) Unwrap() error

type ServicesInterface

+ Wave func() (WaveInterface, error)

+ type SparkApplication struct

+ ApplicationID string

+ ClusterIdentifier string

+ Obj interface{}

+ State string

+ type SparkApplicationsFilter struct

+ ApplicationID string

+ ApplicationState string

+ ClusterIdentifier string

+ Name string

+ type SparkApplicationsSorter struct

+ SparkApplications []*SparkApplication

+ func (s *SparkApplicationsSorter) Len() int

+ func (s *SparkApplicationsSorter) Less(i, j int) bool

+ func (s *SparkApplicationsSorter) Swap(i, j int)

+ type WaveCluster struct

+ Components []WaveComponent

+ Obj interface{}

+ State string

+ type WaveClustersFilter struct

+ ClusterIdentifier string

+ ClusterState string

+ type WaveClustersSorter struct

+ Clusters []*WaveCluster

+ func (s *WaveClustersSorter) Len() int

+ func (s *WaveClustersSorter) Less(i, j int) bool

+ func (s *WaveClustersSorter) Swap(i, j int)

+ type WaveComponent struct

+ Name string

+ OperatorVersion string

+ Properties map[string]string

+ State string

+ UID string

+ Version string

+ type WaveInterface interface

+ DeleteCluster func(ctx context.Context, clusterID string, deleteOcean bool) error

+ GetCluster func(ctx context.Context, clusterID string) (*WaveCluster, error)

+ GetSparkApplication func(ctx context.Context, id string) (*SparkApplication, error)

+ ListClusters func(ctx context.Context, filter *WaveClustersFilter) ([]*WaveCluster, error)

+ ListSparkApplications func(ctx context.Context, filter *SparkApplicationsFilter) ([]*SparkApplication, error)

v0.0.18

Feb 18, 2021

v0.0.17

Dec 27, 2020

v0.0.16

Dec 8, 2020

Changes in this version

+ var ErrNotImplemented = errors.New("spot: not implemented")

+ type Account struct

+ ExternalID *string

+ ID string

+ Name string

+ OrganizationID string

+ type AccountsInterface interface

+ ListAccounts func(ctx context.Context) ([]*Account, error)

+ type Client interface

+ Accounts func() AccountsInterface

+ Services func() ServicesInterface

+ func New(options ...ClientOption) Client

+ type ClientOption func(*ClientOptions)

+ func WithBaseURL(url string) ClientOption

+ func WithCredentialsProfile(profile string) ClientOption

+ func WithCredentialsStatic(token, account string) ClientOption

+ func WithDryRun(value bool) ClientOption

+ type ClientOptions struct

+ Account string

+ BaseURL string

+ DryRun bool

+ Profile string

+ Token string

+ type CloudProviderName string

+ const CloudProviderAWS

+ const CloudProviderAzure

+ const CloudProviderGCP

+ type ObjectMeta struct

+ CreatedAt time.Time

+ ID string

+ Name string

+ UpdatedAt time.Time

+ type OceanCluster struct

+ Obj interface{}

+ type OceanClusterBuilder interface

+ Build func() (*OceanCluster, error)

+ type OceanClusterOptions struct

+ AssociatePublicIPAddress bool

+ ClusterID string

+ ControllerID string

+ Cooldown int

+ DrainingTimeout int

+ EnableAutoConfig bool

+ EnableAutoScaler bool

+ EnableEBSOptimization bool

+ EnableMonitoring bool

+ EvaluationPeriods int

+ FallbackToOnDemand bool

+ HeadroomCPUPerUnit int

+ HeadroomGPUPerUnit int

+ HeadroomMemoryPerUnit int

+ HeadroomNumPerUnit int

+ IAMInstanceProfileARN string

+ IAMInstanceProfileName string

+ ImageID string

+ InstanceTypesBlacklist []string

+ InstanceTypesWhitelist []string

+ KeyPair string

+ LoadBalancerARN string

+ LoadBalancerName string

+ LoadBalancerType string

+ MaxScaleDownPercentage int

+ MaxSize int

+ MinSize int

+ Name string

+ Region string

+ ResourceLimitMaxMemory int

+ ResourceLimitMaxVCPU int

+ RootVolumeSize int

+ SecurityGroupIDs []string

+ SpotPercentage float64

+ SubnetIDs []string

+ TargetSize int

+ UserData string

+ UtilizeReservedInstances bool

+ type OceanClustersSorter struct

+ Clusters []*OceanCluster

+ func (s *OceanClustersSorter) Len() int

+ func (s *OceanClustersSorter) Less(i, j int) bool

+ func (s *OceanClustersSorter) Swap(i, j int)

+ type OceanInterface interface

+ CreateCluster func(ctx context.Context, cluster *OceanCluster) (*OceanCluster, error)

+ CreateLaunchSpec func(ctx context.Context, spec *OceanLaunchSpec) (*OceanLaunchSpec, error)

+ CreateRollout func(ctx context.Context, rollout *OceanRollout) (*OceanRollout, error)

+ DeleteCluster func(ctx context.Context, clusterID string) error

+ DeleteLaunchSpec func(ctx context.Context, specID string) error

+ GetCluster func(ctx context.Context, clusterID string) (*OceanCluster, error)

+ GetLaunchSpec func(ctx context.Context, specID string) (*OceanLaunchSpec, error)

+ GetRollout func(ctx context.Context, clusterID, rolloutID string) (*OceanRollout, error)

+ ListClusters func(ctx context.Context) ([]*OceanCluster, error)

+ ListLaunchSpecs func(ctx context.Context) ([]*OceanLaunchSpec, error)

+ ListRollouts func(ctx context.Context, clusterID string) ([]*OceanRollout, error)

+ NewClusterBuilder func(fs *pflag.FlagSet, opts *OceanClusterOptions) OceanClusterBuilder

+ NewLaunchSpecBuilder func(fs *pflag.FlagSet, opts *OceanLaunchSpecOptions) OceanLaunchSpecBuilder

+ NewRolloutBuilder func(fs *pflag.FlagSet, opts *OceanRolloutOptions) OceanRolloutBuilder

+ UpdateCluster func(ctx context.Context, cluster *OceanCluster) (*OceanCluster, error)

+ UpdateLaunchSpec func(ctx context.Context, spec *OceanLaunchSpec) (*OceanLaunchSpec, error)

+ UpdateRollout func(ctx context.Context, rollout *OceanRollout) (*OceanRollout, error)

+ type OceanLaunchSpec struct

+ Obj interface{}

+ type OceanLaunchSpecBuilder interface

+ Build func() (*OceanLaunchSpec, error)

+ type OceanLaunchSpecOptions struct

+ ClusterID string

+ ImageID string

+ Name string

+ SecurityGroupIDs []string

+ SpecID string

+ UserData string

+ type OceanLaunchSpecsSorter struct

+ LaunchSpecs []*OceanLaunchSpec

+ func (s *OceanLaunchSpecsSorter) Len() int

+ func (s *OceanLaunchSpecsSorter) Less(i, j int) bool

+ func (s *OceanLaunchSpecsSorter) Swap(i, j int)

+ type OceanRollout struct

+ Obj interface{}

+ type OceanRolloutBuilder interface

+ Build func() (*OceanRollout, error)

+ type OceanRolloutOptions struct

+ BatchSizePercentage int

+ ClusterID string

+ Comment string

+ DisableAutoScaling bool

+ InstanceIDs []string

+ RolloutID string

+ SpecIDs []string

+ Status string

+ type OceanRolloutsSorter struct

+ Rollouts []*OceanRollout

+ func (s *OceanRolloutsSorter) Len() int

+ func (s *OceanRolloutsSorter) Less(i, j int) bool

+ func (s *OceanRolloutsSorter) Swap(i, j int)

+ type OrchestratorName string

+ const OrchestratorECS

+ const OrchestratorKubernetes

+ type ServicesInterface interface

+ Ocean func(provider CloudProviderName, orchestrator OrchestratorName) (OceanInterface, error)

+ type TypeMeta struct

+ Kind string

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