wave

Documentation

Index

• type Cluster
• type Component
• type Config
• type DeleteClusterInput
• type DeleteClusterOutput
• type Environment
• type ListClustersInput
• type ListClustersOutput
• type ListSparkApplicationsInput
• type ListSparkApplicationsOutput
• type ReadClusterInput
• type ReadClusterOutput
• type ReadSparkApplicationInput
• type ReadSparkApplicationOutput
• type Service
• type ServiceOp
  • func New(sess *session.Session, cfgs ...*spotinst.Config) *ServiceOp
  • func (s *ServiceOp) DeleteCluster(ctx context.Context, input *DeleteClusterInput) (*DeleteClusterOutput, error)
  • func (s *ServiceOp) ListClusters(ctx context.Context, input *ListClustersInput) (*ListClustersOutput, error)
  • func (s *ServiceOp) ListSparkApplications(ctx context.Context, input *ListSparkApplicationsInput) (*ListSparkApplicationsOutput, error)
  • func (s *ServiceOp) ReadCluster(ctx context.Context, input *ReadClusterInput) (*ReadClusterOutput, error)
  • func (s *ServiceOp) ReadSparkApplication(ctx context.Context, input *ReadSparkApplicationInput) (*ReadSparkApplicationOutput, error)
• type SparkApplication

Types

type Cluster

type Cluster struct {
	ID                *string      `json:"id,omitempty"`
	ClusterIdentifier *string      `json:"clusterIdentifier,omitempty"`
	Environment       *Environment `json:"environment,omitempty"`
	Config            *Config      `json:"config,omitempty"`
	State             *string      `json:"state,omitempty"`

	// Read-only fields.
	CreatedAt *time.Time `json:"createdAt,omitempty"`
	UpdatedAt *time.Time `json:"updatedAt,omitempty"`
}

type Component

type Component struct {
	UID             *string           `json:"uid,omitempty"`
	Name            *string           `json:"name,omitempty"`
	OperatorVersion *string           `json:"operatorVersion,omitempty"`
	Version         *string           `json:"version,omitempty"`
	Properties      map[string]string `json:"properties,omitempty"`
	State           *string           `json:"state,omitempty"`
}

type Config

type Config struct {
	Components []*Component `json:"components,omitempty"`
}

type DeleteClusterInput

type DeleteClusterInput struct {
	ClusterID         *string `json:"clusterId,omitempty"`
	ShouldDeleteOcean *bool   `json:"shouldDeleteOcean,omitempty"`
}

type DeleteClusterOutput

type DeleteClusterOutput struct{}

type Environment

type Environment struct {
	OperatorVersion         *string `json:"operatorVersion,omitempty"`
	CertManagerDeployed     *bool   `json:"certManagerDeployed,omitempty"`
	K8sClusterProvisioned   *bool   `json:"k8sClusterProvisioned,omitempty"`
	OceanClusterProvisioned *bool   `json:"oceanClusterProvisioned,omitempty"`
	EnvironmentNamespace    *string `json:"environmentNamespace,omitempty"`
	OceanClusterID          *string `json:"oceanClusterId,omitempty"`
}

type ListClustersInput

type ListClustersInput struct {
	ClusterIdentifier *string `json:"clusterIdentifier,omitempty"`
	ClusterState      *string `json:"clusterState,omitempty"`
}

type ListClustersOutput

type ListClustersOutput struct {
	Clusters []*Cluster `json:"clusters,omitempty"`
}

type ListSparkApplicationsInput

type ListSparkApplicationsInput struct {
	ClusterIdentifier *string `json:"clusterIdentifier,omitempty"`
	Name              *string `json:"name,omitempty"`
	Namespace         *string `json:"namespace,omitempty"`
	ApplicationID     *string `json:"applicationId,omitempty"`
	ApplicationState  *string `json:"applicationState,omitempty"`
	Heritage          *string `json:"heritage,omitempty"`
}

type ListSparkApplicationsOutput

type ListSparkApplicationsOutput struct {
	SparkApplications []*SparkApplication `json:"sparkApplications,omitempty"`
}

type ReadClusterInput

type ReadClusterInput struct {
	ClusterID *string `json:"clusterId,omitempty"`
}

type ReadClusterOutput

type ReadClusterOutput struct {
	Cluster *Cluster `json:"cluster,omitempty"`
}

type ReadSparkApplicationInput

type ReadSparkApplicationInput struct {
	ID *string `json:"id,omitempty"`
}

type ReadSparkApplicationOutput

type ReadSparkApplicationOutput struct {
	SparkApplication *SparkApplication `json:"sparkApplication,omitempty"`
}

type Service

type Service interface {
	ReadCluster(context.Context, *ReadClusterInput) (*ReadClusterOutput, error)
	ListClusters(context.Context, *ListClustersInput) (*ListClustersOutput, error)
	DeleteCluster(context.Context, *DeleteClusterInput) (*DeleteClusterOutput, error)
	ReadSparkApplication(context.Context, *ReadSparkApplicationInput) (*ReadSparkApplicationOutput, error)
	ListSparkApplications(context.Context, *ListSparkApplicationsInput) (*ListSparkApplicationsOutput, 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) DeleteCluster

func (s *ServiceOp) DeleteCluster(ctx context.Context, input *DeleteClusterInput) (*DeleteClusterOutput, error)

func (*ServiceOp) ListClusters

func (s *ServiceOp) ListClusters(ctx context.Context, input *ListClustersInput) (*ListClustersOutput, error)

func (*ServiceOp) ListSparkApplications

func (s *ServiceOp) ListSparkApplications(ctx context.Context, input *ListSparkApplicationsInput) (*ListSparkApplicationsOutput, error)

func (*ServiceOp) ReadCluster

func (s *ServiceOp) ReadCluster(ctx context.Context, input *ReadClusterInput) (*ReadClusterOutput, error)

func (*ServiceOp) ReadSparkApplication

func (s *ServiceOp) ReadSparkApplication(ctx context.Context, input *ReadSparkApplicationInput) (*ReadSparkApplicationOutput, error)

type SparkApplication

type SparkApplication struct {
	ID                *string `json:"id,omitempty"`
	ApplicationID     *string `json:"applicationId,omitempty"`
	ClusterIdentifier *string `json:"clusterIdentifier,omitempty"`
	Name              *string `json:"name,omitempty"`
	Namespace         *string `json:"namespace,omitempty"`
	Heritage          *string `json:"heritage,omitempty"`
	ApplicationState  *string `json:"applicationState,omitempty"`

	// Read-only fields.
	CreatedAt *time.Time `json:"createdAt,omitempty"`
	UpdatedAt *time.Time `json:"updatedAt,omitempty"`
}