spark

package
v1.154.0 Latest Latest
Warning

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

Go to latest
Published: Mar 20, 2023 License: Apache-2.0 Imports: 12 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AttachVirtualNodeGroupRequest added in v1.128.0

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

type AttachVngInput

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

type AttachVngOutput

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

type Cluster

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

	// Read-only fields.
	ID                    *string    `json:"id,omitempty"`
	ControllerClusterID   *string    `json:"controllerClusterId,omitempty"`
	OceanClusterID        *string    `json:"oceanClusterId,omitempty"`
	Region                *string    `json:"region,omitempty"`
	State                 *string    `json:"state,omitempty"`
	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"`
	// contains filtered or unexported fields
}

func (Cluster) MarshalJSON added in v1.128.0

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

func (*Cluster) SetConfig added in v1.128.0

func (c *Cluster) SetConfig(v *Config) *Cluster

type ClusterManager

type ClusterManager interface {
}

type ComputeConfig

type ComputeConfig struct {
	UseTaints  *bool `json:"useTaints,omitempty"`
	CreateVngs *bool `json:"createVngs,omitempty"`
	// contains filtered or unexported fields
}

func (ComputeConfig) MarshalJSON added in v1.128.0

func (c ComputeConfig) MarshalJSON() ([]byte, error)

func (*ComputeConfig) SetCreateVNGs added in v1.128.0

func (c *ComputeConfig) SetCreateVNGs(v *bool) *ComputeConfig

func (*ComputeConfig) SetUseTaints added in v1.128.0

func (c *ComputeConfig) SetUseTaints(v *bool) *ComputeConfig

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"`
	Spark         *SparkConfig         `json:"spark,omitempty"`
	// contains filtered or unexported fields
}

func (Config) MarshalJSON added in v1.128.0

func (c Config) MarshalJSON() ([]byte, error)

func (*Config) SetCompute added in v1.128.0

func (c *Config) SetCompute(v *ComputeConfig) *Config

func (*Config) SetIngress added in v1.128.0

func (c *Config) SetIngress(v *IngressConfig) *Config

func (*Config) SetLogCollection added in v1.128.0

func (c *Config) SetLogCollection(v *LogCollectionConfig) *Config

func (*Config) SetSpark added in v1.146.0

func (c *Config) SetSpark(v *SparkConfig) *Config

func (*Config) SetWebhook added in v1.128.0

func (c *Config) SetWebhook(v *WebhookConfig) *Config

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 {
	ForceDelete *bool   `json:"-"`
	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 IngressConfig

type IngressConfig struct {
	// Deprecated: Use LoadBalancer.ServiceAnnotations instead.
	ServiceAnnotations map[string]string `json:"serviceAnnotations,omitempty"`
	// Deprecated: Has no effect.
	DeployIngress *bool `json:"deployIngress,omitempty"`

	Controller     *IngressConfigController     `json:"controller,omitempty"`
	CustomEndpoint *IngressConfigCustomEndpoint `json:"customEndpoint,omitempty"`
	LoadBalancer   *IngressConfigLoadBalancer   `json:"loadBalancer,omitempty"`
	PrivateLink    *IngressConfigPrivateLink    `json:"privateLink,omitempty"`
	// contains filtered or unexported fields
}

func (IngressConfig) MarshalJSON added in v1.128.0

func (i IngressConfig) MarshalJSON() ([]byte, error)

func (*IngressConfig) SetController added in v1.133.0

func (i *IngressConfig) SetController(c *IngressConfigController) *IngressConfig

func (*IngressConfig) SetCustomEndpoint added in v1.133.0

func (i *IngressConfig) SetCustomEndpoint(ce *IngressConfigCustomEndpoint) *IngressConfig

func (*IngressConfig) SetDeployIngress added in v1.128.0

func (i *IngressConfig) SetDeployIngress(v *bool) *IngressConfig

func (*IngressConfig) SetLoadBalancer added in v1.133.0

func (i *IngressConfig) SetLoadBalancer(lb *IngressConfigLoadBalancer) *IngressConfig
func (i *IngressConfig) SetPrivateLink(pl *IngressConfigPrivateLink) *IngressConfig

func (*IngressConfig) SetServiceAnnotations added in v1.128.0

func (i *IngressConfig) SetServiceAnnotations(v map[string]string) *IngressConfig

type IngressConfigController added in v1.133.0

type IngressConfigController struct {
	Managed *bool `json:"managed,omitempty"`
	// contains filtered or unexported fields
}

func (IngressConfigController) MarshalJSON added in v1.133.0

func (c IngressConfigController) MarshalJSON() ([]byte, error)

func (*IngressConfigController) SetManaged added in v1.133.0

type IngressConfigCustomEndpoint added in v1.133.0

type IngressConfigCustomEndpoint struct {
	Enabled *bool   `json:"enabled,omitempty"`
	Address *string `json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (IngressConfigCustomEndpoint) MarshalJSON added in v1.133.0

func (ce IngressConfigCustomEndpoint) MarshalJSON() ([]byte, error)

func (*IngressConfigCustomEndpoint) SetAddress added in v1.133.0

func (*IngressConfigCustomEndpoint) SetEnabled added in v1.133.0

type IngressConfigLoadBalancer added in v1.133.0

type IngressConfigLoadBalancer struct {
	Managed            *bool             `json:"managed,omitempty"`
	TargetGroupARN     *string           `json:"targetGroupArn,omitempty"`
	ServiceAnnotations map[string]string `json:"serviceAnnotations,omitempty"`
	// contains filtered or unexported fields
}

func (IngressConfigLoadBalancer) MarshalJSON added in v1.133.0

func (lb IngressConfigLoadBalancer) MarshalJSON() ([]byte, error)

func (*IngressConfigLoadBalancer) SetManaged added in v1.133.0

func (*IngressConfigLoadBalancer) SetServiceAnnotations added in v1.133.0

func (lb *IngressConfigLoadBalancer) SetServiceAnnotations(v map[string]string) *IngressConfigLoadBalancer

func (*IngressConfigLoadBalancer) SetTargetGroupARN added in v1.133.0

func (lb *IngressConfigLoadBalancer) SetTargetGroupARN(v *string) *IngressConfigLoadBalancer
type IngressConfigPrivateLink struct {
	Enabled            *bool   `json:"enabled,omitempty"`
	VPCEndpointService *string `json:"vpcEndpointService,omitempty"`
	// contains filtered or unexported fields
}

func (IngressConfigPrivateLink) MarshalJSON added in v1.133.0

func (pl IngressConfigPrivateLink) MarshalJSON() ([]byte, error)

func (*IngressConfigPrivateLink) SetEnabled added in v1.133.0

func (*IngressConfigPrivateLink) SetVPCEndpointService added in v1.133.0

func (pl *IngressConfigPrivateLink) SetVPCEndpointService(v *string) *IngressConfigPrivateLink

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 ListVngsInput added in v1.143.0

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

type ListVngsOutput added in v1.143.0

type ListVngsOutput struct {
	VirtualNodeGroups []*DedicatedVirtualNodeGroup `json:"virtualNodeGroups,omitempty"`
}

type LogCollectionConfig

type LogCollectionConfig struct {
	CollectDriverLogs *bool `json:"collectDriverLogs,omitempty"`
	// contains filtered or unexported fields
}

func (LogCollectionConfig) MarshalJSON added in v1.128.0

func (l LogCollectionConfig) MarshalJSON() ([]byte, error)

func (*LogCollectionConfig) SetCollectDriverLogs added in v1.128.0

func (l *LogCollectionConfig) SetCollectDriverLogs(v *bool) *LogCollectionConfig

type ReadClusterInput

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

type ReadClusterOutput

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

type Service

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)

func (*ServiceOp) ListClusters

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

region Cluster

func (*ServiceOp) ListVirtualNodeGroups added in v1.143.0

func (s *ServiceOp) ListVirtualNodeGroups(ctx context.Context, input *ListVngsInput) (*ListVngsOutput, error)

region Virtual Node Group

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 SparkConfig added in v1.146.0

type SparkConfig struct {
	AppNamespaces []*string `json:"appNamespaces,omitempty"`
	// contains filtered or unexported fields
}

func (SparkConfig) MarshalJSON added in v1.146.0

func (s SparkConfig) MarshalJSON() ([]byte, error)

func (*SparkConfig) SetAppNamespaces added in v1.146.0

func (s *SparkConfig) SetAppNamespaces(v []*string) *SparkConfig

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"`
	// contains filtered or unexported fields
}

func (WebhookConfig) MarshalJSON added in v1.128.0

func (w WebhookConfig) MarshalJSON() ([]byte, error)

func (*WebhookConfig) SetHostNetworkPorts added in v1.128.0

func (w *WebhookConfig) SetHostNetworkPorts(v []*int) *WebhookConfig

func (*WebhookConfig) SetUseHostNetwork added in v1.128.0

func (w *WebhookConfig) SetUseHostNetwork(v *bool) *WebhookConfig

Jump to

Keyboard shortcuts

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