spark

Documentation

Index

• type AttachVngInput
• type AttachVngOutput
• type AttacheVirtualNodeGroupRequest
• type Cluster
• type ClusterManager
• type ComputeConfig
• type Config
• type CreateClusterInput
• type CreateClusterOutput
• type CreateClusterRequest
• type DedicatedVirtualNodeGroup
• type DeleteClusterInput
• type DeleteClusterOutput
• type DetachVngInput
• type DetachVngOutput
• type Environment
• type IngressConfig
• type ListClustersInput
• type ListClustersOutput
• type LogCollectionConfig
• type ReadClusterInput
• type ReadClusterOutput
• type Service
• type ServiceOp
  • func New(sess *session.Session, cfgs ...*spotinst.Config) *ServiceOp
  • func (s *ServiceOp) AttachVirtualNodeGroup(ctx context.Context, input *AttachVngInput) (*AttachVngOutput, error)
  • func (s *ServiceOp) CreateCluster(ctx context.Context, input *CreateClusterInput) (*CreateClusterOutput, error)
  • func (s *ServiceOp) DeleteCluster(ctx context.Context, input *DeleteClusterInput) (*DeleteClusterOutput, error)
  • func (s *ServiceOp) DetachVirtualNodeGroup(ctx context.Context, input *DetachVngInput) (*DetachVngOutput, error)
  • func (s *ServiceOp) ListClusters(ctx context.Context, input *ListClustersInput) (*ListClustersOutput, error)
  • func (s *ServiceOp) ReadCluster(ctx context.Context, input *ReadClusterInput) (*ReadClusterOutput, error)
  • func (s *ServiceOp) UpdateCluster(ctx context.Context, input *UpdateClusterInput) (*UpdateClusterOutput, error)
• type UpdateClusterInput
• type UpdateClusterOutput
• type UpdateClusterRequest
• type WebhookConfig

Types

type AttachVngInput

type AttachVngInput struct {
	ClusterID        *string                         `json:"-"`
	VirtualNodeGroup *AttacheVirtualNodeGroupRequest `json:"virtualNodeGroup,omitempty"`
}

type AttachVngOutput

type AttachVngOutput struct {
	VirtualNodeGroup *DedicatedVirtualNodeGroup `json:"virtualNodeGroup,omitempty"`
}

type AttacheVirtualNodeGroupRequest

type AttacheVirtualNodeGroupRequest struct {
	VngID *string `json:"id,omitempty"`
}

type Cluster

type Cluster struct {
	ID                  *string      `json:"id,omitempty"`
	ControllerClusterID *string      `json:"controllerClusterId,omitempty"`
	Region              *string      `json:"region,omitempty"`
	Environment         *Environment `json:"environment,omitempty"`
	Config              *Config      `json:"config,omitempty"`
	State               *string      `json:"state,omitempty"`

	// Read-only fields.
	K8sVersion            *string    `json:"k8sVersion,omitempty"`
	OperatorVersion       *string    `json:"operatorVersion,omitempty"`
	OperatorLastHeartbeat *time.Time `json:"operatorLastHeartbeat,omitempty"`
	CreatedAt             *time.Time `json:"createdAt,omitempty"`
	UpdatedAt             *time.Time `json:"updatedAt,omitempty"`
}

type ClusterManager

type ClusterManager interface {
}

type ComputeConfig

type ComputeConfig struct {
	UseTaints  *bool `json:"useTaints,omitempty"`
	CreateVngs *bool `json:"createVngs,omitempty"`
}

type Config

type Config struct {
	Ingress       *IngressConfig       `json:"ingress,omitempty"`
	Webhook       *WebhookConfig       `json:"webhook,omitempty"`
	Compute       *ComputeConfig       `json:"compute,omitempty"`
	LogCollection *LogCollectionConfig `json:"logCollection,omitempty"`
}

type CreateClusterInput

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

type CreateClusterOutput

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

type CreateClusterRequest

type CreateClusterRequest struct {
	OceanClusterID *string `json:"oceanClusterId,omitempty"`
	Config         *Config `json:"config,omitempty"`
}

type DedicatedVirtualNodeGroup

type DedicatedVirtualNodeGroup struct {
	OceanClusterID      *string `json:"oceanClusterId,omitempty"`
	OceanSparkClusterID *string `json:"oceanSparkClusterId,omitempty"`
	VngID               *string `json:"vngId,omitempty"`
}

type DeleteClusterInput

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

type DeleteClusterOutput

type DeleteClusterOutput struct{}

type DetachVngInput

type DetachVngInput struct {
	ClusterID *string `json:"clusterId,omitempty"`
	VngID     *string `json:"vngId,omitempty"`
}

type DetachVngOutput

type DetachVngOutput 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 IngressConfig

type IngressConfig struct {
	ServiceAnnotations map[string]string `json:"serviceAnnotations,omitempty"`
	DeployIngress      *bool             `json:"deployIngress,omitempty"`
}

type ListClustersInput

type ListClustersInput struct {
	ControllerClusterID *string `json:"controllerClusterId,omitempty"`
	ClusterState        *string `json:"clusterState,omitempty"`
}

type ListClustersOutput

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

type LogCollectionConfig

type LogCollectionConfig struct {
	CollectDriverLogs *bool `json:"collectDriverLogs,omitempty"`
}

type ReadClusterInput

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

type ReadClusterOutput

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

type Service

type Service interface {
	ReadCluster(context.Context, *ReadClusterInput) (*ReadClusterOutput, error)
	ListClusters(context.Context, *ListClustersInput) (*ListClustersOutput, error)
	DeleteCluster(context.Context, *DeleteClusterInput) (*DeleteClusterOutput, error)
	CreateCluster(context.Context, *CreateClusterInput) (*CreateClusterOutput, error)
	UpdateCluster(context.Context, *UpdateClusterInput) (*UpdateClusterOutput, error)
	DetachVirtualNodeGroup(context.Context, *DetachVngInput) (*DetachVngOutput, error)
	AttachVirtualNodeGroup(context.Context, *AttachVngInput) (*AttachVngOutput, 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) AttachVirtualNodeGroup

func (s *ServiceOp) AttachVirtualNodeGroup(ctx context.Context, input *AttachVngInput) (*AttachVngOutput, error)

func (*ServiceOp) CreateCluster

func (s *ServiceOp) CreateCluster(ctx context.Context, input *CreateClusterInput) (*CreateClusterOutput, error)

func (*ServiceOp) DeleteCluster

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

func (*ServiceOp) DetachVirtualNodeGroup

func (s *ServiceOp) DetachVirtualNodeGroup(ctx context.Context, input *DetachVngInput) (*DetachVngOutput, error)

region Virtual Node Group

func (*ServiceOp) ListClusters

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

region Cluster

func (*ServiceOp) ReadCluster

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

func (*ServiceOp) UpdateCluster

func (s *ServiceOp) UpdateCluster(ctx context.Context, input *UpdateClusterInput) (*UpdateClusterOutput, error)

type UpdateClusterInput

type UpdateClusterInput struct {
	ClusterID *string               `json:"-"`
	Cluster   *UpdateClusterRequest `json:"cluster,omitempty"`
}

type UpdateClusterOutput

type UpdateClusterOutput struct{}

type UpdateClusterRequest

type UpdateClusterRequest struct {
	Config *Config `json:"config,omitempty"`
}

type WebhookConfig

type WebhookConfig struct {
	UseHostNetwork   *bool  `json:"useHostNetwork,omitempty"`
	HostNetworkPorts []*int `json:"hostNetworkPorts,omitempty"`
}